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 -%}