Add examples for bulk writes and with_transaction

Author: alcaeus

examples/bulk.php

@@ -0,0 +1,79 @@
+<?php
+declare(strict_types=1);
+
+namespace MongoDB\Examples;
+
+use MongoDB\Client;
+
+use function assert;
+use function dirname;
+use function getenv;
+use function is_object;
+use function MongoDB\BSON\fromPHP;
+use function MongoDB\BSON\toRelaxedExtendedJSON;
+use function printf;
+
+require dirname(__FILE__) . '/../vendor/autoload.php';
+
+function toJSON(object $document): string
+{
+    return toRelaxedExtendedJSON(fromPHP($document));
+}
+
+$client = new Client(getenv('MONGODB_URI') ?: 'mongodb://127.0.0.1/');
+
+$collection = $client->test->coll;
+$collection->drop();
+
+$documents = [];
+
+for ($i = 0; $i < 10; $i++) {
+    $documents[] = ['x' => $i];
+}
+
+$collection->insertMany($documents);
+
+$collection->bulkWrite(
+    [
+        [
+            'deleteMany' => [
+                ['x' => ['$gt' => 7]], // Filter
+            ],
+        ],
+        [
+            'deleteOne' => [
+                ['x' => 4], // Filter
+            ],
+        ],
+        [
+            'replaceOne' => [
+                ['x' => 1], // Filter
+                ['y' => 1], // Replacement
+            ],
+        ],
+        [
+            'updateMany' => [
+                ['x' => ['$gt' => 5]], // Filter
+                ['$set' => ['updateMany' => true]], // Update
+            ],
+        ],
+        [
+            'updateOne' => [
+                ['x' => 2], // Filter
+                ['$set' => ['y' => 2]], // Update
+            ],
+        ],
+        [
+            'insertOne' => [
+                ['x' => 10], // Document
+            ],
+        ],
+    ]
+);
+
+$cursor = $collection->find([], ['batchSize' => 2]);
+
+foreach ($cursor as $document) {
+    assert(is_object($document));
+    printf("%s\n", toJSON($document));
+}

examples/with_transaction.php

@@ -0,0 +1,56 @@
+<?php
+declare(strict_types=1);
+
+namespace MongoDB\Examples;
+
+use MongoDB\Client;
+use MongoDB\Driver\Session;
+
+use function assert;
+use function dirname;
+use function getenv;
+use function is_object;
+use function MongoDB\BSON\fromPHP;
+use function MongoDB\BSON\toRelaxedExtendedJSON;
+use function MongoDB\with_transaction;
+use function printf;
+
+require dirname(__FILE__) . '/../vendor/autoload.php';
+
+function toJSON(object $document): string
+{
+    return toRelaxedExtendedJSON(fromPHP($document));
+}
+
+$client = new Client(getenv('MONGODB_URI') ?: 'mongodb://127.0.0.1/');
+
+$collection = $client->test->coll;
+$collection->drop();
+
+$insertData = function (Session $session) use ($collection): void {
+    $collection->insertMany(
+        [
+            ['x' => 1],
+            ['x' => 2],
+            ['x' => 3],
+        ],
+        ['session' => $session]
+    );
+
+    $collection->updateMany(
+        ['x' => ['$gt' => 1]],
+        ['$set' => ['y' => 1]],
+        ['session' => $session]
+    );
+};
+
+$session = $client->startSession();
+
+with_transaction($session, $insertData);
+
+$cursor = $collection->find([], ['batchSize' => 2]);
+
+foreach ($cursor as $document) {
+    assert(is_object($document));
+    printf("%s\n", toJSON($document));
+}