gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

feat: snail-job_1.0.0 sqlserver 迁移

Browse Source
This commit is contained in:
dhb52 2024-05-13 23:51:42 +08:00
parent a78b1eece4
commit 6bf992651d
11 changed files with 1766 additions and 1822 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3455
doc/sql/snail_job_sqlserver.sql
View File

File diff suppressed because it is too large Load Diff

2
snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/JobLogMessageMapper.xml
View File

@ -18,7 +18,7 @@
<!-- 定义批量新增的 SQL 映射 --> <!-- 定义批量新增的 SQL 映射 -->
<insert id="batchInsert" parameterType="java.util.List"> <insert id="batchInsert" parameterType="java.util.List">
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) log_num, message, create_dt, real_time)
VALUES VALUES
<foreach collection="list" item="item" separator=","> <foreach collection="list" item="item" separator=",">

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

@ -27,9 +27,9 @@
</resultMap> </resultMap>
<update id="updateBatchNextTriggerAtById" parameterType="java.util.List"> <update id="updateBatchNextTriggerAtById" parameterType="java.util.List">
UPDATE job UPDATE sj_job
SET next_trigger_at = src.next_trigger_at SET next_trigger_at = src.next_trigger_at
FROM job AS dest FROM sj_job AS dest
JOIN ( JOIN (
<foreach collection="list" item="item" index="index" separator="UNION ALL"> <foreach collection="list" item="item" index="index" separator="UNION ALL">
SELECT SELECT

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

@ -20,7 +20,7 @@
</resultMap> </resultMap>
<insert id="batchInsert" parameterType="java.util.List" useGeneratedKeys="true" keyProperty="id"> <insert id="batchInsert" parameterType="java.util.List" useGeneratedKeys="true" keyProperty="id">
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) success_num,fail_num,fail_reason,stop_num,stop_reason, cancel_num,cancel_reason)
VALUES VALUES
<foreach collection="list" item="item" separator=","> <foreach collection="list" item="item" separator=",">
@ -42,7 +42,7 @@
</insert> </insert>
<update id="batchUpdate" parameterType="java.util.List"> <update id="batchUpdate" parameterType="java.util.List">
UPDATE job_summary UPDATE sj_job_summary
SET success_num = src.success_num, SET success_num = src.success_num,
fail_num = src.fail_num, fail_num = src.fail_num,
fail_reason = src.fail_reason, fail_reason = src.fail_reason,
@ -50,7 +50,7 @@
stop_reason = src.stop_reason, stop_reason = src.stop_reason,
cancel_num = src.cancel_num, cancel_num = src.cancel_num,
cancel_reason = src.cancel_reason cancel_reason = src.cancel_reason
FROM job_summary AS dest FROM sj_job_summary AS dest
JOIN ( JOIN (
<foreach collection="list" item="item" index="index" separator="UNION ALL"> <foreach collection="list" item="item" index="index" separator="UNION ALL">
SELECT SELECT
@ -84,7 +84,7 @@
stop_num, stop_num,
cancel_num, cancel_num,
fail_num fail_num
FROM job_summary FROM sj_job_summary
${ew.customSqlSegment} ${ew.customSqlSegment}
) AS subquery ) AS subquery
GROUP BY createDt GROUP BY createDt
@ -98,22 +98,21 @@
ISNULL(sum(cancel_num), 0) AS cancelNum, ISNULL(sum(cancel_num), 0) AS cancelNum,
ISNULL(sum(fail_num), 0) AS failNum, ISNULL(sum(fail_num), 0) AS failNum,
ISNULL(sum(success_num + fail_num + stop_num + cancel_num), 0) AS totalNum ISNULL(sum(success_num + fail_num + stop_num + cancel_num), 0) AS totalNum
FROM job_summary FROM sj_job_summary
${ew.customSqlSegment} ${ew.customSqlSegment}
</select> </select>
<select id="dashboardRank" <select id="dashboardRank"
resultType="com.aizuda.snailjob.template.datasource.persistence.dataobject.DashboardRetryLineResponseDO$Rank"> resultType="com.aizuda.snailjob.template.datasource.persistence.dataobject.DashboardRetryLineResponseDO$Rank">
SELECT TOP 10 SELECT TOP 10
<if test="systemTaskType == 3"> <if test="systemTaskType == 3">
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,
</if> </if>
<if test="systemTaskType == 4"> <if test="systemTaskType == 4">
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,
</if> </if>
SUM(fail_num) AS total SUM(fail_num) AS total
FROM job_summary FROM sj_job_summary
${ew.customSqlSegment} ${ew.customSqlSegment}
HAVING SUM(fail_num) > 0 HAVING SUM(fail_num) > 0
ORDER BY name DESC ORDER BY name DESC
@ -126,7 +125,7 @@
group_name AS groupName, group_name AS groupName,
SUM(CASE WHEN (job_status = 1) THEN 1 ELSE 0 END) AS run, SUM(CASE WHEN (job_status = 1) THEN 1 ELSE 0 END) AS run,
COUNT(*) AS total COUNT(*) AS total
FROM job FROM sj_job
${ew.customSqlSegment} ${ew.customSqlSegment}
GROUP BY namespace_id, group_name GROUP BY namespace_id, group_name
ORDER BY group_name ORDER BY group_name
@ -136,7 +135,7 @@
SQL Server SELECT COUNT(*) FROM (... ORDER BY ) 会报错 --> SQL Server SELECT COUNT(*) FROM (... ORDER BY ) 会报错 -->
<select id="countJobTask" resultType="long"> <select id="countJobTask" resultType="long">
SELECT COUNT(DISTINCT group_name) SELECT COUNT(DISTINCT group_name)
FROM job FROM sj_job
${ew.customSqlSegment} ${ew.customSqlSegment}
</select> </select>
</mapper> </mapper>

