diff --git a/snail-job-datasource/snail-job-datasource-template/src/main/resources/template/mapper/JobLogMessageMapper.xml b/snail-job-datasource/snail-job-datasource-template/src/main/resources/template/mapper/JobLogMessageMapper.xml index 2ed968db..2a0c4cfa 100644 --- a/snail-job-datasource/snail-job-datasource-template/src/main/resources/template/mapper/JobLogMessageMapper.xml +++ b/snail-job-datasource/snail-job-datasource-template/src/main/resources/template/mapper/JobLogMessageMapper.xml @@ -2,38 +2,30 @@ + + #{item.namespaceId}, + #{item.groupName}, + #{item.jobId}, + #{item.taskBatchId}, + #{item.taskId}, + #{item.logNum}, + #{item.message}, + #{item.createDt}, + #{item.realTime} + + INSERT INTO sj_job_log_message (namespace_id, group_name, job_id, task_batch_id, task_id, log_num, message, create_dt, real_time) VALUES - - ( - #{item.namespaceId}, - #{item.groupName}, - #{item.jobId}, - #{item.taskBatchId}, - #{item.taskId}, - #{item.logNum}, - #{item.message}, - #{item.createDt}, - #{item.realTime} - ) + + - - SELECT - #{item.namespaceId}, - #{item.groupName}, - #{item.jobId}, - #{item.taskBatchId}, - #{item.taskId}, - #{item.logNum}, - #{item.message}, - #{item.createDt}, - #{item.realTime} - FROM DUAL + + diff --git a/snail-job-datasource/snail-job-datasource-template/src/main/resources/template/mapper/JobSummaryMapper.xml b/snail-job-datasource/snail-job-datasource-template/src/main/resources/template/mapper/JobSummaryMapper.xml index 8e4a5fcb..3a4f1aab 100644 --- a/snail-job-datasource/snail-job-datasource-template/src/main/resources/template/mapper/JobSummaryMapper.xml +++ b/snail-job-datasource/snail-job-datasource-template/src/main/resources/template/mapper/JobSummaryMapper.xml @@ -2,44 +2,33 @@ + + #{item.namespaceId}, + #{item.groupName}, + #{item.businessId}, + #{item.triggerAt}, + #{item.systemTaskType}, + #{item.successNum}, + #{item.failNum}, + #{item.failReason}, + #{item.stopNum}, + #{item.stopReason}, + #{item.cancelNum}, + #{item.cancelReason} + + INSERT INTO sj_job_summary (namespace_id, group_name, business_id, trigger_at, system_task_type, success_num,fail_num,fail_reason,stop_num,stop_reason, cancel_num,cancel_reason) VALUES - - ( - #{item.namespaceId}, - #{item.groupName}, - #{item.businessId}, - #{item.triggerAt}, - #{item.systemTaskType}, - #{item.successNum}, - #{item.failNum}, - #{item.failReason}, - #{item.stopNum}, - #{item.stopReason}, - #{item.cancelNum}, - #{item.cancelReason} - ) + + - - SELECT - #{item.namespaceId}, - #{item.groupName}, - #{item.businessId}, - #{item.triggerAt}, - #{item.systemTaskType}, - #{item.successNum}, - #{item.failNum}, - #{item.failReason}, - #{item.stopNum}, - #{item.stopReason}, - #{item.cancelNum}, - #{item.cancelReason} - FROM DUAL + + diff --git a/snail-job-datasource/snail-job-datasource-template/src/main/resources/template/mapper/JobTaskMapper.xml b/snail-job-datasource/snail-job-datasource-template/src/main/resources/template/mapper/JobTaskMapper.xml index 2ae359ed..1840c931 100644 --- a/snail-job-datasource/snail-job-datasource-template/src/main/resources/template/mapper/JobTaskMapper.xml +++ b/snail-job-datasource/snail-job-datasource-template/src/main/resources/template/mapper/JobTaskMapper.xml @@ -2,33 +2,42 @@ - - + + #{item.namespaceId}, + #{item.groupName}, + #{item.jobId}, + #{item.taskBatchId}, + #{item.parentId}, + #{item.taskStatus}, + #{item.retryCount}, + #{item.mrStage}, + #{item.leaf}, + #{item.taskName}, + #{item.clientInfo}, + #{item.wfContext}, + #{item.argsStr}, + #{item.resultMessage}, + #{item.argsType}, + #{item.extAttrs}, + #{item.createDt}, + #{item.updateDt} + + + INSERT INTO sj_job_task (namespace_id, group_name, job_id, task_batch_id, parent_id, task_status, - retry_count, mr_stage, leaf, task_name, client_info, wf_context, args_str, result_message, args_type, ext_attrs, - create_dt, update_dt) - VALUES - - ( - #{item.namespaceId}, - #{item.groupName}, - #{item.jobId}, - #{item.taskBatchId}, - #{item.parentId}, - #{item.taskStatus}, - #{item.retryCount}, - #{item.mrStage}, - #{item.leaf}, - #{item.taskName}, - #{item.clientInfo}, - #{item.wfContext}, - #{item.argsStr}, - #{item.resultMessage}, - #{item.argsType}, - #{item.extAttrs}, - #{item.createDt}, - #{item.updateDt} - ) - + retry_count, mr_stage, leaf, task_name, client_info, wf_context, args_str, + result_message, args_type, ext_attrs, create_dt, update_dt) + + VALUES + + + + + + + + + + diff --git a/snail-job-datasource/snail-job-datasource-template/src/main/resources/template/mapper/RetryDeadLetterMapper.xml b/snail-job-datasource/snail-job-datasource-template/src/main/resources/template/mapper/RetryDeadLetterMapper.xml index ab7de289..a5c12b91 100644 --- a/snail-job-datasource/snail-job-datasource-template/src/main/resources/template/mapper/RetryDeadLetterMapper.xml +++ b/snail-job-datasource/snail-job-datasource-template/src/main/resources/template/mapper/RetryDeadLetterMapper.xml @@ -2,43 +2,34 @@ - - INSERT INTO sj_retry_dead_letter (namespace_id, unique_id, group_name, scene_name, - idempotent_id, biz_no, executor_name, args_str, - ext_attrs, create_dt) - - VALUES - - ( - #{item.namespaceId,jdbcType=VARCHAR}, - #{item.uniqueId,jdbcType=VARCHAR}, - #{item.groupName,jdbcType=VARCHAR}, - #{item.sceneName,jdbcType=VARCHAR}, - #{item.idempotentId,jdbcType=VARCHAR}, - #{item.bizNo,jdbcType=VARCHAR}, - #{item.executorName,jdbcType=VARCHAR}, - #{item.argsStr,jdbcType=VARCHAR}, - #{item.extAttrs,jdbcType=VARCHAR}, - #{item.createDt,jdbcType=TIMESTAMP} - ) - - - - - SELECT - #{item.namespaceId,jdbcType=VARCHAR}, - #{item.uniqueId,jdbcType=VARCHAR}, - #{item.groupName,jdbcType=VARCHAR}, - #{item.sceneName,jdbcType=VARCHAR}, - #{item.idempotentId,jdbcType=VARCHAR}, - #{item.bizNo,jdbcType=VARCHAR}, - #{item.executorName,jdbcType=VARCHAR}, - #{item.argsStr,jdbcType=VARCHAR}, - #{item.extAttrs,jdbcType=VARCHAR}, - #{item.createDt,jdbcType=TIMESTAMP} - FROM DUAL - - - + + #{item.namespaceId,jdbcType=VARCHAR}, + #{item.uniqueId,jdbcType=VARCHAR}, + #{item.groupName,jdbcType=VARCHAR}, + #{item.sceneName,jdbcType=VARCHAR}, + #{item.idempotentId,jdbcType=VARCHAR}, + #{item.bizNo,jdbcType=VARCHAR}, + #{item.executorName,jdbcType=VARCHAR}, + #{item.argsStr,jdbcType=VARCHAR}, + #{item.extAttrs,jdbcType=VARCHAR}, + #{item.createDt,jdbcType=TIMESTAMP} + + + + INSERT INTO sj_retry_dead_letter (namespace_id, unique_id, group_name, scene_name, + idempotent_id, biz_no, executor_name, args_str, + ext_attrs, create_dt) + + VALUES + + + + + + + + + + diff --git a/snail-job-datasource/snail-job-datasource-template/src/main/resources/template/mapper/RetrySummaryMapper.xml b/snail-job-datasource/snail-job-datasource-template/src/main/resources/template/mapper/RetrySummaryMapper.xml index cacbdb25..1957270e 100644 --- a/snail-job-datasource/snail-job-datasource-template/src/main/resources/template/mapper/RetrySummaryMapper.xml +++ b/snail-job-datasource/snail-job-datasource-template/src/main/resources/template/mapper/RetrySummaryMapper.xml @@ -2,39 +2,31 @@ + + #{item.namespaceId}, + #{item.groupName}, + #{item.sceneName}, + #{item.triggerAt}, + #{item.runningNum}, + #{item.finishNum}, + #{item.maxCountNum}, + #{item.suspendNum} + + INSERT INTO sj_retry_summary (namespace_id, group_name, scene_name, trigger_at, running_num, finish_num, max_count_num, suspend_num) VALUES - - ( - #{item.namespaceId}, - #{item.groupName}, - #{item.sceneName}, - #{item.triggerAt}, - #{item.runningNum}, - #{item.finishNum}, - #{item.maxCountNum}, - #{item.suspendNum} - ) + + - - SELECT - #{item.namespaceId}, - #{item.groupName}, - #{item.sceneName}, - #{item.triggerAt}, - #{item.runningNum}, - #{item.finishNum}, - #{item.maxCountNum}, - #{item.suspendNum} - FROM DUAL + + -