mysql - node.js 合并多个控制流

Question

随着我发现它的更多用途，我慢慢开始越来越多地使用 node.js。我对它有很好的了解，使用 express 进行简单的 REST 服务。我正在尝试用它来编写一个小的实用程序脚本。想象一下这个非常非常简单的示例，它获取 mysql 行，遍历每一行并更新它们，然后打印“完成”。请忽略您显然可以使用一个 mysql 查询执行此操作的事实:

q=mysql_query("select id from table");
while($r=mysql_fetch_array($q)){
  mysql_query("update table set col1 = 'whatever' where id=".$r['id']);
}
print "done here!";

在 node.js 中这样做比较麻烦；我可以进行查询，遍历所有行并使用如下内容发布更新:

doQuery("select id from table",function(rows){
   for(var i=0;i<rows.length;i++){
      doQuery("update table set col1='whatever' where id="+rows[i]['id'],function(){
         //do I do something here? this will run as many times as rows were returned in the select
      })
   }
})

function doQuery(sql, callback){//utility function to help do the query
    var mysqlconnection = mysql.createConnection({
        host     : 'localhost',
        user     : 'user',
        password : '********',
        database:  'dbname'
    });
    mysqlconnection.connect(function(err1){
        mysqlconnection.query(sql, function(error, results) {
            if(callback)callback(results)
        })
    })
}

因此对于这个示例，我进行了单个 select 查询，然后将我的控制流拆分为多个流。我如何将其恢复为一个控制流程？或者，换句话说，当所有 updates 都已完成时，我如何简单地将 console.log “完成”？

我看到 promises 可能会有帮助，但所有这些基本示例都显示了静态数量的查询，我的问题是动态的，并且基于 mysql 的结果。

谢谢!

Answer 1

你可以试试async ，一个流行的 nodejs 模块，用于处理异步任务。

var async = require("async");

function doQuery(sql, callback){
  var mysqlconnection = mysql.createConnection({
    host     : 'localhost',
    user     : 'user',
    password : '********',
    database:  'dbname'
  });
  mysqlconnection.connect(function(err1){
    mysqlconnection.query(sql, function(error, results) {
      if(callback) callback(results);
    });
  });
}

function doUpdateQueryForEachRow(row, callback) {
  doQuery("update table set col1='whatever' where id=" + row.id, function (result) {
    callback(null, result); // the first parameter should be an error object
  });
}

doQuery("select id from table", function (rows) {
  async.map(rows, doUpdateQueryForEachRow, function (error, results) {
    // do something..
  });
});