sqoop-commits mailing list archives

Updated Branches:
  refs/heads/sqoop2 2237d94e6 -> cc506b9eb


SQOOP-953: Sqoop2: Integration: Schema support
(Jarek Jarcec Cecho via Kate Ting)


Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/cc506b9e
Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/cc506b9e
Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/cc506b9e

Branch: refs/heads/sqoop2
Commit: cc506b9ebf44f3ab9b1c6b0b8619849d1021387c
Parents: 2237d94
Author: Kate Ting <kathleen@apache.org>
Authored: Sun Mar 24 12:07:32 2013 -0400
Committer: Kate Ting <kathleen@apache.org>
Committed: Sun Mar 24 12:07:32 2013 -0400

----------------------------------------------------------------------
 .../org/apache/sqoop/test/db/DatabaseProvider.java |    9 +++++++++
 .../org/apache/sqoop/test/db/DerbyProvider.java    |    5 +++++
 .../apache/sqoop/test/db/PostgreSQLProvider.java   |    5 +++++
 .../apache/sqoop/test/db/SqlServerProvider.java    |    5 +++++
 4 files changed, 24 insertions(+), 0 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/sqoop/blob/cc506b9e/test/src/main/java/org/apache/sqoop/test/db/DatabaseProvider.java
----------------------------------------------------------------------
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 dce1043..72d1a95 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 @@ abstract public class DatabaseProvider {
     return "NULL";
   }
 
+  /**
+   * True if the underlying database supports custom schemes (namespaces).
+   *
+   * @return
+   */
+  public boolean isSupportingScheme() {
+    return false;
+  }
+
   public String getJdbcDriver() {
     return null;
   }

http://git-wip-us.apache.org/repos/asf/sqoop/blob/cc506b9e/test/src/main/java/org/apache/sqoop/test/db/DerbyProvider.java
----------------------------------------------------------------------
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 aa6b897..98e83ce 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 class DerbyProvider extends DatabaseProvider {
     return "'" + value + "'";
   }
 
+  @Override
+  public boolean isSupportingScheme() {
+    return true;
+  }
+
   public String escape(String entity) {
     return "\"" + entity + "\"";
   }

http://git-wip-us.apache.org/repos/asf/sqoop/blob/cc506b9e/test/src/main/java/org/apache/sqoop/test/db/PostgreSQLProvider.java
----------------------------------------------------------------------
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 3259768..06156c4 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
@@ -73,6 +73,11 @@ public class PostgreSQLProvider extends DatabaseProvider {
   }
 
   @Override
+  public boolean isSupportingScheme() {
+    return true;
+  }
+
+  @Override
   public String getJdbcDriver() {
     return DRIVER;
   }

http://git-wip-us.apache.org/repos/asf/sqoop/blob/cc506b9e/test/src/main/java/org/apache/sqoop/test/db/SqlServerProvider.java
----------------------------------------------------------------------
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 35b6ef3..327c05e 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
@@ -73,6 +73,11 @@ public class SqlServerProvider extends DatabaseProvider {
   }
 
   @Override
+  public boolean isSupportingScheme() {
+    return true;
+  }
+
+  @Override
   public String getJdbcDriver() {
     return DRIVER;
   }