使用 node.js + mysql 的最后一个 insertId 的全局范围

Question

我正在调用函数，以便使用node.js 的mysql 模块将一些值插入到数据库表中。该函数在 for 循环内调用，我可以在函数内获取每个 INSERT 查询的最后一个 insertId。

我的目的

我想将这些 id's 存储到一个数组中，以便稍后在我的代码中使用它们，但我不能这样做。

- 函数调用

 for(var i=0;i<some_number;i++){
   if (<something is true>){

  var lastid = [];
  //Function calling
  function_a(x, y, z, w,  function(error, result) {
   if(!error){
       lastid.push(result.insertId);
       }
   //To Do
   else{}
  });
 }
}

- 功能

function function_a(a, b, c, d, callback){
//Connection to the DB
const con = mysql.createConnection({
  host: 'host',
  user: 'user',
  password: 'password',
  database: 'database'
});

//DB query
var query = "INSERT INTO my_table (column1, column1, column1, column1) VALUES ('"+a+"', '"+b+"', '"+c+"', '"+d+"')";
con.query(query, (err, rows) => {
 var e = rows.insertId;
 return callback(err, e);
});
con.end(); 
}

问题是我不能在函数外使用 id。

知道我该怎么做吗？这是关于变量范围的吗？

Answer 1

这里有几个问题，是的，它们部分与变量范围有关。

将var lastid = [];放在for循环之前，这样你就可以在循环之后使用它。但是，由于您在循环中有回调机制，因此您必须等待整个循环完成（从 0 到 some_number-1 调用的所有回调，以便在 lastid 数组中具有正确的值。回调是一件麻烦事, 但你可以用它们或承诺来做。你可以谷歌在 for 循环中处理回调。

Answer 2

函数function_a 是一个asynchronous 函数。在您的情况下，您可以使用 async 模块来执行此任务：

var taskIds = Array.apply(null, {length: some_number}).map(Number.call, Number);
var lastid = [];
async.eachLimit(taskIds, 32, function (taskId, done) {
  if (<something is true>) {
    function_a(x, y, z, w,  function(error, result) {
      if(!error){
        lastid.push(result.insertId);
      }
      //To Do
      else{}
      done()
    });
  } else {
    done()
  }
}, function () { 
  // Do some thing with lastid
  console.log(lastid);
});