DOCSP-46389: client bw (#60)

* DOCSP-46389: client bw

* wip

(cherry picked from commit 88dc621)

Author: rustagir

source/includes/write/bulk.kt

@@ -2,13 +2,18 @@ import com.mongodb.client.model.*
 import com.mongodb.client.model.Filters.*
 import com.mongodb.kotlin.client.MongoClient
 
-// start-data-class
+// start-data-classes
 data class Restaurant(
     val name: String,
     val borough: String,
     val cuisine: String
 )
-// end-data-class
+
+data class Movie(
+    val title: String,
+    val year: Int
+)
+// end-data-classes
 
 fun main() {
     val uri = "<connection string>"

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

@@ -0,0 +1,109 @@
+import com.mongodb.MongoNamespace
+import com.mongodb.client.model.Filters.eq
+import com.mongodb.client.model.bulk.ClientBulkWriteOptions
+import com.mongodb.client.model.bulk.ClientBulkWriteResult
+import com.mongodb.client.model.bulk.ClientNamespacedWriteModel
+import com.mongodb.kotlin.client.MongoClient
+import org.bson.Document
+
+
+// start-data-classes
+data class Restaurant(
+    val name: String,
+    val borough: String,
+    val cuisine: String,
+)
+
+data class Movie(
+    val title: String,
+    val year: Int
+)
+// end-data-classes
+
+fun main() {
+    val uri = "<connection string>"
+
+    val mongoClient = MongoClient.create(uri)
+
+    // start-insert-models
+    val restaurantToInsert = ClientNamespacedWriteModel
+        .insertOne(
+            MongoNamespace("sample_restaurants", "restaurants"),
+            Restaurant("Blue Moon Grill", "Brooklyn", "American")
+        )
+
+    val movieToInsert = ClientNamespacedWriteModel
+        .insertOne(
+            MongoNamespace("sample_mflix", "movies"),
+            Movie("Silly Days", 2022)
+        )
+    // end-insert-models
+
+    // start-replace-models
+    val restaurantReplacement = ClientNamespacedWriteModel
+        .replaceOne(
+            MongoNamespace("sample_restaurants", "restaurants"),
+            Filters.eq("_id", 1),
+            Restaurant("Smith Town Diner", "Brooklyn", "American")
+        )
+
+    val movieReplacement = ClientNamespacedWriteModel
+        .replaceOne(
+            MongoNamespace("sample_mflix", "movies"),
+            Filters.eq("_id", 1),
+            Movie("Loving Sylvie", 1999)
+        )
+    // end-replace-models
+
+    // start-perform
+    val restaurantNamespace = MongoNamespace("sample_restaurants", "restaurants")
+    val movieNamespace = MongoNamespace("sample_mflix", "movies")
+
+    val bulkOperations = listOf(
+        ClientNamespacedWriteModel
+            .insertOne(
+                restaurantNamespace,
+                Restaurant("Drea's", "Brooklyn", "Mexican")
+            ),
+        ClientNamespacedWriteModel
+            .replaceOne(
+                movieNamespace,
+                Filters.eq("_id", 1),
+                Movie("Underneath It All", 2002)
+            )
+    )
+
+    val clientBulkResult = mongoClient
+        .bulkWrite(bulkOperations)
+
+    println(clientBulkResult.toString())
+    // end-perform
+
+    // start-options
+    val namespace = MongoNamespace("sample_restaurants", "restaurants")
+
+    val options = ClientBulkWriteOptions
+        .clientBulkWriteOptions()
+        .ordered(false)
+
+    val bulkOps = listOf(
+        ClientNamespacedWriteModel.insertOne(
+            namespace,
+            Document("_id", 1).append("name", "Freezyland")
+        ),
+        // Causes a duplicate key error
+        ClientNamespacedWriteModel.insertOne(
+            namespace,
+            Document("_id", 1).append("name", "Coffee Stand No. 1")
+        ),
+        ClientNamespacedWriteModel.insertOne<Any>(
+            namespace,
+            Document("name", "Kelly's Krepes")
+        )
+    )
+
+    val result= mongoClient
+        .bulkWrite(bulkOps, options)
+    // end-options
+}
+

source/whats-new.txt

@@ -42,6 +42,11 @@ improvements, and fixes:
       :ref:`kotlin-sync-write-replace`, and
       :ref:`kotlin-sync-bulk-write` guides
 
+- 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:`kotlin-sync-client-bulk-write`
+  section of the Bulk Write Operations guide.
+
 .. _kotlin-sync-version-5.2:
 
 What's New in 5.2