0001291: Transforms can cause an error when attempting to use the cre…

…ate tables feature of SymmetricDS
JumpMind · Jun 19, 2013 · a73620d · a73620d
1 parent a4ee98e
commit a73620d
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/TransformWriter.java b/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/TransformWriter.java
@@ -120,6 +120,7 @@ public boolean start(Table table) {
             this.sourceTable = table;
             return true;
         } else {
+            this.sourceTable = null;
             return super.start(table);
         }
     }
@@ -185,7 +186,13 @@ public void write(CsvData data) {
             }
 
         } else {
+            if (sourceTable != null) {
+                super.start(sourceTable);
+            }
             super.write(data);
+            if (sourceTable != null) {
+                super.end(sourceTable);
+            }
         }
 
     }