DOCSP-34191 and DOCSP-34193 code examples (#151)

Author: rustagir

examples/src/test/kotlin/InsertTest.kt

@@ -1,5 +1,3 @@
-
-
 import com.mongodb.MongoBulkWriteException
 import com.mongodb.kotlin.client.coroutine.MongoClient
 import config.getConfig

source/examples/ServerManualCodeExamples.kt

@@ -0,0 +1,162 @@
+import com.mongodb.MongoException
+import com.mongodb.client.model.Filters.*
+import com.mongodb.kotlin.client.coroutine.MongoClient
+import kotlinx.coroutines.flow.firstOrNull
+import kotlinx.coroutines.runBlocking
+import org.bson.Document
+
+fun main() = runBlocking {
+    val uri = "<connection string>"
+    val mongoClient = MongoClient.create(uri)
+    val database = mongoClient.getDatabase("db")
+    val collection = database.getCollection<Document>("inventory")
+
+    // Start Example 1
+    val result = collection.insertOne(
+        Document("item", "canvas")
+            .append("qty", 100)
+            .append("tags", listOf("cotton"))
+            .append("size", Document("h", 28)
+                .append("w", 35.5)
+                .append("uom", "cm")
+            )
+    )
+    // End Example 1
+
+    println("Success! Inserted document: " + result.insertedId)
+
+    // Start Example 2
+    val flowInsertOne = collection.withDocumentClass<Document>()
+        .find(eq("item", "canvas"))
+        .firstOrNull()
+    // End Example 2
+
+    if (flowInsertOne == null) {
+        println("No results found.");
+    } else {
+        println(flowInsertOne)
+    }
+
+    collection.deleteMany(empty())
+
+    // Start Example 3
+    val results = collection.insertMany(
+        listOf(
+            Document("item", "journal")
+                .append("qty", 25)
+                .append("tags", listOf("blank", "red"))
+                .append("size", Document("h", 14)
+                    .append("w", 21)
+                    .append("uom", "cm")
+                ),
+            Document("item", "mat")
+                .append("qty", 25)
+                .append("tags", listOf("gray"))
+                .append("size", Document("h", 27.9)
+                    .append("w", 35.5)
+                    .append("uom", "cm")
+                ),
+            Document("item", "mousepad")
+                .append("qty", 25)
+                .append("tags", listOf("gel", "blue"))
+                .append("size", Document("h", 19)
+                    .append("w", 22.85)
+                    .append("uom", "cm")
+                )
+        )
+    )
+    // End Example 3
+
+    println("Success! Inserted documents: " + results.insertedIds)
+
+    // Start Example 7
+    val flowInsertMany = collection.withDocumentClass<Document>()
+        .find(empty())
+    // End Example 7
+
+    flowInsertMany.collect { println(it) }
+    collection.deleteMany(empty())
+
+    // Start Example 6
+    collection.insertMany(
+        listOf(
+            Document("item", "journal")
+                .append("qty", 25)
+                .append("size", Document("h", 14)
+                    .append("w", 21)
+                    .append("uom", "cm")
+                )
+                .append("status", "A"),
+            Document("item", "notebook")
+                .append("qty", 50)
+                .append("size", Document("h", 8.5)
+                    .append("w", 11)
+                    .append("uom", "in")
+                )
+                .append("status", "A"),
+            Document("item", "paper")
+                .append("qty", 100)
+                .append("size", Document("h", 8.5)
+                    .append("w", 11)
+                    .append("uom", "in")
+                )
+                .append("status", "D"),
+            Document("item", "planner")
+                .append("qty", 75)
+                .append("size", Document("h", 22.85)
+                    .append("w", 30)
+                    .append("uom", "cm")
+                )
+                .append("status", "D"),
+            Document("item", "postcard")
+                .append("qty", 45)
+                .append("size", Document("h", 10)
+                    .append("w", 15.25)
+                    .append("uom", "cm")
+                )
+                .append("status", "A"),
+        )
+    )
+    // End Example 6
+
+    // Start Example 9
+    val flowFindEquality = collection.withDocumentClass<Document>()
+        .find(eq("status", "D"))
+    // End Example 9
+
+    flowFindEquality.collect { println(it) }
+
+    // Start Example 10
+    val flowFindOperator = collection.withDocumentClass<Document>()
+        .find(`in`("status", "A", "D"))
+    // End Example 10
+
+    flowFindOperator.collect { println(it) }
+
+    // Start Example 11
+    val flowFindAND = collection.withDocumentClass<Document>()
+        .find(and(eq("status", "A"), lt("qty", 30)))
+    // End Example 11
+
+    flowFindAND.collect { println(it) }
+
+    // Start Example 12
+    val flowFindOR = collection.withDocumentClass<Document>()
+        .find(or(eq("status", "A"), lt("qty", 30)))
+    // End Example 12
+
+    flowFindOR.collect { println(it) }
+
+    // Start Example 13
+    val flowFindANDOR = collection.withDocumentClass<Document>()
+        .find(
+            and(eq("status", "A"),
+                or(lt("qty", 30), regex("item", "^p")))
+        )
+    // End Example 13
+
+    flowFindANDOR.collect { println(it) }
+    collection.deleteMany(empty())
+
+    mongoClient.close()
+}