Merge pull request #2119 from oracle-devrel/witold-swierzy-soda-java

Witold swierzy soda java

Author: JesusGitHubOracle

data-platform/autonomous-database/autonomous-json/SODAJavaDemo/RERADME.md

@@ -0,0 +1,11 @@
+This repository contains simple SODA Java console application
+This application DOES NOT USE standard Oracle JDBC driver.
+Instead of this it uses SODA JDBC driver to perform SODA operations on document data structures (collections, documents) in an Oracle Database
+
+# License
+
+Copyright (c) 2024 Oracle and/or its affiliates.
+
+Licensed under the Universal Permissive License (UPL), Version 1.0.
+
+See [LICENSE](https://github.com/oracle-devrel/technology-engineering/blob/main/LICENSE) for more details.

data-platform/autonomous-database/autonomous-json/SODAJavaDemo/pom.xml

@@ -0,0 +1,29 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>com.oracle</groupId>
+    <artifactId>SODAJavaDemo</artifactId>
+    <version>1.0-SNAPSHOT</version>
+
+    <properties>
+        <maven.compiler.source>21</maven.compiler.source>
+        <maven.compiler.target>21</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+    <dependencies>
+        <!-- https://mvnrepository.com/artifact/com.oracle.database.soda/orajsoda -->
+        <dependency>
+            <groupId>com.oracle.database.soda</groupId>
+            <artifactId>orajsoda</artifactId>
+            <version>1.1.29</version>
+        </dependency>
+        <dependency>
+            <groupId>com.oracle.database.security</groupId>
+            <artifactId>oraclepki</artifactId>
+            <version>23.9.0.25.07</version>
+        </dependency>
+    </dependencies>
+</project>

data-platform/autonomous-database/autonomous-json/SODAJavaDemo/src/main/java/com/oracle/Main.java

@@ -0,0 +1,90 @@
+package com.oracle;
+
+import oracle.soda.*;
+import oracle.soda.rdbms.OracleRDBMSClient;
+import oracle.jdbc.datasource.impl.OracleDataSource;
+import java.util.List;
+
+public class Main {
+    private static OracleDatabase sodaDb;
+    private static OracleDatabaseAdmin sodaDbAdmin;
+    private static OracleCollection sodaSampleCollection;
+
+    public static void prepareSODAConnection() throws Exception {
+        OracleDataSource ods = new OracleDataSource();
+        ods.setURL(System.getenv("DB_URL"));
+        ods.setUser(System.getenv("DB_USERNAME"));
+        ods.setPassword(System.getenv("DB_PASSWORD"));
+        OracleRDBMSClient client = new OracleRDBMSClient();
+        sodaDb = client.getDatabase(ods.getConnection());
+        sodaDbAdmin = sodaDb.admin();
+    }
+
+    public static void listExistingCollections() throws Exception {
+        List<String> collections = sodaDbAdmin.getCollectionNames();
+        System.out.println("Listing existing collections : ");
+
+        for (String name: collections) {
+            System.out.println("Collection : "+name);
+        }
+    }
+
+    public static void resetSampleCollection() {
+        try {
+            sodaSampleCollection = sodaDb.openCollection("sodaSampleCollection");
+            sodaSampleCollection.admin().drop();
+            System.out.println("sodaSampleCollection dropped succesfully");
+        }
+        catch (Exception e) {
+            System.out.println("sodaSampleCollection has not been created yet. Dropping was unneeded.");
+        }
+
+        try {
+            sodaSampleCollection = sodaDbAdmin.createCollection("sodaSampleCollection");
+            System.out.println("sodaSampleCollection created succesfully");
+        }
+        catch (Exception e) {
+            e.printStackTrace();
+        }
+    }
+
+    public static void insertSampleData() throws Exception {
+        String docs;
+        OracleDocument doc;
+        for ( int i = 0; i < 100; i++ ) {
+            docs = "{\"name\": \"SampleDoc"+i+"\",\"value\":"+i+"}";
+            System.out.println("Inserting document# : "+i+" : "+docs);
+            doc = sodaDb.createDocumentFromString(docs);
+            sodaSampleCollection.insert(doc);
+        }
+    }
+
+    public static void findSampleData() throws Exception {
+        System.out.println("Looking for document 12");
+        OracleCursor cursor = sodaSampleCollection.find().filter("{\"value\":12}").getCursor();
+        System.out.println("Results : ");
+        while (cursor.hasNext()) {
+            OracleDocument doc = cursor.next();
+            System.out.println("Key : "+doc.getKey());
+            System.out.println("Media type : "+doc.getMediaType());
+            System.out.println("Doc : "+doc.getContentAsString());
+        }
+    }
+
+    public static void closeSODAConnection() throws Exception {
+        sodaDbAdmin.getConnection().close();
+        System.out.println("Database connection closed succesfully.");
+    }
+
+    public static void main(String[] args) {
+        try {
+            prepareSODAConnection();
+            listExistingCollections();
+            resetSampleCollection();
+            insertSampleData();
+            findSampleData();
+            closeSODAConnection();
+        }
+        catch (Exception e) {e.printStackTrace();}
+    }
+}