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() 方法以提交交易，並使資料庫達到新的 consistent 狀態

session.commitTransaction()

現在，新記錄將同時存在於交易會話發生的 MongoDB Shell 和交易外部的 MongoDB Shell 實例中。

中止交易

現在我們已經從啟動會話一直到提交會話，我們可以探索交易的替代結果。

此路徑的開頭相同，僅在提交點發生變化。如果我們想要捨棄交易正在進行的變更，那麼我們可以使用 abortTransaction() 方法，如下所示在會話 Shell 中

session.abortTransaction()

此方法取消交易會話並捨棄任何潛在的變更。資料庫不會產生新的 consistent 狀態，而是回滾變更，並保持與交易會話首次啟動時相同的狀態。