Add no mapper for find()

Author: clun

docs/samples/sdk-quickstart-astra/src/main/java/com/datastax/tutorial/DocumentApiRaw.java

@@ -0,0 +1,52 @@
+package com.datastax.tutorial;
+
+import com.datastax.astra.sdk.AstraClient;
+import com.datastax.stargate.sdk.core.Page;
+import com.datastax.stargate.sdk.doc.CollectionClient;
+import com.datastax.stargate.sdk.doc.Document;
+import com.datastax.stargate.sdk.doc.DocumentMapper;
+import com.datastax.stargate.sdk.doc.domain.PageableQuery;
+import com.datastax.stargate.sdk.utils.JsonUtils;
+
+
+public class DocumentApiRaw {
+    
+    public static final String ASTRA_DB_TOKEN    = "AstraCS:gdZaqzmFZszaBTOlLgeecuPs:edd25600df1c01506f5388340f138f277cece2c93cb70f4b5fa386490daa5d44";
+    public static final String ASTRA_DB_ID       = "3ed83de7-d97f-4fb6-bf9f-82e9f7eafa23";
+    public static final String ASTRA_DB_REGION   = "eu-central-1";
+    public static final String ASTRA_DB_KEYSPACE = "feeds_reader";
+    
+    public static void main(String[] args) {
+       
+        try (AstraClient astraClient = AstraClient.builder()
+                .withToken(ASTRA_DB_TOKEN)
+                .withDatabaseId(ASTRA_DB_ID)
+                .withDatabaseRegion(ASTRA_DB_REGION)
+                .withCqlKeyspace(ASTRA_DB_KEYSPACE)
+                .build()) {
+            
+            CollectionClient cp = astraClient.apiStargateDocument()
+                    .namespace(ASTRA_DB_KEYSPACE)
+                    .collection("person");
+            
+            PageableQuery query = PageableQuery.builder()
+                    .selectAll()
+                    .where("firstName").isEqualsTo("John")
+                    .and("lastName").isEqualsTo("Connor")
+                    .pageSize(3)
+                    .build();
+            
+            Page<Document<String>> page1 = cp.findPage(query);
+            
+            if (page1.getPageState().isPresent()) {
+                query.setPageState(page1.getPageState().get());
+                Page<Document<String>> page2 = cp.findPage(query);
+            }
+            
+            
+            
+        }
+    }
+   
+    
+}

stargate-sdk/src/main/java/com/datastax/stargate/sdk/doc/DocumentClient.java

@@ -95,6 +95,36 @@ public <DOC> String update(DOC doc) {
         return marshallDocumentId(res.getBody());
     }
 
+    /**
+     * Get a document by id.
+     *
+     * @return
+     *      the json payload if document exists.
+     */
+    public Optional<String> find() {
+        ApiResponseHttp res = stargateHttpClient.GET(documentResource, "?raw=true");
+        if (HttpURLConnection.HTTP_OK == res.getCode()) {
+            return Optional.of(res.getBody());
+         }
+         return Optional.empty();
+    }
+    
+    /**
+     * Get a document by id.
+     *
+     * @param <DOC>
+     *      nea
+     * @param docm 
+     */
+    public <DOC> Optional<DOC> find(DocumentMapper<DOC> docm) {
+        Assert.notNull(docm, "documentMapper");
+        Optional<String> f = find();
+        if (f.isPresent()) {
+            return f.map(docm::map);
+        }
+        return Optional.empty();
+    }
+    
     /**
      * Get a document by {document-id}. https://docs.datastax.com/en/astra/docs/_attachments/docv2.html#operation/getDocById
      *
@@ -104,12 +134,9 @@ public <DOC> String update(DOC doc) {
      */
     public <DOC> Optional<DOC> find(Class<DOC> clazz) {
         Assert.notNull(clazz, "className");
-        ApiResponseHttp res = stargateHttpClient.GET(documentResource, "?raw=true");
-        if (HttpURLConnection.HTTP_OK == res.getCode()) {
-           return Optional.of(marshallDocument(res.getBody(), clazz));
-        }
-        if (HttpURLConnection.HTTP_NOT_FOUND == res.getCode()) {
-            return Optional.empty();
+        Optional<String> f = find();
+        if (f.isPresent()) {
+            return f.map(b -> marshallDocument(b, clazz));
         }
         return Optional.empty();
     }

stargate-sdk/src/main/java/com/datastax/stargate/sdk/doc/test/ApiDocumentDocumentTest.java

@@ -401,6 +401,29 @@ public void n_execute_function() {
         Assertions.assertTrue(jsonOutput.contains("red"));
     }
 
+    @Test
+    @Order(15)
+    @DisplayName("15-Find a doc document")
+    public void o_should_find_document() throws InterruptedException {
+        LOGGER.info("o_should_find_document");
+        // Given
+        Assertions.assertTrue(personClient.exist());
+        // When
+        personClient.document("doc2Retrieve")
+                    .upsert(new Person("loulou", "looulou", 20, new Address("Paris", 75000)));
+        Thread.sleep(2000);
+        // Then
+        Assertions.assertTrue(personClient.document("doc2Retrieve").exist());
+        Assertions.assertTrue(personClient.document("doc2Retrieve").find().isPresent());
+        Assertions.assertTrue(personClient.document("doc2Retrieve").find(Person.class).isPresent());
+        Assertions.assertTrue(personClient.document("doc2Retrieve").find(
+           new DocumentMapper<Person>() {
+             public Person map(String record) { return new Person(); }
+        }).isPresent());
+        LOGGER.info("Documents Founds.");
+    }
+    
+    
     // ============================
     //           Custom Beans
     // ============================