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

…the target tables catalog, schema and table name
JumpMind · Oct 22, 2013 · d718319 · d718319
1 parent 10cd856
commit d718319
Showing 1 changed file with 2 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
@@ -381,10 +381,11 @@ protected boolean filterBefore(CsvData data) {
                 statistics.get(batch).startTimer(DataWriterStatisticConstants.FILTERMILLIS);
                 for (IDatabaseWriterFilter filter : filters) {
                     process &= filter.beforeWrite(this.context, this.sourceTable, data);
-                    // re-lookup target table in case the source has changed
+                    // re-lookup target table in case the source table has changed
                     Table oldTargetTable = targetTable;
                     targetTable = lookupTableAtTarget(this.sourceTable);
                     if (!oldTargetTable.equals(targetTable)) {
+                        // allow for auto increment columns to be inserted into if appropriate
                         String quote = getPlatform().getDatabaseInfo().getDelimiterToken();
                         transaction.allowInsertIntoAutoIncrementColumns(false, oldTargetTable, quote);
                         transaction.allowInsertIntoAutoIncrementColumns(true, targetTable, quote);