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;