介绍
Sequelize 是一个 Node.js 的 ORM 框架，用于操作 SQL 数据库。其中非常重要的一个功能是事务管理，可以帮助我们在一连串的 SQL 操作中保证数据的一致性和完整性。
在本文中，我们将深入探讨 Sequelize 中如何进行事务管理，以及在使用中可能出现的错误。
事务管理
基本使用
在 Sequelize 中，我们可以使用 sequelize.transaction() 方法来创建一个事务，然后在事务内执行一系列的 SQL 操作。
-- -------------------- ---- ------- -- ---- ----- ----------- - ----- ------------------------ --- - -- ------ --- -- ----- ------------- ----- ------- -- - ------ - --- - -- ----------- --- ----- --------------- ------ - ------- - -- ----------- --- -- ---- ----- --------------------- - ----- ------- - -- ---- ----- ----------------------- -
在上面的例子中，我们首先创建了一个名为 transaction 的事务，并在其中执行了两个 SQL 操作：更新 User 中 id 为 1 的用户的名字为 Alice，和删除 Order 中 userId 为 1 的所有订单。最后我们用 transaction.commit() 提交了事务。
在这个过程中，如果任何一个 SQL 操作失败了或者抛出了异常，我们就会用 transaction.rollback() 来回滚整个事务，并将报错信息通知到调用方。
嵌套事务
Sequelize 还支持嵌套事务，也就是在一个事务中嵌套另一个事务。
-- -------------------- ---- -------
-- ----
----- ------------ - ----- ------------------------
--- -
-- -------- --- --
----- ------------- ----- ------- -- - ------ - --- - -- ------------ ------------ ---
-- ------
----- ------------ - ----- ---------------------------
--- -
-- -------- --- --
----- --------------- ------ - ------- - -- ------------ ------------ ---
-- ------
----- ----------------------
- ----- ------- -
-- ------
----- ------------------------
----- ------
-
-- -------- --- --
----- ---------------- ------- ---- ------- - -- - ------------ ------------ ---
-- ------
----- ----------------------
- ----- ------- -
-- ------
----- ------------------------
-在上面的例子中，我们首先创建了一个名为 transaction1 的外层事务，并在其中执行了一个 SQL 操作：更新 User 中 id 为 1 的用户的名字为 Alice。
然后我们在外层事务中创建了一个叫 transaction2 的内层事务，并在其中执行了一个 SQL 操作：删除 Order 中 userId 为 1 的所有订单。如果这个 SQL 操作出错了，我们就会回滚内层事务。
然后在外层事务中再执行一个 SQL 操作：在 Payment 中创建一个 amount 为 100，userId 为 1 的付款记录。最后我们提交外层事务。
如果任何一个 SQL 操作失败了或者抛出了异常，我们就会用 transaction1.rollback() 来回滚整个事务，并将报错信息通知到调用方。注意，当我们回滚内层事务时，我们需要将错误向外抛出。
并发控制
在并发情况下，多个客户端可能同时读取和修改同一批数据。为了避免数据冲突的问题，我们可以使用事务来实现并发控制。
在 Sequelize 中，我们可以使用 Sequelize.Transaction.ISOLATION_LEVEL 枚举来设置事务的隔离级别。一般来说，可选的隔离级别有四种，从低到高依次是 READ_UNCOMMITTED、READ_COMMITTED、REPEATABLE_READ 和 SERIALIZABLE。隔离级别越高，事务的隔离性也就越强，但相应的并发性能也会下降。
const transaction = await sequelize.transaction({
isolationLevel: Sequelize.Transaction.ISOLATION_LEVELS.SERIALIZABLE
});在默认情况下，Sequelize 会使用数据库的默认隔离级别，一般是 READ_COMMITTED。如果我们需要自定义隔离级别，可以在事务创建时传入相应的参数。
Savepoints
在嵌套事务中，由于内层事务的回滚只会撤销内层事务中的更改，而不会撤销外层事务中的更改，因此我们可以通过设置 savepoints 来实现在内层事务回滚时对外层事务的部分回滚。
-- -------------------- ---- -------
-- ----
----- ------------ - ----- ------------------------
--- -
-- -------- --- --
----- ------------- ----- ------- -- - ------ - --- - -- ------------ ------------ ---
-- -- ----------
----- -------------------------
-- ------
----- ------------ - ----- ---------------------------
--- -
-- -------- --- --
----- --------------- ------ - ------- - -- ------------ ------------ ---
-- --- ----------
----- -----------------------------------
- ----- ------- -
-- ------
----- ------------------------
----- ------
-
-- -- ----------
----- --------------------------------
-- -------- --- --
----- ---------------- ------- ---- ------- - -- - ------------ ------------ ---
-- ------
----- ----------------------
- ----- ------- -
-- ------
----- ------------------------
-在上面的例子中，我们首先创建了一个名为 transaction1 的外层事务，并在其中执行了一个 SQL 操作：更新 User 中 id 为 1 的用户的名字为 Alice。
然后我们在外层事务中创建了一个 savepoints，并在其之上创建了一个名为 transaction2 的内层事务，并在其中执行了一个 SQL 操作：删除 Order 中 userId 为 1 的所有订单。
如果这个 SQL 操作出错了，我们就会回滚内层事务，并回滚到 savepoints（也就是外层事务执行更新操作的状态），以此来实现对外层事务的部分回滚。
最后在外层事务内执行一个 SQL 操作：在 Payment 中创建一个 amount 为 100，userId 为 1 的付款记录。最后我们提交外层事务。如果任何一个 SQL 操作失败了或者抛出了异常，我们就会用 transaction1.rollback() 来回滚整个事务，并将报错信息通知到调用方。
可能遇到的错误
在使用 Sequelize 进行事务管理时，我们可能会遇到以下的错误。
错误：事务 rollback 之后仍然触发了外部回调
在上面的示例代码中，我们使用了 transaction.rollback() 来回滚事务，然后使用了 throw error 来抛出错误信息。然而，由于 Sequelize 是异步的，事务回滚的过程也是异步的，因此我们需要等到事务回滚完毕之后再抛出错误。否则就会出现事务已经回滚了，但仍然触发了外部回调的情况。
-- -------------------- ---- ------- ----- ----------- - ----- ------------------------ --- - -- ------ --- -- -- --- -- ---- ----- --------------------- - ----- ------- - -- ---- ----- ----------------------- -- --------------- ----- --- ----------------- -- ------------------- ---- ----- ------ -
在上面的代码中，我们使用了一个简单的延时方法 setTimeout(resolve, 0) 来等待事务回滚完毕之后再抛出错误。
总结
在本文中，我们深入学习了 Sequelize 中的事务管理，包括基本使用、嵌套事务、并发控制和 savepoints，以及在使用中可能出现的错误。在实际开发中，我们可以根据具体的业务需要来选择使用这些事务管理的功能，从而达到保证数据的一致性和完整性的目的。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/648ab65448841e98948d01e5