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

Question

我正在尝试构建一个应用程序，它要求我对每个 View / Controller 进行多个查询。

我尝试使用嵌套结构进行异步操作，但 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 对于异步调用非常有用。您可以使用异步模块很好地维护您的代码。

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