ARGO-212125: handling select where clause

AndreyIg · Mar 5, 2020 · 4619fcd · 4619fcd
1 parent 135e732
commit 4619fcd
Showing 1 changed file with 10 additions and 1 deletion.
diff --git a/...ver/src/main/java/io/debezium/connector/sqlserver/SqlServerSnapshotChangeEventSource.java b/...ver/src/main/java/io/debezium/connector/sqlserver/SqlServerSnapshotChangeEventSource.java
@@ -226,7 +226,16 @@ private String checkBlacklistedColumns(TableId tableId){
         if (blackListColumnStr != null && blackListColumnStr.trim().length() > 0
                 && blackListColumnStr.contains(tableId.table())) {
             Table table = sqlServerDatabaseSchema.tableFor(tableId);
-            modifiedColumns = table.retrieveColumnNames().stream().collect(Collectors.joining(","));
+            modifiedColumns = table.retrieveColumnNames().stream()
+                    .map(s->{
+                        StringBuilder sb = new StringBuilder();
+                        if (!s.contains(tableId.table())){
+                            sb.append(tableId.table()).append(".").append(s);
+                        } else {
+                            sb.append(s);
+                        }
+                        return sb.toString();
+                    }).collect(Collectors.joining(","));
         }
         return modifiedColumns;
     }