gobblin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From a...@apache.org
Subject [1/3] incubator-gobblin git commit: updating connection url for sqlserver with database name
Date Sat, 29 Jul 2017 02:41:44 GMT
Repository: incubator-gobblin
Updated Branches:
  refs/heads/master cec91e610 -> a889431e0


updating connection url for sqlserver with database name


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

Branch: refs/heads/master
Commit: d0fb9ad39387a58699b14a16e0f3799bca782d36
Parents: 817db30
Author: Arjun <abora@linkedin.com>
Authored: Tue Jul 25 11:40:01 2017 -0700
Committer: Arjun <abora@linkedin.com>
Committed: Tue Jul 25 11:40:01 2017 -0700

----------------------------------------------------------------------
 .../src/main/java/gobblin/source/jdbc/SqlServerExtractor.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/d0fb9ad3/gobblin-modules/gobblin-sql/src/main/java/gobblin/source/jdbc/SqlServerExtractor.java
----------------------------------------------------------------------
diff --git a/gobblin-modules/gobblin-sql/src/main/java/gobblin/source/jdbc/SqlServerExtractor.java
b/gobblin-modules/gobblin-sql/src/main/java/gobblin/source/jdbc/SqlServerExtractor.java
index ebe8289..fa502d4 100644
--- a/gobblin-modules/gobblin-sql/src/main/java/gobblin/source/jdbc/SqlServerExtractor.java
+++ b/gobblin-modules/gobblin-sql/src/main/java/gobblin/source/jdbc/SqlServerExtractor.java
@@ -187,7 +187,8 @@ public class SqlServerExtractor extends JdbcExtractor {
   public String getConnectionUrl() {
     String host = this.workUnitState.getProp(ConfigurationKeys.SOURCE_CONN_HOST_NAME);
     String port = this.workUnitState.getProp(ConfigurationKeys.SOURCE_CONN_PORT);
-    String url = "jdbc:sqlserver://" + host.trim() + ":" + port;
+    String database = this.workUnitState.getProp(ConfigurationKeys.SOURCE_QUERYBASED_SCHEMA);
+    String url = "jdbc:sqlserver://" + host.trim() + ":" + port + ";databaseName=" + database.trim();
     return url;
   }
 


Mime
View raw message