MongoDB 事務簡介

建立事務會話

事務通常透過 API 方法之一，利用應用程式語言的相應 MongoDB 驅動程式，從外部應用程式編寫和執行。

為了演示目的，我們將透過 MongoDB shell 逐步介紹事務的建立過程。我們將使用一個示例資料庫和集合來幫助您理解事務在實踐中如何工作。

注意：如果事務會話在初始 startTransaction() 方法之後執行超過 60 秒，MongoDB 將自動中止操作。發生這種情況是因為事務通常在自動工作的應用程式中執行，而不是由人員在 shell 中發出命令。以下步驟用於概念化從開始到結束的事務會話。

首先，我們有一個名為 literature 的簡單資料庫，其中包含一個名為 authors 的集合。快速執行一個 find() 查詢，我們可以看到包含作者姓名及其作品標題的文件結構。

db.authors.find()

[
  {
    _id: ObjectId("620397dd4b871fc65c193106"),
    first_name: 'James',
    last_name: 'Joyce',
    title: 'Ulysses'
  },
  {
    _id: ObjectId("620398016ed0bb9e23785973"),
    first_name: 'William',
    last_name: 'Gibson',
    title: 'Neuromancer'
  },
  {
    _id: ObjectId("6203981d6ed0bb9e23785974"),
    first_name: 'George',
    last_name: 'Orwell',
    title: 'Homage to Catalonia'
  },
  {
    _id: ObjectId("620398516ed0bb9e23785975"),
    first_name: 'James',
    last_name: 'Baldwin',
    title: 'The Fire Next Time'
  }
]

現在我們有了資料庫，我們可以展示如何在 MongoDB shell 中直接使用事務的步驟。我們還將演示在一個會話中進行的事務如何可能對外部源不可見。

首先，我們需要建立一個會話，就像您使用 API 時一樣。

var session = db.getMongo().startSession()

這個新建立的 session 變數將儲存會話物件。

下一步是透過呼叫 startTransaction() 方法來啟動事務

session.startTransaction(
    { "readConcern": { "level": "snapshot" },
      "writeConcern": { "w": "majority }
     }
)

startTransaction() 方法有兩個選項，readConcern 和 writeConcern。您可以在MongoDB 的文件中詳細瞭解這些選項。我們將 readConcern 的 level 設定為 snapshot，如果事務以 writeConcern “majority” 提交，則它會返回多數已提交資料的快照。

當您使用 w: "majority" 寫入關注和 "snapshot" 讀取關注級別進行提交時，這保證了操作具有多數已提交資料的同步快照。如果沒有特定要求，這種寫入和讀取關注的配置可以被認為是很好的預設設定。

如果成功，該方法不會返回任何內容；如果出現任何錯誤，則需要中止事務，我們將在稍後討論。

在事務會話中工作

現在您已經啟動了事務會話，您必須在上一節的 session 變數的上下文中執行語句。

在會話中用一個變量表示您的集合有助於簡化語法。您可以這樣做：

var authors = session.getDatabase('literature').getCollection('authors')

這個新建立的變數將像在事務會話之外的 shell 中工作時的 db.authors 一樣。您可以透過開啟第二個 shell 視窗，連線到您的叢集，並執行 db.authors.find() 來驗證這一點。這兩個語句都將返回相同的文件。

在會話內部，我們現在要模擬外部應用程式可能執行的操作，並向資料庫新增一條記錄。我們可以透過以下方式對 authors 集合進行操作：

authors.insertOne( {
    "first_name": "Virginie",
    "last_name": "Despentes",
    "title": "Vernon Subutex") }
)

MongoDB 將返回成功

{
  acknowledged: true,
  insertedId: ObjectId("6203a075c374636bc6976baa")
}

如果我們現在在會話中執行 authors.find()，我們將返回之前的結果，其中包含我們新增的內容。

[
  {
    _id: ObjectId("620397dd4b871fc65c193106"),
    first_name: 'James',
    last_name: 'Joyce',
    best_title: 'Ulysses'
  },
  {
    _id: ObjectId("620398016ed0bb9e23785973"),
    first_name: 'William',
    last_name: 'Gibson',
    best_title: 'Neuromancer'
  },
  {
    _id: ObjectId("6203981d6ed0bb9e23785974"),
    first_name: 'George',
    last_name: 'Orwell',
    best_title: 'Homage to Catalonia'
  },
  {
    _id: ObjectId("620398516ed0bb9e23785975"),
    first_name: 'James',
    last_name: 'Baldwin',
    best_title: 'The Fire Next Time'
  },
  {
    _id: ObjectId("6203a075c374636bc6976baa"),
    first_name: 'Virginie',
    last_name: 'Despentes',
    best_title: 'Vernon Subutex'
  }
]

由於此事務會話尚未提交，因此我們在會話外部的 MongoDB shell 中不會看到相同的結果。為了確認，我們在另一個 MongoDB shell 例項中執行 db.authors.find()，並返回原始文件。

[
  {
    _id: ObjectId("620397dd4b871fc65c193106"),
    first_name: 'James',
    last_name: 'Joyce',
    best_title: 'Ulysses'
  },
  {
    _id: ObjectId("620398016ed0bb9e23785973"),
    first_name: 'William',
    last_name: 'Gibson',
    best_title: 'Neuromancer'
  },
  {
    _id: ObjectId("6203981d6ed0bb9e23785974"),
    first_name: 'George',
    last_name: 'Orwell',
    best_title: 'Homage to Catalonia'
  },
  {
    _id: ObjectId("620398516ed0bb9e23785975"),
    first_name: 'James',
    last_name: 'Baldwin',
    best_title: 'The Fire Next Time'
  }
]

這種差異表明事務目前仍處於不確定狀態。它可能成功並提交到資料庫，也可能失敗並被中止。無論哪種方式，資料庫都將最終處於一致狀態。它將包含新記錄，或者回滾到事務會話開始之前的相同狀態。

我們在會話中執行 commitTransaction() 方法，以提交事務並將資料庫帶到新的一致狀態。

session.commitTransaction()

現在，新記錄將同時存在於兩個例項中：進行事務會話的 MongoDB shell 和事務之外的 MongoDB shell。

中止事務

現在我們已經從啟動會話到提交會話，我們可以探討事務的另一種結果。

此路徑開始時相同，僅在提交點發生變化。如果我們想丟棄事務正在進行的更改，則在會話 shell 中使用 abortTransaction() 方法如下：

session.abortTransaction()

此方法取消事務會話並丟棄任何潛在更改。資料庫不會產生新的一致狀態，而是回滾更改，保持與事務會話首次啟動時相同的狀態。