add query examples

Author: rustagir

source/examples/atlas-examples/ComplexQuery.kt

@@ -0,0 +1,52 @@
+import com.mongodb.client.model.Aggregates.limit
+import com.mongodb.client.model.Aggregates.project
+import com.mongodb.client.model.Filters.eq
+import com.mongodb.client.model.Projections.*
+import com.mongodb.kotlin.client.coroutine.MongoClient
+import kotlinx.coroutines.runBlocking
+import org.bson.Document
+
+fun main() {
+    val uri = "<connection string>"
+    val mongoClient = MongoClient.create(uri)
+    val database = mongoClient.getDatabase("sample_mflix")
+    val collection = database.getCollection<Document>("movies")
+
+    runBlocking {
+        val agg = Document(
+            "must", listOf(
+                Document("text", Document("query", listOf("Hawaii", "Alaska"))
+                    .append("path", "plot")),
+                Document(
+                    "regex",
+                    Document("query", "([0-9]{4})")
+                        .append("path", "plot")
+                        .append("allowAnalyzedField", true)
+                )
+            )
+        )
+            .append(
+                "mustNot", listOf(
+                    Document("text", Document("query", listOf("Comedy", "Romance"))
+                        .append("path", "genres")),
+                    Document("text", Document("query", listOf("Beach", "Snow"))
+                        .append("path", "title"))
+                )
+            )
+
+        val resultsFlow = collection.aggregate<Document>(
+            listOf(
+                eq("\$search", eq("compound", agg)),
+                project(fields(
+                    excludeId(),
+                    include("title", "plot", "genres")
+                ))
+            )
+        )
+
+        resultsFlow.collect { println(it) }
+    }
+
+    mongoClient.close()
+}
+

source/examples/atlas-examples/SimpleQuery.kt

@@ -0,0 +1,31 @@
+import com.mongodb.client.model.Aggregates.limit
+import com.mongodb.client.model.Aggregates.project
+import com.mongodb.client.model.Filters.eq
+import com.mongodb.client.model.Projections.*
+import com.mongodb.kotlin.client.coroutine.MongoClient
+import kotlinx.coroutines.runBlocking
+import org.bson.Document
+
+fun main() {
+    val uri = "<connection string>"
+    val mongoClient = MongoClient.create(uri)
+    val database = mongoClient.getDatabase("sample_mflix")
+    val collection = database.getCollection<Document>("movies")
+
+    runBlocking {
+        val agg = Document("query", "baseball").append("path","plot")
+
+        val resultsFlow = collection.aggregate<Document>(
+            listOf(
+                eq("\$search", eq("text", agg)),
+                limit(5),
+                project(fields(excludeId(), include("title", "plot")))
+            )
+        )
+
+        resultsFlow.collect { println(it) }
+    }
+
+    mongoClient.close()
+}
+