MongoDB事务处理实战引言MongoDB 4.0支持多文档事务提供了ACID保证。事务操作1.1 事务使用import com.mongodb.client.ClientSession; import com.mongodb.client.MongoClient; /** * 事务处理 */ public class TransactionHandling { /** * 使用事务 */ public void executeTransaction(MongoClient mongoClient, MongoDatabase database) { try (ClientSession session mongoClient.startSession()) { session.startTransaction(); try { MongoCollectionDocument orders database.getCollection(orders); MongoCollectionDocument inventory database.getCollection(inventory); orders.insertOne(session, new Document(item, product1)); inventory.updateOne(session, Filters.eq(product, product1), Updates.inc(quantity, -1) ); session.commitTransaction(); } catch (Exception e) { session.abortTransaction(); throw e; } } } }总结事务为MongoDB提供了ACID保证。
MongoDB事务处理实战
发布时间：2026/5/30 2:04:50
MongoDB事务处理实战引言MongoDB 4.0支持多文档事务提供了ACID保证。事务操作1.1 事务使用import com.mongodb.client.ClientSession; import com.mongodb.client.MongoClient; /** * 事务处理 */ public class TransactionHandling { /** * 使用事务 */ public void executeTransaction(MongoClient mongoClient, MongoDatabase database) { try (ClientSession session mongoClient.startSession()) { session.startTransaction(); try { MongoCollectionDocument orders database.getCollection(orders); MongoCollectionDocument inventory database.getCollection(inventory); orders.insertOne(session, new Document(item, product1)); inventory.updateOne(session, Filters.eq(product, product1), Updates.inc(quantity, -1) ); session.commitTransaction(); } catch (Exception e) { session.abortTransaction(); throw e; } } } }总结事务为MongoDB提供了ACID保证。
