レプリカセットでの 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);

データベース構成

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

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

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

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

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

コレクション構成

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

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

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

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

$collection = $client->selectCollection('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->selectDatabase(
    'test_database',
    ['readPreference' => $readPreference],
);

LocalThreshold

指定した読み込み設定（ 読み込み設定 (read preference) ）とタグセットと一致するレプリカセット ノードが複数ある場合、 MongoDB PHPライブラリは、 ping時間に応じて選択された、最も近いレプリカセット ノードから読み取ります。

デフォルトでは 、ライブラリはping時間がクエリの最も近いメンバーの15ミリ秒以内であるメンバーのみを使用します。 より高いレイテンシを持つメンバー間で読み取りを分散するには、 localThresholdMSオプションを設定するMongoDB\Clientコンストラクターにオプション配列を渡します。

次の例えでは、 35ミリ秒のローカルしきい値を指定します。

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

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