only process tables that exist

JumpMind · May 9, 2012 · d4938f4 · d4938f4
1 parent 32a34eb
commit d4938f4
Showing 1 changed file with 8 additions and 5 deletions.
diff --git a/...ric/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/TransformWriter.java b/...ric/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/TransformWriter.java
@@ -158,17 +158,20 @@ public void write(CsvData data) {
             }
 
             List<TransformedData> dataThatHasBeenTransformed = new ArrayList<TransformedData>();
-            for (TransformTable transformation : activeTransforms) {                
-                transformation = transformation.enhanceWithImpliedColumns(sourceKeyValues, oldSourceValues, sourceValues);
+            for (TransformTable transformation : activeTransforms) {
+                transformation = transformation.enhanceWithImpliedColumns(sourceKeyValues,
+                        oldSourceValues, sourceValues);
                 dataThatHasBeenTransformed.addAll(transform(eventType, context, transformation,
                         sourceKeyValues, oldSourceValues, sourceValues));
             }
 
             for (TransformedData transformedData : dataThatHasBeenTransformed) {
                 Table table = transformedData.buildTargetTable();
-                this.targetWriter.start(table);
-                this.targetWriter.write(transformedData.buildTargetCsvData());
-                this.targetWriter.end(table);
+                CsvData csvData = transformedData.buildTargetCsvData();
+                if (this.targetWriter.start(table) || !csvData.requiresTable()) {
+                    this.targetWriter.write(csvData);
+                    this.targetWriter.end(table);
+                }
             }
 
         } else {