2
snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/RetryDeadLetterMapper.xml
View File

@ -21,7 +21,7 @@
</sql> </sql>
<insert id="insertBatch"> <insert id="insertBatch">
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, idempotent_id, biz_no, executor_name, args_str,
ext_attrs, create_dt) ext_attrs, create_dt)
values values

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

@ -16,47 +16,44 @@
</resultMap> </resultMap>
<insert id="batchInsert" parameterType="java.util.List" useGeneratedKeys="true" keyProperty="id"> <insert id="batchInsert" parameterType="java.util.List" useGeneratedKeys="true" keyProperty="id">
INSERT INTO INSERT INTO sj_retry_summary (namespace_id, group_name, scene_name, trigger_at,
retry_summary (namespace_id, group_name, scene_name, trigger_at, running_num, finish_num, max_count_num, running_num, finish_num, max_count_num, suspend_num)
suspend_num)
VALUES VALUES
<foreach collection="list" item="item" separator=","> <foreach collection="list" item="item" separator=",">
( (
#{item.namespaceId}, #{item.namespaceId},
#{item.groupName}, #{item.groupName},
#{item.sceneName}, #{item.sceneName},
#{item.triggerAt}, #{item.triggerAt},
#{item.runningNum}, #{item.runningNum},
#{item.finishNum}, #{item.finishNum},
#{item.maxCountNum}, #{item.maxCountNum},
#{item.suspendNum} #{item.suspendNum}
) )
</foreach> </foreach>
</insert> </insert>
<update id="batchUpdate" parameterType="java.util.List"> <update id="batchUpdate" parameterType="java.util.List">
UPDATE retry_summary UPDATE sj_retry_summary
SET running_num = src.running_num, SET running_num = src.running_num,
finish_num = src.finish_num, finish_num = src.finish_num,
max_count_num = src.max_count_num, max_count_num = src.max_count_num,
suspend_num = src.suspend_num suspend_num = src.suspend_num
FROM retry_summary AS dest FROM sj_retry_summary AS dest
JOIN ( JOIN (
<foreach collection="list" item="item" index="index" separator="UNION ALL"> <foreach collection="list" item="item" index="index" separator="UNION ALL">
SELECT SELECT
#{item.runningNum} AS running_num, #{item.runningNum} AS running_num,
#{item.finishNum} AS finish_num, #{item.finishNum} AS finish_num,
#{item.maxCountNum} AS max_count_num, #{item.maxCountNum} AS max_count_num,
#{item.suspendNum} AS suspend_num, #{item.suspendNum} AS suspend_num,
#{item.triggerAt} AS trigger_at, #{item.triggerAt} AS trigger_at,
#{item.sceneName} AS scene_name, #{item.sceneName} AS scene_name,
#{item.namespaceId} AS namespace_id, #{item.namespaceId} AS namespace_id,
#{item.groupName} AS group_name #{item.groupName} AS group_name
</foreach> </foreach>
) AS src ) AS src ON (dest.trigger_at = src.trigger_at AND dest.group_name = src.group_name
ON (dest.trigger_at = src.trigger_at AND dest.group_name = src.group_name AND dest.scene_name = src.scene_name AND dest.namespace_id = src.namespace_id)
AND dest.scene_name = src.scene_name AND dest.namespace_id = src.namespace_id
)
</update> </update>
<select id="retryTask" <select id="retryTask"
@ -79,7 +76,7 @@
finish_num, finish_num,
max_count_num, max_count_num,
suspend_num suspend_num
FROM retry_summary FROM sj_retry_summary
${ew.customSqlSegment} ${ew.customSqlSegment}
</select> </select>
@ -99,7 +96,7 @@
running_num, running_num,
max_count_num, max_count_num,
suspend_num suspend_num
FROM retry_summary FROM sj_retry_summary
${ew.customSqlSegment} ${ew.customSqlSegment}
) AS subquery ) AS subquery
GROUP BY createDt GROUP BY createDt
@ -110,7 +107,7 @@
SELECT TOP 10 SELECT TOP 10
CONCAT(group_name, '/', scene_name) AS name, CONCAT(group_name, '/', scene_name) AS name,
SUM(running_num + finish_num + max_count_num + suspend_num) AS total SUM(running_num + finish_num + max_count_num + suspend_num) AS total
FROM retry_summary FROM sj_retry_summary
${ew.customSqlSegment} ${ew.customSqlSegment}
HAVING SUM(running_num + finish_num + max_count_num + suspend_num) > 0 HAVING SUM(running_num + finish_num + max_count_num + suspend_num) > 0
ORDER BY total DESC ORDER BY total DESC
@ -123,7 +120,7 @@
group_name AS groupName, group_name AS groupName,
SUM(CASE WHEN (scene_status = 1) THEN 1 ELSE 0 END) AS run, SUM(CASE WHEN (scene_status = 1) THEN 1 ELSE 0 END) AS run,
COUNT(*) AS total COUNT(*) AS total
FROM scene_config FROM sj_retry_scene_config
${ew.customSqlSegment} ${ew.customSqlSegment}
GROUP BY namespace_id, group_name GROUP BY namespace_id, group_name
ORDER BY group_name ORDER BY group_name
@ -133,7 +130,7 @@
SQL Server SELECT COUNT(*) FROM (... ORDER BY group_name) 会报错 --> SQL Server SELECT COUNT(*) FROM (... ORDER BY group_name) 会报错 -->
<select id="countRetryTask" resultType="long"> <select id="countRetryTask" resultType="long">
SELECT COUNT(DISTINCT group_name) SELECT COUNT(DISTINCT group_name)
FROM scene_config FROM sj_retry_scene_config
${ew.customSqlSegment} ${ew.customSqlSegment}
</select> </select>
</mapper> </mapper>

