トランザクション

Overview

このガイドでは、Rust ドライバーを使用してトランザクションを実行する方法を学習できます。 トランザクションを使用すると、トランザクション全体がコミットされた場合にのみ、データを変更する一連の操作を実行できます。 トランザクション内のいずれかの操作が成功しない場合、ドライバーはトランザクションを停止し、変更が反映される前にすべてのデータ変更を破棄します。 この特徴はアトミック性と 呼ばれます。

MongoDB では、トランザクションは論理セッション内で実行されます。 セッションは 、順番に実行されるよう関連付けられた読み取り操作または書き込み操作のグループです。 セッションにより、一連の操作に対する 因果整合性 が有効になり、 ACID 準拠のトランザクション（アトミック性、整合性、分離、耐久性の期待を満たすトランザクション）内で操作を実行できるようになります。 MongoDBは、トランザクション操作で予期せぬエラーが発生した場合でも、その操作に関わるデータの一貫性が保たれることを保証します。

Rust ドライバーを使用すると、 ClientインスタンスからClientSession型の新しいセッションを作成できます。 毎回新しいクライアントをインスタンス化するのではなく、クライアントを複数のセッションやトランザクションで再利用することで、アプリのパフォーマンスを向上させることができます。

メソッド

Clientインスタンスでstart_session()メソッドを使用してClientSessionを作成します。 その後、 ClientSessionタイプが提供するメソッドを使用してセッション状態を変更できます。 次の表では、これらの方法について説明します。

例

次のコードでは、insert_media() コレクションと コレクションにデータを挿入するbooks filmsコールバック関数を定義します。

async fn insert_media(session: &mut ClientSession) -> Result<(), Error> {
    let books_coll = session
        .client()
        .database("db")
        .collection::<Document>("books");
    let films_coll = session
        .client()
        .database("db")
        .collection::<Document>("films");
    books_coll
        .insert_one(doc! {
            "name": "Sula",
            "author": "Toni Morrison"
        })
        .session(&mut *session)
        .await?;
    films_coll
        .insert_one(doc! {
            "name": "Nostalgia",
            "year": 1983
        })
        .session(&mut *session)
        .await?;
    Ok(())
}

次のコードは、トランザクションを実行するために次のアクションを完了します。

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

2. トランザクションを開始するには、 start_transaction()メソッドを呼び出します。

3. トランザクション内でinsert_media()コールバック 関数を実行するためにand_run()メソッドを呼び出します。

let mut session = client.start_session().await?;
session
    .start_transaction()
    .and_run((), |session, _| insert_media(session).boxed())
    .await?;
println!("Successfully committed transaction!");

Successfully committed transaction!

トランザクションをさらに制御する必要がある場合は、 ClientSession APIドキュメント を参照して、トランザクションを手動で作成してコミットする方法を示す例を見つけてください。

詳細情報

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

• トランザクション

• サーバー セッション

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

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

挿入操作の詳細については、ドキュメントの挿入ガイドを参照してください。