0001449: Add support for allowing a database writer filter to change …

…the target tables catalog, schema and table name
JumpMind · Oct 24, 2013 · e24db90 · e24db90
1 parent 0ca7786
commit e24db90
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/DatabaseWriter.java b/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/DatabaseWriter.java
@@ -384,7 +384,9 @@ protected boolean filterBefore(CsvData data) {
                 }
                 // re-lookup target table in case the source table has changed
                 Table oldTargetTable = targetTable;
-                targetTable = lookupTableAtTarget(this.sourceTable);
+                if (this.sourceTable!=null) {
+                    targetTable = lookupTableAtTarget(this.sourceTable);
+                }
                 if (targetTable!=null && !targetTable.equals(oldTargetTable)) {
                     // allow for auto increment columns to be inserted into if appropriate
                     String quote = getPlatform().getDatabaseInfo().getDelimiterToken();