From d4938f43c2162b58fdd0d3a47a7da9a57b4d72cc Mon Sep 17 00:00:00 2001
From: chenson42 <chenson42@gmail.com>
Date: Wed, 9 May 2012 13:35:09 +0000
Subject: [PATCH] only process tables that exist

---
 .../symmetric/io/data/writer/TransformWriter.java   | 13 ++++++++-----
 1 file changed, 8 insertions(+), 5 deletions(-)

diff --git a/symmetric/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/TransformWriter.java b/symmetric/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/TransformWriter.java
index a09d6e98a1..d04608dbbe 100644
--- a/symmetric/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/TransformWriter.java
+++ b/symmetric/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 {