[geode] branch feature/GEODE-6225 updated: WIP: started trying to figure out how to setup schemas in mysql and postgress. Test is currently broken

[ds...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

dschneider pushed a commit to branch feature/GEODE-6225
in repository https://gitbox.apache.org/repos/asf/geode.git


The following commit(s) were added to refs/heads/feature/GEODE-6225 by this push:
     new a79018c  WIP: started trying to figure out how to setup schemas in mysql and postgress. Test is currently broken
a79018c is described below

commit a79018cf06e6a7bc55e0ff0cf62ebbff32c3962e
Author: Darrel Schneider <ds...@pivotal.io>
AuthorDate: Wed Dec 19 16:13:30 2018 -0800

    WIP: started trying to figure out how to setup schemas in mysql and postgress. Test is currently broken
---
 .../geode/connectors/jdbc/JdbcWriterIntegrationTest.java   | 14 +++++++++++++-
 1 file changed, 13 insertions(+), 1 deletion(-)

diff --git a/geode-connectors/src/acceptanceTest/java/org/apache/geode/connectors/jdbc/JdbcWriterIntegrationTest.java b/geode-connectors/src/acceptanceTest/java/org/apache/geode/connectors/jdbc/JdbcWriterIntegrationTest.java
index 4db143f..5bc70e6 100644
--- a/geode-connectors/src/acceptanceTest/java/org/apache/geode/connectors/jdbc/JdbcWriterIntegrationTest.java
+++ b/geode-connectors/src/acceptanceTest/java/org/apache/geode/connectors/jdbc/JdbcWriterIntegrationTest.java
@@ -65,7 +65,10 @@ public abstract class JdbcWriterIntegrationTest {
 
     connection = getConnection();
     statement = connection.createStatement();
-    statement.execute("Create Table " + REGION_TABLE_NAME
+    statement.execute("Create Schema mySchema");
+    //connection.setSchema("mySchema");
+    statement = connection.createStatement();
+    statement.execute("Create Table " + "mySchema." + REGION_TABLE_NAME
         + " (id varchar(10) primary key not null, name varchar(10), age int)");
     pdx1 = cache.createPdxInstanceFactory(Employee.class.getName()).writeString("id", "1")
         .writeString("name", "Emp1")
@@ -75,6 +78,15 @@ public abstract class JdbcWriterIntegrationTest {
         .writeInt("age", 21).create();
     employee1 = (Employee) pdx1.getObject();
     employee2 = (Employee) pdx2.getObject();
+    
+    {
+    Connection connection2 = getConnection();
+    statement.execute("Create Schema mySchema2");
+    //connection2.setSchema("mySchema2");
+    statement = connection2.createStatement();
+    statement.execute("Create Table " + "mySchema2." + REGION_TABLE_NAME
+        + " (id varchar(10) primary key not null, name varchar(10), age int)");
+    }
   }
 
   private void setupRegion(String ids) throws RegionMappingExistsException {