Node.js中的多个依赖SQL查询

Question

我试图构建一个应用程序，它要求我在每个视图/控制器上进行多个查询。

Im试图使用嵌套结构异步执行该操作，但sql结果在内部闭包中未定义。

这是我用来做这个的函数：

var conn = db.config(mysql);

function run_queries(conn,callback) {

    conn.query(sql1, var1, function(err, res1) {

        if(err){ callback(err); return; }

        console.log(res1);     // RETURNS SUCCESSFULLY!

        conn.query(sql2, var2, function(err, res2) {

            if(err){ callback(err); return; }

            console.log(res2); // UNDEFINED :(

            callback(null, res2);

        });

    });

}

run_queries(conn,function(err, result){

    console.log(result);       // UNDEFINED :(

});

我已经检查了我的SQL，它没有错误。如果我将sq1与sq2交换，外部闭包将返回对sq2的正确查询。

内部闭包只是没有返回一个查询。

Answer 1

异步对于异步调用非常有用。您可以使用异步模块很好地维护代码。

使用async.parallel的代码示例

var conn = db.config(mysql);
var async = require('async');

function run_queries(conn, cb) {


    async.parallel({

      res1: function (cb) {

        conn.query(sql1, var1, function (err, res1) {
          if (err) { cb(err) }
          else { cb(null, res1) }
        })
      },
      res2: function (cb) {

        conn.query(sql2, var2, function (err, res2) {
          if (err) { cb(err) }
          else { cb(null, res2) }
        })
      }
    },
    function (err, result) {
      if (err) { cb(err) }
      else { cb(null, result) }
    })

}

run_queries(conn, function (err, result) {
  console.log(result);       // UNDEFINED :(
  // GET OBJECT OF res1 AND res2
});