CRUD操作の構成

クライアント構成

この例では、 コンストラクターに配列を渡すことで、 MongoDB\Clientインスタンスの読み込み設定（ 読み込み設定 (read preference)）、読み取り保証（ 読み取り保証 (read concern)）、書込み保証 (write concern)（write concern）を設定する方法を示しています。 このコードは、次の設定を構成します。

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

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

• 2 書込み保証 ( 書込み保証 (write concern)) : プライマリと 1 つのセカンダリレプリカセットノードは、書込み (write)操作を確認する必要があります

$clientOptions = [
    'readPreference' => 'secondary',
    'readConcernLevel' => 'local',
    'w' => '2',
];
$client = new Client('mongodb://localhost:27017', $clientOptions);

あるいは、接続 URI で読み取り設定と書込み設定を指定することもできます。これはMongoDB\Clientコンストラクターにパラメーターとして渡されます。

$uri = 'mongodb://localhost:27017/?readPreference=secondary&readConcernLevel=local&w=2';
$client = new Client($uri);

セッション構成

この例では、 startSession()メソッドに配列を渡すことで、セッションの 読み込み設定（ 読み込み設定 (read preference)） 、 読み取り保証（ 読み取り保証 (read concern)） 、書込み保証 (write concern)（write concern） を設定する方法を示しています。 このコードは、次の設定を構成します。

• PRIMARY_PREFERRED 読み込み設定 ( 読み込み設定 (read preference)) : 読み取り操作は、プライマリレプリカセットメンバーからデータを取得します。プライマリが使用できない場合は セカンダリ メンバーからデータが取得されます

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

• MAJORITY 書込み保証（ 書込み保証 (write concern) ） : すべてのレプリカセットの過半数が書込み（write）操作を確認する必要があります

$sessionOptions = [
    'readPreference' => new ReadPreference(ReadPreference::PRIMARY_PREFERRED),
    'readConcern' => new ReadConcern(ReadConcern::LOCAL),
    'writeConcern' => new WriteConcern(WriteConcern::MAJORITY),
];
$session = $client->startSession($sessionOptions);

トランザクション構成

この例では、 startTransaction()メソッドに配列を渡すことで、トランザクションの 読み込み設定（ 読み込み設定 (read preference)） 、 読み取り保証（ 読み取り保証 (read concern)） 、書込み保証 (write concern)（write concern） を設定する方法を示しています。 このコードは、次の設定を構成します。

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

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

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

$transactionOptions = [
    'readPreference' => new ReadPreference(ReadPreference::PRIMARY),
    'readConcern' => new ReadConcern(ReadConcern::MAJORITY),
    'writeConcern' => new WriteConcern(1),
];
$session->startTransaction($transactionOptions);

データベース構成

この例では、オプション配列をgetDatabase()メソッドに渡すことで、 test_databaseというデータベースの読み込み設定（ 読み込み設定 (read preference)）、読み取り保証（ 読み取り保証 (read concern)）、書込み保証 (write concern)（write concern）を設定する方法を示します。 このコードは、次の設定を構成します。

• PRIMARY_PREFERRED 読み込み設定 ( 読み込み設定 (read preference)) : 読み取り操作は、プライマリレプリカセットメンバーからデータを取得します。プライマリが使用できない場合は セカンダリ メンバーからデータが取得されます

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

• MAJORITY 書込み保証（ 書込み保証 (write concern) ） : すべてのレプリカセットの過半数が書込み（write）操作を確認する必要があります

$db = $client->getDatabase('test_database', [
    'readPreference' => new ReadPreference(ReadPreference::PRIMARY_PREFERRED),
    'readConcern' => new ReadConcern(ReadConcern::AVAILABLE),
    'writeConcern' => new WriteConcern(WriteConcern::MAJORITY),
]);

コレクション構成

この例では、オプション配列をgetCollection()メソッドに渡すことで、 test_collectionというコレクションの読み込み設定（ 読み込み設定 (read preference)）、読み取り保証（ 読み取り保証 (read concern)）、書込み保証 (write concern)（write concern）を設定する方法を示します。 このコードは、次の設定を構成します。

• SECONDARY_PREFERRED 読み込み設定 ( 読み込み設定 (read preference)) : 読み取り操作は、セカンダリレプリカセットメンバーからデータを取得します。セカンダリが使用できない場合は、プライマリ ノードからデータが取得されます。

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

• 0 書込み保証 ( 書込み保証 (write concern)) : 書込み (write)操作の確認応答を要求しません

$collection = $client->getCollection('test_database', 'test_collection', [
    'readPreference' => new ReadPreference(ReadPreference::SECONDARY_PREFERRED),
    'readConcern' => new ReadConcern(ReadConcern::AVAILABLE),
    'writeConcern' => new WriteConcern(0),
]);

タグセット

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

デフォルトでは 、 MongoDB PHPライブラリは、読み取り元ノードを選択するときに タグを無視します。 MongoDB PHPライブラリに特定のタグを優先するように指定するには、それらをMongoDB\Driver\ReadPreferenceクラスコンストラクターにパラメーターとして渡します。 次に、 MongoDB\Driver\ReadPreferenceオブジェクトをreadPreferenceデータベースオプションの値として設定します。

米国の複数のデータセンターでホストされているノードを含むレプリカセットに接続しているとします。 このコード例では、 readPreferenceオプションをタグセットに設定し、セカンダリレプリカセットメンバーからの読み取りを次の順序で優先するようtest_databaseに指示します。

1. ニューヨークデータセンターのメンバー（ ['dc' => 'ny'] ）

2. サンフランシスコデータセンターのメンバー（ ['dc' => 'sf'] ）

3. 任意のセカンダリ ノード（ [] ）

$readPreference = new ReadPreference(
    ReadPreference::RP_SECONDARY,
    [
        ['dc' => 'ny'],
        ['dc' => 'sf'],
        [],
    ],
);
$db = $client->getDatabase(
    'test_database',
    ['readPreference' => $readPreference],
);

ロード バランシング

シャーディングされたクラスターまたはレプリカセットに接続する場合、 PHPライブラリは負荷分散を使用して読み取りおよび書込みリクエストを処理します。負荷バランシングにより、ライブラリはこれらのリクエストを複数のサーバーに分散して、1 つのサーバーが過負荷になるのを回避し、最適なパフォーマンスを確保できます。

シャーディングされたクラスターに接続する場合、 PHPライブラリは、ネットワーク ラウンド トリップ時間が最も短いインスタンスを計算して、最も近い mongosインスタンスを決定します。次に、ライブラリはこの mongos の平均ラウンドトリップ時間を localThresholdMS 値 に追加してレイテンシウィンドウを決定します。ライブラリは、レイテンシウィンドウ内の最大 2 つのランダムな mongos インスタンスにわたってリクエストを分散します。ライブラリは、リクエストごとに、operationCount 値を決定し、操作負荷がより低いサーバーを選択します。

レプリカセットに接続すると、 PHPライブラリはまず読み込み設定 (read preference)に従ってレプリカセットメンバーを選択します。その後、ライブラリは前のセクションで説明されているのと同じプロセスに従います。レイテンシウィンドウを計算した後、ライブラリはウィンドウ内にあるランダムなレプリカセットメンバーを最大 2 つ選択し、リクエストを受信するために operationCount 値が低いメンバーを選択します。

$options = [
    'replicaSet' => 'repl0',
    'readPreference' => new ReadPreference(ReadPreference::RP_SECONDARY_PREFERRED),
    'localThresholdMS' => 35,
];
$client = new Client('mongodb://localhost:27017', [], $options);