javascript 查询mysql_javascript-Node.js中的MySQL问题-获取所有查询
您应该将回调传递到db.query中,或者返回promise而不是dist,因为db.query是一种异步方法,因此无法以同步方式调用异步方法.在过去,例如,我们将使用回调
exports.getList = function(db, conf, callback) {
db.query('', function (err, result) {
if(err) return callback(err);
callback(null, result);
});
}
getList(db,conf, function(err, result) {
console.log(result);
});
现在我想建议使用Promise.
exports.getList = function(db, conf) {
return new Promise(function(resolve, reject) {
db.query("SELECT id, title FROM animal a " + (conf.limit > 0 ? " LIMIT " + conf.limit : "" ), function(err, rows, fields) {
if(err) {
reject(err);
return;
}
var dict = [];
for(var key in rows) {
var row = rows[key];
//
dict.push({
'title' : 'Buster',
'animal' : 'Dog',
'age' : '12',
'photo' : 'https://placeholdit.imgix.net/~text?txtsize=24&txt=260×200&w=260&h=200'
});
});
resolve(dict);
});
}
getList(db,config).then(function(result) {
console.log(result);
}).catch(function(e) {
console.log(e);
});
例如,您还可以并行调用两个查询
Promise.all([getList1(db,config), getList2(db,config)]).then(function(result) {
console.log('result of getList1', result[0]);
console.log('result of getList2', result[1]);
});
并保证,您可以将es6生成器与co一起使用,以同步方式调用异步方法
var co = require('co');
co(function* () {
try {
var result = yield getList(db, conf);
// here is your result
} catch(e) {
console.log(e);
}
});