トランザクション

トランザクション内でのコレクションとインデックスの作成

トランザクションが クロスシャード書込みトランザクション (write transaction)でない場合、トランザクション内で次の操作を実行できます。

• コレクションを作成する。

• 同じトランザクション内で以前に作成された新しい空のコレクションにインデックスを作成する

トランザクション内でコレクションを作成する際、以下を実行できます。

• 暗黙的にコレクションを作成できます。たとえば次のいずれかを使用します。

  • 存在しないコレクションに対する挿入操作。

  • 存在しないコレクションを upsert: true に設定した update/findAndModify 操作。

• create コマンドまたはそのヘルパーである db.createCollection() を使用して、明示的にコレクションを作成できます。

トランザクション内でインデックスを作成する場合 [1]、作成するインデックスは次のいずれかに配置される必要があります。

• 存在しないコレクション。コレクションは、操作中に作成されます。

• 同じトランザクション内で以前に作成された新しい空のコレクション。

カウント操作

トランザクション内でカウント操作を実行するには、$count 集計ステージまたは $group（$sum式を使用） 集計ステージを使用します。

MongoDB ドライバーは、$group と $sum 式を併用してカウントを実行するヘルパー メソッドとして、コレクションレベルの API countDocuments(filter, options)を提供します。

mongosh provides the db.collection.countDocuments() helper method that uses the $group with a $sum expression to perform a count.

個別の操作

トランザクション内で個別の操作を実行するには、以下を使用できます。

• シャーディングされていないコレクションの場合、db.collection.distinct() メソッドまたは distinct コマンド、および 集計パイプラインを $group ステージと併用できます。

• シャーディングされたコレクションの場合、db.collection.distinct() メソッド、または distinct コマンドは使用できません。

  シャーディングされたコレクションの個別の値を検索するには、代わりに $group ステージで集計パイプラインを使用します。以下に例を挙げます。

  • db.coll.distinct("x") の代わりに以下を使用します

    db.coll.aggregate([
       { $group: { _id: null, distinctValues: { $addToSet: "$x" } } },
       { $project: { _id: 0 } }
    ])

  • db.coll.distinct("x", { status: "A" }) の代わりに以下を使用します。

    db.coll.aggregate([
       { $match: { status: "A" } },
       { $group: { _id: null, distinctValues: { $addToSet: "$x" } } },
       { $project: { _id: 0 } }
    ])

  パイプラインはドキュメントにカーソルを返します。

  { "distinctValues" : [ 2, 3, 1 ] }

  カーソルを反復して、結果ドキュメントにアクセスします。

情報に関する操作

情報提供コマンドには、hello、buildInfo、connectionStatus（およびこれらのヘルパー メソッド）などがあり、トランザクションに含めることができますが、最初の操作になることはできません。

制限付き操作

次の操作はトランザクションでは許可されません。

• クロスシャードの書き込みトランザクションで新しいコレクションを作成します。たとえば、あるシャードで既存コレクションに書き込み、別のシャードで暗示的にコレクションを作成する場合、MongoDB では同じトランザクションで両方の操作を実行できません。

• コレクションの明示的な作成（db.createCollection()メソッドやインデックスの明示的な作成（db.collection.createIndexes() および db.collection.createIndex() メソッドなど）で、"local" 以外の読み取り保証（read concern）レベルを使用する場合

• listCollections コマンドと listIndexes コマンド、およびそのヘルパー メソッド。

• その他の CRUD 操作や情報操作以外の操作、例えば createUser、getParameter、count などおよびその補助ツール。

トランザクションと読み込み設定（read preference）

トランザクション内の操作では、トランザクションレベルの読み込み設定（read preference）が使用されます。

ドライバーを使用すると、トランザクション開始時にトランザクションレベルの読み込み設定（read preference）を設定できます。

• 読み込み設定（read preference）がトランザクションレベルで設定されていない場合、セッションレベルの読み込み設定がトランザクションで使用されます。

• 読み込み設定（read preference）がトランザクションとセッションのいずれのレベルでも設定されていない場合、クライアントレベルの読み込み設定がトランザクションで使用されます。デフォルトでは、クライアントレベルの読み込み設定が primary となります。

Transactions that contain read operations must use read preference primary. All operations in a given transaction must route to the same member.

トランザクションと読み取り保証

