如何将 Sequelize 事务传递给关联辅助方法

在使用 Sequelize ORM 时，我们可能会遇到需要使用事务来处理关联辅助方法的情况，例如添加或删除关联。本文将介绍如何将 Sequelize 事务传递给关联辅助方法。

环境准备

在开始本文之前，请确保你已经安装了以下环境：

• Node.js 12.x 或更高版本
• Sequelize ORM 6.x

创建事务

首先，我们需要创建一个 Sequelize 事务。假设我们已经创建了一个 Sequelize 实例并连接到了数据库：

const { Sequelize } = require('sequelize');

const sequelize = new Sequelize({
  dialect: 'mysql',
  host: 'localhost',
  port: 3306,
  username: 'root',
  password: 'password',
  database: 'database',
});

我们可以使用 sequelize.transaction() 方法来创建一个事务：

await sequelize.transaction(async (t) => {
  // 在事务内执行操作
});

在这个回调函数内，我们可以执行任意的 Sequelize 方法，并将事务对象作为参数传递进去。所有在该回调函数内执行的操作都将在该事务内执行。

传递事务到关联辅助方法

当我们需要在事务内添加或删除关联时，我们可以使用 Sequelize 提供的关联辅助方法。例如，在下面的示例中，我们有两个模型：Book 和 Author。一个书籍可能会有多个作者，所以我们将它们之间建立了多对多的关联。

const Book = sequelize.define('book', {
  title: Sequelize.STRING,
});

const Author = sequelize.define('author', {
  name: Sequelize.STRING,
});

Book.belongsToMany(Author, { through: 'BookAuthor' });
Author.belongsToMany(Book, { through: 'BookAuthor' });

await sequelize.sync();

接下来，我们将介绍如何在事务内添加或删除关联。

添加关联

要在事务内添加关联，我们可以使用 addAssociation() 方法：

await sequelize.transaction(async (t) => {
  const book = await Book.create({ title: 'Book' }, { transaction: t });
  const author = await Author.create({ name: 'Author' }, { transaction: t });

  await book.addAuthor(author, { transaction: t });
});

在上面的代码中，我们使用 addAuthor() 方法向书籍中添加了一个作者。我们将 transaction 参数传递给了 addAuthor() 方法，以便将事务对象传递给它。

删除关联

要在事务内删除关联，我们可以使用 removeAssociation() 方法：

await sequelize.transaction(async (t) => {
  const book = await Book.findByPk(1, { transaction: t });
  const author = await Author.findByPk(1, { transaction: t });

  await book.removeAuthor(author, { transaction: t });
});

在上面的代码中，我们使用 removeAuthor() 方法从书籍中删除了一个作者。我们将 transaction 参数传递给了 removeAuthor() 方法，以便将事务对象传递给它。

结论

在本文中，我们介绍了如何将 Sequelize 事务传递给关联辅助方法。通过在添加或删除关联时将事务对象作为参数传递给关联辅助方法，我们可以确保这些操作也是在该事务内执行的。