在MongoDB中使用多文檔事務的詳細步驟

更新時間：2026年04月07日 10:26:50 作者：Victor356

在MongoDB中使用多文檔事務,確保多個操作要么全部成功要么全部失敗,實現(xiàn)數(shù)據(jù)一致性,通過會話和TransactionOptions配置事務,執(zhí)行跨集合寫操作,并提交或回滾事務,適用于需要確保數(shù)據(jù)一致性的復雜應用場景,本文介紹在MongoDB中使用多文檔事務的步驟,感興趣的朋友一起看看吧

在MongoDB中使用多文檔事務可以確保多個操作要么全部成功，要么全部失敗，從而確保數(shù)據(jù)的一致性。MongoDB的多文檔事務類似于傳統(tǒng)關系型數(shù)據(jù)庫的事務，支持ACID（原子性、一致性、隔離性和持久性）特性。以下是詳細的步驟和Java代碼示例，展示如何在MongoDB中使用多文檔事務。

前提條件

復制集：事務需要在MongoDB復制集（Replica Set）或分片集群（Sharded Cluster）中運行。
MongoDB版本：確保使用MongoDB 4.0或更高版本。

1. 引入Maven依賴

首先，在 pom.xml 中引入 MongoDB Java 驅動依賴：

<dependency>
  <groupId>org.mongodb</groupId>
  <artifactId>mongodb-driver-sync</artifactId>
  <version>4.4.0</version>
</dependency>

2. Java代碼示例

以下是一個完整的Java代碼示例，展示如何在MongoDB中使用多文檔事務：

import com.mongodb.MongoClientSettings;
import com.mongodb.MongoException;
import com.mongodb.ReadConcern;
import com.mongodb.ReadPreference;
import com.mongodb.TransactionOptions;
import com.mongodb.WriteConcern;
import com.mongodb.client.ClientSession;
import com.mongodb.client.MongoClient;
import com.mongodb.client.MongoClients;
import com.mongodb.client.MongoCollection;
import com.mongodb.client.MongoDatabase;
import org.bson.Document;
public class MongoDBTransactionExample {
    public static void main(String[] args) {
        // 創(chuàng)建 MongoClient
        MongoClient mongoClient = MongoClients.create("mongodb://localhost:27017");
        // 獲取數(shù)據(jù)庫和集合
        MongoDatabase database = mongoClient.getDatabase("testdb");
        MongoCollection<Document> collection1 = database.getCollection("collection1");
        MongoCollection<Document> collection2 = database.getCollection("collection2");
        // 插入一些初始數(shù)據(jù)
        collection1.insertOne(new Document("account", "Alice").append("balance", 100));
        collection2.insertOne(new Document("account", "Bob").append("balance", 0));
        // 開始會話
        ClientSession session = mongoClient.startSession();
        // 配置事務選項
        TransactionOptions txnOptions = TransactionOptions.builder()
                .readPreference(ReadPreference.primary())
                .readConcern(ReadConcern.LOCAL)
                .writeConcern(WriteConcern.MAJORITY)
                .build();
        try {
            // 開始事務
            session.startTransaction(txnOptions);
            // 執(zhí)行跨集合的寫操作
            Document aliceAccount = collection1.find(session, new Document("account", "Alice")).first();
            if (aliceAccount != null && aliceAccount.getInteger("balance") >= 50) {
                collection1.updateOne(session, new Document("account", "Alice"),
                        new Document("$inc", new Document("balance", -50)));
                collection2.updateOne(session, new Document("account", "Bob"),
                        new Document("$inc", new Document("balance", 50)));
            } else {
                throw new RuntimeException("Insufficient balance!");
            }
            // 提交事務
            session.commitTransaction();
            System.out.println("Transaction committed.");
        } catch (MongoException | RuntimeException e) {
            // 回滾事務
            session.abortTransaction();
            System.err.println("Transaction aborted due to: " + e.getMessage());
        } finally {
            session.close();
        }
        mongoClient.close();
    }
}

解釋代碼

創(chuàng)建 MongoClient：連接到 MongoDB 實例。

MongoClient mongoClient = MongoClients.create("mongodb://localhost:27017");

獲取數(shù)據(jù)庫和集合：獲取所需的數(shù)據(jù)庫和集合引用。

MongoDatabase database = mongoClient.getDatabase("testdb");
MongoCollection<Document> collection1 = database.getCollection("collection1");
MongoCollection<Document> collection2 = database.getCollection("collection2");

插入初始數(shù)據(jù)：向集合中插入一些示例數(shù)據(jù)。

collection1.insertOne(new Document("account", "Alice").append("balance", 100));
collection2.insertOne(new Document("account", "Bob").append("balance", 0));

開始會話：通過 mongoClient.startSession() 開始一個會話。

ClientSession session = mongoClient.startSession();

