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 <[email protected]>
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 {
