DOCSP-46427: client bulk write (#111)

* DOCSP-46427: client BW

* small fixes

* MW PR fixes 1

* VB tech review 1

Author: rustagir

source/includes/write/bulk-write.scala

@@ -32,7 +32,7 @@ object BulkWrite {
       // start-bulk-update-many
       val updateManyFilter = equal("name", "Wendy's")
       val updateManyDoc = set("cuisine", "Fast food")
-      val updateManyModel = UpdateOneModel(updateManyFilter, updateManyDoc)
+      val updateManyModel = UpdateManyModel(updateManyFilter, updateManyDoc)
       // end-bulk-update-many
 
       // start-bulk-replace-one

source/includes/write/client-bulk-write.scala

@@ -0,0 +1,106 @@
+package quickstart
+
+import org.mongodb.scala._
+import org.mongodb.scala.model.Filters._
+import com.mongodb.client.model.bulk.{ClientBulkWriteOptions, ClientBulkWriteResult, ClientNamespacedWriteModel}
+import org.mongodb.scala.model.Updates._
+
+object Main {
+
+  def main(args: Array[String]): Unit = {
+    val mongoClient = MongoClient("<connection string>")
+
+    {
+      // start-insert-models
+      val personToInsert = ClientNamespacedWriteModel.insertOne(
+        MongoNamespace("db", "people"),
+        Document("name" -> "Julia Smith")
+      )
+
+      val thingToInsert = ClientNamespacedWriteModel.insertOne(
+        MongoNamespace("db", "things"),
+        Document("object" -> "washing machine")
+      );
+      // end-insert-models
+    }
+    {
+      // start-update-models
+      val personUpdate = ClientNamespacedWriteModel.updateOne(
+        MongoNamespace("db", "people"),
+        equal("name", "Freya Polk"),
+        inc("age", 1)
+      )
+
+      val thingUpdate = ClientNamespacedWriteModel.updateMany(
+        MongoNamespace("db", "things"),
+        equal("category", "electronic"),
+        set("manufacturer", "Premium Technologies")
+      )
+      // end-update-models
+    }
+
+    {
+      // start-replace-models
+      val personReplacement = ClientNamespacedWriteModel.replaceOne(
+        MongoNamespace("db", "people"),
+        equal("_id", 1),
+        Document("name" -> "Frederic Hilbert")
+      )
+
+      val thingReplacement = ClientNamespacedWriteModel.replaceOne(
+        MongoNamespace("db", "things"),
+        equal("_id", 1),
+        Document("object" -> "potato")
+      )
+      // end-replace-models
+    }
+
+    {
+      // start-perform
+      val peopleNamespace = MongoNamespace("db", "people")
+      val thingsNamespace = MongoNamespace("db", "things")
+
+      val writeModels = List(
+        ClientNamespacedWriteModel.insertOne(
+          peopleNamespace,
+          Document("name" -> "Corey Kopper")
+        ),
+        ClientNamespacedWriteModel.replaceOne(
+          thingsNamespace,
+          equal("_id", 1),
+          Document("object" -> "potato")
+        )
+      )
+
+      val observable = mongoClient.bulkWrite(writeModels)
+
+      observable.subscribe(
+        (result: ClientBulkWriteResult) => println(result.toString),
+        (error: Throwable) => println(s"Error: ${error.getMessage}"),
+        () => println("Completed")
+      )
+      // end-perform
+    }
+    {
+      // start-options
+      val namespace = MongoNamespace("db", "people")
+
+      val options = ClientBulkWriteOptions.clientBulkWriteOptions().ordered(false)
+
+      val writeModels = List(
+        ClientNamespacedWriteModel.insertOne(namespace, Document("_id" -> 1, "name" -> "Rudra Suraj")),
+        // Causes a duplicate key error
+        ClientNamespacedWriteModel.insertOne(namespace, Document("_id" -> 1, "name" -> "Mario Bianchi")),
+        ClientNamespacedWriteModel.insertOne(namespace, Document("name" -> "Wendy Zhang"))
+      )
+
+      val observable = mongoClient.bulkWrite(writeModels, options)
+      // end-options
+    }
+
+    Thread.sleep(1000)
+    mongoClient.close()
+
+  }
+
+}

source/whats-new.txt

@@ -20,12 +20,26 @@ What's New
 Learn about new features, improvements, and fixes introduced in the
 following versions of the {+driver-long+}:
 
+* :ref:`Version 5.4 <scala-version-5.4>`
 * :ref:`Version 5.3 <scala-version-5.3>`
 * :ref:`Version 5.2 <scala-version-5.2>`
 * :ref:`Version 5.1.3 <scala-version-5.1.3>`
 * :ref:`Version 5.1.1 <scala-version-5.1.1>`
 * :ref:`Version 5.1 <scala-version-5.1>`
 
+.. _scala-version-5.4:
+
+What's New in 5.4
+-----------------
+
+The 5.4 driver release includes the following changes, fixes,
+and features:
+
+- Implements a *client* bulk write API that allows you to perform write
+  operations on multiple databases and collections in the same call. To learn
+  more about this feature, see the :ref:`scala-client-bulk-write`
+  section of the Bulk Write Operations guide.
+
 .. _scala-version-5.3:
 
 What's New in 5.3