如何仅在另一个使用 express js 完成时运行查询

Question

请对我温柔一点，我是 node js 的新手。我在 for 循环中运行两个查询，将值插入到两个名为 orders 和 requests 的表中。在插入订单表后，我将 insertId 传递给变量 orderid，然后将其添加到我的第二个插入查询中。所有这些工作正常，完成后我想查询一个名为 invoice 的视图，以便我可以获得一些我刚刚放入数据库的信息。问题是它甚至在完成两个查询之前就从视图返回结果，因此我得到一个空响应。这是我的代码。

for(var i = 0; i<items.length; i++){
  connection.query('INSERT INTO orders(referenceid,itemid,quantity,dac,requestid,locationid) VALUES(?,?,?,?,?,?);',[referenceid,items[i].id,items[i].quantity,dac,requestid,locationid], function(errors,results,fields){
                if(errors){ throw errors};
                    var orderid = results.insertId;
                connection.query('INSERT INTO requests(requestid,orderid,price) VALUES(?,?,?)',[requestid,orderid,price],function(errors,results,fields){
                })
  })

}
connection.query('SELECT * FROM invoice WHERE requestid = ? ,[requestid],function(errors,results,fields){
                })

所以任何人都可以帮助我让 SELECT 查询仅在 for 循环中的所有插入都完成时运行。我的数据库是mysql。

Answer 1

我不确定您使用的是哪个 SQL npm 模块，因此我无法参考任何文档，但我相信您对 connection.query() 的调用是异步的，因为它们应该是异步的。这会导致您在 for 循环外的最终 connection.query() 在 for 循环内的那些之前执行，因此，您将没有 requestId 可在最终查询中使用。

我可以立即提供两种可能的解决方案：

• 将查询调用嵌套到回调中
• 使用明确的承诺

因此，对于第一个选项，您可以将最终查询放入查询的嵌套回调中，放入 requests 表中。据我了解，您只希望在插入到orders 和requests 完成后从invoice 中选择行。

至于第二个选项，您可以将 for 循环的内容重构为辅助函数，并将其封装为 return new Promise()，如下所示：

const helper = (<any_params_you_need>) => {
   return new Promise(resolve, reject) => {
      for(var i = 0; i<items.length; i++){
         connection.query('INSERT INTO orders(referenceid,itemid,quantity,dac,requestid,locationid) VALUES(?,?,?,?,?,?);',[referenceid,items[i].id,items[i].quantity,dac,requestid,locationid], function(errors,results,fields){
                if(errors) { reject(err); }
                var orderid = results.insertId;
                connection.query('INSERT INTO requests(requestid,orderid,price) 
                VALUES(?,?,?)', 
                [requestid,orderid,price],function(errors,results,fields){
                    resolve(results);
                })
         })
      }
   }
}

一旦你设置了帮助函数，你就可以在你的选择查询之前使用await 像这样调用它：await helper();。例如，在调用函数中，它看起来像：

...
const results = await helper();
connection.query('SELECT * FROM invoice WHERE requestid = ? ,[requestid],function(errors,results,fields){});
...