eg output

Author: rachel-mack

source/aggregation.txt

@@ -141,17 +141,21 @@ manual.
 
    .. replacement:: atlas-query-operators-example
 
-    .. code-block:: java
-
-        Bson searchStageFilters = Aggregates.search(
-            SearchOperator.compound()
-                .filter(
-                    List.of(
-                        SearchOperator.text(fieldPath("genres"), "Drama"),
-                        SearchOperator.phrase(fieldPath("cast"), "sylvester stallone"),
-                        SearchOperator.numberRange(fieldPath("year")).gtLt(1980, 1989),
-                        SearchOperator.wildcard(fieldPath("title"),"Rocky *")
-                        )));
+      .. io-code-block::
+
+         .. input:: source/includes/aggregation/atlas-search-examples.java
+            :language: java
+            :start-after: // begin atlasHelperMethods
+            :end-before: // end atlasHelperMethods
+            :language: java
+            :dedent:
+
+         .. output::
+            :language: console
+            :visible: false
+
+            {"_id": {"$oid": "573a1397f29313caabce86db"}, "genres": ["Drama", "Sport"], "cast": ["Sylvester Stallone", "Talia Shire", "Burt Young", "Carl Weathers"], "title": "Rocky III", "year": 1982}
+            {"_id": {"$oid": "573a1398f29313caabce9af0"}, "genres": ["Drama", "Sport"], "cast": ["Sylvester Stallone", "Talia Shire", "Burt Young", "Carl Weathers"], "title": "Rocky IV", "year": 1985}
 
    .. replacement:: searchoperator-interface-api-docs
 

source/includes/aggregation/atlas-search-examples.java

@@ -0,0 +1,59 @@
+package org.example;
+import com.mongodb.*;
+import com.mongodb.client.model.Projections;
+import com.mongodb.reactivestreams.client.*;
+import org.bson.Document;
+
+import reactor.core.publisher.Mono;
+import java.util.List;
+import org.bson.conversions.Bson;
+
+import com.mongodb.client.model.Aggregates;
+import com.mongodb.client.model.search.SearchOperator;
+import static com.mongodb.client.model.search.SearchPath.fieldPath;
+import org.reactivestreams.Publisher;
+
+public class Main {
+    public static void main(String[] args) {
+        // Replace the placeholder with your Atlas connection string
+        String uri = "mongodb+srv://admin:[email protected]/?retryWrites=true&w=majority&appName=Cluster0";
+
+        // Construct a ServerApi instance using the ServerApi.builder() method
+        ServerApi serverApi = ServerApi.builder()
+                .version(ServerApiVersion.V1)
+                .build();
+
+        MongoClientSettings settings = MongoClientSettings.builder()
+                .applyConnectionString(new ConnectionString(uri))
+                .serverApi(serverApi)
+                .build();
+
+        // Create a new client and connect to the server
+        try (MongoClient mongoClient = MongoClients.create(settings)) {
+            MongoDatabase database = mongoClient.getDatabase("sample_mflix");
+            MongoCollection<Document> movies = database.getCollection("movies");
+
+            // start atlasHelperMethods
+            Bson searchStageFilters = Aggregates.search(
+                    SearchOperator.compound()
+                            .filter(
+                                    List.of(
+                                            SearchOperator.text(fieldPath("genres"), "Drama"),
+                                            SearchOperator.phrase(fieldPath("cast"), "sylvester stallone"),
+                                            SearchOperator.numberRange(fieldPath("year")).gtLt(1980, 1989),
+                                            SearchOperator.wildcard(fieldPath("title"),"Rocky *")
+                                    )));
+
+            Bson projection = Aggregates.project(Projections.fields(
+                    Projections.include("title", "year", "genres", "cast")
+            ));
+
+            List<Bson> aggregateStages = List.of(searchStageFilters,projection);
+
+            Publisher<Document> publisher = movies.aggregate(aggregateStages);
+            publisher.subscribe(new SubscriberHelpers.PrintDocumentSubscriber());
+            Mono.from(publisher).block();
+            // end atlasHelperMethods
+        }
+    }
+}