diff --git a/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/JobLogMessageMapper.xml b/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/JobLogMessageMapper.xml index 01af54498..38c4686b2 100644 --- a/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/JobLogMessageMapper.xml +++ b/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/JobLogMessageMapper.xml @@ -18,7 +18,7 @@ - INSERT INTO job_log_message (namespace_id, group_name, job_id, task_batch_id, task_id, + 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 diff --git a/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/JobMapper.xml b/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/JobMapper.xml index e50500b81..5e116e7c9 100644 --- a/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/JobMapper.xml +++ b/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/JobMapper.xml @@ -27,7 +27,7 @@ - UPDATE job rt, + UPDATE sj_job rt, ( SELECT diff --git a/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/JobSummaryMapper.xml b/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/JobSummaryMapper.xml index c4054cf39..c53c8281d 100644 --- a/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/JobSummaryMapper.xml +++ b/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/JobSummaryMapper.xml @@ -20,7 +20,7 @@ - INSERT INTO job_summary (namespace_id, group_name, business_id, trigger_at, system_task_type, + 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 @@ -42,7 +42,7 @@ - UPDATE job_summary rt, + UPDATE sj_job_summary rt, ( SELECT @@ -77,7 +77,7 @@ IFNULL(SUM(cancel_num), 0) AS cancel, IFNULL(SUM(fail_num), 0) AS fail, IFNULL(SUM(success_num + fail_num + stop_num + cancel_num), 0) AS total - FROM job_summary + FROM sj_job_summary ${ew.customSqlSegment} GROUP BY DATE_FORMAT(trigger_at, #{dateFormat}) @@ -90,7 +90,7 @@ IFNULL(SUM(cancel_num), 0) AS cancelNum, IFNULL(SUM(fail_num), 0) AS failNum, IFNULL(SUM(success_num + fail_num + stop_num + cancel_num), 0) AS totalNum - FROM job_summary + FROM sj_job_summary ${ew.customSqlSegment} @@ -98,13 +98,13 @@ resultType="com.aizuda.snailjob.template.datasource.persistence.dataobject.DashboardRetryLineResponseDO$Rank"> SELECT - CONCAT(group_name, '/', (SELECT job_name FROM job WHERE id = business_id)) name, + CONCAT(group_name, '/', (SELECT job_name FROM sj_job WHERE id = business_id)) name, - CONCAT(group_name, '/', (SELECT workflow_name FROM workflow WHERE id = business_id)) name, + CONCAT(group_name, '/', (SELECT workflow_name FROM sj_workflow WHERE id = business_id)) name, SUM(fail_num) AS total - FROM job_summary + FROM sj_job_summary ${ew.customSqlSegment} HAVING total > 0 ORDER BY total DESC @@ -116,7 +116,7 @@ SELECT group_name AS groupName, SUM(CASE WHEN (job_status = 1) THEN 1 ELSE 0 END) AS run, COUNT(*) AS total - FROM job + FROM sj_job ${ew.customSqlSegment} GROUP BY namespace_id, group_name diff --git a/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/RetryDeadLetterMapper.xml b/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/RetryDeadLetterMapper.xml index 7e6f29336..d0283de8d 100644 --- a/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/RetryDeadLetterMapper.xml +++ b/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/RetryDeadLetterMapper.xml @@ -21,7 +21,7 @@ - INSERT INTO retry_dead_letter (namespace_id, unique_id, group_name, scene_name, + 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 ) diff --git a/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/RetrySummaryMapper.xml b/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/RetrySummaryMapper.xml index 4be439c30..9f41bb5e9 100644 --- a/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/RetrySummaryMapper.xml +++ b/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/RetrySummaryMapper.xml @@ -16,9 +16,8 @@ - INSERT INTO - retry_summary (namespace_id, group_name, scene_name, trigger_at, running_num, finish_num, max_count_num, - suspend_num) + INSERT INTO sj_retry_summary (namespace_id, group_name, scene_name, trigger_at, + running_num, finish_num, max_count_num, suspend_num) VALUES ( @@ -35,7 +34,7 @@ - UPDATE retry_summary rt, + UPDATE sj_retry_summary rt, ( SELECT @@ -66,7 +65,7 @@ IFNULL(SUM(max_count_num), 0) AS maxCountNum, IFNULL(SUM(suspend_num), 0) AS suspendNum, IFNULL(SUM(running_num + finish_num + max_count_num + suspend_num), 0) AS totalNum - FROM retry_summary + FROM sj_retry_summary ${ew.customSqlSegment} @@ -77,7 +76,7 @@ finish_num, max_count_num, suspend_num - FROM retry_summary + FROM sj_retry_summary ${ew.customSqlSegment} LIMIT 7 @@ -91,7 +90,7 @@ IFNULL(SUM(max_count_num), 0) AS maxCountNum, IFNULL(SUM(suspend_num), 0) AS suspendNum, IFNULL(SUM(finish_num + running_num + max_count_num + suspend_num), 0) AS total - FROM retry_summary + FROM sj_retry_summary ${ew.customSqlSegment} GROUP BY createDt @@ -100,7 +99,7 @@ resultType="com.aizuda.snailjob.template.datasource.persistence.dataobject.DashboardRetryLineResponseDO$Rank"> SELECT CONCAT(group_name, '/', scene_name) `name`, SUM(running_num + finish_num + max_count_num + suspend_num) AS total - FROM retry_summary + FROM sj_retry_summary ${ew.customSqlSegment} HAVING total > 0 ORDER BY total DESC @@ -112,7 +111,7 @@ SELECT group_name AS groupName, SUM(CASE WHEN (scene_status = 1) THEN 1 ELSE 0 END) AS run, COUNT(*) AS total - FROM scene_config + FROM sj_retry_scene_config ${ew.customSqlSegment} GROUP BY namespace_id, group_name diff --git a/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/RetryTaskLogMapper.xml b/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/RetryTaskLogMapper.xml index 5a99dc896..5494821e0 100644 --- a/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/RetryTaskLogMapper.xml +++ b/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/RetryTaskLogMapper.xml @@ -23,7 +23,7 @@ - INSERT INTO retry_task_log (unique_id, group_name, scene_name, idempotent_id, biz_no, executor_name, + INSERT INTO sj_retry_task_log (unique_id, group_name, scene_name, idempotent_id, biz_no, executor_name, args_str, ext_attrs, task_type, create_dt, namespace_id) VALUES @@ -43,7 +43,7 @@ SUM(CASE WHEN (retry_status = 1) THEN 1 ELSE 0 END) AS finishNum, SUM(CASE WHEN (retry_status = 2) THEN 1 ELSE 0 END) AS maxCountNum, SUM(CASE WHEN (retry_status = 3) THEN 1 ELSE 0 END) AS suspendNum - FROM retry_task_log + FROM sj_retry_task_log ${ew.customSqlSegment} diff --git a/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/RetryTaskLogMessageMapper.xml b/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/RetryTaskLogMessageMapper.xml index c829224cd..f596d795c 100644 --- a/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/RetryTaskLogMessageMapper.xml +++ b/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/RetryTaskLogMessageMapper.xml @@ -15,7 +15,7 @@ - INSERT INTO retry_task_log_message (namespace_id, group_name, unique_id, log_num, message, + INSERT INTO sj_retry_task_log_message (namespace_id, group_name, unique_id, log_num, message, create_dt, real_time) VALUES @@ -32,7 +32,7 @@ - UPDATE retry_task_log_message jlm, + UPDATE sj_retry_task_log_message jlm, ( SELECT diff --git a/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/RetryTaskMapper.xml b/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/RetryTaskMapper.xml index 51494dd6a..a0760f85d 100644 --- a/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/RetryTaskMapper.xml +++ b/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/RetryTaskMapper.xml @@ -27,7 +27,7 @@ - INSERT INTO retry_task (namespace_id, unique_id, group_name, scene_name, idempotent_id, biz_no, executor_name, args_str, ext_attrs, next_trigger_at, task_type, retry_status, create_dt) + INSERT INTO sj_retry_task (namespace_id, unique_id, group_name, scene_name, idempotent_id, biz_no, executor_name, args_str, ext_attrs, next_trigger_at, task_type, retry_status, create_dt) VALUES ( @@ -49,7 +49,7 @@ - UPDATE retry_task_${partition} rt, + UPDATE sj_retry_task_${partition} rt, ( SELECT diff --git a/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/ServerNodeMapper.xml b/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/ServerNodeMapper.xml index 100a0cda9..c99e157cc 100644 --- a/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/ServerNodeMapper.xml +++ b/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/ServerNodeMapper.xml @@ -40,7 +40,7 @@ - UPDATE server_node rt, + UPDATE sj_server_node rt, ( SELECT @@ -58,7 +58,7 @@ resultType="com.aizuda.snailjob.template.datasource.persistence.dataobject.ActivePodQuantityResponseDO"> SELECT node_type AS nodeType, COUNT(*) AS total - FROM server_node + FROM sj_server_node ${ew.customSqlSegment} diff --git a/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/WorkflowMapper.xml b/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/WorkflowMapper.xml index b8f7e198d..ff3add74b 100644 --- a/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/WorkflowMapper.xml +++ b/snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/WorkflowMapper.xml @@ -17,7 +17,7 @@ - UPDATE workflow rt, + UPDATE sj_workflow rt, ( SELECT