From 6bdbd2c41e0bd8630a2af3d3680695b46e16c53b Mon Sep 17 00:00:00 2001 From: dhb52 Date: Sat, 22 Jun 2024 15:53:14 +0800 Subject: [PATCH] =?UTF-8?q?wip(sj=5F1.1.0-beta1):=20updateBatch=E7=B3=BB?= =?UTF-8?q?=E5=88=97=E8=84=9A=E6=9C=AC=E5=A2=9E=E5=8A=A0update=5Fdt=3DCURR?= =?UTF-8?q?ENT=5FTIMESTAMP?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/resources/dm/mapper/JobMapper.xml | 3 ++- .../src/main/resources/dm/mapper/JobSummaryMapper.xml | 3 ++- .../src/main/resources/dm/mapper/RetrySummaryMapper.xml | 3 ++- .../main/resources/dm/mapper/RetryTaskLogMessageMapper.xml | 3 ++- .../src/main/resources/dm/mapper/RetryTaskMapper.xml | 3 ++- .../src/main/resources/dm/mapper/ServerNodeMapper.xml | 3 ++- .../src/main/resources/dm/mapper/WorkflowMapper.xml | 3 ++- .../src/main/resources/oracle/mapper/JobMapper.xml | 3 ++- .../src/main/resources/oracle/mapper/JobSummaryMapper.xml | 3 ++- .../src/main/resources/oracle/mapper/RetrySummaryMapper.xml | 3 ++- .../resources/oracle/mapper/RetryTaskLogMessageMapper.xml | 3 ++- .../src/main/resources/oracle/mapper/RetryTaskMapper.xml | 3 ++- .../src/main/resources/oracle/mapper/ServerNodeMapper.xml | 3 ++- .../src/main/resources/oracle/mapper/WorkflowMapper.xml | 3 ++- .../src/main/resources/postgresql/mapper/JobMapper.xml | 3 ++- .../src/main/resources/postgresql/mapper/JobSummaryMapper.xml | 3 ++- .../main/resources/postgresql/mapper/RetrySummaryMapper.xml | 3 ++- .../resources/postgresql/mapper/RetryTaskLogMessageMapper.xml | 3 ++- .../src/main/resources/postgresql/mapper/RetryTaskMapper.xml | 3 ++- .../src/main/resources/postgresql/mapper/ServerNodeMapper.xml | 3 ++- .../src/main/resources/postgresql/mapper/WorkflowMapper.xml | 3 ++- .../src/main/resources/sqlserver/mapper/JobMapper.xml | 3 ++- .../src/main/resources/sqlserver/mapper/JobSummaryMapper.xml | 3 ++- .../main/resources/sqlserver/mapper/RetrySummaryMapper.xml | 3 ++- .../resources/sqlserver/mapper/RetryTaskLogMessageMapper.xml | 4 +++- .../src/main/resources/sqlserver/mapper/RetryTaskMapper.xml | 3 ++- .../src/main/resources/sqlserver/mapper/ServerNodeMapper.xml | 3 ++- .../src/main/resources/sqlserver/mapper/WorkflowMapper.xml | 3 ++- 28 files changed, 57 insertions(+), 28 deletions(-) diff --git a/snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/JobMapper.xml b/snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/JobMapper.xml index 17fa63ba..4b00e9b0 100644 --- a/snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/JobMapper.xml +++ b/snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/JobMapper.xml @@ -5,7 +5,8 @@ UPDATE sj_job - SET next_trigger_at = #{item.nextTriggerAt} + SET next_trigger_at = #{item.nextTriggerAt}, + update_dt = CURRENT_TIMESTAMP WHERE id = #{item.id} diff --git a/snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/JobSummaryMapper.xml b/snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/JobSummaryMapper.xml index f55cf529..c6da109e 100644 --- a/snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/JobSummaryMapper.xml +++ b/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} diff --git a/snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/RetrySummaryMapper.xml b/snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/RetrySummaryMapper.xml index 0831c9dd..6ccc037b 100644 --- a/snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/RetrySummaryMapper.xml +++ b/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} diff --git a/snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/RetryTaskLogMessageMapper.xml b/snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/RetryTaskLogMessageMapper.xml index 4baa7e44..61e81f84 100644 --- a/snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/RetryTaskLogMessageMapper.xml +++ b/snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/RetryTaskLogMessageMapper.xml @@ -5,7 +5,8 @@ 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} diff --git a/snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/RetryTaskMapper.xml b/snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/RetryTaskMapper.xml index 28af87c1..2c904a37 100644 --- a/snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/RetryTaskMapper.xml +++ b/snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/RetryTaskMapper.xml @@ -5,7 +5,8 @@ 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} diff --git a/snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/ServerNodeMapper.xml b/snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/ServerNodeMapper.xml index 92f29cfa..1e7a1b21 100644 --- a/snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/ServerNodeMapper.xml +++ b/snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/ServerNodeMapper.xml @@ -5,7 +5,8 @@ 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} diff --git a/snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/WorkflowMapper.xml b/snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/WorkflowMapper.xml index 47eac4bb..5b8ac1e9 100644 --- a/snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/WorkflowMapper.xml +++ b/snail-job-datasource/snail-job-dm8-datasource/src/main/resources/dm/mapper/WorkflowMapper.xml @@ -5,7 +5,8 @@ UPDATE sj_workflow - SET next_trigger_at = #{item.nextTriggerAt} + SET next_trigger_at = #{item.nextTriggerAt}, + update_dt = CURRENT_TIMESTAMP WHERE id = #{item.id} diff --git a/snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/JobMapper.xml b/snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/JobMapper.xml index 17fa63ba..4b00e9b0 100644 --- a/snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/JobMapper.xml +++ b/snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/JobMapper.xml @@ -5,7 +5,8 @@ UPDATE sj_job - SET next_trigger_at = #{item.nextTriggerAt} + SET next_trigger_at = #{item.nextTriggerAt}, + update_dt = CURRENT_TIMESTAMP WHERE id = #{item.id} diff --git a/snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/JobSummaryMapper.xml b/snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/JobSummaryMapper.xml index f55cf529..c6da109e 100644 --- a/snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/JobSummaryMapper.xml +++ b/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} diff --git a/snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/RetrySummaryMapper.xml b/snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/RetrySummaryMapper.xml index 712d2a82..6b85ab64 100644 --- a/snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/RetrySummaryMapper.xml +++ b/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} diff --git a/snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/RetryTaskLogMessageMapper.xml b/snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/RetryTaskLogMessageMapper.xml index 4baa7e44..61e81f84 100644 --- a/snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/RetryTaskLogMessageMapper.xml +++ b/snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/RetryTaskLogMessageMapper.xml @@ -5,7 +5,8 @@ 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} diff --git a/snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/RetryTaskMapper.xml b/snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/RetryTaskMapper.xml index 28af87c1..2c904a37 100644 --- a/snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/RetryTaskMapper.xml +++ b/snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/RetryTaskMapper.xml @@ -5,7 +5,8 @@ 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} diff --git a/snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/ServerNodeMapper.xml b/snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/ServerNodeMapper.xml index 92f29cfa..1e7a1b21 100644 --- a/snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/ServerNodeMapper.xml +++ b/snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/ServerNodeMapper.xml @@ -5,7 +5,8 @@ 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} diff --git a/snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/WorkflowMapper.xml b/snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/WorkflowMapper.xml index 54abf2cb..20c9436c 100644 --- a/snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/WorkflowMapper.xml +++ b/snail-job-datasource/snail-job-oracle-datasource/src/main/resources/oracle/mapper/WorkflowMapper.xml @@ -5,7 +5,8 @@ UPDATE sj_workflow - SET next_trigger_at = #{item.nextTriggerAt} + SET next_trigger_at = #{item.nextTriggerAt}, + update_dt = CURRENT_TIMESTAMP WHERE id = #{item.id} diff --git a/snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/JobMapper.xml b/snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/JobMapper.xml index d70be508..5aec43a8 100644 --- a/snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/JobMapper.xml +++ b/snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/JobMapper.xml @@ -4,7 +4,8 @@ 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 ( SELECT diff --git a/snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/JobSummaryMapper.xml b/snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/JobSummaryMapper.xml index cc91ee8d..ecb5725d 100644 --- a/snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/JobSummaryMapper.xml +++ b/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 ( SELECT diff --git a/snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/RetrySummaryMapper.xml b/snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/RetrySummaryMapper.xml index 591a5605..a94ce6dd 100644 --- a/snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/RetrySummaryMapper.xml +++ b/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 ( SELECT diff --git a/snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/RetryTaskLogMessageMapper.xml b/snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/RetryTaskLogMessageMapper.xml index 6f6a83f1..c09eeb3d 100644 --- a/snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/RetryTaskLogMessageMapper.xml +++ b/snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/RetryTaskLogMessageMapper.xml @@ -13,7 +13,8 @@ ) 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 diff --git a/snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/RetryTaskMapper.xml b/snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/RetryTaskMapper.xml index 8eff6f32..4c9bc35e 100644 --- a/snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/RetryTaskMapper.xml +++ b/snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/RetryTaskMapper.xml @@ -4,7 +4,8 @@ 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 ( SELECT diff --git a/snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/ServerNodeMapper.xml b/snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/ServerNodeMapper.xml index 4efad6ee..af84c9de 100644 --- a/snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/ServerNodeMapper.xml +++ b/snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/ServerNodeMapper.xml @@ -4,7 +4,8 @@ UPDATE sj_server_node AS rt - SET expire_at = tt.expire_at + SET expire_at = tt.expire_at, + update_dt = CURRENT_TIMESTAMP FROM ( SELECT diff --git a/snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/WorkflowMapper.xml b/snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/WorkflowMapper.xml index 56bc8eb8..f402bb30 100644 --- a/snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/WorkflowMapper.xml +++ b/snail-job-datasource/snail-job-postgres-datasource/src/main/resources/postgresql/mapper/WorkflowMapper.xml @@ -4,7 +4,8 @@ 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 ( SELECT diff --git a/snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/JobMapper.xml b/snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/JobMapper.xml index 2883f3b4..3a59b076 100644 --- a/snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/JobMapper.xml +++ b/snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/JobMapper.xml @@ -4,7 +4,8 @@ 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 ( diff --git a/snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/JobSummaryMapper.xml b/snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/JobSummaryMapper.xml index f37c883e..3518a2a5 100644 --- a/snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/JobSummaryMapper.xml +++ b/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 ( diff --git a/snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/RetrySummaryMapper.xml b/snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/RetrySummaryMapper.xml index fd720d3f..75acc817 100644 --- a/snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/RetrySummaryMapper.xml +++ b/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 ( diff --git a/snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/RetryTaskLogMessageMapper.xml b/snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/RetryTaskLogMessageMapper.xml index ab28b0c2..b170dec0 100644 --- a/snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/RetryTaskLogMessageMapper.xml +++ b/snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/RetryTaskLogMessageMapper.xml @@ -4,7 +4,9 @@ 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 ( diff --git a/snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/RetryTaskMapper.xml b/snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/RetryTaskMapper.xml index db5a0cdf..940b7427 100644 --- a/snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/RetryTaskMapper.xml +++ b/snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/RetryTaskMapper.xml @@ -4,7 +4,8 @@ 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 ( diff --git a/snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/ServerNodeMapper.xml b/snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/ServerNodeMapper.xml index fd6b05b7..fad6e588 100644 --- a/snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/ServerNodeMapper.xml +++ b/snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/ServerNodeMapper.xml @@ -4,7 +4,8 @@ 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 ( diff --git a/snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/WorkflowMapper.xml b/snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/WorkflowMapper.xml index 7f84cc51..cc22cfa0 100644 --- a/snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/WorkflowMapper.xml +++ b/snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/WorkflowMapper.xml @@ -4,7 +4,8 @@ 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 (