Add nested JSONB example. Fix cases where connection string has a space in it.

jjspiegel · jjspiegel · commit 458daafb8142 · 2022-03-18T15:03:00.000-07:00
diff --git a/JdbcExamples/src/main/java/emp/CreateTable.java b/JdbcExamples/src/main/java/emp/CreateTable.java
@@ -14,7 +14,7 @@ public class CreateTable {
 
     public static void main(String[] args) throws SQLException {
         PoolDataSource pool = PoolDataSourceFactory.getPoolDataSource();
-        pool.setURL(args[0]);
+        pool.setURL(String.join("", args));
         pool.setConnectionFactoryClassName("oracle.jdbc.pool.OracleDataSource");
         
         try (Connection con = pool.getConnection()) {
diff --git a/JdbcExamples/src/main/java/emp/DropTable.java b/JdbcExamples/src/main/java/emp/DropTable.java
@@ -14,7 +14,7 @@ public class DropTable {
 
     public static void main(String[] args) throws SQLException {
         PoolDataSource pool = PoolDataSourceFactory.getPoolDataSource();
-        pool.setURL(args[0]);
+        pool.setURL(String.join("", args));
         pool.setConnectionFactoryClassName("oracle.jdbc.pool.OracleDataSource");
         
         try (Connection con = pool.getConnection()) {
diff --git a/JdbcExamples/src/main/java/emp/Filter.java b/JdbcExamples/src/main/java/emp/Filter.java
@@ -20,7 +20,7 @@ public class Filter {
 
     public static void main(String[] args) throws SQLException {
         PoolDataSource pool = PoolDataSourceFactory.getPoolDataSource();
-        pool.setURL(args[0]);
+        pool.setURL(String.join("", args));
         pool.setConnectionFactoryClassName("oracle.jdbc.pool.OracleDataSource");
         
         try (Connection con = pool.getConnection()) {
diff --git a/JdbcExamples/src/main/java/emp/Filter2.java b/JdbcExamples/src/main/java/emp/Filter2.java
@@ -24,7 +24,7 @@ public class Filter2 {
 
     public static void main(String[] args) throws SQLException {
         PoolDataSource pool = PoolDataSourceFactory.getPoolDataSource();
-        pool.setURL(args[0]);
+        pool.setURL(String.join("", args));
         pool.setConnectionFactoryClassName("oracle.jdbc.pool.OracleDataSource");
         
         try (Connection con = pool.getConnection()) {
diff --git a/JdbcExamples/src/main/java/emp/GSON.java b/JdbcExamples/src/main/java/emp/GSON.java
@@ -7,6 +7,7 @@
 
 import com.google.gson.Gson;
 
+import emp.model.Emp;
 import oracle.ucp.jdbc.PoolDataSource;
 import oracle.ucp.jdbc.PoolDataSourceFactory;
 
@@ -26,7 +27,7 @@ public class GSON {
     public static void main(String[] args) throws SQLException {
         
         PoolDataSource pool = PoolDataSourceFactory.getPoolDataSource();
-        pool.setURL(args[0]);
+        pool.setURL(String.join("", args));
         pool.setConnectionFactoryClassName("oracle.jdbc.pool.OracleDataSource");
         
         try (Connection con = pool.getConnection()) {
diff --git a/JdbcExamples/src/main/java/emp/GetAll.java b/JdbcExamples/src/main/java/emp/GetAll.java
@@ -19,7 +19,7 @@ public class GetAll {
 
     public static void main(String[] args) throws SQLException {
         PoolDataSource pool = PoolDataSourceFactory.getPoolDataSource();
-        pool.setURL(args[0]);
+        pool.setURL(String.join("", args));
         pool.setConnectionFactoryClassName("oracle.jdbc.pool.OracleDataSource");
         
         try (Connection con = pool.getConnection()) {
diff --git a/JdbcExamples/src/main/java/emp/Insert.java b/JdbcExamples/src/main/java/emp/Insert.java
@@ -26,7 +26,7 @@ public class Insert {
 
     public static void main(String[] args) throws Exception {
         PoolDataSource pool = PoolDataSourceFactory.getPoolDataSource();
-        pool.setURL(args[0]);
+        pool.setURL(String.join("", args));
         pool.setConnectionFactoryClassName("oracle.jdbc.pool.OracleDataSource");
         
         try (Connection con = pool.getConnection()) {
diff --git a/JdbcExamples/src/main/java/emp/JSONB.java b/JdbcExamples/src/main/java/emp/JSONB.java
@@ -6,13 +6,17 @@
 import java.sql.PreparedStatement;
 import java.sql.ResultSet;
 import java.sql.SQLException;
+import java.util.ArrayList;
+import java.util.List;
 
 import javax.json.bind.JsonbBuilder;
 import javax.json.stream.JsonGenerator;
 import javax.json.stream.JsonParser;
 
 import org.eclipse.yasson.YassonJsonb;
 
+import emp.model.Emp;
+import emp.model.Phone;
 import oracle.jdbc.OracleTypes;
 import oracle.sql.json.OracleJsonFactory;
 import oracle.ucp.jdbc.PoolDataSource;
@@ -30,7 +34,7 @@ public static void main(String[] args) throws SQLException {
         YassonJsonb jsonb = (YassonJsonb) JsonbBuilder.create();
         
         PoolDataSource pool = PoolDataSourceFactory.getPoolDataSource();
-        pool.setURL(args[0]);
+        pool.setURL(String.join("", args));
         pool.setConnectionFactoryClassName("oracle.jdbc.pool.OracleDataSource");
         
         try (Connection con = pool.getConnection()) {
@@ -41,6 +45,11 @@ public static void main(String[] args) throws SQLException {
             emp.setSalary(BigDecimal.valueOf(200000));
             emp.setJob("President");
             
+            List<Phone> phones = new ArrayList<Phone>();
+            phones.add(new Phone(Phone.Type.MOBILE, "555-333-2222"));
+            phones.add(new Phone(Phone.Type.WORK, "555-333-1111"));
+            emp.setPhoneNumbers(phones);
+            
             // convert Emp class to binary JSON
             ByteArrayOutputStream out = new ByteArrayOutputStream();
             JsonGenerator gen = factory.createJsonBinaryGenerator(out)
@@ -65,6 +74,9 @@ public static void main(String[] args) throws SQLException {
             Emp e = jsonb.fromJson(parser, Emp.class);
             System.out.println("Emp object retrieved from database. ");
             System.out.println(e.getName() + ", " + e.getEmail());
+            for (Phone p : e.getPhoneNumbers()) {
+                System.out.println("  " + p.getType() + " " + p.getNumber());
+            }
         }
         
     }
diff --git a/JdbcExamples/src/main/java/emp/JSONP.java b/JdbcExamples/src/main/java/emp/JSONP.java
@@ -32,7 +32,7 @@ public static void main(String[] args) throws SQLException {
         JsonBuilderFactory factory = Json.createBuilderFactory(null);
         
         PoolDataSource pool = PoolDataSourceFactory.getPoolDataSource();
-        pool.setURL(args[0]);
+        pool.setURL(String.join("", args));
         pool.setConnectionFactoryClassName("oracle.jdbc.pool.OracleDataSource");
         
         try (Connection con = pool.getConnection()) {
diff --git a/JdbcExamples/src/main/java/emp/Jackson.java b/JdbcExamples/src/main/java/emp/Jackson.java
@@ -73,7 +73,7 @@ public static void main(String[] args) throws Exception {
         gen.close();
         
         byte[] oson = out.toByteArray();
-        try (Connection con = DriverManager.getConnection(args[0])) {
+        try (Connection con = DriverManager.getConnection(String.join("", args))) {
             PreparedStatement stmt = con.prepareStatement("INSERT INTO emp VALUES (?)");
             stmt.setObject(1, oson, OracleType.JSON);
             stmt.execute();
diff --git a/JdbcExamples/src/main/java/emp/Update.java b/JdbcExamples/src/main/java/emp/Update.java
@@ -23,7 +23,7 @@ public static void main(String[] args) throws Exception {
         OracleJsonFactory factory = new OracleJsonFactory();
         
         PoolDataSource pool = PoolDataSourceFactory.getPoolDataSource();
-        pool.setURL(args[0]);
+        pool.setURL(String.join("", args));
         pool.setConnectionFactoryClassName("oracle.jdbc.pool.OracleDataSource");
         
         try (Connection con = pool.getConnection()) {
diff --git a/JdbcExamples/src/main/java/emp/UpdateMerge.java b/JdbcExamples/src/main/java/emp/UpdateMerge.java
@@ -22,7 +22,7 @@ public static void main(String[] args) throws SQLException {
         OracleJsonFactory factory = new OracleJsonFactory();
         
         PoolDataSource pool = PoolDataSourceFactory.getPoolDataSource();
-        pool.setURL(args[0]);
+        pool.setURL(String.join("", args));
         pool.setConnectionFactoryClassName("oracle.jdbc.pool.OracleDataSource");
         
         try (Connection con = pool.getConnection()) {
diff --git a/JdbcExamples/src/main/java/emp/UpdateTransform.java b/JdbcExamples/src/main/java/emp/UpdateTransform.java
@@ -19,7 +19,7 @@ public class UpdateTransform {
     public static void main(String[] args) throws SQLException {
         
         PoolDataSource pool = PoolDataSourceFactory.getPoolDataSource();
-        pool.setURL(args[0]);
+        pool.setURL(String.join("", args));
         pool.setConnectionFactoryClassName("oracle.jdbc.pool.OracleDataSource");
         
         try (Connection con = pool.getConnection()) {
diff --git a/JdbcExamples/src/main/java/emp/model/Emp.java b/JdbcExamples/src/main/java/emp/model/Emp.java
@@ -1,6 +1,8 @@
-package emp;
+package emp.model;
 
 import java.math.BigDecimal;
+import java.util.ArrayList;
+import java.util.List;
 
 public class Emp {
 
@@ -11,7 +13,13 @@ public class Emp {
     BigDecimal salary;
     
     String email;
+    
+    List<Phone> phoneNumbers = new ArrayList<Phone>();
 
+    public Emp() {
+        
+    }
+    
     public String getName() {
         return name;
     }
@@ -43,5 +51,13 @@ public String getEmail() {
     public void setEmail(String email) {
         this.email = email;
     }
+    
+    public List<Phone> getPhoneNumbers() {
+        return this.phoneNumbers;
+    }
+    
+    public void setPhoneNumbers(List<Phone> phones) {
+        this.phoneNumbers = phones;
+    }
 
 }
diff --git a/JdbcExamples/src/main/java/emp/model/Phone.java b/JdbcExamples/src/main/java/emp/model/Phone.java
@@ -0,0 +1,37 @@
+package emp.model;
+
+public class Phone {
+
+    public enum Type { MOBILE, HOME, WORK }
+    
+    String number;
+    
+    Type type;
+    
+    public Phone () {
+        
+    }
+    
+    public Phone(Type type, String number) {
+        this.type = type;
+        this.number = number;
+    }
+
+    public String getNumber() {
+        return number;
+    }
+
+    public void setNumber(String number) {
+        this.number = number;
+    }
+
+    public Type getType() {
+        return type;
+    }
+
+    public void setType(Type type) {
+        this.type = type;
+    }
+    
+    
+}
