如何使用Sequelize在MySQL中实现跨Schema事务？

首先得明确：Sequelize官方文档里确实没有提供直接跨多个独立连接实例的统一事务API，但我们可以利用MySQL本身的特性来实现你想要的需求，下面给你两种实用的方案：

方案一：复用单个连接，跨Schema操作（推荐） #

因为MySQL允许在同一个数据库连接的单个事务中访问多个数据库（也就是你说的Schema），所以我们完全可以只创建一个Sequelize连接实例，然后给不同的模型指定对应的Schema，这样就能用常规的Sequelize事务来操作两个数据库了。

代码示例：

const Sequelize = require("sequelize");
const config = require("../config");

// 只创建一个主连接，后续通过模型指定Schema来操作不同数据库
const mainDb = new Sequelize(config.usersDatabaseName, config.username, config.password, config.options);

// 定义users数据库的模型，指定schema为usersDatabaseName
const User = mainDb.define('User', {
  // 这里定义你的User模型属性，比如name, email等
  name: Sequelize.STRING,
  email: Sequelize.STRING
}, { schema: config.usersDatabaseName });

// 定义products数据库的模型，指定schema为productsDatabaseName
const Product = mainDb.define('Product', {
  // 定义Product模型属性，比如title, price等
  title: Sequelize.STRING,
  price: Sequelize.FLOAT
}, { schema: config.productsDatabaseName });

// 现在就可以用常规的事务方法同时操作两个模型了
await mainDb.transaction(async (transaction) => {
  // 在事务中创建用户
  await User.create({ name: "John", email: "john@example.com" }, { transaction });
  // 在同一个事务中创建商品
  await Product.create({ title: "Laptop", price: 999.99 }, { transaction });
});

这种方式的好处是完全沿用Sequelize原生的事务API，不需要额外的复杂操作，而且性能更好，因为只用了一个数据库连接。

方案二：使用XA分布式事务（适合必须用两个独立连接的场景） #

如果你因为某些原因必须保留两个独立的Sequelize连接实例，那可以用MySQL支持的XA事务来实现分布式事务。不过这种方式需要手动管理事务的各个阶段，相对繁琐一些。

代码示例：

const Sequelize = require("sequelize");
const config = require("../config");

// 保留你原来的两个独立连接实例
const UsersDb = new Sequelize(config.usersDatabaseName, config.username, config.password, config.options);
const ProductsDb = new Sequelize(config.productsDatabaseName, config.username, config.password, config.options);

// 定义模型（这里假设你已经定义好了UsersDb.models.User和ProductsDb.models.Product）
async function runCrossSchemaTransaction() {
  // 生成一个唯一的事务ID，用来关联两个数据库的XA事务
  const txId = `cross_schema_tx_${Date.now()}`;
  let rollbackNeeded = true;

  try {
    // 在两个连接上启动XA事务
    await UsersDb.query(`XA START '${txId}'`);
    await ProductsDb.query(`XA START '${txId}'`);

    // 执行你的业务逻辑：操作两个数据库
    await UsersDb.models.User.create({ name: "Jane", email: "jane@example.com" });
    await ProductsDb.models.Product.create({ title: "Phone", price: 599.99 });

    // 结束并准备提交事务（XA的PREPARE阶段，确保两个数据库都能提交）
    await UsersDb.query(`XA END '${txId}'; XA PREPARE '${txId}'`);
    await ProductsDb.query(`XA END '${txId}'; XA PREPARE '${txId}'`);

    // 提交两个数据库的事务
    await UsersDb.query(`XA COMMIT '${txId}'`);
    await ProductsDb.query(`XA COMMIT '${txId}'`);

    rollbackNeeded = false;
  } catch (error) {
    console.error("事务执行失败，开始回滚:", error);
    // 回滚两个数据库的事务，忽略回滚可能出现的错误
    await UsersDb.query(`XA ROLLBACK '${txId}'`).catch(() => {});
    await ProductsDb.query(`XA ROLLBACK '${txId}'`).catch(() => {});
    throw error; // 抛出错误让上层处理
  } finally {
    // 防止万一有遗漏的情况，确保事务状态正确
    if (rollbackNeeded) {
      await UsersDb.query(`XA ROLLBACK '${txId}'`).catch(() => {});
      await ProductsDb.query(`XA ROLLBACK '${txId}'`).catch(() => {});
    }
  }
}

// 调用这个函数执行跨Schema事务
await runCrossSchemaTransaction();

需要注意的是，XA事务要求你的MySQL版本支持InnoDB引擎（大部分现代MySQL版本都支持），而且需要确保两个数据库的用户有足够的权限执行XA命令。

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