0002636: Issue 0002584 in 3.7.33 broke AS/400 triggers

JumpMind · Jun 8, 2016 · c4765b8 · c4765b8
1 parent c0b2da5
commit c4765b8
Showing 1 changed file with 8 additions and 6 deletions.
diff --git a/symmetric-client/src/main/java/org/jumpmind/symmetric/db/db2/Db2As400TriggerTemplate.java b/symmetric-client/src/main/java/org/jumpmind/symmetric/db/db2/Db2As400TriggerTemplate.java
@@ -22,7 +22,7 @@ public Db2As400TriggerTemplate(ISymmetricDialect symmetricDialect) {
 "                                        INSERT into $(defaultSchema)$(prefixName)_data                                                                                                                 " +
 "                                            (table_name, event_type, trigger_hist_id, row_data, channel_id, transaction_id, source_node_id, external_data, create_time)                                " +
 "                                        VALUES('$(targetTableName)', 'I', $(triggerHistoryId),                                                                                                         " +
-"                                            $(oracleToClob)$(columns),                                                                                                                                 " +
+"                                            $(columns),                                                                                                                                                " +
 "                                            $(channelExpression), $(txIdExpression), $(sourceNodeExpression),                                                                                          " +
 "                                            $(externalSelect),                                                                                                                                         " +
 "                                            CURRENT_TIMESTAMP);                                                                                                                                        " +
@@ -41,9 +41,9 @@ public Db2As400TriggerTemplate(ISymmetricDialect symmetricDialect) {
 "                                            INSERT into $(defaultSchema)$(prefixName)_data                                                                                                             \n"+
 "                                                (table_name, event_type, trigger_hist_id, pk_data, row_data, old_data, channel_id, transaction_id, source_node_id, external_data, create_time)         \n"+
 "                                            VALUES('$(targetTableName)', 'U', $(triggerHistoryId),                                                                                                     \n"+
-"                                                $(oracleToClob)$(oldKeys),                                                                                                                             \n"+
-"                                                $(oracleToClob)$(columns),                                                                                                                             \n"+
-"                                                $(oracleToClob)$(oldColumns),                                                                                                                          \n"+
+"                                                $(oldKeys),                                                                                                                                            \n"+
+"                                                $(columns),                                                                                                                                          \n"+
+"                                                $(oldColumns),                                                                                                                                          \n"+
 "                                                $(channelExpression),                                                                                                                                      \n"+
 "                                                $(txIdExpression),                                                                                                                                     \n"+
 "                                                $(sourceNodeExpression),                                                                                                                               \n"+
@@ -63,8 +63,8 @@ public Db2As400TriggerTemplate(ISymmetricDialect symmetricDialect) {
 "                                        INSERT into $(defaultSchema)$(prefixName)_data                                                                                                                 " +
 "                                            (table_name, event_type, trigger_hist_id, pk_data, old_data, channel_id, transaction_id, source_node_id, external_data, create_time)                       " +
 "                                        VALUES ('$(targetTableName)', 'D', $(triggerHistoryId),                                                                                                        " +
-"                                            $(oracleToClob)$(oldKeys),                                                                                                                                 " +
-"                                            $(oracleToClob)$(oldColumns),                                                                                                                              " +
+"                                            $(oldKeys),                                                                                                                                                " +
+"                                            $(oldColumns),                                                                                                                                             " +
 "                                            $(channelExpression),                                                                                                                                          " +
 "                                            $(txIdExpression),                                                                                                                                         " +
 "                                            $(sourceNodeExpression),                                                                                                                                   " +
@@ -74,6 +74,8 @@ public Db2As400TriggerTemplate(ISymmetricDialect symmetricDialect) {
 "                                    $(custom_on_delete_text)                                                                                                                                           " +
 "                                END                                                                                                                                                                    " );
 
+        sqlTemplates.put("initialLoadSqlTemplate" ,
+"select $(columns) from $(schemaName)$(tableName) t where $(whereClause)                                                                                                                                " );
 
     }