事务是一组数据库操作的集合，这些操作要么全部完成，要么全部取消。在 Sequelize 中使用事务可以确保一组操作的原子性，从而保证数据库的数据一致性和完整性。本文将介绍如何在 Sequelize 中使用事务，以及如何正确处理异常情况。
基础使用
使用 Sequelize 创建事务很简单，只需要调用 sequelize.transaction() 方法获取一个事务对象即可，如下所示：
-- -------------------- ---- ------- ----- --------- - --- --------------------- ----------- ----------- - -- --- --- --------------------------- - -- - -- -------- ----- ------------------------------ --------- ------ -- - ------ - --- - - -- - ------------ - --- ----- ------------------------------ ------ ------ -- - ------ - --- - - -- - ------------ - --- ---
上述代码中，我们通过 sequelize.transaction() 方法获取了一个事务对象 t，然后在事务中执行了两个数据库更新操作。由于这两个操作都设置了 transaction: t，所以它们都在同一个事务中。
如果事务中的所有操作都执行成功，则事务自动提交并结束。如果其中任何一个操作执行失败，则事务将自动回滚，并且所有已执行的操作都将撤销。例如，在上面的例子中，如果第二个操作执行失败，则第一个操作也将被撤销。
错误处理
在事务中处理错误非常重要，因为如果不小心忽略了一个错误，整个事务可能会失败，从而导致数据不一致或完整性被破坏。因此，在使用 Sequelize 事务时，请务必注意以下几点。
抛出异常
如果在事务中的任何操作失败，则必须通过抛出异常来通知 Sequelize 撤销事务。要抛出异常，只需在操作中使用 throw new Error() 即可。例如：
sequelize.transaction(async t => {
await sequelize.models.User.update({ username: 'test' }, { where: { id: 1 } }, { transaction: t });
throw new Error('Something went wrong');
await sequelize.models.Post.update({ title: 'test' }, { where: { id: 1 } }, { transaction: t });
});上述代码中，第二个操作使用 throw new Error() 抛出了一个异常。这将导致事务自动回滚，并且第一个操作将被撤销。
捕获异常
在抛出异常后，必须在代码中处理异常情况。如果不处理异常，则程序可能会崩溃，并且事务可能不会正确回滚。为了捕获异常，可以使用 try...catch 语句，如下所示：
-- -------------------- ---- -------
--- -
----- --------------------------- - -- -
----- ------------------------------ --------- ------ -- - ------ - --- - - -- - ------------ - ---
----- --- ---------------- ---- --------
----- ------------------------------ ------ ------ -- - ------ - --- - - -- - ------------ - ---
---
- ----- ------- -
-- ----
-上述代码中，我们将 sequelize.transaction() 包装在一个 try...catch 语句中，并使用 catch 代码块处理异常。这将确保在出现异常时事务被正确回滚，并且程序不会崩溃。
Promise 错误处理
如果使用 Promise 作为数据库操作的返回值，则必须使用 Promise 的错误处理机制来处理异常。您可以使用 .catch() 方法或 async...await 语句来处理 Promise 中的异常。例如：
sequelize.transaction(async t => {
await sequelize.models.User.update({ username: 'test' }, { where: { id: 1 } }, { transaction: t });
await Promise.reject(new Error('Something went wrong'));
await sequelize.models.Post.update({ title: 'test' }, { where: { id: 1 } }, { transaction: t });
}).catch(error => {
// 处理异常
});上述代码中，我们使用 Promise.reject() 抛出了一个异常，并使用 .catch() 方法来处理异常。这将确保在出现异常时事务被正确回滚，并且程序不会崩溃。
高级用法
Sequelize 事务除了基本用法外，还支持一些高级用法，如下所示。
嵌套事务
Sequelize 支持嵌套事务，这意味着您可以在事务内部创建新的事务。子事务与父事务完全独立，它们之间的操作互不干扰。在子事务中，您可以执行与父事务相同或不同的操作。当子事务结束时，它们可以选择提交或回滚，而它们的结果将影响父事务的结果。例如：
-- -------------------- ---- -------
--------------------------- -- -- -
----- ------------------------------ --------- ------ -- - ------ - --- - - -- - ------------ -- ---
----- --------------------------- -- -- -
----- ------------------------------ ------ ------ -- - ------ - --- - - -- - ------------ -- ---
----- --- ---------------- ---- --------
---
----- --------------------------------- -------- ------ -- - ------ - --- - - -- - ------------ -- ---
---上述代码中，我们在父事务 t1 中创建了一个子事务 t2，并在其中执行数据库操作。当子事务抛出异常时，它将回滚并影响父事务的结果。在这个例子中，由于子事务抛出了异常，父事务将回滚，并且所有已执行的操作都将撤销。
保存点
Sequelize 事务支持保存点，这相当于在事务执行过程中创建一个标记，允许您在以后的时间点恢复到其之前的状态。例如：
-- -------------------- ---- ------- --------------------------- - -- - ----- ------------------------------ --------- ------ -- - ------ - --- - - -- - ------------ - --- ----- --------- - - ------ ---------------------------------------------------- ----- -------------- -- ----- ----------------------- ----- ------------------------------ ------ ------ -- - ------ - --- - - -- - ------------ - --- ----- --------------------------------- ----- --------------------------------- -------- ------ -- - ------ - --- - - -- - ------------ - --- ---
上述代码中，我们在事务中创建了一个保存点 my_savepoint，然后在其中执行了一些操作。接着，我们回滚到保存点并执行另一些操作。最后，我们提交了事务。在这个例子中，我们使用 t.savepoint() 和 t.rollbackToSavepoint() 方法来处理保存点。
结论
Sequelize 是一种流行的 Node.js ORM 库，它提供了强大的事务支持来确保数据库操作的原子性。在使用事务时，请务必处理异常情况，以确保数据的一致性和完整性。我们希望这篇文章能够帮助您了解如何在 Sequelize 中使用事务，并提供一些实际的示例代码供您参考。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/672de15feedcc8a97c863d57