レプリカセットでの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マニュアルの 書込み保証 (write concern) を参照してください。詳細な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

API ドキュメント

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

• 書込み保証 (write concern)

• 読み取り保証（read concern）

• 読み込み設定 (read preference)