CRUD操作の構成

Overview

このガイドでは、 書込み保証（ write concern ） 、 読み取り保証（ read concern ） 、 読み込み設定（ read preference ） の構成を使用して、MongoDB がレプリカセットに対して作成、読み取り、アップデート、削除（CRUD）操作を実行する方法を変更する方法を説明します。

次のレベルで、書込み保証、読み取り保証、読み込み設定（read preference）のオプションを設定できます。

• クライアント（オーバーライドされない限り、すべての操作実行にデフォルトを設定します）

• セッション

• トランザクション

• Database

• コレクション

前のリストは、 オプション設定の優先順位の増加順も示しています。例、トランザクションに読み取り保証 (read concern)レベルを設定すると、クライアントに設定された読み取り保証 (read concern)レベルが上書きされます。

これらのオプションを使用すると、レプリカセット内のデータの因果整合性と可用性をカスタマイズできます。

書込み保証 (write concern)

書込み保証 (write concern) は、挿入や更新などの書込み (write) 操作について MongoDB から要求される確認応答のレベルを指定します。その後、操作は正常に返されます。 明示的な書込み保証（write concern）を指定しない操作は、グローバルなデフォルトの書込み保証（write concern）設定を継承します。

詳細については、 MongoDB Serverマニュアルの書込み保証を参照してください。詳細なAPIドキュメントについては、書込み保証 (write concern) APIドキュメントを参照してください。

以下の表では、 write_concernパラメータを説明しています。

client = Mongo::Client.new(['IP_ADDRESS_001:27017'], database: 'myDB')
myDB = client.database
myCollection = myDB[:myCollection]
myCollection.insert_one(
  { name: 'anotherDocumentName' },
  write: {
    w: 2,
    wtimeout: 5000
  }
)

myDoc = { name: 'New Document' }
new_write_concern = Mongo::WriteConcern.get(myDB.write_concern)
myDB[:myCollection].with(write: new_write_concern).insert_one(myDoc)

読み取り保証（read concern）

読み取り保証 (read concern) は、次の動作を指定します。

• レプリカセット間の因果整合性のレベル

• クエリ中に維持される分離の保証

読み取り保証 (read concern)設定は、level パラメータを使用して指定できます。デフォルトの読み取り保証 (read concern)レベルは local です。つまり、クライアントは接続先のレプリカセットクライアントからデータを返しますが、そのデータがすべてのレプリカセットメンバーに書き込まれた保証はありません。

読み取り保証 (read concern) または読み取り保証 (read concern)レベルの詳細については、 MongoDB Serverマニュアルの「 読み取り保証 (read concern) 」を参照してください。read_concern のタイプと読み取り保証 (read concern)レベルの定義の詳細については、 APIドキュメントの「 読み取り保証（read concern） 」を参照してください。

pipeline = [
  { "$match" => { category: 'KITCHENWARE' } },
  { "$unset" => ['_id', 'category'] }
]
result = myCollection.aggregate(pipeline,
read: { read_concern: { level: :available } })

client = Mongo::Client.new(['IP_ADDRESS_001:27017'], 
  database: 'mydb', 
  read_concern: { level: :local })
myDB = client.database

読み込み設定 (read preference)

読み込み設定 (read preference) は、クエリの実行中時にMongoDB がレプリカセットのどのノードを読み込むかを決定します。

詳細なAPIドキュメントについては、読み込み設定 (read preference) APIドキュメントを参照してください。

次の表には、サーバーがメンバーを評価する方法をカスタマイズするために使用できるオプションが示されています。

transaction_options = {
  read: { mode: :primary },
  read_concern: { level: :local },
  write_concern: { w: :majority }
}
session = client.start_session
session.start_transaction(transaction_options)
session.commit_transaction
# ...
rescue => e
    session.abort_transaction
    puts "Transaction aborted due to an error: #{e.message}"
ensure
    session.end_session
end

uri = 'mongodb+srv://<user>:<password>@<cluster-url>'
options = {
  read: {
    mode: :secondary,
    max_staleness: 120
  }
}
client = Mongo::Client.new(uri, options)
myDB = client.database

再試行可能な読み取りと書込み

Rubyドライバーは、ネットワークまたはサーバーエラーにより失敗した場合、特定の読み取りおよび書込み操作が自動的に再試行されます。

新しいクライアントを 作成する ときに、retry_reads または retry_writes オプションを false に設定することで、最新の再試行可能な読み取りまたは再試行可能な書込みを明示的に無効にすることができます。false に設定すると、レガシー再試行動作が有効になります。

次の例では、クライアントの最新の再試行可能な読み取りと書込みを無効にします。

uri = 'mongodb+srv://<user>:<password>@<cluster-url>'
options = { 
  retry_reads: false, 
  retry_writes: false 
}
client = Mongo::Client.new(uri, options)
myDB = client.database

サポートされている再試行可能な読み取り操作の詳細については、 MongoDB Serverマニュアルの「 再試行可能な読み取り 」を参照してください。サポートされている再試行可能な書込み操作の詳細については、 MongoDB Serverマニュアルの「 再試行可能な書込み 」を参照してください。

API ドキュメント

このガイドで言及されているメソッドとタイプの詳細については、次のAPIドキュメントを参照してください。

• 書込み保証 (write concern)

• 読み取り保証（read concern）

• 読み込み設定 (read preference)