0001366: If a custom column transformation isn't found the engine sil…

…ently ignores it. An error should be thrown.
JumpMind · Aug 4, 2013 · 4478727 · 4478727
1 parent 727fec7
commit 4478727
Showing 1 changed file with 3 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
@@ -50,6 +50,7 @@
 import org.jumpmind.symmetric.io.data.transform.SubstrColumnTransform;
 import org.jumpmind.symmetric.io.data.transform.TransformColumn;
 import org.jumpmind.symmetric.io.data.transform.TransformColumn.IncludeOnType;
+import org.jumpmind.symmetric.io.data.transform.TransformColumnException;
 import org.jumpmind.symmetric.io.data.transform.TransformPoint;
 import org.jumpmind.symmetric.io.data.transform.TransformTable;
 import org.jumpmind.symmetric.io.data.transform.TransformedData;
@@ -418,6 +419,8 @@ protected Object transformColumn(DataContext context, TransformedData data,
             String oldValue = oldSourceValues.get(transformColumn.getSourceColumnName());
             returnValue = transform.transform(platform, context, transformColumn, data,
                     sourceValues, value, oldValue);
+        } else {
+            throw new TransformColumnException(String.format("Could not locate a column transform of type '%s'", transformColumn.getTransformType()));
         }
         return returnValue;
     }