JS - 如何用链式承诺结束数据库连接

Question

我在一个文件中声明了我的数据库函数，并希望它们返回一个承诺，以便我可以在其他地方重新使用它们。问题是如何结束连接？我知道我可以在我调用数据库函数的每个地方调用conn.end()，但我不能在数据库函数本身中这样做吗？

来电者...

function scanBoard(qrCode) {
    getBoard(qrCode)
    .then(b => {
        board = b;
    });
}

DB 函数（注意，代码不会运行，因为它包含我尝试过的所有内容）

function getBoard(qrcode) {

    return db.createConnection(dbConfig)
    .then(conn => {
        let rows = conn.query("SELECT * FROM boards WHERE id = ?", [qrcode])
        .then(() => { conn.end() }); // Can't call it here cus it ends conn before rows is set

        conn.end(); // Can't call it here cus rows is still pending

        if (rows.length >= 1)
            return rows[0];

        return null;
    })
    .finally({
        conn.end(); // Can't call it here cus it gets called before the 'then' block in the caller
    });


}

Answer 1

conn.query 是异步的，因此then 将完成，finally 将在查询产生任何结果之前触发，即使只需要几毫秒。不管你是在解决 promise，封闭的 promise 会实现，还是链式的 then 会实现。

async function getBoard(qrcode) {
  const conn = await db.createConnection(dbConfig);

  try {
    return await conn.query("SELECT * FROM boards WHERE id = ?", [qrcode]);
  } finally {
    conn.end();
  }
}

提示 - 如果此应用程序持续运行，您只需连接到数据库一次并重用连接，那么就无需为每个查询打开和关闭连接。

Answer 2

我认为最好的解决方案是遵循最佳实践... 为了解决您的问题，我认为最好将conn.end(); 与承诺链的finally 部分中的conn.end(); 结合起来，只有当查询顺利或没有待处理的请求时才会触发它。我会这样做：

.finally({
      if(conn){
          conn.end();
      }
 });

显然，您必须从源代码的任何其他部分中删除 conn.end(); 代码行。我什至会考虑使用更多catch() 来检查其他错误。

希望它能帮助我解决你想要的任何问题。

Answer 3

我不建议在每次调用 db 方法后关闭连接。它的效率非常低，您可以使用连接池。更多详情请看这里

https://www.npmjs.com/package/mysql#pooling-connections

当所有工作完成后，您可以关闭池中的连接。看到这个

https://www.npmjs.com/package/mysql#closing-all-the-connections-in-a-pool

希望这会有所帮助。

Answer 4

  async function scanBoard(qrCode)
 {

      let board = await getBoard(qrCode);
  }
  catch (e)
  {
      throw e;
  }

 }

async function getBoard(qrcode)
      {

                let dbConn = await  db.createConnection(dbConfig);
                let rows = await dbConn.query("SELECT * FROM boards WHERE id = ?", [qrcode]);
                if (rows.length >= 1)

                // If you need to re-use connection, create a connection instance and re-use.Do not close here

                return rows[0];            
        }