0001610: CopyIfChangedTransform should only evaluate on non-delete DML

JumpMind · Feb 28, 2014 · 6259a17 · 6259a17
1 parent 54dc905
commit 6259a17
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/.../src/main/java/org/jumpmind/symmetric/io/data/transform/CopyIfChangedColumnTransform.java b/.../src/main/java/org/jumpmind/symmetric/io/data/transform/CopyIfChangedColumnTransform.java
@@ -26,6 +26,7 @@
 import org.jumpmind.db.platform.IDatabasePlatform;
 import org.jumpmind.extension.IBuiltInExtensionPoint;
 import org.jumpmind.symmetric.io.data.DataContext;
+import org.jumpmind.symmetric.io.data.DataEventType;
 
 public class CopyIfChangedColumnTransform extends CopyColumnTransform implements ISingleValueColumnTransform, IBuiltInExtensionPoint {
 
@@ -41,8 +42,9 @@ public String transform(IDatabasePlatform platform, DataContext context, Transfo
                         TransformedData data, Map<String, String> sourceValues, String newValue, String oldValue)
                         throws IgnoreColumnException, IgnoreRowException {
 
-                if (StringUtils.trimToEmpty(newValue).equals(StringUtils.trimToEmpty(oldValue))) {
-                        if (EXPRESSION_IGNORE_COLUMN.equalsIgnoreCase(column.getTransformExpression())) {
+            if (!DataEventType.DELETE.equals(context.getData().getDataEventType()) 
+                    && (StringUtils.trimToEmpty(newValue).equals(StringUtils.trimToEmpty(oldValue)))) {
+                if (EXPRESSION_IGNORE_COLUMN.equalsIgnoreCase(column.getTransformExpression())) {
                                 throw new IgnoreColumnException();
                         } else {
                                 throw new IgnoreRowException();