Sequelize循环后事务提前提交，如何让事务执行后续逻辑？

你的问题核心在于循环里过早使用return，导致Promise链提前终止，事务也就跟着提交了。第一个for循环的第一次迭代就return Roomtype.create(...)，这会直接让外层的then函数返回这个Promise，Sequelize会认为当前事务的所有操作已经完成，立刻提交事务，后面的第二个循环代码根本没机会执行。

要解决这个问题，我们需要把循环中的所有异步操作（Roomtype.create、User.create）都包装成Promise数组，用Promise.all()来等待所有操作完成后，再继续后续逻辑，这样事务就会等到所有操作都执行完毕才会提交。

修正后的代码示例（串行执行循环） #

return sm.sequelize.transaction(function (t) { 
  // 第一步：创建Room记录
  return Room.create({ room_type: req.body.room_type }, { transaction: t })
    .then(function(roomtype) { 
      // 收集第一个循环的所有Promise
      const roomtypePromises = [];
      for (let i = 0; i < room.length; i++) { 
        roomtypePromises.push(Roomtype.create({ name: req.body.roomtype[i] }, { transaction: t }));
      }
      // 等待第一个循环的所有操作完成
      return Promise.all(roomtypePromises);
    })
    .then(function(roomtypeResults) {
      // 第一个循环完成后，处理第二个循环
      const userPromises = [];
      for (let i = 0; i < another.length; i++) { 
        userPromises.push(User.create({ email: req.body.email[i] }, { transaction: t }));
      }
      // 等待第二个循环的所有操作完成
      return Promise.all(userPromises);
    })
    .then(function(userResults) {
      // 所有操作完成，可在这里统一处理结果
      return { createdRoomtypes: roomtypeResults, createdUsers: userResults };
    })
    .catch(function(err) {
      // 捕获错误，事务会自动回滚
      throw err;
    });
});

关键说明 #

• 避免循环内return：循环里只收集Promise，不要直接return，否则会直接中断循环和整个Promise链。
• 使用Promise.all：它会等待数组中所有Promise都成功resolve后，才会进入下一个then逻辑，确保循环里的所有操作都执行完毕。
• 用let声明循环变量：循环里的i必须用let声明，避免闭包导致的变量污染问题（如果用var，所有循环迭代会共享同一个i值，导致异步操作拿到的参数出错）。
• 事务自动管理：只要事务回调中返回的Promise链正常走完，Sequelize会自动提交事务；如果任何一个Promise reject（比如数据库操作失败），事务会自动回滚所有已执行的操作。

可选优化：并行执行两个循环 #

如果你的业务逻辑允许两个循环的操作同时执行（不需要严格串行），可以把两个循环的Promise合并后一起用Promise.all，效率会更高：

return sm.sequelize.transaction(function (t) { 
  return Room.create({ room_type: req.body.room_type }, { transaction: t })
    .then(function(roomtype) { 
      const allPromises = [];
      // 收集第一个循环的Promise
      for (let i = 0; i < room.length; i++) { 
        allPromises.push(Roomtype.create({ name: req.body.roomtype[i] }, { transaction: t }));
      }
      // 收集第二个循环的Promise
      for (let i = 0; i < another.length; i++) { 
        allPromises.push(User.create({ email: req.body.email[i] }, { transaction: t }));
      }
      // 等待所有操作完成
      return Promise.all(allPromises);
    })
    .catch(function(err) {
      throw err;
    });
});

内容的提问来源于stack exchange，提问作者hudan abdur r