admin/mongo-php-driver
1
0
Fork 0
mirror of https://github.com/macintoshplus/mongo-php-driver.git synced 2026-04-02 22:32:12 +02:00
Code Issues Packages Projects Releases Wiki Activity

Test for PHPC-186

Browse Source
This commit is contained in:
Hannes Magnusson
2015-03-23 13:53:33 -07:00
parent 4daeefa3a5
commit bb02c4861b
1 changed files with 105 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

105
tests/replicaset/writeresult-getserver-002.phpt Normal file
View File

@@ -0,0 +1,105 @@
--TEST--
MongoDB\Driver\Server: Manager->getServer() returning correct server
--SKIPIF--
<?php require "tests/utils/basic-skipif.inc"; CLEANUP(REPLICASET); ?>
--FILE--
<?php
require_once "tests/utils/basic.inc";
$manager = new MongoDB\Driver\Manager(REPLICASET);
$doc = array("example" => "document");
$bulk = new \MongoDB\Driver\BulkWrite();
$bulk->insert($doc);
$wresult = $manager->executeBulkWrite(NS, $bulk);
$bulk = new \MongoDB\Driver\BulkWrite();
$bulk->insert($doc);
/* writes go to the primary */
$server = $wresult->getServer();
/* This is the same server */
$server2 = $server->executeBulkWrite(NS, $bulk)->getServer();
/* Both are the primary, e.g. the same server */
var_dump($server == $server2);
$rp = new MongoDB\Driver\ReadPreference(MongoDB\Driver\ReadPreference::RP_SECONDARY);
/* Fetch a secondary */
$server3 = $manager->executeQuery(NS, new MongoDB\Driver\Query(array()), $rp)->getServer();
var_dump($server == $server3);
var_dump($server->getPort(), $server3->getPort());
$bulk = new \MongoDB\Driver\BulkWrite();
$bulk->insert($doc);
$result = $server3->executeBulkWrite("local.examples", $bulk);
var_dump($result, $result->getServer()->getHost(), $result->getServer()->getPort());
$result = $server3->executeQuery("local.examples", new MongoDB\Driver\Query(array()));
foreach($result as $document) {
var_dump($document);
}
$cmd = new MongoDB\Driver\Command(array("drop" => "examples"));
$server3->executeCommand("local", $cmd);
throws(function() use ($server3, $bulk) {
$result = $server3->executeBulkWrite(NS, $bulk);
}, "MongoDB\\Driver\\RuntimeException");
?>
===DONE===
<?php exit(0); ?>
--EXPECTF--
bool(true)
bool(false)
int(3000)
int(3001)
object(MongoDB\Driver\WriteResult)#%d (%d) {
["nInserted"]=>
int(1)
["nMatched"]=>
int(0)
["nModified"]=>
int(0)
["nRemoved"]=>
int(0)
["nUpserted"]=>
int(0)
["upsertedIds"]=>
array(0) {
}
["writeErrors"]=>
array(0) {
}
["writeConcernError"]=>
array(0) {
}
["writeConcern"]=>
array(4) {
["wmajority"]=>
bool(false)
["wtimeout"]=>
int(0)
["fsync"]=>
bool(false)
["journal"]=>
bool(false)
}
}
string(14) "192.168.112.10"
int(3001)
array(2) {
["_id"]=>
object(BSON\ObjectID)#%d (1) {
["oid"]=>
string(24) "%s"
}
["example"]=>
string(8) "document"
}
OK: Got MongoDB\Driver\RuntimeException
===DONE===