PHPC-653: Tests for WriteResult and error classes

tests/writeConcernError/writeconcernerror-debug-001.phpt

@@ -0,0 +1,34 @@
+--TEST--
+MongoDB\Driver\WriteConcernError debug output
+--SKIPIF--
+<?php require __DIR__ . "/../utils/basic-skipif.inc"; ?>
+<?php NEEDS("REPLICASET_30"); CLEANUP(REPLICASET_30); ?>
+--FILE--
+<?php
+require_once __DIR__ . "/../utils/basic.inc";
+
+$manager = new MongoDB\Driver\Manager(REPLICASET_30);
+
+$bulk = new MongoDB\Driver\BulkWrite;
+$bulk->insert(['x' => 1]);
+
+try {
+    /* We assume that the replica set does not have 12 nodes */
+    $manager->executeBulkWrite(NS, $bulk, new MongoDB\Driver\WriteConcern(12));
+} catch(MongoDB\Driver\Exception\BulkWriteException $e) {
+    var_dump($e->getWriteResult()->getWriteConcernError());
+}
+
+?>
+===DONE===
+<?php exit(0); ?>
+--EXPECTF--
+object(MongoDB\Driver\WriteConcernError)#%d (%d) {
+  ["message"]=>
+  string(29) "Not enough data-bearing nodes"
+  ["code"]=>
+  int(100)
+  ["info"]=>
+  NULL
+}
+===DONE===

tests/writeConcernError/writeconcernerror-debug-002.phpt

@@ -0,0 +1,38 @@
+--TEST--
+MongoDB\Driver\WriteConcernError debug output
+--SKIPIF--
+<?php require __DIR__ . "/../utils/basic-skipif.inc"; SLOW(); ?>
+<?php NEEDS("REPLICASET_30"); CLEANUP(REPLICASET_30); ?>
+--FILE--
+<?php
+require_once __DIR__ . "/../utils/basic.inc";
+
+$manager = new MongoDB\Driver\Manager(REPLICASET_30);
+
+$bulk = new MongoDB\Driver\BulkWrite;
+for ($i = 0; $i < 6; $i++) {
+    $bulk->insert(['x' => $i, 'y' => str_repeat('a', 4194304)]);
+}
+
+try {
+    $manager->executeBulkWrite(NS, $bulk, new MongoDB\Driver\WriteConcern(2, 1));
+} catch(MongoDB\Driver\Exception\BulkWriteException $e) {
+    var_dump($e->getWriteResult()->getWriteConcernError());
+}
+
+?>
+===DONE===
+<?php exit(0); ?>
+--EXPECTF--
+object(MongoDB\Driver\WriteConcernError)#%d (%d) {
+  ["message"]=>
+  string(33) "waiting for replication timed out"
+  ["code"]=>
+  int(64)
+  ["info"]=>
+  object(stdClass)#%d (%d) {
+    ["wtimeout"]=>
+    bool(true)
+  }
+}
+===DONE===

tests/writeConcernError/writeconcernerror-getcode-001.phpt

@@ -0,0 +1,27 @@
+--TEST--
+MongoDB\Driver\WriteConcernError::getCode()
+--SKIPIF--
+<?php require __DIR__ . "/../utils/basic-skipif.inc"; ?>
+<?php NEEDS("REPLICASET_30"); CLEANUP(REPLICASET_30); ?>
+--FILE--
+<?php
+require_once __DIR__ . "/../utils/basic.inc";
+
+$manager = new MongoDB\Driver\Manager(REPLICASET_30);
+
+$bulk = new MongoDB\Driver\BulkWrite;
+$bulk->insert(['x' => 1]);
+
+try {
+    /* We assume that the replica set does not have 12 nodes */
+    $manager->executeBulkWrite(NS, $bulk, new MongoDB\Driver\WriteConcern(12));
+} catch(MongoDB\Driver\Exception\BulkWriteException $e) {
+    var_dump($e->getWriteResult()->getWriteConcernError()->getCode());
+}
+
+?>
+===DONE===
+<?php exit(0); ?>
+--EXPECT--
+int(100)
+===DONE===

