From 749c4816ac1845fb652d1ddbd47e4e43b4b8c151 Mon Sep 17 00:00:00 2001
From: rustagir <rea.rustagi@mongodb.com>
Date: Tue, 6 Feb 2024 15:33:03 -0500
Subject: [PATCH] DOCSP-34191 and DOCSP-34193 code examples

---
 examples/src/test/kotlin/InsertTest.kt      |   2 -
 source/examples/ServerManualCodeExamples.kt | 162 ++++++++++++++++++++
 2 files changed, 162 insertions(+), 2 deletions(-)
 create mode 100644 source/examples/ServerManualCodeExamples.kt

diff --git a/examples/src/test/kotlin/InsertTest.kt b/examples/src/test/kotlin/InsertTest.kt
index 77761244..221db750 100644
--- a/examples/src/test/kotlin/InsertTest.kt
+++ b/examples/src/test/kotlin/InsertTest.kt
@@ -1,5 +1,3 @@
-
-
 import com.mongodb.MongoBulkWriteException
 import com.mongodb.kotlin.client.coroutine.MongoClient
 import config.getConfig
diff --git a/source/examples/ServerManualCodeExamples.kt b/source/examples/ServerManualCodeExamples.kt
new file mode 100644
index 00000000..8802341d
--- /dev/null
+++ b/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()
+}