wip

Author: rustagir

examples/src/test/kotlin/ClientBulkTest.kt

@@ -1,7 +1,6 @@
 import com.mongodb.MongoNamespace
 import com.mongodb.client.model.Filters
 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.coroutine.MongoClient
 import config.getConfig
@@ -77,8 +76,7 @@ internal class ClientBulkTest {
             )
         )
 
-        val clientBulkResult = client
-            .bulkWrite(docsToInsert)
+        val clientBulkResult = client.bulkWrite(docsToInsert)
         // :snippet-end:
 
         // Junit test for the above code
@@ -93,22 +91,21 @@ internal class ClientBulkTest {
 
         docsReplacements.add(ClientNamespacedWriteModel
             .replaceOne(
-                MongoNamespace("sample_restaurants", "restaurants"),
+                MongoNamespace("sample_db", "people"),
                 Filters.eq(Person::id.name, 1),
                 Person(1, "Frederic Hilbert")
             )
         )
 
         docsReplacements.add(ClientNamespacedWriteModel
             .replaceOne(
-                MongoNamespace("sample_mflix", "movies"),
+                MongoNamespace("sample_db", "objects"),
                 Filters.eq(Object::id.name, 1),
                 Object(1, "ironing board")
             )
         )
 
-        val clientBulkResult = client
-            .bulkWrite(docsReplacements)
+        val clientBulkResult = client.bulkWrite(docsReplacements)
         // :snippet-end:
 
         // Junit test for the above code
@@ -140,7 +137,7 @@ internal class ClientBulkTest {
             )
         )
 
-        val result: ClientBulkWriteResult = client.bulkWrite(bulkOperations, options)
+        val result = client.bulkWrite(bulkOperations, options)
         // :snippet-end:
 
         // Junit test for the above code

source/examples/generated/ClientBulkTest.snippet.insert-models.kt

@@ -14,5 +14,4 @@ docsToInsert.add(ClientNamespacedWriteModel
     )
 )
 
-val clientBulkResult = client
-    .bulkWrite(docsToInsert)
+val clientBulkResult = client.bulkWrite(docsToInsert)

source/examples/generated/ClientBulkTest.snippet.options.kt

@@ -20,4 +20,4 @@ val bulkOperations = listOf(
     )
 )
 
-val result: ClientBulkWriteResult = client.bulkWrite(bulkOperations, options)
+val result = client.bulkWrite(bulkOperations, options)

source/examples/generated/ClientBulkTest.snippet.replace-models.kt

@@ -2,19 +2,18 @@ val docsReplacements = mutableListOf<ClientNamespacedWriteModel>()
 
 docsReplacements.add(ClientNamespacedWriteModel
     .replaceOne(
-        MongoNamespace("sample_restaurants", "restaurants"),
+        MongoNamespace("sample_db", "people"),
         Filters.eq(Person::id.name, 1),
         Person(1, "Frederic Hilbert")
     )
 )
 
 docsReplacements.add(ClientNamespacedWriteModel
     .replaceOne(
-        MongoNamespace("sample_mflix", "movies"),
+        MongoNamespace("sample_db", "objects"),
         Filters.eq(Object::id.name, 1),
         Object(1, "ironing board")
     )
 )
 
-val clientBulkResult = client
-    .bulkWrite(docsReplacements)
+val clientBulkResult = client.bulkWrite(docsReplacements)

source/fundamentals/crud/write-operations/bulk.txt

@@ -505,6 +505,7 @@ insert multiple documents.
 
 .. literalinclude:: /examples/generated/ClientBulkTest.snippet.options.kt
    :language: kotlin
+   :emphasize-lines: 3-5
 
 Even though the write operation inserting a document with a duplicate key results
 in an error, the other operations are executed because the write operation is