PHPLIB-1627: BulkWriteCommand API

.evergreen/config/templates/build/build-extension.yml

@@ -5,6 +5,9 @@
         vars:
           PHP_VERSION: "%phpVersion%"
       - func: "compile extension"
+        # TODO: Remove vars to switch to latest stable version when 2.1.0 is releeased
+        vars:
+          EXTENSION_BRANCH: "v2.x"
       - func: "upload extension"
   - name: "build-php-%phpVersion%-lowest"
     tags: ["build", "php%phpVersion%", "lowest", "pr", "tag"]
@@ -14,7 +17,9 @@
           PHP_VERSION: "%phpVersion%"
       - func: "compile extension"
         vars:
-          EXTENSION_VERSION: "2.0.0"
+          # TODO: Switch to 2.1.0 when it is released
+          # EXTENSION_VERSION: "2.0.0"
+          EXTENSION_BRANCH: "v2.x"
       - func: "upload extension"
   - name: "build-php-%phpVersion%-next-stable"
     tags: ["build", "php%phpVersion%", "next-stable", "pr", "tag"]
@@ -24,7 +29,9 @@
           PHP_VERSION: "%phpVersion%"
       - func: "compile extension"
         vars:
-          EXTENSION_BRANCH: "v2.0"
+          # TODO: Switch to v2.1 when 2.1.0 is released
+          # EXTENSION_VERSION: "v2.1"
+          EXTENSION_BRANCH: "v2.x"
       - func: "upload extension"
   - name: "build-php-%phpVersion%-next-minor"
     tags: ["build", "php%phpVersion%", "next-minor"]

.github/workflows/coding-standards.yml

@@ -13,7 +13,9 @@ on:
 
 env:
   PHP_VERSION: "8.2"
-  DRIVER_VERSION: "stable"
+  # TODO: change to "stable" once 2.0.0 is released
+  # DRIVER_VERSION: "stable"
+  DRIVER_VERSION: "mongodb/[email protected]"
 
 jobs:
   phpcs:

.github/workflows/generator.yml

@@ -13,7 +13,9 @@ on:
 
 env:
   PHP_VERSION: "8.2"
-  DRIVER_VERSION: "stable"
+  # TODO: change to "stable" once 2.0.0 is released
+  # DRIVER_VERSION: "stable"
+  DRIVER_VERSION: "mongodb/[email protected]"
 
 jobs:
   diff:

.github/workflows/static-analysis.yml

@@ -19,7 +19,9 @@ on:
 
 env:
   PHP_VERSION: "8.2"
-  DRIVER_VERSION: "stable"
+  # TODO: change to "stable" once 2.0.0 is released
+  # DRIVER_VERSION: "stable"
+  DRIVER_VERSION: "mongodb/[email protected]"
 
 jobs:
   psalm:

.github/workflows/tests.yml

@@ -12,7 +12,9 @@ on:
       - "feature/*"
 
 env:
-  DRIVER_VERSION: "stable"
+  # TODO: change to "stable" once 2.0.0 is released
+  # DRIVER_VERSION: "stable"
+  DRIVER_VERSION: "mongodb/[email protected]"
 
 jobs:
   phpunit:

composer.json

