Mongo事務完全指南

一、Mongo事務介紹

MongoDB是一種流行的NoSQL數據庫，其中包含一個事務引擎。MongoDB的事務引擎是一項相對新的功能，它在實現ACID（原子性、一致性、隔離性和持久性）方面扮演着重要角色。

在MongoDB中使用事務可以確保數據完整性，這是一種非常重要的特性，如果應用程序需要對多個文檔進行更改，則可以使用事務確保它們原子性地提交。

在MongoDB中，事務綁定到一個單獨的數據庫，而不是多個數據庫。因此，只能在同一個數據庫內執行事務，跨多個數據庫執行事務尚不支持。

二、Mongo事務C#

對於.NET，MongoDB提供了一個兼容.NET Standard 2.0的驅動程序。您可以使用C#編寫應用程序，該應用程序針對.NET Framework、.NET Core、Mono或Xamarin運行時的Windows、Linux或macOS進行編譯。

    var session = client.StartSession();

    try
    {
        session.StartTransaction();

        // Perform transaction operations here

        session.CommitTransaction();
    }
    catch (Exception e)
    {
        session.AbortTransaction();
    }
    finally
    {
        session.Dispose();
    }

三、Mongo事務隔離級別

MongoDB支持四種事務隔離級別：讀未提交、讀已提交、可重複讀和串行化。

在MongoDB中，默認的事務隔離級別是序列化，也就是說，對於一個數據庫中的一組事務，只有一個事務在任何時候都可以訪問任何給定的文檔。

如果需要更改隔離級別，可以在執行事務之前使用事務選項更改或不更改默認事務隔離級別，如下所示：

    var sessionOptions = new ClientSessionOptions
    {
        DefaultTransactionOptions = new TransactionOptions(
            readConcern: ReadConcern.Snapshot,
            writeConcern: WriteConcern.WMajority)
    };

    var session = await client.StartSessionAsync(sessionOptions);

四、Mongo事務原理

在MongoDB中，事務實現是利用兩個具有代表性的特性：多版本並發控制（MVCC）和確認日誌（redo log）。

MVCC可以確保在讀未提交的情況下，讀操作佔用所需的鎖數量最小，不會阻塞寫操作。確認日誌在執行事務期間記錄所有修改，在事務完成時，將確認應用於所有操作。

五、Mongo事務操作

在MongoDB中，事務操作是使用BEGIN命令啟動的，然後可以執行UPDATE、DELETE和INSERT命令，並在完成之後使用COMMIT進行確認。如果在執行期間遇到錯誤，可以使用ROLLBACK回滾。

下面是一個基礎的事務操作示例：

    session.StartTransaction();
    try
    {
        await collectionA.InsertOneAsync(session, newBsonDocumentA);
        await collectionB.ReplaceOneAsync(session, filter, newBsonDocumentB);
        session.CommitTransaction();
    }
    catch (Exception exception)
    {
        session.AbortTransaction();
    }

六、Mongo事務處理

在MongoDB中，事務處理是通過級別指定、操作聲明和實例化處理程序進行的。根據級別指定了什麼操作應該在事務處理程序內執行，始終使用實例化處理程序創建事務處理器對象。

以下是事務處理的示例：

    const string connectionString = "mongodb://localhost:27017";
    var mongoClient = new MongoClient(connectionString);

    var clientSessionProvider = new ClientSessionProvider(mongoClient);
    var readWriteModelFacade = new ReadWriteModelFacade(mongoClient);
    
    var transactionOperationProcessor = new MongoDbTransactionProcessor(new TransactionOperationFactory(identityMap, readWriteModelFacade));
    var transactionProcessor = new MongoDbTransactionProcessor(
        new TransactionOperationFactory(identityMap, readWriteModelFacade));
    var createOrderTransactionHandler = new CreateOrderTransactionHandler(transactionProcessor);

    var orderRepository = new OrderRepository(identityMap, mongoClient, clientSessionProvider);
    var orderItemRepository = new OrderItemRepository(identityMap, mongoClient, clientSessionProvider);

    var createOrderCommandHandler = new CreateOrderCommandHandler(orderRepository,
        orderItemRepository, createOrderTransactionHandler);

七、Mongo事務Python

MongoDB提供了適用於Python的官方驅動程序-PyMongo。在Python中使用MongoDB事務可以確保數據完整性，下面是一個Python的事務示例：

    session = client.start_session()
    with session.start_transaction():
        collection_a.insert_one({"field": "value"})
        collection_b.delete_one({"field": "value"})
    session.commit_transaction()

八、Mongo事務配置

MongoDB在3.6版本中首次推出事務引擎。如果使用早期版本的MongoDB，需要確保配置文件中正確配置了replication.enableMajorityReadConcern參數：

    replication:
      enableMajorityReadConcern: true

九、Mongo事務回滾原理

在MongoDB中，可以通過事務回滾來撤銷已提交的事務，並返回所有事務修改的文檔原始狀態。回滾是使用先前記錄的事務日誌完成的，可以滾回到事務啟動之前的狀態。

以下是回滾的示例：

    session.StartTransaction();
    try
    {
        await collectionA.InsertOneAsync(session, newBsonDocumentA);
        await collectionB.ReplaceOneAsync(session, filter, newBsonDocumentB);
        session.CommitTransaction();
    }
    catch (Exception exception)
    {
        session.AbortTransaction();
    }

十、Mongo事務中不允許執行哪個操作

在MongoDB中，有幾個操作不允許在事務中執行：

1.不能跨多個數據庫執行事務，事務只能在一個數據庫內執行。
2.不能在非副本集群數據庫上執行事務。
3.不能在執行分片的數據庫上執行事務。
4.不能在已凍結的集合上執行事務。

感謝您的閱讀，我們介紹了MongoDB事務的多個方面和常見操作，您現在應該對MongoDB事務有了更深入的了解。

原創文章，作者：小藍，如若轉載，請註明出處：https://www.506064.com/zh-hant/n/160524.html