NoSQL - Helidon 4 - First version / Java QueryIterable

option/src/app/java_helidon/microprofile-config.properties.j2.tmpl

@@ -22,3 +22,18 @@ javax.sql.DataSource.ds1.dataSource.user=##DB_USER##
 javax.sql.DataSource.ds1.dataSource.password=##DB_PASSWORD##
 {%- endif %}
 
+{%- if db_family == "nosql" %}
+# Oracle NoSQL Connection
+jnosql.keyvalue.database=dept
+jnosql.document.database=dept
+jnosql.oracle.nosql.table.read.limit=10
+jnosql.oracle.nosql.table.write.limit=10
+jnosql.oracle.nosql.table.storage.gb=1
+jnosql.oracle.nosql.host=${TF_VAR_nosql_endpoint}
+jnosql.oracle.nosql.compartment=${TF_VAR_compartment_ocid}
+{%- if deploy_type in ["compute", "kubernetes", "instance_pool"] %}
+jnosql.oracle.nosql.deployment=CLOUD_INSTANCE_PRINCIPAL
+{%- else %}
+jnosql.oracle.nosql.deployment=CLOUD_RESOURCE_PRINCIPAL
+{%- endif %}  
+{%- endif %}

option/src/app/java_helidon4_nosql/src/main/java/me/opc/mp/database/Dept.java

@@ -0,0 +1,15 @@
+package me.opc.mp.database;
+
+import jakarta.json.bind.annotation.JsonbVisibility;
+import jakarta.nosql.*;
+
+@Entity
+@JsonbVisibility(FieldAccessStrategy.class)
+public class Dept {
+    @Id
+    private int deptno;
+    @Column
+    private String dname;
+    @Column
+    private String loc;
+}

option/src/app/java_helidon4_nosql/src/main/java/me/opc/mp/database/DeptRepository.java

@@ -0,0 +1,9 @@
+package me.opc.mp.database;
+
+import jakarta.data.repository.Query;
+import jakarta.data.repository.Repository;
+import org.eclipse.jnosql.databases.oracle.mapping.OracleNoSQLRepository;
+
+@Repository
+public interface DeptRepository extends OracleNoSQLRepository<Dept, Integer> {
+}

option/src/app/java_helidon4_nosql/src/main/java/me/opc/mp/database/DeptResource.j2.java

@@ -0,0 +1,31 @@
+{% import "java.j2_macro" as m with context %}
+package me.opc.mp.database;
+
+import jakarta.persistence.*;
+import jakarta.ws.rs.*;
+import jakarta.ws.rs.core.MediaType;
+import jakarta.inject.*;
+{{ m.import() }}
+
+/**
+ * Dept Table 
+ */
+@Path("/")
+public class DeptResource {
+    @Inject
+    private DeptRepository deptRepository;
+
+    @GET
+    @Path("dept")
+    @Produces(MediaType.APPLICATION_JSON)
+    public List<Dept> getDept() throws Exception {
+        return deptRepository.findAll().toList();
+    }
+
+    @GET
+    @Path("info")
+    @Produces(MediaType.TEXT_PLAIN)
+    public String getInfo() {
+        return "Java - Helidon - {{ dbName }}";
+    }
+}

option/src/app/java_helidon4_nosql/src/main/java/me/opc/mp/database/FieldAccessStrategy.java

@@ -0,0 +1,18 @@
+package me.opc.mp.database;
+
+import jakarta.json.bind.config.PropertyVisibilityStrategy;
+
+import java.lang.reflect.Field;
+import java.lang.reflect.Method;
+
+public class FieldAccessStrategy implements PropertyVisibilityStrategy {
+    @Override
+    public boolean isVisible(Field field) {
+        return true;
+    }
+
+    @Override
+    public boolean isVisible(Method method) {
+        return true;
+    }
+}

option/src/app/java_helidon4_nosql/src/main/resources/application.yaml

@@ -0,0 +1,9 @@
+# Oracle NoSQL Configuration
+jnosql:
+  keyvalue:
+    database: beers
+  document:
+    database: beers
+  oracle:
+    nosql:
+      host: http://localhost:8080

option/src/j2_macro/java.j2_macro

@@ -224,12 +224,10 @@ import javax.json.*;
 {%- endmacro -%}   
 
 {% macro nosql() -%}    
+        // See https://github.com/oracle/nosql-examples/blob/master/examples-nosql-java-sdk/sqlexamples/QueryData.java
         QueryRequest queryRequest = new QueryRequest().setStatement("SELECT deptno, dname, loc FROM dept");
-        QueryResult queryResult = handle.query(queryRequest);
-        do {
-            List<MapValue> results = queryResult.getResults();
-            for (MapValue row : results) {
-                rows.add( new Dept( row.get("deptno").asInteger().getValue(), row.get("dname").asString().getValue(), row.get("loc").asString().getValue() ) );
-            }
-        } while (!queryRequest.isDone());
+        QueryIterableResult results = handle.queryIterable(queryRequest);
+        for (MapValue row : results) {
+           rows.add( new Dept( row.get("deptno").asInteger().getValue(), row.get("dname").asString().getValue(), row.get("loc").asString().getValue() ) );
+        }        
 {%- endmacro -%}