0004256: Oracle trigger creates row data and old data when streaming row

JumpMind · Jan 22, 2020 · 00dc7d5 · 00dc7d5
1 parent 34c19f0
commit 00dc7d5
Showing 1 changed file with 13 additions and 20 deletions.
diff --git a/symmetric-client/src/main/java/org/jumpmind/symmetric/db/oracle/OracleTriggerTemplate.java b/symmetric-client/src/main/java/org/jumpmind/symmetric/db/oracle/OracleTriggerTemplate.java
@@ -186,29 +186,22 @@ public OracleTriggerTemplate(ISymmetricDialect symmetricDialect) {
         sqlTemplates.put("updateReloadTriggerTemplate",
 "create or replace trigger $(triggerName) after update on $(schemaName)$(tableName)\n" +
 "for each row\n" +
-"declare\n" +
-"    var_row_data $(oracleLobType);\n" +
-"    var_old_data $(oracleLobType);\n" +
 "begin\n" +
 "    $(custom_before_update_text)\n" +
 "    if $(syncOnUpdateCondition) and $(syncOnIncomingBatchCondition) then\n" +
-"        select $(oracleToClob)$(columns) into var_row_data from dual;\n" +
-"        select $(oracleToClob)$(oldColumns) into var_old_data from dual;\n" +
-"        if $(dataHasChangedCondition) then\n" +
-"            insert into $(defaultSchema)$(prefixName)_data\n" +
-"            (table_name, event_type, trigger_hist_id, pk_data, channel_id, transaction_id, source_node_id, external_data, create_time)\n" +
-"            values(\n" +
-"            '$(targetTableName)',\n" +
-"            'R',\n" +
-"            $(triggerHistoryId),\n" +
-"            $(oldKeys),\n" +
-"            $(channelExpression),\n" +
-"            $(txIdExpression),\n" +
-"            $(prefixName)_pkg.disable_node_id,\n" +
-"            $(externalSelect),\n" +
-"            " + getCreateTimeExpression(symmetricDialect) + "\n" +
-"            );\n" +
-"        end if;\n" +
+"        insert into $(defaultSchema)$(prefixName)_data\n" +
+"        (table_name, event_type, trigger_hist_id, pk_data, channel_id, transaction_id, source_node_id, external_data, create_time)\n" +
+"        values(\n" +
+"        '$(targetTableName)',\n" +
+"        'R',\n" +
+"        $(triggerHistoryId),\n" +
+"        $(oldKeys),\n" +
+"        $(channelExpression),\n" +
+"        $(txIdExpression),\n" +
+"        $(prefixName)_pkg.disable_node_id,\n" +
+"        $(externalSelect),\n" +
+"        " + getCreateTimeExpression(symmetricDialect) + "\n" +
+"        );\n" +
 "    end if;\n" +
 "    $(custom_on_update_text)\n" +
 "end;\n");