如何在出错时从异步函数返回

 await conn.getconnection().catch((error)=>{
        console.log("No connection");
        return;
    });
    let collection = conn.getdb().collection(type);

async function getconnection(){
    client = new MongoClient(url);
    await client.connect();
    db = client.db(dbName);
    console.log("Connected to db");
}

以上代码用于连接mongodb数据库。但是在不连接到数据库时，异步函数不会返回并且集合正在尝试执行导致错误。我如何停止执行函数并返回父函数？

注意：-该功能在数据库运行时正常工作。但是当不运行应用程序崩溃时。我希望错误被捕获而不是崩溃。

错误是

No connection
let collection = conn.getdb().collection(type);
                                 ^

TypeError: Cannot read properties of undefined (reading 'collection')

编辑：-

await conn.getconnection().catch(console.error);
    let collection = conn.getdb().collection(type);
    console.log("Entered collection");
    await collection.updateOne(query,{$set : newdata})
        .then(()=>{
            res.send("Done");
        })
        .catch((error)=>{
            console.log(error);
            res.send("Error");
        })
    conn.closedb();

完全添加 catch 的问题是，如果连接成功后发生连接错误，则连接不会关闭。所以再次调用该函数时会发生错误。

但我无法使用 finally 关闭连接，因为如果

connect()

首先，这段代码有点乱，因为你是通过“副作用”来编码的。你调用像

getConnection()

client

db

getconnection()

再次强调，由于您在这里只显示了一小段代码上下文，我们无法就如何最好地解决此问题提出更大的建议。可能你应该做像

getConnection()

getConnection()

不管怎样，回到你问的主要问题。您在此处获取连接的功能：

async function getconnection(){
    client = new MongoClient(url);
    await client.connect();
    db = client.db(dbName);
    console.log("Connected to db");
}

client.connect()

 失败，

await conn.getconnection().catch(console.error);
    let collection = conn.getdb().collection(type);
    console.log("Entered collection");
    await collection.updateOne(query,{$set : newdata})
        .then(()=>{
            res.send("Done");
        })
        .catch((error)=>{
            console.log(error);
            res.send("Error");
        })
    conn.closedb();

我建议这样重写：

try {
    await conn.getconnection();
} catch(e) {
    console.error('error getting database connection', e);
    res.status(500).send('Error connecting to database');
    return;
}
try {
    const collection = conn.getdb().collection(type);
    // may need to sanitize the query variable to make sure it's safe
    await collection.updateOne(query, { $set: newdata });
    res.send("Done");
} catch(e) {
    console.error(e);
    res.status(500).send("Database error");
} finally {
    conn.closedb();
}

这完成了以下事情：

1. 它直接和单独地处理来自

   conn.getconnection()

   的拒绝，因为除了发送错误响应之外，您不想在该错误之后执行任何代码。
2. 它不会混合

   await

   和

   .then()

   和

   .catch()

   。为任何给定的功能选择另一种风格，因为当您混合使用它们时，流程控制会变得混乱和混乱。
3. 它在所有可能的错误情况下都对请求发送适当的响应。
4. 确保在检索数据库连接的所有可能错误路径中调用

   conn.closedb()

   。

注意：您没有显示

query

.updateOne()