From 71a25c8c2bd6a2696e455dab4338741d5ea82c5d Mon Sep 17 00:00:00 2001
From: chenson42 <chenson42@gmail.com>
Date: Tue, 28 Jun 2011 20:56:58 +0000
Subject: [PATCH] SYMMETRICDS-462 - refactor transformer

---
 .../symmetric/transform/TransformDataLoader.java | 12 ++++++------
 .../symmetric/transform/TransformedData.java     | 16 ++++++++--------
 2 files changed, 14 insertions(+), 14 deletions(-)

diff --git a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/transform/TransformDataLoader.java b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/transform/TransformDataLoader.java
index 63d2c24407..0ae8f82a13 100644
--- a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/transform/TransformDataLoader.java
+++ b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/transform/TransformDataLoader.java
@@ -68,9 +68,9 @@ protected boolean transform(DmlType dmlType, IDataLoaderContext context, String[
     protected boolean perform(TransformedData data, TransformTable transformation,
             Map<String, String> originalValues) {
         boolean persistData = false;
-        if (data.getDmlType() != DmlType.DELETE) {
-            if (data.getDmlType() == DmlType.INSERT && transformation.isUpdateFirst()) {
-                data.setDmlType(DmlType.UPDATE);
+        if (data.getTargetDmlType() != DmlType.DELETE) {
+            if (data.getTargetDmlType() == DmlType.INSERT && transformation.isUpdateFirst()) {
+                data.setTargetDmlType(DmlType.UPDATE);
             }
             for (String columnName : originalValues.keySet()) {
                 List<TransformColumn> transformColumns = transformation.getTransformColumnFor(columnName);
@@ -87,11 +87,11 @@ protected boolean perform(TransformedData data, TransformTable transformation,
             case NONE:
                 break;
             case DEL_ROW:
-                data.setDmlType(DmlType.DELETE);
+                data.setTargetDmlType(DmlType.DELETE);
                 persistData = true;
                 break;
             case NULL_COL:
-                data.setDmlType(DmlType.UPDATE);
+                data.setTargetDmlType(DmlType.UPDATE);
                 persistData = true;
                 break;
             }
@@ -129,7 +129,7 @@ public void apply(IDataLoaderContext context, TransformedData data) {
         tableTemplate.setKeyNames(data.getKeyNames());
         // TODO Need more advanced fallback logic? Support typical
         // symmetric fallback/recovery settings?
-        switch (data.getDmlType()) {
+        switch (data.getTargetDmlType()) {
         case INSERT:
             try {
                 tableTemplate.insert(context, data.getColumnValues());
diff --git a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/transform/TransformedData.java b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/transform/TransformedData.java
index 701c487f5e..4836dac83d 100644
--- a/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/transform/TransformedData.java
+++ b/symmetric/symmetric-core/src/main/java/org/jumpmind/symmetric/transform/TransformedData.java
@@ -11,7 +11,7 @@
 
 public class TransformedData {
 
-    protected DmlType dmlType;
+    protected DmlType targetDmlType;
 
     protected DmlType originalDmlType;
 
@@ -23,16 +23,16 @@ public class TransformedData {
 
     public TransformedData(TransformTable transformation, DmlType dmlType) {
         this.transformation = transformation;
-        this.dmlType = dmlType;
+        this.targetDmlType = dmlType;
         this.originalDmlType = dmlType;
     }
 
-    public DmlType getDmlType() {
-        return dmlType;
+    public DmlType getTargetDmlType() {
+        return targetDmlType;
     }
 
-    public void setDmlType(DmlType dmlType) {
-        this.dmlType = dmlType;
+    public void setTargetDmlType(DmlType dmlType) {
+        this.targetDmlType = dmlType;
     }
 
     public String getTableName() {
@@ -86,9 +86,9 @@ protected List<String> retrieve(
         }
 
         IncludeOnType type = IncludeOnType.DELETE;
-        if (dmlType == DmlType.UPDATE && originalDmlType != DmlType.DELETE) {
+        if (targetDmlType == DmlType.UPDATE && originalDmlType != DmlType.DELETE) {
             type = IncludeOnType.UPDATE;
-        } else if (dmlType == DmlType.INSERT) {
+        } else if (targetDmlType == DmlType.INSERT) {
             type = IncludeOnType.INSERT;
         }