fix transform save bug

JumpMind · Apr 21, 2012 · 46aab55 · 46aab55
1 parent a8a0121
commit 46aab55
Showing 1 changed file with 4 additions and 19 deletions.
diff --git a/...ic/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/TransformService.java b/...ic/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/TransformService.java
@@ -147,7 +147,7 @@ public void saveTransformTable(TransformTableNodeGroupLink transformTable) {
                     .getSourceSchemaName(), transformTable.getSourceTableName(), transformTable
                     .getTargetCatalogName(), transformTable.getTargetSchemaName(), transformTable
                     .getTargetTableName(), transformTable.getTransformPoint().toString(),
-                    transformTable.isUpdateFirst(), transformTable.getDeleteAction().toString(),
+                    transformTable.isUpdateFirst() ? 1 : 0, transformTable.getDeleteAction().toString(),
                     transformTable.getTransformOrder(), transformTable.getTransformId()) == 0) {
                 transaction.prepareAndExecute(getSql("insertTransformTableSql"), transformTable
                         .getNodeGroupLink().getSourceNodeGroupId(), transformTable
@@ -156,7 +156,7 @@ public void saveTransformTable(TransformTableNodeGroupLink transformTable) {
                         transformTable.getSourceTableName(), transformTable.getTargetCatalogName(),
                         transformTable.getTargetSchemaName(), transformTable.getTargetTableName(),
                         transformTable.getTransformPoint().toString(), transformTable
-                                .isUpdateFirst(), transformTable.getDeleteAction().toString(),
+                                .isUpdateFirst() ? 1 : 0, transformTable.getDeleteAction().toString(),
                         transformTable.getTransformOrder(), transformTable.getTransformId());
             }
             deleteTransformColumns(transaction, transformTable.getTransformId());
@@ -194,33 +194,18 @@ public void deleteTransformTable(String transformTableId) {
 
     protected void saveTransformColumn(ISqlTransaction transaction, TransformColumn transformColumn) {
         if (transaction.prepareAndExecute(getSql("updateTransformColumnSql"),
-                transformColumn.getSourceColumnName(), transformColumn.isPk(),
+                transformColumn.getSourceColumnName(), transformColumn.isPk() ? 1 : 0,
                 transformColumn.getTransformType(), transformColumn.getTransformExpression(),
                 transformColumn.getTransformOrder(), transformColumn.getTransformId(),
                 transformColumn.getIncludeOn().toDbValue(), transformColumn.getTargetColumnName()) == 0) {
             transaction.prepareAndExecute(getSql("insertTransformColumnSql"),
                     transformColumn.getTransformId(), transformColumn.getIncludeOn().toDbValue(),
                     transformColumn.getTargetColumnName(), transformColumn.getSourceColumnName(),
-                    transformColumn.isPk(), transformColumn.getTransformType(),
+                    transformColumn.isPk() ? 1 : 0, transformColumn.getTransformType(),
                     transformColumn.getTransformExpression(), transformColumn.getTransformOrder());
         }
     }
 
-    public void deleteTransformColumn(String transformTableId, Boolean includeOn,
-            String targetColumnName) {
-
-        String includeOnAsChar = null;
-        if (includeOn) {
-            includeOnAsChar = "Y";
-        } else {
-            includeOnAsChar = "N";
-        }
-
-        sqlTemplate.update(getSql("deleteTransformColumnSql"), (Object) transformTableId,
-                includeOnAsChar, targetColumnName);
-        refreshCache();
-    }
-
     class TransformTableMapper implements ISqlRowMapper<TransformTableNodeGroupLink> {
         public TransformTableNodeGroupLink mapRow(Row rs) {
             TransformTableNodeGroupLink table = new TransformTableNodeGroupLink();