Node Mysql async beberapa kueri

Jadi, Anda harus menunggu semua panggilan balik kembali sebelum Anda mengirim respons. Jika kita mengabaikan penanganan kesalahan dan mengosongkan hasil untuk kesederhanaan, ini dapat dilakukan seperti:

var callback = function(blogs) {
    res.send(blogs);
}

connection.query("SELECT * FROM blogs ORDER BY time DESC", function(err, blogs, fields) {
    var pending = blogs.length;

   for (blog in blogs) {

        connection.query("SELECT * FROM tags WHERE blog_id='blog.id' ", function(err, tags, fields) {
        blog.tags = tags;

        if (0 === --pending) {
            callback(blogs);
        }
     });
   }
});

Dengan janji, lihat fungsi Promise.all yang mengembalikan janji baru. Janji ini diselesaikan ketika semua janji yang diteruskan ke dalam array diselesaikan. Dengan pustaka Q seharusnya seperti ini:

var getTags = function(blog) {
    var deferred = Q.defer();
    connection.query("SELECT * FROM tags WHERE blog_id='blog.id' ", function(err, tags, fields) {
        blog.tags = tags;
        deferred.resolve();
    });
    return deferred.promise;
}

var promises = blogs.map(getTags(blog));

Q.all(promises).then(res.send(blogs));