Merge pull request #130 from data-integrations/fix/CDAP-17516-populate-schema

sagarkapare · web-flow · commit 1e8d1f755574 · 2021-01-08T00:56:54.000-08:00
CDAP-17516 Populate the schema name for SQL server since that info is available in the list table call.
diff --git a/sqlserver-delta-plugins/src/main/java/io/cdap/delta/sqlserver/SqlServerTableRegistry.java b/sqlserver-delta-plugins/src/main/java/io/cdap/delta/sqlserver/SqlServerTableRegistry.java
@@ -81,8 +81,9 @@ public TableList listTables() throws IOException {
             if (!tableNames.contains(tableName)) {
               continue;
             }
+            String schemaName = tableResults.getString("TABLE_SCHEM");
             // ignore the total number of columns for listing tables
-            tables.add(new TableSummary(config.getDatabase(), tableName, 0, null));
+            tables.add(new TableSummary(config.getDatabase(), tableName, 0, schemaName));
           }
         }
         return new TableList(tables);

Original file line number	Diff line number	Diff line change
`@@ -81,8 +81,9 @@ public TableList listTables() throws IOException {`
`81`	`81`	`if (!tableNames.contains(tableName)) {`
`82`	`82`	`continue;`
`83`	`83`	`}`
	`84`	`+ String schemaName = tableResults.getString("TABLE_SCHEM");`
`84`	`85`	`// ignore the total number of columns for listing tables`
`85`		`- tables.add(new TableSummary(config.getDatabase(), tableName, 0, null));`
	`86`	`+ tables.add(new TableSummary(config.getDatabase(), tableName, 0, schemaName));`
`86`	`87`	`}`
`87`	`88`	`}`
`88`	`89`	`return new TableList(tables);`