トランザクション

Overview

このガイドでは、 Kotlinドライバー を使用してトランザクションを実行する方法を学習できます。 トランザクションを使用すると、トランザクションがコミットされるまでデータを変更しない一連の操作を実行できます。トランザクション内のいずれかの操作でエラーが返された場合、ドライバーはトランザクションをキャンセルし、変更が反映される前にすべてのデータ変更を破棄します。

In MongoDB, transactions run within logical sessions. A session is a grouping of related read or write operations that you intend to run sequentially. Sessions enable causal consistency for a group of operations or allow you to execute operations in an ACID transaction. MongoDB guarantees that the data involved in your transaction operations remains consistent, even if the operations encounter unexpected errors.

Kotlin ドライバーを使用すると、 MongoClientインスタンスからClientSessionとして新しいセッションを作成できます。 毎回新しいクライアントをインスタンス化するのではなく、クライアントを複数のセッションやトランザクションで再利用することを推奨します。

メソッド

ClientインスタンスでstartSession()メソッドを使用してClientSessionを作成します。 その後、次の方法を使用してセッション状態を変更できます。

ClientSession には、セッション プロパティを取得し、可変セッション プロパティを変更するメソッドもあります。これらのメソッドの詳細については、 APIドキュメントを表示します。

例

この例では、次の Kotlin データ クラスを使用してドキュメントをモデル化します。

data class Account(
    val accountId: String,
    val amount: Int
)

次の例は、セッションを作成し、トランザクションを作成し、既存のドキュメントに変更をコミットする方法を示しています。

1. startSession() メソッドを使用してクライアントからセッションを作成します。

2. トランザクションを開始するには、 startTransaction() メソッドを使用します。

3. 指定されたドキュメントを更新し、すべての操作が成功した場合はcommitTransaction()メソッドを使用するか、いずれかの操作が失敗した場合はabortTransaction()を使用します。

// Set up the session
val session = client.startSession()
try {
    session.startTransaction()
    val savingsColl = database
        .getCollection<Account>("savings_accounts")
    val checkingColl = database
        .getCollection<Account>("checking_accounts")
    savingsColl.findOneAndUpdate(
        session,
        eq(Account::accountId.name, "9876"),
        inc(Account::amount.name, -100),
    )
    checkingColl.findOneAndUpdate(
        session,
        eq(Account::accountId.name, "9876"),
        inc(Account::amount.name, 100)
    )
    // Commit the transaction
    val result = session.commitTransaction()
    println("Transaction committed.")
} catch (error: Exception) {
    println("An error occurred during the transaction: ${error.message}")
    // Abort the transaction
    session.abortTransaction()
}

詳細情報

このガイドで言及されている概念の詳細については、サーバー マニュアルの次のページを参照してください。

• トランザクション

• サーバー セッション

• 読み取りの分離、整合性、最新性

ACID compliance の詳細については、 「 データベース管理システムの ACID プロパティとは 」を参照してください。 MongoDB Webサイトの記事。