mirror of
https://github.com/macintoshplus/mongo-php-driver.git
synced 2026-03-29 12:22:07 +02:00
b8bd32f8f3
The previous inconsistency was likely the result of copypasta (especially where executeReadCommand was used). There is no issue with using executeCommand here since an explicit write concern is provided (nothing will be inherited).
69 lines
2.0 KiB
PHP
69 lines
2.0 KiB
PHP
--TEST--
|
|
MongoDB\Driver\Server::executeQuery() pins transaction to server
|
|
--SKIPIF--
|
|
<?php require __DIR__ . "/../utils/basic-skipif.inc"; ?>
|
|
<?php skip_if_not_mongos_with_replica_set(); ?>
|
|
<?php skip_if_server_version('<', '4.1.6'); ?>
|
|
<?php skip_if_not_clean(); ?>
|
|
--FILE--
|
|
<?php
|
|
require_once __DIR__ . "/../utils/basic.inc";
|
|
|
|
$manager = new MongoDB\Driver\Manager(URI);
|
|
|
|
/* Create collections as that can't be (automatically) done in a transaction */
|
|
$manager->executeCommand(
|
|
DATABASE_NAME,
|
|
new \MongoDB\Driver\Command([ 'create' => COLLECTION_NAME ]),
|
|
[ 'writeConcern' => new \MongoDB\Driver\WriteConcern( \MongoDB\Driver\WriteConcern::MAJORITY ) ]
|
|
);
|
|
|
|
$servers = $manager->getServers();
|
|
$selectedServer = array_pop($servers);
|
|
$wrongServer = array_pop($servers);
|
|
var_dump($selectedServer != $wrongServer);
|
|
|
|
$session = $manager->startSession();
|
|
var_dump($session->getServer() instanceof \MongoDB\Driver\Server);
|
|
|
|
$session->startTransaction();
|
|
var_dump($session->getServer() instanceof \MongoDB\Driver\Server);
|
|
|
|
$query = new MongoDB\Driver\Query([]);
|
|
$selectedServer->executeQuery(NS, $query, ['session' => $session]);
|
|
|
|
var_dump($session->getServer() == $selectedServer);
|
|
|
|
$bulk = new MongoDB\Driver\BulkWrite();
|
|
$bulk->insert(['x' => 1]);
|
|
$selectedServer->executeBulkWrite(NS, $bulk, ['session' => $session]);
|
|
|
|
echo throws(function () use ($wrongServer, $session) {
|
|
$query = new MongoDB\Driver\Query([]);
|
|
$wrongServer->executeQuery(NS, $query, ['session' => $session]);
|
|
}, \MongoDB\Driver\Exception\RuntimeException::class), "\n";
|
|
|
|
$session->commitTransaction();
|
|
|
|
var_dump($session->getServer() == $selectedServer);
|
|
|
|
$bulk = new MongoDB\Driver\BulkWrite();
|
|
$bulk->insert(['x' => 1]);
|
|
$selectedServer->executeBulkWrite(NS, $bulk, ['session' => $session]);
|
|
|
|
var_dump($session->getServer() instanceof \MongoDB\Driver\Server);
|
|
|
|
?>
|
|
===DONE===
|
|
<?php exit(0); ?>
|
|
--EXPECT--
|
|
bool(true)
|
|
bool(false)
|
|
bool(false)
|
|
bool(true)
|
|
OK: Got MongoDB\Driver\Exception\RuntimeException
|
|
Requested server id does not matched pinned server id
|
|
bool(true)
|
|
bool(false)
|
|
===DONE===
|