如何正確使用Promise.all（）和然後（）與異步函數？

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

像評論說，你需要手動promisify的異步調用，：

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"); 
});