Sequelize事务执行后数据库未更新 求助排查

核心原因分析 #

控制台显示SQL执行但数据未写入，90%的概率是事务未提交，或者数据库操作没有关联到事务对象上——事务内的操作会在临时空间执行，只有提交后才会持久化到数据库；如果操作没绑定事务，那它不在事务上下文里，但若事务没提交，也可能导致数据被回滚（取决于隔离级别）。

正确的事务使用方式 #

1. 通过Model的sequelize实例创建事务（推荐写法） #

从你的Model中获取已初始化的sequelize实例，手动管理事务的提交与回滚：

// 假设你的模型是User
const User = require('./models/User');
const sequelize = User.sequelize;

async function createUserWithTransaction() {
  let transaction;
  try {
    // 启动事务
    transaction = await sequelize.transaction();

    // 所有数据库操作必须显式传递transaction参数
    await User.create({
      username: 'test',
      email: 'test@example.com'
    }, { transaction });

    // 提交事务——这一步是数据写入的关键
    await transaction.commit();
    console.log('事务提交成功，数据已写入');
  } catch (err) {
    // 出错必须回滚，否则事务会占用数据库连接
    if (transaction) await transaction.rollback();
    console.error('事务执行失败，已回滚:', err);
    throw err;
  }
}

2. 回调式自动事务（避免手动提交/回滚） #

如果不想手动处理commit和rollback，可以用回调式写法，Sequelize会自动在回调成功时提交，出错时回滚：

const sequelize = User.sequelize;

async function createUser() {
  await sequelize.transaction(async (t) => {
    // 操作绑定事务对象t
    await User.create({
      username: 'auto-test',
      email: 'auto@test.com'
    }, { transaction: t });

    // 如果回调内抛出错误，Sequelize自动回滚；否则自动提交
  });
}

解决你遇到的报错问题 #

「sequelize is not a function」报错 #

你注入的sequelizeInstance大概率不是初始化后的sequelize实例，而是Sequelize构造函数本身。区分两者：

// 错误：用了Sequelize类而非实例
const Sequelize = require('sequelize');
Sequelize.transaction(); // 报错，transaction是实例方法

// 正确：使用初始化后的实例
const sequelize = new Sequelize({
  dialect: 'mysql',
  host: 'localhost',
  database: 'your_db'
});
await sequelize.transaction(); // 正常执行

「Sequelize.transaction不存在」报错 #

同样是混淆了Sequelize类和实例：transaction是实例方法，不是静态方法，必须用已初始化的sequelize实例调用，不能直接用Sequelize.transaction()。

关键注意事项 #

• 所有在事务内的数据库操作（create/update/destroy等），必须显式传递{ transaction }选项，否则该操作不在事务上下文内，会独立执行或导致事务异常。
• 务必处理异常，未捕获的错误会导致事务挂起，占用数据库连接，甚至引发死锁。
• 检查数据库引擎是否支持事务（比如MySQL的MyISAM引擎不支持事务，需改用InnoDB）。

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