sql >> Databasteknik >  >> RDS >> Mysql

Node Mysql asynkronisera flera frågor

Så du måste vänta på att alla återuppringningar kommer tillbaka innan du skickar svaret. Om vi ​​ignorerar felhantering och tomma resultat för enkelhets skull kan detta göras på samma sätt som:

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

Med löften, titta på Promise.all-funktionen som returnerar ett nytt löfte. Dessa löften är lösta när alla löften som skickas till den i arrayen är lösta. Med Q-biblioteket borde det vara något i stil med:

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


  1. SQLite användarbehörigheter

  2. Vilken metod är bättre för att validera användaruppgifter?

  3. Vilket är snabbare:flera enkla INSERT eller en INSERT med flera rader?

  4. Automatiserad testning av uppgraderingsprocessen för PXC/MariaDB Galera Cluster