Sequelize在forEach循环中使用事务未提交至数据库问题

嘿，我来帮你搞定这个头疼的问题！你遇到的核心问题是forEach和async/await的兼容性缺陷，再加上Sequelize事务的使用姿势没到位，导致控制台能打印结果，但数据根本没真正提交到数据库。

问题根源分析 #

forEach方法本身不会等待异步回调函数执行完成——它会一股脑把所有回调都触发，然后直接跳过，完全不管里面的await操作有没有做完。这就导致你的事务逻辑可能还在异步处理中，程序就已经走到了后面的流程，要么事务没来得及提交就被销毁，要么每个回调里的事务因为异步顺序混乱，根本没正确绑定到数据库操作上。

正确的解决方案 #

改用for...of循环（它能完美支持async/await的等待逻辑），同时把Sequelize事务的控制放在循环外层，确保所有数据库操作都在同一个事务上下文里执行，要么全成功提交，要么全失败回滚。

给你写个完整的示例代码：

// 先获取Sequelize实例，假设你已经初始化好了
const sequelize = require('./your-sequelize-instance');

async function processDocuments(docFiles, documentInfo, req, res) {
  let transaction;
  try {
    // 1. 启动一个事务
    transaction = await sequelize.transaction();

    // 2. 用for...of循环处理每个文档，确保等待异步操作完成
    for (const doc of documentInfo) {
      // 等待图片上传完成
      const frontImgName = await module.exports.uploadImage(docFiles, doc.front, req, res);
      const backImgName = await module.exports.uploadImage(docFiles, doc.back, req, res);

      // 3. 执行数据库操作时，一定要传入transaction参数
      // 这里假设你是要创建KycDoc记录，替换成你的实际模型操作
      await KycDoc.create({
        frontImg: frontImgName,
        backImg: backImgName,
        // 其他必填字段...
      }, { transaction });
    }

    // 4. 所有操作都成功后，提交事务
    await transaction.commit();
    console.log('所有文档数据已成功提交到数据库！');
    // 这里可以给前端返回成功响应
    res.status(200).json({ message: '处理完成' });
  } catch (error) {
    // 5. 任何一步出错，立即回滚事务
    if (transaction) await transaction.rollback();
    console.error('处理失败，事务已回滚:', error);
    // 返回错误响应给前端
    res.status(500).json({ error: '处理失败' });
  }
}

关键注意事项 #

• 不要用forEach处理异步逻辑：forEach、map这类数组方法天生不支持等待异步回调，遇到异步场景优先用for...of或者Promise.all（如果可以并行处理的话）。
• 事务上下文要统一：所有涉及数据库的操作必须传入{ transaction }参数，否则Sequelize会用默认的独立事务执行，和你手动创建的事务无关。
• 必须处理错误回滚：用try/catch包裹整个流程，一旦出错就回滚事务，避免出现部分数据提交、部分失败的不一致情况。

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