Node.js循环内调用SQL查询无法顺序执行的解决方法

这个问题的核心是JavaScript异步操作的特性加上闭包陷阱导致的：

1. request.query()是异步方法，它不会阻塞循环执行——循环会先快速跑完所有迭代，此时变量i已经变成了updateObj.length（也就是你案例里的4），之后异步回调才开始逐个执行，这时候访问updateObj[i]自然会拿到undefined，抛出类型错误。
2. 同时，所有查询会被并行发起，所以回调的执行顺序没法和循环顺序对应，导致日志混乱。

下面是逐步优化的解决方案，最终实现你想要的顺序执行效果：

第一步：先解决闭包中i的取值问题（并行执行） #

如果只是想让每个回调能拿到对应迭代的i值，不要求严格顺序执行，可以把循环变量i改成let（块级作用域），这样每次迭代都会创建一个独立的i绑定：

try {
  console.log('updateData');
  mssql.connect(config, function(err) {
    if (err) throw err; // 别忘了处理连接错误
    console.log('Connect');
    var request = new mssql.Request();
    var updateObj = JSON.parse(req.body.data);
    console.log('updateObj :', updateObj);
    
    // 把var i改成let i，创建块级作用域
    for (let i = 0; i < updateObj.length; i++) {
      var selectQueryString = "SELECT * FROM tBM WHERE BM_i = " + updateObj[i].c_BM_IDs;
      console.log("Query : " + selectQueryString);
      console.log('loop I :', i);
      request.query(selectQueryString, function(err, recordset) {
        if (err) throw err; // 处理查询错误
        console.log("BM_i : " + recordset.recordset[0].BM_i);
        console.log('request I :', i); // 现在能拿到正确的i值了
        console.log("org up : " + updateObj[i].orgUpIDs);
        console.log("org lo : " + updateObj[i].orgLoIDs);
      });
    }
  });
} catch (err) {
  console.log(err)
}

不过这个方案还是会并行发起所有查询，日志里的回调输出顺序依然可能混乱，只是每个回调能拿到正确的i了。

第二步：实现严格顺序执行（async/await） #

如果要完全按照循环顺序逐个执行查询，让日志严格按你期望的顺序输出，推荐使用async/await来处理异步流程，这是现在最清晰的异步编程方式：

// 把整个逻辑放在async函数中
async function updateData() {
  try {
    console.log('updateData');
    // 用Promise版本的connect，避免回调嵌套
    await mssql.connect(config);
    console.log('Connect');
    
    const request = new mssql.Request();
    const updateObj = JSON.parse(req.body.data);
    console.log('updateObj :', updateObj);
    
    // 用for循环配合await，逐个执行查询
    for (let i = 0; i < updateObj.length; i++) {
      // 注意：这里要避免SQL注入！建议用参数化查询
      const selectQueryString = `SELECT * FROM tBM WHERE BM_i = @bmId`;
      request.input('bmId', mssql.Int, updateObj[i].c_BM_IDs); // 假设BM_i是整数类型，根据实际调整
      
      console.log("Query : " + selectQueryString.replace('@bmId', updateObj[i].c_BM_IDs));
      console.log('loop I :', i);
      
      // await等待查询完成，再执行下一次循环
      const recordset = await request.query(selectQueryString);
      console.log("BM_i : " + recordset.recordset[0].BM_i);
      console.log('request I :', i);
      console.log("org up : " + updateObj[i].orgUpIDs);
      console.log("org lo : " + updateObj[i].orgLoIDs);
    }
    
    // 操作完成后关闭连接
    await mssql.close();
  } catch (err) {
    console.error('出错了:', err);
    // 发生错误时也要确保连接关闭
    await mssql.close();
  }
}

// 调用这个async函数
updateData();

关键改动说明： #

1. 改用async/await：把整个逻辑包装在async函数里，用await等待每个异步操作完成，确保循环按顺序执行。
2. 参数化查询：替换了字符串拼接SQL的方式，用request.input()来传入参数，避免严重的SQL注入风险（这是你原代码里的一个隐患，一定要注意！）。
3. Promise化mssql方法：mssql的现代版本已经支持Promise，所以可以用await mssql.connect(config)代替回调，让代码更简洁。
4. 错误处理：完善了连接和查询的错误处理，确保发生错误时能关闭数据库连接。

这样修改后，就能完全实现你期望的日志输出顺序，同时解决了原代码里的闭包陷阱和异步执行顺序问题。

内容的提问来源于stack exchange，提问作者kudy