wip(sj_1.1.0-beta1): updateBatch系列脚本增加update_dt=CURRENT_TIMESTAMP

snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/JobMapper.xml

@@ -5,7 +5,8 @@
     <update id="updateBatchNextTriggerAtById" parameterType="java.util.List">
         <foreach collection="list" item="item" open="BEGIN" separator=";" close=";END;">
             UPDATE sj_job
-               SET next_trigger_at = #{item.nextTriggerAt}
+               SET next_trigger_at = #{item.nextTriggerAt},
+                   update_dt = CURRENT_TIMESTAMP
              WHERE id = #{item.id}
         </foreach>
     </update>

snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/JobSummaryMapper.xml

@@ -11,7 +11,8 @@
                    stop_num = #{item.stopNum},
                    stop_reason = #{item.stopReason},
                    cancel_num = #{item.cancelNum},
-                   cancel_reason = #{item.cancelReason}
+                   cancel_reason = #{item.cancelReason},
+                   update_dt = CURRENT_TIMESTAMP
              WHERE system_task_type = #{item.systemTaskType}
                AND business_id = #{item.businessId}
                AND trigger_at = #{item.triggerAt}

snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/RetrySummaryMapper.xml

@@ -8,7 +8,8 @@
                SET running_num = #{item.runningNum},
                    finish_num = #{item.finishNum},
                    max_count_num = #{item.maxCountNum},
-                   suspend_num = #{item.suspendNum}
+                   suspend_num = #{item.suspendNum},
+                   update_dt = CURRENT_TIMESTAMP
              WHERE trigger_at = #{item.triggerAt}
                AND group_name = #{item.groupName}
                AND namespace_id = #{item.namespaceId}

snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/RetryTaskLogMessageMapper.xml

@@ -5,7 +5,8 @@
     <update id="updateBatch" parameterType="java.util.List">
         <foreach collection="list" item="item" index="index" open="BEGIN" separator=";" close=";END;">
             UPDATE sj_retry_task_log_message
-               SET message = #{item.message}, log_num = #{item.logNum}
+               SET message = #{item.message}, log_num = #{item.logNum},
+                   update_dt = CURRENT_TIMESTAMP
              WHERE id = #{item.id}
         </foreach>
     </update>

snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/RetryTaskMapper.xml

@@ -5,7 +5,8 @@
     <update id="updateBatchNextTriggerAtById" parameterType="java.util.List">
         <foreach collection="list" item="item" index="index" open="BEGIN" separator=";" close=";END;">
             UPDATE sj_retry_task_${partition}
-               SET next_trigger_at = #{item.nextTriggerAt}
+               SET next_trigger_at = #{item.nextTriggerAt},
+                   update_dt = CURRENT_TIMESTAMP
              WHERE id = #{item.id}
         </foreach>
     </update>

snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/ServerNodeMapper.xml

@@ -5,7 +5,8 @@
     <update id="updateBatchExpireAt" parameterType="java.util.List">
         <foreach collection="list" item="item" open="BEGIN" separator=";" close=";END;">
             UPDATE sj_server_node
-               SET expire_at = #{item.expireAt}
+               SET expire_at = #{item.expireAt},
+                   update_dt = CURRENT_TIMESTAMP
              WHERE host_id = #{item.hostId}
                AND host_ip = #{item.hostIp}
         </foreach>

snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/WorkflowMapper.xml

@@ -5,7 +5,8 @@
     <update id="updateBatchNextTriggerAtById" parameterType="java.util.List">
         <foreach collection="list" item="item" open="BEGIN" separator=";" close=";END;">
             UPDATE sj_workflow
-               SET next_trigger_at = #{item.nextTriggerAt}
+               SET next_trigger_at = #{item.nextTriggerAt},
+                   update_dt = CURRENT_TIMESTAMP
              WHERE id = #{item.id}
         </foreach>
     </update>

snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/JobMapper.xml

@@ -5,7 +5,8 @@
     <update id="updateBatchNextTriggerAtById" parameterType="java.util.List">
         <foreach collection="list" item="item" open="BEGIN" separator=";" close=";END;">
             UPDATE sj_job
-               SET next_trigger_at = #{item.nextTriggerAt}
+               SET next_trigger_at = #{item.nextTriggerAt},
+                   update_dt = CURRENT_TIMESTAMP
              WHERE id = #{item.id}
         </foreach>
     </update>

snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/JobSummaryMapper.xml

@@ -11,7 +11,8 @@
                    stop_num = #{item.stopNum},
                    stop_reason = #{item.stopReason},
                    cancel_num = #{item.cancelNum},