配置事務選項：使用 TransactionOptions 配置事務的選項，比如讀偏好、讀關注和寫關注。

TransactionOptions txnOptions = TransactionOptions.builder()
        .readPreference(ReadPreference.primary())
        .readConcern(ReadConcern.LOCAL)
        .writeConcern(WriteConcern.MAJORITY)
        .build();

開始事務：通過 session.startTransaction(txnOptions) 開始事務。

session.startTransaction(txnOptions);

執(zhí)行跨集合的寫操作：在事務中執(zhí)行多個集合的寫操作。

Document aliceAccount = collection1.find(session, new Document("account", "Alice")).first();
if (aliceAccount != null && aliceAccount.getInteger("balance") >= 50) {
    collection1.updateOne(session, new Document("account", "Alice"),
            new Document("$inc", new Document("balance", -50)));
    collection2.updateOne(session, new Document("account", "Bob"),
            new Document("$inc", new Document("balance", 50)));
} else {
    throw new RuntimeException("Insufficient balance!");
}

提交事務：如果所有操作成功，通過 session.commitTransaction() 提交事務。

session.commitTransaction();
System.out.println("Transaction committed.");

回滾事務：如果發(fā)生異常，通過 session.abortTransaction() 回滾事務。

catch (MongoException | RuntimeException e) {
    session.abortTransaction();
    System.err.println("Transaction aborted due to: " + e.getMessage());
}

關閉會話和客戶端：最后關閉會話和 MongoDB 客戶端連接。

finally {
    session.close();
}
mongoClient.close();

總結

通過上述代碼示例，展示了如何在MongoDB中使用多文檔事務來實現(xiàn)ACID特性。合理利用這些特性，可以在復雜應用場景中確保數(shù)據(jù)的一致性和可靠性。通過事務，可以保證在多個集合中的操作具有原子性、一致性、隔離性和持久性，從而確保數(shù)據(jù)的可靠性和一致性。

到此這篇關于如何在MongoDB中使用多文檔事務的文章就介紹到這了,更多相關MongoDB使用多文檔事務內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章:

MongoDB的基礎查詢和索引操作方法總結
MongoDB使用JavaScript作為shell腳本,可以代替關系型數(shù)據(jù)庫中的SQL語句完成查詢操作,包括索引下的查詢操作,這里我們就來整理MongoDB的基礎查詢和索引操作方法總結:
2016-07-07
MongoDB數(shù)據(jù)庫安裝配置、基本操作實例詳解
這篇文章主要介紹了MongoDB數(shù)據(jù)庫安裝配置、基本操作,結合實例形式詳細分析了MongoDB數(shù)據(jù)庫安裝配置具體步驟、相關命令與基本操作實現(xiàn)技巧,需要的朋友可以參考下
2020-01-01
Mongodb 忘記密碼的解決辦法
這篇文章主要介紹了Mongodb數(shù)據(jù)庫忘記密碼的解決辦法,需要的朋友可以參考下
2014-03-03
window下mongodb在dos下服務器啟動及連接
這篇文章主要介紹了window下mongodb在dos下服務器啟動及連接的相關資料,需要的朋友可以參考下
2017-06-06
如何對 MongoDB 進行性能優(yōu)化（五個簡單步驟）
MongoDB一直是最流行的NoSQL，而根據(jù)DB-Engines Ranking最新的排行，時下MongoDB已經擊敗PostgreSQL躍居數(shù)據(jù)庫總排行的第四位，僅次于Oracle、MySQL和Microsoft SQL Server。本文給大家介紹MongoDB性能優(yōu)化的簡單總結。
2015-10-10
MongoDB創(chuàng)建一個索引而性能提升1000倍示例代碼
這篇文章主要給大家介紹了關于如何在MongoDB中創(chuàng)建一個索引而性能提升1000倍的相關資料，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
2019-01-01
MongoDB的創(chuàng)建、更新和刪除
下面開始學習MongoDB最重要也是最基礎的部分：C（創(chuàng)建）R（查詢）U（更新）D（刪除）；由于R（查詢）操作相對來說內容比較多，也比較繁瑣，同時使用頻率也比較高，所以下一篇會拿出來單獨介紹。廢話不多說，連上服務器，我們直接進入正題
2017-05-05
mongo中模糊查詢的綜合應用
這篇文章主要給大家介紹了關于mongo中模糊查詢的相關資料，文中通過示例代碼介紹的非常詳細，對大家學習或者使用mongodb具有一定的參考學習價值，需要的朋友們下面來一起學習學習吧
2019-04-04
MongoDB 快速入門
MongoDB 快速入門，想要學習MongoDB的朋友可以參考下。
2011-10-10
【MongoDB for Java】Java操作MongoDB數(shù)據(jù)庫
本篇文章現(xiàn)在我們就用Java來操作MongoDB的數(shù)據(jù)。小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
2016-12-12