Skip to content

Commit a3731b0

Browse files
committed
PHPC-691: Test Server execute methods send RP to mongos
1 parent a2632f3 commit a3731b0

File tree

2 files changed

+68
-0
lines changed

2 files changed

+68
-0
lines changed
Lines changed: 34 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,34 @@
1+
--TEST--
2+
MongoDB\Driver\Server::executeCommand() sends read preference to mongos
3+
--SKIPIF--
4+
<?php require __DIR__ . "/../utils/basic-skipif.inc"; ?>
5+
<?php skip_if_not_mongos(); ?>
6+
--FILE--
7+
<?php
8+
require_once __DIR__ . "/../utils/basic.inc";
9+
require_once __DIR__ . "/../utils/observer.php";
10+
11+
$manager = new MongoDB\Driver\Manager(URI);
12+
$server = $manager->selectServer(new MongoDB\Driver\ReadPreference(MongoDB\Driver\ReadPreference::RP_PRIMARY));
13+
14+
(new CommandObserver)->observe(
15+
function() use ($server) {
16+
$server->executeCommand(
17+
DATABASE_NAME,
18+
new MongoDB\Driver\Command(['ping' => true]),
19+
[
20+
'readPreference' => new \MongoDB\Driver\ReadPreference(\MongoDB\Driver\ReadPreference::RP_NEAREST),
21+
]
22+
);
23+
},
24+
function(stdClass $command) {
25+
echo "Read Preference: ", $command->{'$readPreference'}->mode, "\n";
26+
}
27+
);
28+
29+
?>
30+
===DONE===
31+
<?php exit(0); ?>
32+
--EXPECTF--
33+
Read Preference: nearest
34+
===DONE===
Lines changed: 34 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,34 @@
1+
--TEST--
2+
MongoDB\Driver\Server::executeQuery() sends read preference to mongos
3+
--SKIPIF--
4+
<?php require __DIR__ . "/../utils/basic-skipif.inc"; ?>
5+
<?php skip_if_not_mongos(); ?>
6+
--FILE--
7+
<?php
8+
require_once __DIR__ . "/../utils/basic.inc";
9+
require_once __DIR__ . "/../utils/observer.php";
10+
11+
$manager = new MongoDB\Driver\Manager(URI);
12+
$server = $manager->selectServer(new MongoDB\Driver\ReadPreference(MongoDB\Driver\ReadPreference::RP_PRIMARY));
13+
14+
(new CommandObserver)->observe(
15+
function() use ($server) {
16+
$server->executeQuery(
17+
NS,
18+
new MongoDB\Driver\Query(['x' => 1]),
19+
[
20+
'readPreference' => new \MongoDB\Driver\ReadPreference(\MongoDB\Driver\ReadPreference::RP_NEAREST),
21+
]
22+
);
23+
},
24+
function(stdClass $command) {
25+
echo "Read Preference: ", $command->{'$readPreference'}->mode, "\n";
26+
}
27+
);
28+
29+
?>
30+
===DONE===
31+
<?php exit(0); ?>
32+
--EXPECTF--
33+
Read Preference: nearest
34+
===DONE===

0 commit comments

Comments
 (0)