Node.js中如何让for循环等待数据库操作完成后再执行下一轮迭代

你当前使用的是回调风格的数据库异步API，JavaScript的同步for循环不会等待回调函数执行完成就会进入下一次迭代，所有的数据库操作会在极短时间内全部发起，最终执行完成的顺序完全取决于各自操作的耗时，所以会出现顺序混乱的情况。

这是目前可读性最高、最适合新手的方案，核心逻辑是把异步操作包装为Promise，再通过await关键字强制等待单次操作完成后再进入下一轮循环。

第一步：包装回调式方法为Promise #

Node.js内置的util.promisify可以快速把符合错误优先回调规范的异步方法转为返回Promise的方法：

const { promisify } = require('util');
// 包装UPDATE方法
const runUpdate = promisify(clientChart.run.bind(clientChart));
// 如果chartInsert也是回调风格，同样做包装
const chartInsertAsync = promisify(chartInsert);

第二步：改写循环逻辑 #

async function insert_into_db() {
  // 先把循环次数转成整数，避免浮点运算导致的次数异常
  const loopCount = Math.floor(howmuch / dueAmount);
  for (let i = loopCount; i > 0; i--) {
    // 补上变量声明，避免全局变量污染导致的数值覆盖问题
    const clientChartArray = [aa1, bb1, (cc1 * i), dd1, ee1, ff1, gg1, hh1];
    const PreviousChangesArray = [a1, b1, c1, d1, rowid];

    try {
      if (check_bal) {
        // 等待UPDATE操作完成再执行后续逻辑
        await runUpdate(`UPDATE hp2269 SET RD = ?, DL = ?, BA = ?, RA = ?  WHERE rowid = ? ;`, PreviousChangesArray);
        if (check_reminder == false) {
          // 等待插入操作完成
          await chartInsertAsync(clientChartArray);
        }
      } else {
        // 等待插入操作完成
        await chartInsertAsync(clientChartArray);
      }
    } catch (err) {
      // 可在这里自定义错误处理逻辑，比如打印日志、终止循环
      console.error('数据库操作失败：', err);
      // 如果需要出错就终止后续操作，放开下面的注释即可
      // throw err;
    }
  }
  // 所有循环执行完成后，可在这里调用依赖最终插入行的后续函数
  // yourNextFunction();
}

• 调用insert_into_db时，要么在其他async函数中用await调用，要么通过.then()处理后续逻辑，因为它本身已经是返回Promise的异步函数。
• 如果你使用的数据库驱动本身已经提供了Promise风格的API（比如mysql2的promise接口、sqlite的promise版包），可以直接使用自带的方法，不需要手动包装。
• 如果你的业务允许并行操作且不需要保证顺序，也可以用Promise.all批量执行操作，执行效率会更高，但你当前需求要求严格顺序，所以必须用串行方案。

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