javascript - NodeJS mysql同步查询

Question

我想像这样在 nodejs 中运行同步查询...

for (var i in data){

conn.query("Select 1 from user where userid="+data[i].id,function(err,row){
     Rows.push(row);
});

}

console.log(Rows);

在此代码块中，我的行始终为空...我想运行同步查询

Answer 1

你可能无法在线程阻塞的意义上同步使用这样的函数(你也不应该!)但是如果你使用数据库连接的 promise 版本(使用 Bluebird 的 promisifyAll 或特定的promise 版本的 mysql 驱动程序在 npm 上可用)和新的 async/await 语法(或基于生成器的协程，用于早于 Node 7.x 的平台，其中 async/await 不可用——另一种选择是使用 Babel 进行转译)。

示例 - 您可以使用这样的代码:

for (var i in data) {
  let row = await conn.query("Select 1 from user where 
  userid="+data[i].id);
  Rows.push(row);
}
console.log(Rows);

但如果它可以并行运行，那么这样的事情会更高效、更短:

let Rows = await Promise.all(data.map(item =>
  conn.query("Select 1 from user where userid=" + item.id));
console.log(Rows);

有关该主题的更多详细信息，请参阅:

• Do async in a blocking program language way?
• Using async/await + Bluebird to promisifyAll
• try/catch blocks with async/await
• Using acyns/await in Node 6 with Babel
• jQuery: Return data after ajax call success

注意 - 它只能在用 async 关键字声明的函数内部使用。

警告:您的代码可能容易受到 SQL 注入(inject)攻击。您应该在 SQL 中使用占位符而不是字符串连接。我没有修复您代码的那个方面 - 有关更多详细信息，请参阅这些答案:

• cannot use backtick when using nodejs 7.3.0
• Node.js - The multi part could not be bound
• How to escape mysql special characters with sockets.io/node.js/javascript
• Node js - Promise Rejection Warning when process a lot of data
• Is it possible to listen for object instantiation in Node.js?