@@ -11,9 +11,10 @@
     ],
     "require": {
         "php": "^8.1",
-        "ext-mongodb": "^2.0",
+        "ext-mongodb": "^2.1",
         "composer-runtime-api": "^2.0",
-        "psr/log": "^1.1.4|^2|^3"
+        "psr/log": "^1.1.4|^2|^3",
+        "symfony/polyfill-php85": "^1.32"
     },
     "require-dev": {
         "doctrine/coding-standard": "^12.0",

psalm-baseline.xml

@@ -235,6 +235,12 @@
       <code><![CDATA[$pipeline]]></code>
     </PossiblyInvalidArgument>
   </file>
+  <file src="src/ClientBulkWrite.php">
+    <PossiblyInvalidArgument>
+      <code><![CDATA[$document]]></code>
+      <code><![CDATA[$replacement]]></code>
+    </PossiblyInvalidArgument>
+  </file>
   <file src="src/Codec/EncodeIfSupported.php">
     <ArgumentTypeCoercion>
       <code><![CDATA[$value]]></code>
@@ -545,6 +551,14 @@
       <code><![CDATA[$args[2]]]></code>
     </MixedOperand>
   </file>
+  <file src="src/Operation/ClientBulkWriteCommand.php">
+    <MixedMethodCall>
+      <code><![CDATA[isInTransaction]]></code>
+    </MixedMethodCall>
+    <MixedReturnStatement>
+      <code><![CDATA[$server->executeBulkWriteCommand($this->bulkWriteCommand, $options)]]></code>
+    </MixedReturnStatement>
+  </file>
   <file src="src/Operation/Count.php">
     <MixedAssignment>
       <code><![CDATA[$cmd[$option]]]></code>

psalm.xml.dist

@@ -20,6 +20,9 @@
     </projectFiles>
 
     <stubs>
+        <file name="stubs/Driver/BulkWriteCommand.stub.php"/>
+        <file name="stubs/Driver/BulkWriteCommandException.stub.php"/>
+        <file name="stubs/Driver/BulkWriteCommandResult.stub.php"/>
         <file name="stubs/Driver/Cursor.stub.php"/>
         <file name="stubs/Driver/CursorInterface.stub.php"/>
         <file name="stubs/Driver/WriteResult.stub.php"/>

src/Client.php

@@ -24,6 +24,8 @@
 use MongoDB\Builder\BuilderEncoder;
 use MongoDB\Builder\Pipeline;
 use MongoDB\Codec\Encoder;
+use MongoDB\Driver\BulkWriteCommand;
+use MongoDB\Driver\BulkWriteCommandResult;
 use MongoDB\Driver\ClientEncryption;
 use MongoDB\Driver\Exception\InvalidArgumentException as DriverInvalidArgumentException;
 use MongoDB\Driver\Exception\RuntimeException as DriverRuntimeException;
@@ -39,6 +41,7 @@
 use MongoDB\Model\BSONArray;
 use MongoDB\Model\BSONDocument;
 use MongoDB\Model\DatabaseInfo;
+use MongoDB\Operation\ClientBulkWriteCommand;
 use MongoDB\Operation\DropDatabase;
 use MongoDB\Operation\ListDatabaseNames;
 use MongoDB\Operation\ListDatabases;
@@ -189,6 +192,32 @@ final public function addSubscriber(Subscriber $subscriber): void
         $this->manager->addSubscriber($subscriber);
     }
 
+    /**
+     * Executes multiple write operations across multiple namespaces.
+     *
+     * @param BulkWriteCommand|ClientBulkWrite $bulk    Assembled bulk write command or builder
+     * @param array                            $options Additional options
+     * @throws UnsupportedException if options are unsupported on the selected server
+     * @throws InvalidArgumentException for parameter/option parsing errors
+     * @throws DriverRuntimeException for other driver errors (e.g. connection errors)
+     * @see ClientBulkWriteCommand::__construct() for supported options
+     */
+    public function bulkWrite(BulkWriteCommand|ClientBulkWrite $bulk, array $options = []): BulkWriteCommandResult
+    {
+        if (! isset($options['writeConcern']) && ! is_in_transaction($options)) {
+            $options['writeConcern'] = $this->writeConcern;
+        }
+
+        if ($bulk instanceof ClientBulkWrite) {
+            $bulk = $bulk->bulkWriteCommand;
+        }
+
+        $operation = new ClientBulkWriteCommand($bulk, $options);
+        $server = select_server_for_write($this->manager, $options);
+
+        return $operation->execute($server);
+    }
+
     /**
      * Returns a ClientEncryption instance for explicit encryption and decryption
      *