ChangeStream example

Author: jmikola

examples/changestream.php

@@ -0,0 +1,54 @@
+<?php
+declare(strict_types=1);
+
+namespace MongoDB\Examples;
+
+require '../vendor/autoload.php';
+
+use MongoDB\Client;
+
+use function fprintf;
+use function getenv;
+use function hrtime;
+use function MongoDB\BSON\fromPHP;
+use function MongoDB\BSON\toRelaxedExtendedJSON;
+use function printf;
+
+use const STDERR;
+
+function toJSON(object $document): string
+{
+    return toRelaxedExtendedJSON(fromPHP($document));
+}
+
+$client = new Client(getenv('MONGODB_URI') ?? null);
+
+$collection = $client->test->coll;
+$collection->drop();
+
+$changeStream = $collection->watch();
+
+$documents = [];
+
+for ($i = 0; $i < 10; $i++) {
+    $documents[] = ['x' => $i];
+}
+
+$collection->insertMany($documents);
+
+$changeStream->rewind();
+
+$startTime = hrtime(true);
+
+while (true) {
+    if ($changeStream->valid()) {
+        printf("%s\n", toJSON($changeStream->current()));
+    }
+
+    $changeStream->next();
+
+    if (hrtime(true) - $startTime > 5e+9) {
+        fprintf(STDERR, "Aborting after 5 seconds...\n");
+        break;
+    }
+}