CRUD操作の構成

読み取り設定と書込み設定の優先順位

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

• トランザクション

• Database

• コレクション

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

トランザクション構成

start_session()トランザクションはmongocxx::options::transaction セッション 内で実行されます。これは、順番に実行されるよう関連付けられた読み取り操作または書込み操作のグループです。トランザクションに使用するセッションを取得するには、 メソッドを使用します。次に、 オブジェクトをセッションのwith_transaction() メソッドに渡します。この例では、トランザクションの 読み込み設定（読み込み設定 (read preference)、読み取り保証 (read concern)、書込み保証 (write concern)を設定する方法を示しています。

この例では、次の設定を構成しています。

• k_primary 読み込み設定 (read preference): 読み取り操作は、 プライマリレプリカセットメンバーからデータを取得します。

• k_majority 読み取り保証 (read concern) : 読み取り操作は、レプリカセットノードの過半数に書き込まれたインスタンスの最新データを返します。

• k_acknowledged 書込み保証 (write concern)) : プライマリレプリカセットノードは書込み (write)操作を確認する必要があります。

auto session = client.start_session();
mongocxx::options::transaction txn_opts;
{
    mongocxx::read_preference rp;
    mongocxx::read_concern rc;
    mongocxx::write_concern wc;
    rp.mode(mongocxx::read_preference::read_mode::k_primary);
    rc.acknowledge_level(mongocxx::read_concern::level::k_majority);
    wc.acknowledge_level(mongocxx::write_concern::level::k_acknowledged);
    txn_opts.read_preference(rp);
    txn_opts.read_concern(rc);
    txn_opts.write_concern(wc);
}
session.with_transaction([&](mongocxx::client_session*) {
    // Specify transaction operations here
}, txn_opts);

データベース構成

この例では、データベースの次の読み取り設定を構成する方法を示します。

• k_secondary 読み込み設定 (read preference): 読み取り操作は、 セカンダリレプリカセットメンバーからのみデータを取得します。

• k_majority 読み取り保証 (read concern) : 読み取り操作は、レプリカセットノードの過半数に書き込まれたインスタンスの最新データを返します。

auto db = client["test_database"];
mongocxx::read_preference rp;
mongocxx::read_concern rc;
rp.mode(mongocxx::read_preference::read_mode::k_secondary);
rc.acknowledge_level(mongocxx::read_concern::level::k_majority);
db.read_preference(rp);
db.read_concern(rc);

コレクション構成

この例では、コレクションに対して次の読み取り保証と書込み保証 (write concern)保証を指定する方法を示しています。

• k_local 読み取り保証 (read concern) : 読み取り操作はインスタンスの最新データを返します。このデータがレプリカセットのノードの過半数に書き込まれたことを保証するものではありません。

• k_acknowledged 書込み保証 (write concern)) : プライマリレプリカセットノードは書込み (write)操作を確認する必要があります。

auto coll = client["test_database"]["test_collection"];
mongocxx::read_concern rc;
mongocxx::write_concern wc;
rc.acknowledge_level(mongocxx::read_concern::level::k_local);
wc.acknowledge_level(mongocxx::write_concern::level::k_acknowledged);
coll.read_concern(rc);
coll.write_concern(wc);

タグセット

MongoDB Serverでは、選択した任意の基準に従ってレプリカセット メンバーにキーと値のタグを適用できます。次に、それらのタグを使用して、1 つ以上のノードを 読み取り操作の対象にすることができます。

デフォルトでは 、 C++ドライバーは、読み取り元ノードを選択するときに タグを無視します。 C++ドライバーに特定のタグを優先するように指定するには、mongocxx::read_preferenceオブジェクトを作成し、その tags() ノード関数を呼び出します。 希望するタグを配列引数として tags() に渡します。

次のコード例では、tags() 関数に渡されるタグセットは、 C++ドライバーに対して、ニューヨークデータセンター（"dc": "ny"）からの読み取りを優先し、サンフランシスコデータセンター（"dc": "sf"）にフォールバックするように指示します。

auto tag_set_ny = make_document(kvp("dc", "ny"));
auto tag_set_sf = make_document(kvp("dc", "sf"));
mongocxx::read_preference rp;
rp.mode(mongocxx::read_preference::read_mode::k_secondary);
rp.tags(make_array(tag_set_ny, tag_set_sf).view());

LocalThreshold

C++ドライバーは、ローカルしきい値を使用して、サーバー選択のレイテンシウィンドウを計算します。この値により、読み取りリクエストと書込みリクエストを受信する資格のあるサーバーが決まります。

デフォルトでは 、ドライバーは 個のサーバーからping時間が 15 ミリ秒以内である mongos インスタンスまたはレプリカセットメンバーのみを使用します。レイテンシが高いサーバー間で読み取りを分散するには、接続 URI で localThreshold パラメータを設定します。

次の例ではレプリカセットに接続し、35 ミリ秒のローカルしきい値を指定します。

mongocxx::uri uri{"mongodb://localhost:27017/?replicaSet=repl0&localThresholdMS=35"};
mongocxx::client client{uri};

前の例では、 C++ドライバーは、最も近いメンバーのping時間の 35 ミリ秒以内に、一致するメンバーに読み取りを分散します。

照合の例

以下のドキュメントを持つコレクションを考えてみましょう。

{ _id: 1, category: "café" },
{ _id: 2, category: "cafe" },
{ _id: 3, category: "cafE" }

次の例では、ロケールのロケールを指定し、大文字と小文字と文字の違いを無視する照合を作成しています。次に、この照合を使用して、categoryフィールド値が "cafe" と一致するドキュメントを検索します。指定された照合により、クエリは 3 つのドキュメントすべてを返します。

mongocxx::options::find opts{};
opts.collation(bsoncxx::from_json(R"({"locale": "fr", "strength": 1})"));
auto cursor = collection.find(make_document(kvp("category", "cafe")), opts);
for(auto&& doc : cursor) {
    std::cout << bsoncxx::to_json(doc) << std::endl;
}

{ "_id": { "$oid" : "1" }, "category": "café" }
{ "_id": { "$oid" : "2" }, "category": "cafe" }
{ "_id": { "$oid" : "3" }, "category": "cafE" }