0001206: dataloader.ignore.missing.tables not working for initial loa…

…d when initial.load.delete.first=true
JumpMind · May 10, 2013 · b7d3e82 · b7d3e82
1 parent b1288cf
commit b7d3e82
Showing 1 changed file with 4 additions and 2 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
@@ -156,12 +156,14 @@ public boolean start(Table table) {
     }
 
     public void write(CsvData data) {
-        if (data.requiresTable() && targetTable == null) {
+        if (data.requiresTable() && 
+                (targetTable == null && data.getDataEventType() != DataEventType.SQL)) {
             // if we cross batches and the table isn't specified, then
             // use the last table we used
             start(context.getLastParsedTable());
         }
-        if (targetTable != null || !data.requiresTable()) {
+        if (targetTable != null || !data.requiresTable() || 
+                (targetTable == null && data.getDataEventType() == DataEventType.SQL)) {
             try {
                 statistics.get(batch).increment(DataWriterStatisticConstants.STATEMENTCOUNT);
                 statistics.get(batch).increment(DataWriterStatisticConstants.LINENUMBER);