tests/writeConcernError/writeconcernerror-getinfo-001.phpt

@@ -0,0 +1,27 @@
+--TEST--
+MongoDB\Driver\WriteConcernError::getInfo()
+--SKIPIF--
+<?php require __DIR__ . "/../utils/basic-skipif.inc"; ?>
+<?php NEEDS("REPLICASET_30"); CLEANUP(REPLICASET_30); ?>
+--FILE--
+<?php
+require_once __DIR__ . "/../utils/basic.inc";
+
+$manager = new MongoDB\Driver\Manager(REPLICASET_30);
+
+$bulk = new MongoDB\Driver\BulkWrite;
+$bulk->insert(['x' => 1]);
+
+try {
+    /* We assume that the replica set does not have 12 nodes */
+    $manager->executeBulkWrite(NS, $bulk, new MongoDB\Driver\WriteConcern(12));
+} catch(MongoDB\Driver\Exception\BulkWriteException $e) {
+    var_dump($e->getWriteResult()->getWriteConcernError()->getInfo());
+}
+
+?>
+===DONE===
+<?php exit(0); ?>
+--EXPECT--
+NULL
+===DONE===

tests/writeConcernError/writeconcernerror-getinfo-002.phpt

@@ -0,0 +1,31 @@
+--TEST--
+MongoDB\Driver\WriteConcernError::getInfo()
+--SKIPIF--
+<?php require __DIR__ . "/../utils/basic-skipif.inc"; SLOW(); ?>
+<?php NEEDS("REPLICASET_30"); CLEANUP(REPLICASET_30); ?>
+--FILE--
+<?php
+require_once __DIR__ . "/../utils/basic.inc";
+
+$manager = new MongoDB\Driver\Manager(REPLICASET_30);
+
+$bulk = new MongoDB\Driver\BulkWrite;
+for ($i = 0; $i < 6; $i++) {
+    $bulk->insert(['x' => $i, 'y' => str_repeat('a', 4194304)]);
+}
+
+try {
+    $manager->executeBulkWrite(NS, $bulk, new MongoDB\Driver\WriteConcern(2, 1));
+} catch(MongoDB\Driver\Exception\BulkWriteException $e) {
+    var_dump($e->getWriteResult()->getWriteConcernError()->getInfo());
+}
+
+?>
+===DONE===
+<?php exit(0); ?>
+--EXPECTF--
+object(stdClass)#%d (%d) {
+  ["wtimeout"]=>
+  bool(true)
+}
+===DONE===

tests/writeConcernError/writeconcernerror-getmessage-001.phpt

@@ -0,0 +1,27 @@
+--TEST--
+MongoDB\Driver\WriteConcernError::getMessage()
+--SKIPIF--
+<?php require __DIR__ . "/../utils/basic-skipif.inc"; ?>
+<?php NEEDS("REPLICASET_30"); CLEANUP(REPLICASET_30); ?>
+--FILE--
+<?php
+require_once __DIR__ . "/../utils/basic.inc";
+
+$manager = new MongoDB\Driver\Manager(REPLICASET_30);
+
+$bulk = new MongoDB\Driver\BulkWrite;
+$bulk->insert(['x' => 1]);
+
+try {
+    /* We assume that the replica set does not have 12 nodes */
+    $manager->executeBulkWrite(NS, $bulk, new MongoDB\Driver\WriteConcern(12));
+} catch(MongoDB\Driver\Exception\BulkWriteException $e) {
+    var_dump($e->getWriteResult()->getWriteConcernError()->getMessage());
+}
+
+?>
+===DONE===
+<?php exit(0); ?>
+--EXPECT--
+string(29) "Not enough data-bearing nodes"
+===DONE===

tests/writeError/writeerror-debug-001.phpt