-                   cancel_reason = #{item.cancelReason}
+                   cancel_reason = #{item.cancelReason},
+                   update_dt = CURRENT_TIMESTAMP
              WHERE system_task_type = #{item.systemTaskType}
                AND business_id = #{item.businessId}
                AND trigger_at = #{item.triggerAt}

snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/RetrySummaryMapper.xml

@@ -8,7 +8,8 @@
                SET running_num = #{item.runningNum},
                    finish_num = #{item.finishNum},
                    max_count_num = #{item.maxCountNum},
-                   suspend_num = #{item.suspendNum}
+                   suspend_num = #{item.suspendNum},
+                   update_dt = CURRENT_TIMESTAMP
              WHERE trigger_at = #{item.triggerAt}
                AND group_name = #{item.groupName}
                AND namespace_id = #{item.namespaceId}

snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/RetryTaskLogMessageMapper.xml

@@ -5,7 +5,8 @@
     <update id="updateBatch" parameterType="java.util.List">
         <foreach collection="list" item="item" index="index" open="BEGIN" separator=";" close=";END;">
             UPDATE sj_retry_task_log_message
-               SET message = #{item.message}, log_num = #{item.logNum}
+               SET message = #{item.message}, log_num = #{item.logNum},
+                   update_dt = CURRENT_TIMESTAMP
              WHERE id = #{item.id}
         </foreach>
     </update>

snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/RetryTaskMapper.xml

@@ -5,7 +5,8 @@
     <update id="updateBatchNextTriggerAtById" parameterType="java.util.List">
         <foreach collection="list" item="item" index="index" open="BEGIN" separator=";" close=";END;">
             UPDATE sj_retry_task_${partition}
-               SET next_trigger_at = #{item.nextTriggerAt}
+               SET next_trigger_at = #{item.nextTriggerAt},
+                   update_dt = CURRENT_TIMESTAMP
              WHERE id = #{item.id}
         </foreach>
     </update>

snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/ServerNodeMapper.xml

@@ -5,7 +5,8 @@
     <update id="updateBatchExpireAt" parameterType="java.util.List">
         <foreach collection="list" item="item" open="BEGIN" separator=";" close=";END;">
             UPDATE sj_server_node
-               SET expire_at = #{item.expireAt}
+               SET expire_at = #{item.expireAt},
+                   update_dt = CURRENT_TIMESTAMP
              WHERE host_id = #{item.hostId}
                AND host_ip = #{item.hostIp}
         </foreach>

snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/WorkflowMapper.xml

@@ -5,7 +5,8 @@
     <update id="updateBatchNextTriggerAtById" parameterType="java.util.List">
         <foreach collection="list" item="item" open="BEGIN" separator=";" close=";END;">
             UPDATE sj_workflow
-               SET next_trigger_at = #{item.nextTriggerAt}
+               SET next_trigger_at = #{item.nextTriggerAt},
+                   update_dt = CURRENT_TIMESTAMP
              WHERE id = #{item.id}
         </foreach>
     </update>

snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/JobMapper.xml

@@ -4,7 +4,8 @@
 
     <update id="updateBatchNextTriggerAtById" parameterType="java.util.List">
         UPDATE sj_job AS rt
