node-mysql 获取值问题？（已解决）
示例代码：
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 的值？
8 回复
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 (res_aaa, cb) {
console.log(res_aaa); // 是放这里吗？放这里也得不到 name 值
}], function (err, result) {
});
});https://github.com/alsotang/node-lessons/tree/master/lesson4 看看这个吧。换用 eventproxy 方便点
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？
});
}
这一段用async.forEachOf改写，形如：
async.forEachOf(array, (item, key, cb) => {
}, (err, results) => {
})
补充一个sql执行的封装。
/**
* 执行sql语句
* @param {string} sql 执行的语句
* @param {function} next 回调函数
*/
function sqlExecute (sql, next = function () {}) {
pool.getConnection((err, connection) => {
if (err) {
next(err, null)
} else {
connection.query(sql, (err, rows) => {
if (err) {
sails.log.warn('sql err', sql)
}
next(err, rows)
connection.release()
})
}
})
}
以后需要执行的时候就这样子：
let sql = 'your sql';
sqlExecute(sql, function(err, rows) {
})
