JAVA MongoDB 事务回滚

在Java中使用MongoDB进行事务操作时，MongoDB官方驱动提供了对事务的支持，但需要注意的是，MongoDB的事务是从版本4.0开始支持的。以下是一个简单的示例，展示了如何在Java中使用MongoDB的事务功能以及如何进行回滚。

首先，确保你的MongoDB服务器版本至少是4.0，并且在你的项目中引入了MongoDB的Java驱动依赖。

<!-- 在pom.xml中添加MongoDB Java驱动依赖 -->
<dependency>
    <groupId>org.mongodb</groupId>
    <artifactId>mongodb-driver-sync</artifactId>
    <version>4.3.1</version>
</dependency>

下面是一个简单的事务操作和回滚的示例代码：

import com.mongodb.client.MongoClients;
import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoDatabase;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.ClientSession;
import com.mongodb.client.model.WriteModel;
import org.bson.Document;
 
public class MongoDBTransactionExample {
 
    public static void main(String[] args) {
        MongoClient mongoClient = MongoClients.create("mongodb://localhost:27017");
        MongoDatabase database = mongoClient.getDatabase("test");
        MongoCollection<Document> collection = database.getCollection("example");
 
        ClientSession session = mongoClient.startSession();
        try {
            session.startTransaction();
 
            // 插入一个文档
            Document doc1 = new Document("name", "John Doe").append("age", 30);
            collection.insertOne(session, doc1);
 
            // 更新一个文档
            Document doc2 = new Document("name", "Jane Doe").append("age", 25);
            collection.updateOne(session, new Document("name", "Jane Doe"), new Document("$set", doc2));
 
            // 提交事务
            session.commitTransaction();
            System.out.println("Transaction committed successfully.");
        } catch (Exception e) {
            // 回滚事务
            session.abortTransaction();
            System.out.println("Transaction rolled back due to error: " + e.getMessage());
        } finally {
            // 关闭session
            session.close();
        }
 
        mongoClient.close();
    }
}

在这个例子中，我们首先创建了一个ClientSession，然后开始了一个事务。在事务中，我们执行了两个操作：一个插入和一个更新。如果这两个操作都成功，我们提交事务。如果在这两个操作中任何一个抛出异常，我们会捕获异常并回滚事务。最后，无论是提交还是回滚，我们都关闭了session并且关闭了MongoDB客户端。