示例代码:
pool.getConnection(function(err, connection) {
async.waterfall([function (cb) {
connection.query('SELECT * FROM aaa', function(err, res_aaa) {
cb(err, res_aaa);
});
}, function (res_aaa, cb) {
for (let i = 0, l = res_aaa.length; i < l; i++) {
connection.query('SELECT name FROM bbb WHERE id = ?', [user_id], function(err, name) {
res_aaa[i].name = name; // name 如何才能传到外部 res_aaa?
});
}
console.log(res_aaa); // 这里如何获取上面 name 的值?
cb(err, res_aaa);
}], function (err, result) {
});
});
console.log(res_aaa); 这里的 res_aaa 怎么才能得到 name 的值?