@@ -0,0 +1,37 @@
+--TEST--
+MongoDB\Driver\WriteError debug output
+--SKIPIF--
+<?php require __DIR__ . "/../utils/basic-skipif.inc"; ?>
+<?php NEEDS('STANDALONE_30'); CLEANUP(STANDALONE_30) ?>
+--FILE--
+<?php
+require_once __DIR__ . "/../utils/basic.inc";
+
+$manager = new MongoDB\Driver\Manager(STANDALONE_30);
+
+$bulk = new MongoDB\Driver\BulkWrite;
+$bulk->insert(['_id' => 1]);
+$bulk->insert(['_id' => 1]);
+$bulk->insert(['_id' => 1]);
+
+try {
+    $manager->executeBulkWrite(NS, $bulk);
+} catch(MongoDB\Driver\Exception\BulkWriteException $e) {
+    var_dump($e->getWriteResult()->getWriteErrors()[0]);
+}
+
+?>
+===DONE===
+<?php exit(0); ?>
+--EXPECTF--
+object(MongoDB\Driver\WriteError)#%d (%d) {
+  ["message"]=>
+  string(95) "E11000 duplicate key error index: phongo.writeError_writeerror_debug_001.$_id_ dup key: { : 1 }"
+  ["code"]=>
+  int(11000)
+  ["index"]=>
+  int(1)
+  ["info"]=>
+  NULL
+}
+===DONE===

tests/writeError/writeerror-getCode-001.phpt

@@ -0,0 +1,28 @@
+--TEST--
+MongoDB\Driver\WriteError::getCode()
+--SKIPIF--
+<?php require __DIR__ . "/../utils/basic-skipif.inc"; ?>
+<?php NEEDS('STANDALONE_30'); CLEANUP(STANDALONE_30) ?>
+--FILE--
+<?php
+require_once __DIR__ . "/../utils/basic.inc";
+
+$manager = new MongoDB\Driver\Manager(STANDALONE_30);
+
+$bulk = new MongoDB\Driver\BulkWrite;
+$bulk->insert(['_id' => 1]);
+$bulk->insert(['_id' => 1]);
+$bulk->insert(['_id' => 1]);
+
+try {
+    $manager->executeBulkWrite(NS, $bulk);
+} catch(MongoDB\Driver\Exception\BulkWriteException $e) {
+    var_dump($e->getWriteResult()->getWriteErrors()[0]->getCode());
+}
+
+?>
+===DONE===
+<?php exit(0); ?>
+--EXPECT--
+int(11000)
+===DONE===

tests/writeError/writeerror-getIndex-001.phpt

@@ -0,0 +1,28 @@
+--TEST--
+MongoDB\Driver\WriteError::getIndex()
+--SKIPIF--
+<?php require __DIR__ . "/../utils/basic-skipif.inc"; ?>
+<?php NEEDS('STANDALONE_30'); CLEANUP(STANDALONE_30) ?>
+--FILE--
+<?php
+require_once __DIR__ . "/../utils/basic.inc";
+
+$manager = new MongoDB\Driver\Manager(STANDALONE_30);
+
+$bulk = new MongoDB\Driver\BulkWrite;
+$bulk->insert(['_id' => 1]);
+$bulk->insert(['_id' => 1]);
+$bulk->insert(['_id' => 1]);
+
+try {
+    $manager->executeBulkWrite(NS, $bulk);
+} catch(MongoDB\Driver\Exception\BulkWriteException $e) {
+    var_dump($e->getWriteResult()->getWriteErrors()[0]->getIndex());
+}
+
+?>
+===DONE===
+<?php exit(0); ?>
+--EXPECT--
+int(1)
+===DONE===

tests/writeError/writeerror-getInfo-001.phpt

@@ -0,0 +1,29 @@
+--TEST--
+MongoDB\Driver\WriteError::getInfo()
+--SKIPIF--
+<?php require __DIR__ . "/../utils/basic-skipif.inc"; ?>
+<?php NEEDS('STANDALONE_30'); CLEANUP(STANDALONE_30) ?>
+--FILE--
+<?php
+require_once __DIR__ . "/../utils/basic.inc";
+
+$manager = new MongoDB\Driver\Manager(STANDALONE_30);
+
+$bulk = new MongoDB\Driver\BulkWrite;
+$bulk->insert(['_id' => 1]);
+$bulk->insert(['_id' => 1]);
+$bulk->insert(['_id' => 1]);
+
+try {
+    $manager->executeBulkWrite(NS, $bulk);
+} catch(MongoDB\Driver\Exception\BulkWriteException $e) {
+    // "errInfo" is rarely populated on a WriteError (e.g. shard version error)
+    var_dump($e->getWriteResult()->getWriteErrors()[0]->getInfo());
+}
+
+?>
+===DONE===
+<?php exit(0); ?>
+--EXPECT--
+NULL
+===DONE===

