MongoDB 4.0 及以上版本支持多文档事务,事务可以保证一系列操作的原子性,即要么全部成功,要么全部失败。这对于需要高并发、高一致性的应用场景非常有用,例如金融交易、库存管理等。
以下是 MongoDB 事务处理的基本步骤:
-
启动事务:
使用
session.startTransaction()
方法启动一个新的事务。const session = client.startSession(); session.startTransaction();
-
执行操作:
在事务中执行需要原子性的操作,例如插入、更新或删除文档。这些操作需要在同一个会话(session)中进行。
// 示例:插入一个文档 const collection = db.getCollection('myCollection'); collection.insertOne({ name: 'John Doe', age: 30 }, { session }); // 示例:更新一个文档 collection.updateOne({ name: 'John Doe' }, { $set: { age: 31 } }, { session });
-
提交或回滚事务:
如果所有操作都成功执行,则提交事务。如果任何一个操作失败,则回滚事务。
try { // 执行一系列操作 // ... // 提交事务 session.commitTransaction(); } catch (error) { // 回滚事务 session.abortTransaction(); throw error; } finally { // 结束会话 session.endSession(); }
注意:事务不支持跨分片集群和副本集。在使用事务时,请确保您的操作在同一个分片或副本集中执行。
此外,MongoDB 还提供了一些高级事务功能,例如乐观并发控制、多文档 ACID 事务等。您可以根据具体需求选择合适的事务处理策略。