4
snail-job-datasource/snail-job-sqlserver-datasource/src/main/resources/sqlserver/mapper/RetryTaskLogMapper.xml
View File

@ -24,7 +24,7 @@
<!-- 定义批量新增的 SQL 映射 --> <!-- 定义批量新增的 SQL 映射 -->
<insert id="batchInsert" parameterType="java.util.List"> <insert id="batchInsert" parameterType="java.util.List">
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) args_str, ext_attrs, task_type, create_dt, namespace_id)
VALUES VALUES
<foreach collection="list" item="item" separator=","> <foreach collection="list" item="item" separator=",">
@ -44,7 +44,7 @@
SUM(CASE WHEN (retry_status = 1) THEN 1 ELSE 0 END) AS finishNum, 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 = 2) THEN 1 ELSE 0 END) AS maxCountNum,
SUM(CASE WHEN (retry_status = 3) THEN 1 ELSE 0 END) AS suspendNum SUM(CASE WHEN (retry_status = 3) THEN 1 ELSE 0 END) AS suspendNum
FROM retry_task_log FROM sj_retry_task_log
${ew.customSqlSegment} ${ew.customSqlSegment}
</select> </select>
</mapper> </mapper>

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

@ -15,7 +15,7 @@
<!-- 定义批量新增的 SQL 映射 --> <!-- 定义批量新增的 SQL 映射 -->
<insert id="batchInsert" parameterType="java.util.List"> <insert id="batchInsert" parameterType="java.util.List">
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) create_dt, real_time)
VALUES VALUES
<foreach collection="list" item="item" separator=","> <foreach collection="list" item="item" separator=",">
@ -32,9 +32,9 @@
</insert> </insert>
<update id="batchUpdate" parameterType="java.util.List"> <update id="batchUpdate" parameterType="java.util.List">
UPDATE retry_task_log_message UPDATE sj_retry_task_log_message
SET message = src.message, log_num = src.log_num SET message = src.message, log_num = src.log_num
FROM retry_task_log_message AS dest FROM sj_retry_task_log_message AS dest
JOIN ( JOIN (
<foreach collection="list" item="item" index="index" separator="UNION ALL"> <foreach collection="list" item="item" index="index" separator="UNION ALL">
SELECT SELECT

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

@ -27,7 +27,7 @@
<!-- 定义批量新增的 SQL 映射 --> <!-- 定义批量新增的 SQL 映射 -->
<insert id="batchInsert" parameterType="java.util.List"> <insert id="batchInsert" parameterType="java.util.List">
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 VALUES
<foreach collection="list" item="item" separator=","> <foreach collection="list" item="item" separator=",">
( (
@ -49,9 +49,9 @@
</insert> </insert>
<update id="updateBatchNextTriggerAtById" parameterType="java.util.List"> <update id="updateBatchNextTriggerAtById" parameterType="java.util.List">
UPDATE retry_task_${partition} UPDATE sj_retry_task_${partition}
SET next_trigger_at = src.next_trigger_at SET next_trigger_at = src.next_trigger_at
FROM retry_task_${partition} as target FROM sj_retry_task_${partition} as target
JOIN ( JOIN (
<foreach collection="list" item="item" index="index" separator="UNION ALL"> <foreach collection="list" item="item" index="index" separator="UNION ALL">
SELECT SELECT

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

@ -20,7 +20,7 @@
</sql> </sql>
<insert id="batchInsert" parameterType="java.util.List" useGeneratedKeys="true" keyProperty="id"> <insert id="batchInsert" parameterType="java.util.List" useGeneratedKeys="true" keyProperty="id">
INSERT INTO server_node (namespace_id, group_name, host_id, host_ip, host_port, INSERT INTO sj_server_node (namespace_id, group_name, host_id, host_ip, host_port,
expire_at, node_type, ext_attrs, create_dt) expire_at, node_type, ext_attrs, create_dt)
VALUES VALUES
<foreach collection="records" item="item" index="index" separator=","> <foreach collection="records" item="item" index="index" separator=",">
@ -39,10 +39,9 @@
</insert> </insert>
<update id="batchUpdateExpireAt" parameterType="java.util.List"> <update id="batchUpdateExpireAt" parameterType="java.util.List">
UPDATE server_node UPDATE sj_server_node
SET expire_at = src.expire_at, SET expire_at = src.expire_at
context_path = src.context_path FROM sj_server_node AS dest
FROM server_node AS dest
JOIN ( JOIN (
<foreach collection="list" item="item" index="index" separator="UNION ALL"> <foreach collection="list" item="item" index="index" separator="UNION ALL">
SELECT SELECT
@ -59,7 +58,7 @@
SELECT SELECT
node_type AS nodeType, node_type AS nodeType,
COUNT(*) AS total COUNT(*) AS total
FROM server_node FROM sj_server_node
${ew.customSqlSegment} ${ew.customSqlSegment}
</select> </select>
</mapper> </mapper>

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

@ -17,9 +17,9 @@
</resultMap> </resultMap>
<update id="updateBatchNextTriggerAtById" parameterType="java.util.List"> <update id="updateBatchNextTriggerAtById" parameterType="java.util.List">
UPDATE workflow UPDATE sj_workflow
SET next_trigger_at = src.next_trigger_at SET next_trigger_at = src.next_trigger_at
FROM workflow dest FROM sj_workflow dest
JOIN ( JOIN (
<foreach collection="list" item="item" index="index" separator="UNION ALL"> <foreach collection="list" item="item" index="index" separator="UNION ALL">
SELECT SELECT