如何正确使用 Promise.all() 和 then() 异步函数？

Question

在下面的代码中，我试图将第一个和第二个查询的结果放入一个名为 result 的全局变量中。问题是 Promise.all() 没有等待查询完成，然后才继续 then()。

我该如何解决？

代码：

var result = {};
Promise.all([
  connection.query('SELECT * FROM analysis', 
    function(err, rows, fields) {
      if (err) throw err;
      result.analysis = rows;
      console.log("query 1");
  }), 
  connection.query('SELECT * FROM analysis_description', 
    function(err, rows, fields) {
      if (err) throw err;
      result.analysis_description = rows;
      console.log("query 2");
  })
])
.then(function(result){
  console.log(result);
  console.log("result");
});

输出：

result
query 1
query 2

Answer 1

如评论中所述，您需要手动承诺异步调用：

queryAsync = query => new Promise((resolve, reject) => {
  connection.query(query, (err, rows) => {
    if(err) return reject(err)
    resolve(rows)
  })
})

或者首选方法是使用像 bluebird:

这样的库

connection  = require('bluebird').promisifyAll(connection)

你的代码可以修改成：

var result = {};
Promise.all([
  connection.queryAsync('SELECT * FROM analysis').then(rows => result.analysis = rows), 
  connection.queryAsync('SELECT * FROM analysis_description').then(rows => result.analysis_description = rows)
]).then(function(result){
  console.log(result);
  console.log("result");
}).catch(e => console.error(e));

Answer 2

谢谢大家！正如大家所说，问题出在 Promise.all() 中的错误参数。这是修改后的代码。

代码：

Promise.promisifyAll(require("mysql/lib/Connection").prototype)

var result = {};
Promise.all([
  connection.queryAsync('SELECT * FROM analysis')
  .then(function(rows){
    console.log(rows);
    result.analysis = rows;
  }), 
  connection.queryAsync('SELECT * FROM analysis_description')
  .then(function(rows){
    result.analysis_description = rows;
  })
])
.then(function(){
  console.log(result);
  console.log("result");
});

如何正确使用 Promise.all() 和 then() 异步函数？

How to properly use Promise.all() and then() with async functions?

javascript

callback

node.js

promise

bluebird