From cc506b9ebf44f3ab9b1c6b0b8619849d1021387c Mon Sep 17 00:00:00 2001 From: Kate Ting Date: Sun, 24 Mar 2013 12:07:32 -0400 Subject: [PATCH] SQOOP-953: Sqoop2: Integration: Schema support (Jarek Jarcec Cecho via Kate Ting) --- .../java/org/apache/sqoop/test/db/DatabaseProvider.java | 9 +++++++++ .../java/org/apache/sqoop/test/db/DerbyProvider.java | 5 +++++ .../org/apache/sqoop/test/db/PostgreSQLProvider.java | 5 +++++ .../java/org/apache/sqoop/test/db/SqlServerProvider.java | 5 +++++ 4 files changed, 24 insertions(+) diff --git a/test/src/main/java/org/apache/sqoop/test/db/DatabaseProvider.java b/test/src/main/java/org/apache/sqoop/test/db/DatabaseProvider.java index dce1043a..72d1a954 100644 --- a/test/src/main/java/org/apache/sqoop/test/db/DatabaseProvider.java +++ b/test/src/main/java/org/apache/sqoop/test/db/DatabaseProvider.java @@ -104,6 +104,15 @@ public String nullConstant() { return "NULL"; } + /** + * True if the underlying database supports custom schemes (namespaces). + * + * @return + */ + public boolean isSupportingScheme() { + return false; + } + public String getJdbcDriver() { return null; } diff --git a/test/src/main/java/org/apache/sqoop/test/db/DerbyProvider.java b/test/src/main/java/org/apache/sqoop/test/db/DerbyProvider.java index aa6b897d..98e83ce4 100644 --- a/test/src/main/java/org/apache/sqoop/test/db/DerbyProvider.java +++ b/test/src/main/java/org/apache/sqoop/test/db/DerbyProvider.java @@ -76,6 +76,11 @@ public String escapeValueString(String value) { return "'" + value + "'"; } + @Override + public boolean isSupportingScheme() { + return true; + } + public String escape(String entity) { return "\"" + entity + "\""; } diff --git a/test/src/main/java/org/apache/sqoop/test/db/PostgreSQLProvider.java b/test/src/main/java/org/apache/sqoop/test/db/PostgreSQLProvider.java index 32597688..06156c43 100644 --- a/test/src/main/java/org/apache/sqoop/test/db/PostgreSQLProvider.java +++ b/test/src/main/java/org/apache/sqoop/test/db/PostgreSQLProvider.java @@ -72,6 +72,11 @@ public String escapeValueString(String value) { return "'" + value + "'"; } + @Override + public boolean isSupportingScheme() { + return true; + } + @Override public String getJdbcDriver() { return DRIVER; diff --git a/test/src/main/java/org/apache/sqoop/test/db/SqlServerProvider.java b/test/src/main/java/org/apache/sqoop/test/db/SqlServerProvider.java index 35b6ef39..327c05ef 100644 --- a/test/src/main/java/org/apache/sqoop/test/db/SqlServerProvider.java +++ b/test/src/main/java/org/apache/sqoop/test/db/SqlServerProvider.java @@ -72,6 +72,11 @@ public String escapeValueString(String value) { return "'" + value + "'"; } + @Override + public boolean isSupportingScheme() { + return true; + } + @Override public String getJdbcDriver() { return DRIVER;