tests/writeError/writeerror-getMessage-001.phpt

@@ -0,0 +1,28 @@
+--TEST--
+MongoDB\Driver\WriteError::getMessage()
+--SKIPIF--
+<?php require __DIR__ . "/../utils/basic-skipif.inc"; ?>
+<?php NEEDS('STANDALONE_30'); CLEANUP(STANDALONE_30) ?>
+--FILE--
+<?php
+require_once __DIR__ . "/../utils/basic.inc";
+
+$manager = new MongoDB\Driver\Manager(STANDALONE_30);
+
+$bulk = new MongoDB\Driver\BulkWrite;
+$bulk->insert(['_id' => 1]);
+$bulk->insert(['_id' => 1]);
+$bulk->insert(['_id' => 1]);
+
+try {
+    $manager->executeBulkWrite(NS, $bulk);
+} catch(MongoDB\Driver\Exception\BulkWriteException $e) {
+    var_dump($e->getWriteResult()->getWriteErrors()[0]->getMessage());
+}
+
+?>
+===DONE===
+<?php exit(0); ?>
+--EXPECT--
+string(100) "E11000 duplicate key error index: phongo.writeError_writeerror_getMessage_001.$_id_ dup key: { : 1 }"
+===DONE===

tests/writeResult/writeresult-debug-002.phpt

@@ -1,7 +1,8 @@
 --TEST--
 MongoDB\Driver\WriteResult debug output with errors
 --SKIPIF--
-<?php require __DIR__ . "/../utils/basic-skipif.inc"; CLEANUP(REPLICASET); ?>
+<?php require __DIR__ . "/../utils/basic-skipif.inc"; ?>
+<?php NEEDS("REPLICASET"); CLEANUP(REPLICASET); ?>
 --FILE--
 <?php
 require_once __DIR__ . "/../utils/basic.inc";
@@ -19,6 +20,7 @@ $bulk->insert(['_id' => 3]);
 $bulk->insert(['_id' => 3]);
 
 try {
+    /* We assume that the replica set does not have 30 nodes */
     $result = $manager->executeBulkWrite(NS, $bulk, new MongoDB\Driver\WriteConcern(30));
 } catch (MongoDB\Driver\Exception\BulkWriteException $e) {
     var_dump($e->getWriteResult());

tests/writeResult/writeresult-getdeletedcount-001.phpt

@@ -0,0 +1,27 @@
+--TEST--
+MongoDB\Driver\WriteResult::getDeletedCount() with acknowledged write
+--SKIPIF--
+<?php require __DIR__ . "/../utils/basic-skipif.inc"; CLEANUP(STANDALONE) ?>
+--FILE--
+<?php
+require_once __DIR__ . "/../utils/basic.inc";
+
+$manager = new MongoDB\Driver\Manager(STANDALONE);
+
+$bulk = new MongoDB\Driver\BulkWrite;
+$bulk->insert(['x' => 1]);
+$bulk->update(['x' => 1], ['$set' => ['y' => 3]]);
+$bulk->update(['x' => 2], ['$set' => ['y' => 1]], ['upsert' => true]);
+$bulk->update(['x' => 3], ['$set' => ['y' => 2]], ['upsert' => true]);
+$bulk->delete(['x' => 1]);
+
+$result = $manager->executeBulkWrite(NS, $bulk);
+
+var_dump($result->getDeletedCount());
+
+?>
+===DONE===
+<?php exit(0); ?>
+--EXPECT--
+int(1)
+===DONE===