-           SET next_trigger_at = tt.next_trigger_at
+           SET next_trigger_at = tt.next_trigger_at,
+               update_dt = CURRENT_TIMESTAMP
           FROM (
                 <foreach collection="list" item="item" index="index" separator="UNION ALL">
                     SELECT

snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/JobSummaryMapper.xml

@@ -10,7 +10,8 @@
                stop_num = tt.stop_num,
                stop_reason = tt.stop_reason,
                cancel_num = tt.cancel_num,
-               cancel_reason = tt.cancel_reason
+               cancel_reason = tt.cancel_reason,
+               update_dt = CURRENT_TIMESTAMP
           FROM (
                 <foreach collection="list" item="item" index="index" separator="UNION ALL">
                     SELECT

snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/RetrySummaryMapper.xml

@@ -7,7 +7,8 @@
            SET running_num = tt.running_num,
                finish_num = tt.finish_num,
                max_count_num = tt.max_count_num,
-               suspend_num = tt.suspend_num
+               suspend_num = tt.suspend_num,
+               update_dt = CURRENT_TIMESTAMP
           FROM (
                 <foreach collection="list" item="item" index="index" separator="UNION ALL">
                     SELECT

snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/RetryTaskLogMessageMapper.xml

@@ -13,7 +13,8 @@
                     </foreach>
                 ) tt
            SET rt.message = tt.message,
-               rt.log_num = tt.log_num
+               rt.log_num = tt.log_num,
+               rt.update_dt = CURRENT_TIMESTAMP
          WHERE rt.id = tt.id
     </update>
 

snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/RetryTaskMapper.xml

@@ -4,7 +4,8 @@
 
     <update id="updateBatchNextTriggerAtById" parameterType="java.util.List">
         UPDATE sj_retry_task_${partition} AS rt
-           SET next_trigger_at = tt.next_trigger_at
+           SET next_trigger_at = tt.next_trigger_at,
+               update_dt = CURRENT_TIMESTAMP
           FROM (
                 <foreach collection="list" item="item" index="index" separator="UNION ALL">
                     SELECT

snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/ServerNodeMapper.xml

@@ -4,7 +4,8 @@
 
     <update id="updateBatchExpireAt" parameterType="java.util.List">
         UPDATE sj_server_node AS rt
-           SET expire_at = tt.expire_at
+           SET expire_at = tt.expire_at,
+               update_dt = CURRENT_TIMESTAMP
           FROM (
                 <foreach collection="list" item="item" index="index" separator="UNION ALL">
                     SELECT

snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/WorkflowMapper.xml

@@ -4,7 +4,8 @@
 
     <update id="updateBatchNextTriggerAtById" parameterType="java.util.List">
         UPDATE sj_workflow AS rt
-           SET next_trigger_at = tt.next_trigger_at
+           SET next_trigger_at = tt.next_trigger_at,
+               update_dt = CURRENT_TIMESTAMP
          FROM (
                 <foreach collection="list" item="item" index="index" separator="UNION ALL">
                     SELECT

snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/JobMapper.xml

@@ -4,7 +4,8 @@
 
     <update id="updateBatchNextTriggerAtById" parameterType="java.util.List">
         UPDATE sj_job
-           SET next_trigger_at = src.next_trigger_at
+           SET next_trigger_at = src.next_trigger_at,
+               update_dt = CURRENT_TIMESTAMP
           FROM sj_job AS dest
                JOIN (
                    <foreach collection="list" item="item" index="index" separator="UNION ALL">

snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/JobSummaryMapper.xml

@@ -10,7 +10,8 @@
                stop_num = src.stop_num,
                stop_reason = src.stop_reason,
                cancel_num = src.cancel_num,
-               cancel_reason = src.cancel_reason
+               cancel_reason = src.cancel_reason,
+               update_dt = CURRENT_TIMESTAMP
           FROM sj_job_summary AS dest
                JOIN (
                    <foreach collection="list" item="item" index="index" separator="UNION ALL">

snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/RetrySummaryMapper.xml

@@ -7,7 +7,8 @@
            SET running_num = src.running_num,
                finish_num = src.finish_num,
                max_count_num = src.max_count_num,
-               suspend_num = src.suspend_num
+               suspend_num = src.suspend_num,
+               update_dt = CURRENT_TIMESTAMP
           FROM sj_retry_summary AS dest
                 JOIN (
                 <foreach collection="list" item="item" index="index" separator="UNION ALL">

snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/RetryTaskLogMessageMapper.xml

@@ -4,7 +4,9 @@
 
     <update id="updateBatch" parameterType="java.util.List">
         UPDATE sj_retry_task_log_message
-           SET message = src.message, log_num = src.log_num
+           SET message = src.message,
+               log_num = src.log_num,
+               update_dt = CURRENT_TIMESTAMP
           FROM sj_retry_task_log_message AS dest
                 JOIN (
                     <foreach collection="list" item="item" index="index" separator="UNION ALL">

snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/RetryTaskMapper.xml

@@ -4,7 +4,8 @@
 
     <update id="updateBatchNextTriggerAtById" parameterType="java.util.List">
         UPDATE sj_retry_task_${partition}
-           SET next_trigger_at = src.next_trigger_at
+           SET next_trigger_at = src.next_trigger_at,
+               update_dt = CURRENT_TIMESTAMP
           FROM sj_retry_task_${partition} AS target
                 JOIN (
                 <foreach collection="list" item="item" index="index" separator="UNION ALL">

snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/ServerNodeMapper.xml

@@ -4,7 +4,8 @@
 
     <update id="updateBatchExpireAt" parameterType="java.util.List">
         UPDATE sj_server_node
-           SET expire_at = src.expire_at
+           SET expire_at = src.expire_at,
+               update_dt = CURRENT_TIMESTAMP
           FROM sj_server_node AS dest
                JOIN (
                  <foreach collection="list" item="item" index="index" separator="UNION ALL">

snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/WorkflowMapper.xml

@@ -4,7 +4,8 @@
 
     <update id="updateBatchNextTriggerAtById" parameterType="java.util.List">
         UPDATE sj_workflow
-           SET next_trigger_at = src.next_trigger_at
+           SET next_trigger_at = src.next_trigger_at,
+               update_dt = CURRENT_TIMESTAMP
           FROM sj_workflow dest
                 JOIN (
                 <foreach collection="list" item="item" index="index" separator="UNION ALL">