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 <[email protected]> Authored: Tue Jul 25 11:40:01 2017 -0700 Committer: Arjun <[email protected]> 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; }