トランザクション内の操作では、トランザクションレベルの読み取り保証（read concern）が使用されます。つまり、コレクションレベルとデータベースレベルで設定された読み取り保証は、トランザクション内では無視されます。

トランザクションの開始時に、トランザクションレベルの読み取り保証（read concern）を設定できます。

• トランザクションレベルの読み取り保証（read concern）の設定が解除されている場合、トランザクションレベルの読み取り保証はデフォルトでセッションレベルの読み取り保証になります。

• トランザクションレベルとセッションレベルの読み取り保証（read concern）の設定が解除されている場合、トランザクションレベルの読み取り保証はデフォルトでクライアントレベルの読み取り保証に設定されます。デフォルトでは、クライアントレベルの読み取り保証は プライマリでの読み取りで "local" となります。以下も参照してください。

  • トランザクションと読み込み設定（read preference）

  • MongoDB のデフォルト

トランザクションは次の読み取り保証（read concern）レベルをサポートします。

トランザクションと書込み保証

トランザクションは、トランザクションレベルの書込み保証 (write concern)を使用して書込み操作をコミットします。トランザクション内の書込み操作は、明示的な書込み保証 (write concern)保証を指定せずに、デフォルトの書込み保証 (write concern)を使用して実行される必要があります。コミット時に、書込み操作はトランザクションレベルの書込み保証 (write concern)を使用してコミットされます。

トランザクションの開始時に、トランザクションレベルの書込み保証（write concern）を設定できます。

• トランザクションレベルの書込み保証（write concern）の設定が解除されている場合、トランザクションレベルの書込み保証はデフォルトでセッションレベルの書込み保証でコミットされます。

• トランザクションレベルとセッションレベルのいずれでも書込み保証（write concern）の設定が解除されている場合、トランザクションレベルの書込み保証はデフォルトでクライアントレベルの書込み保証になります。

  • w: "majority"（MongoDB 5.0 以降の場合）。アービタを含む配置では差異があります。詳細については、「暗黙のデフォルト書込み保証（write concern）」を参照してください。

  • w: 1

トランザクションは、以下を含むすべての書込み保証（write concern）の w 値をサポートします。

本番環境での考慮事項

本番環境でのトランザクションについては、「本番環境での考慮事項」を参照してください。シャーディングされたクラスターについては、「本番環境での考慮事項（シャーディングされたクラスター）」も参照してください。

アービタ

レプリカセットにアービタがある場合、トランザクションを使用してシャードキーを変更することはできません。 アービタは、 マルチシャード トランザクションに必要なデータ操作に参加することはできません。

書込み操作が複数のシャードにまたがるトランザクションで、アービタを含むシャードを対象に読み取りまたは書込み操作が実行される場合、そのトランザクションはエラーとなり中止します。

シャード構成の制限

シャーディングされたクラスターのうち writeConcernMajorityJournalDefault が false に設定されているもの（インメモリ ストレージエンジンを使用する投票ノードのあるシャードなど）ではトランザクションを実行できません。

診断

トランザクションのステータスとメトリクスを取得するには、次のメソッドを使用します。

機能の互換性バージョン（fCV）

トランザクションを使用するには、配置のすべてのノードの FeatureCompatibilityVersion が次のバージョン以上である必要があります。

ノードの機能の互換性バージョンを確認するには、該当ノードに接続して次のコマンドを実行します。

db.adminCommand( { getParameter: 1, featureCompatibilityVersion: 1 } )

詳細については、setFeatureCompatibilityVersion に関する参考ページを参照してください。

ストレージ エンジン

トランザクションは、次のレプリカセットとシャーディングされたクラスターでサポートされます。

• プライマリが WiredTiger ストレージエンジンを使用しており、かつ

• セカンダリ ノードが、WiredTiger ストレージエンジンまたはインメモリ ストレージエンジンのいずれかを使用している。

クリティカル セクションの待機時間の制限

MongoDB 5.2 以降（および 5.0.4で）、以下の項目が適用されます。

• クエリがシャードにアクセスしたときに、チャンク移行または DDL 操作によってコレクションのクリティカル セクションが保持されている可能性があります。

• トランザクション内のクリティカル セクションをシャードが待機する時間を制限するには、metadataRefreshInTransactionMaxWaitBehindCritSecMS パラメーターを使用します。