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

…the target tables catalog, schema and table name
JumpMind · Oct 24, 2013 · 0ca7786 · 0ca7786
1 parent f47dce7
commit 0ca7786
Showing 1 changed file with 1 addition and 3 deletions.
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
@@ -385,9 +385,7 @@ protected boolean filterBefore(CsvData data) {
                 // re-lookup target table in case the source table has changed
                 Table oldTargetTable = targetTable;
                 targetTable = lookupTableAtTarget(this.sourceTable);
-                if (targetTable == null) {
-                    throw new IllegalStateException("Unable to locate table " +this.sourceTable.getFullyQualifiedTableName()+" in target database.");
-                } else if (!targetTable.equals(oldTargetTable)) {
+                if (targetTable!=null && !targetTable.equals(oldTargetTable)) {
                     // allow for auto increment columns to be inserted into if appropriate
                     String quote = getPlatform().getDatabaseInfo().getDelimiterToken();
                     if (oldTargetTable!=null) {