feat(sj_1.1.0-beta1):提取所有insertBatch xml语句到template

snail-job-datasource/snail-job-datasource-template/src/main/java/com/aizuda/snailjob/template/datasource/persistence/mapper/RetryDeadLetterMapper.java

@@ -8,6 +8,6 @@ import java.util.List;
 
 public interface RetryDeadLetterMapper extends BaseMapper<RetryDeadLetter> {
 
-    int insertBatch(@Param("retryDeadLetters") List<RetryDeadLetter> retryDeadLetter);
+    int insertBatch(@Param("list") List<RetryDeadLetter> list);
 
 }

snail-job-datasource/snail-job-datasource-template/src/main/java/com/aizuda/snailjob/template/datasource/persistence/mapper/RetryTaskLogMapper.java

@@ -11,7 +11,7 @@ import java.util.List;
 
 public interface RetryTaskLogMapper extends BaseMapper<RetryTaskLog> {
 
-    int insertBatch(List<RetryTaskLog> list);
+    int insertBatch(@Param("list") List<RetryTaskLog> list);
 
     List<DashboardRetryResponseDO> selectRetryRetryTaskLogSummaryList(@Param("ew") Wrapper<RetryTaskLog> wrapper);
 }

snail-job-datasource/snail-job-datasource-template/src/main/java/com/aizuda/snailjob/template/datasource/persistence/mapper/RetryTaskLogMessageMapper.java

@@ -3,6 +3,7 @@ package com.aizuda.snailjob.template.datasource.persistence.mapper;
 import com.aizuda.snailjob.template.datasource.persistence.po.RetryTaskLogMessage;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
 
 import java.util.List;
 
@@ -17,7 +18,8 @@ import java.util.List;
 @Mapper
 public interface RetryTaskLogMessageMapper extends BaseMapper<RetryTaskLogMessage> {
 
-    int insertBatch(List<RetryTaskLogMessage> list);
+    int insertBatch(@Param("list") List<RetryTaskLogMessage> list);
+
+    int updateBatch(@Param("list") List<RetryTaskLogMessage> list);
 
-    int updateBatch(List<RetryTaskLogMessage> list);
 }

snail-job-datasource/snail-job-datasource-template/src/main/java/com/aizuda/snailjob/template/datasource/persistence/mapper/RetryTaskMapper.java

@@ -11,4 +11,5 @@ public interface RetryTaskMapper extends BaseMapper<RetryTask> {
     int insertBatch(@Param("list") List<RetryTask> list);
 
     int updateBatchNextTriggerAtById(@Param("partition") Integer partition, @Param("list") List<RetryTask> list);
+
 }

snail-job-datasource/snail-job-datasource-template/src/main/java/com/aizuda/snailjob/template/datasource/persistence/mapper/ServerNodeMapper.java

@@ -12,9 +12,9 @@ import java.util.List;
 @Mapper
 public interface ServerNodeMapper extends BaseMapper<ServerNode> {
 
-    int updateBatchExpireAt(@Param("list") List<ServerNode> list);
+    int insertBatch(@Param("list") List<ServerNode> list);
 
-    int insertBatch(@Param("records") List<ServerNode> records);
+    int updateBatchExpireAt(@Param("list") List<ServerNode> list);
 
     List<ActivePodQuantityResponseDO> selectActivePodCount(@Param("ew") Wrapper<ServerNode> wrapper);
 

snail-job-datasource/snail-job-datasource-template/src/main/resources/template/mapper/JobLogMessageMapper.xml

@@ -2,7 +2,7 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.JobLogMessageMapper">
 
-    <insert id="insertBatch" parameterType="java.util.List">
+    <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="false">
         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

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

@@ -2,6 +2,28 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.JobSummaryMapper">
 
+    <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="false">
+        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
+        <foreach collection="list" item="item" separator=",">
+            (
+                #{item.namespaceId},
+                #{item.groupName},
+                #{item.businessId},
+                #{item.triggerAt},
+                #{item.systemTaskType},
+                #{item.successNum},
+                #{item.failNum},
+                #{item.failReason},
+                #{item.stopNum},
+                #{item.stopReason},
+                #{item.cancelNum},
+                #{item.cancelReason}
+            )
+        </foreach>
+    </insert>
+
     <select id="selectJobTaskList"
             resultType="com.aizuda.snailjob.template.datasource.persistence.dataobject.DashboardRetryLineResponseDO$Task">
         SELECT group_name                                               AS groupName,

snail-job-datasource/snail-job-datasource-template/src/main/resources/template/mapper/RetryDeadLetterMapper.xml

@@ -0,0 +1,27 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryDeadLetterMapper">
+
+  <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="false">
+      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
+          <foreach collection="list" item="item" separator=",">
+              (
+                  #{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}
+              )
+          </foreach>
+  </insert>
+
+</mapper>

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

@@ -2,6 +2,24 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetrySummaryMapper">
 
+    <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="false">
+        INSERT INTO sj_retry_summary (namespace_id, group_name, scene_name, trigger_at,
+                                      running_num, finish_num, max_count_num, suspend_num)
+        VALUES
+        <foreach collection="list" item="item" separator=",">
+            (
+                #{item.namespaceId},
+                #{item.groupName},
+                #{item.sceneName},
+                #{item.triggerAt},
+                #{item.runningNum},
+                #{item.finishNum},
+                #{item.maxCountNum},
+                #{item.suspendNum}
+            )
+        </foreach>
+    </insert>
+
     <select id="selectRetryTaskList"
             resultType="com.aizuda.snailjob.template.datasource.persistence.dataobject.DashboardRetryLineResponseDO$Task">
         SELECT group_name                                              AS groupName,

snail-job-datasource/snail-job-datasource-template/src/main/resources/template/mapper/RetryTaskLogMapper.xml

@@ -2,6 +2,19 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryTaskLogMapper">
 
+    <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="false">
+        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
+        <foreach collection="list" item="item" separator=",">
+            (
+                #{item.uniqueId}, #{item.groupName}, #{item.sceneName}, #{item.idempotentId},
+                #{item.bizNo}, #{item.executorName}, #{item.argsStr}, #{item.extAttrs},
+                #{item.taskType}, #{item.createDt}, #{item.namespaceId}
+            )
+        </foreach>
+    </insert>
+
     <!-- 重试统计 -->
     <select id="selectRetryRetryTaskLogSummaryList"
             resultType="com.aizuda.snailjob.template.datasource.persistence.dataobject.DashboardRetryResponseDO">

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

@@ -1,18 +1,16 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.JobLogMessageMapper">
+<mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryTaskLogMessageMapper">
 
-    <insert id="insertBatch" parameterType="java.util.List">
-        INSERT INTO sj_job_log_message (namespace_id, group_name, job_id, task_batch_id, task_id,
-                                        log_num, message, create_dt, real_time)
+    <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="false">
+        INSERT INTO sj_retry_task_log_message (namespace_id, group_name, unique_id, log_num, message,
+                                               create_dt, real_time)
         VALUES
             <foreach collection="list" item="item" separator=",">
                 (
                     #{item.namespaceId},
                     #{item.groupName},
-                    #{item.jobId},
-                    #{item.taskBatchId},
-                    #{item.taskId},
+                    #{item.uniqueId},
                     #{item.logNum},
                     #{item.message},
                     #{item.createDt},

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

@@ -0,0 +1,29 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryTaskMapper">
+
+    <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="false">
+        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
+            <foreach collection="list" item="item" separator=",">
+                (
+                     #{item.namespaceId},
+                     #{item.uniqueId},
+                     #{item.groupName},
+                     #{item.sceneName},
+                     #{item.idempotentId},
+                     #{item.bizNo},
+                     #{item.executorName},
+                     #{item.argsStr},
+                     #{item.extAttrs},
+                     #{item.nextTriggerAt},
+                     #{item.taskType},
+                     #{item.retryStatus},
+                     #{item.createDt}
+                )
+            </foreach>
+    </insert>
+
+</mapper>

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

@@ -2,6 +2,25 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.ServerNodeMapper">
 
+    <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="false">
+        INSERT INTO sj_server_node (namespace_id, group_name, host_id, host_ip, host_port,
+                                    expire_at, node_type, ext_attrs, create_dt)
+        VALUES
+        <foreach collection="list" item="item" index="index" separator=",">
+            (
+                #{item.namespaceId,jdbcType=VARCHAR},
+                #{item.groupName,jdbcType=VARCHAR},
+                #{item.hostId,jdbcType=VARCHAR},
+                #{item.hostIp,jdbcType=VARCHAR},
+                #{item.hostPort,jdbcType=INTEGER},
+                #{item.expireAt,jdbcType=TIMESTAMP},
+                #{item.nodeType,jdbcType=TINYINT},
+                #{item.extAttrs,jdbcType=VARCHAR},
+                #{item.createDt,jdbcType=TIMESTAMP}
+            )
+        </foreach>
+    </insert>
+
     <select id="selectActivePodCount"
             resultType="com.aizuda.snailjob.template.datasource.persistence.dataobject.ActivePodQuantityResponseDO">
         SELECT node_type AS nodeType,

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

@@ -1,25 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.JobLogMessageMapper">
-
-    <!-- 定义批量新增的 SQL 映射 -->
-    <insert id="insertBatch" parameterType="java.util.List">
-        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
-        <foreach collection="list" item="item" separator=",">
-            (
-                #{item.namespaceId},
-                #{item.groupName},
-                #{item.jobId},
-                #{item.taskBatchId},
-                #{item.taskId},
-                #{item.logNum},
-                #{item.message},
-                #{item.createDt},
-                #{item.realTime}
-            )
-        </foreach>
-    </insert>
-
-</mapper>

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

@@ -2,28 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.JobSummaryMapper">
 
-    <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="false" keyProperty="id">
-        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
-        <foreach collection="list" item="item" separator=",">
-            (
-                #{item.namespaceId},
-                #{item.groupName},
-                #{item.businessId},
-                #{item.triggerAt},
-                #{item.systemTaskType},
-                #{item.successNum},
-                #{item.failNum},
-                #{item.failReason},
-                #{item.stopNum},
-                #{item.stopReason},
-                #{item.cancelNum},
-                #{item.cancelReason}
-            )
-        </foreach>
-    </insert>
-
     <update id="updateBatch" parameterType="java.util.List">
         <foreach collection="list" item="item" index="index" open="BEGIN" separator=";" close=";END;">
             UPDATE sj_job_summary

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

@@ -1,21 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryDeadLetterMapper">
-
-    <insert id="insertBatch"  parameterType="java.util.List" useGeneratedKeys="false" keyProperty="id">
-        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
-        <foreach collection="retryDeadLetters" item="retryDeadLetter" separator=",">
-            (
-                #{retryDeadLetter.namespaceId,jdbcType=VARCHAR}, #{retryDeadLetter.uniqueId,jdbcType=VARCHAR},
-                #{retryDeadLetter.groupName,jdbcType=VARCHAR}, #{retryDeadLetter.sceneName,jdbcType=VARCHAR},
-                #{retryDeadLetter.idempotentId,jdbcType=VARCHAR}, #{retryDeadLetter.bizNo,jdbcType=VARCHAR},
-                #{retryDeadLetter.executorName,jdbcType=VARCHAR}, #{retryDeadLetter.argsStr,jdbcType=VARCHAR},
-                #{retryDeadLetter.extAttrs,jdbcType=VARCHAR}, #{retryDeadLetter.createDt,jdbcType=TIMESTAMP}
-            )
-        </foreach>
-    </insert>
-
-</mapper>

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

@@ -2,24 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetrySummaryMapper">
 
-    <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="false" keyProperty="id">
-        INSERT INTO sj_retry_summary (namespace_id, group_name, scene_name, trigger_at,
-                                      running_num, finish_num, max_count_num, suspend_num)
-        VALUES
-        <foreach collection="list" item="item" separator=",">
-            (
-                #{item.namespaceId},
-                #{item.groupName},
-                #{item.sceneName},
-                #{item.triggerAt},
-                #{item.runningNum},
-                #{item.finishNum},
-                #{item.maxCountNum},
-                #{item.suspendNum}
-            )
-        </foreach>
-    </insert>
-
     <update id="updateBatch" parameterType="java.util.List">
         <foreach collection="list" item="item" index="index" open="BEGIN" separator=";" close=";END;">
             UPDATE sj_retry_summary

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

@@ -1,19 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryTaskLogMapper">
-
-    <!-- 定义批量新增的 SQL 映射 -->
-    <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="false" keyProperty="id">
-        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
-        <foreach collection="list" item="item" separator=",">
-            (
-                #{item.uniqueId}, #{item.groupName}, #{item.sceneName}, #{item.idempotentId},
-                #{item.bizNo}, #{item.executorName}, #{item.argsStr}, #{item.extAttrs},
-                #{item.taskType}, #{item.createDt}, #{item.namespaceId}
-            )
-        </foreach>
-    </insert>
-
-</mapper>

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

@@ -2,23 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryTaskLogMessageMapper">
 
-    <insert id="insertBatch" parameterType="java.util.List">
-        INSERT INTO sj_retry_task_log_message (namespace_id, group_name, unique_id, log_num, message,
-                                               create_dt, real_time)
-        VALUES
-        <foreach collection="list" item="item" separator=",">
-            (
-                #{item.namespaceId},
-                #{item.groupName},
-                #{item.uniqueId},
-                #{item.logNum},
-                #{item.message},
-                #{item.createDt},
-                #{item.realTime}
-            )
-        </foreach>
-    </insert>
-
     <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

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

@@ -2,20 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryTaskMapper">
 
-    <!-- 定义批量新增的 SQL 映射 -->
-    <insert id="insertBatch" parameterType="java.util.List">
-        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
-        <foreach collection="list" item="item" separator=",">
-            (
-                #{item.namespaceId}, #{item.uniqueId}, #{item.groupName}, #{item.sceneName}, #{item.idempotentId},
-                #{item.bizNo}, #{item.executorName}, #{item.argsStr}, #{item.extAttrs}, #{item.nextTriggerAt},
-                #{item.taskType}, #{item.retryStatus}, #{item.createDt}
-            )
-        </foreach>
-    </insert>
-
     <update id="updateBatchNextTriggerAtById" parameterType="java.util.List">
         <foreach collection="list" item="item" index="index" open="BEGIN" separator=";" close=";END;">
             UPDATE sj_retry_task_${partition}
@@ -23,4 +9,5 @@
              WHERE id = #{item.id}
         </foreach>
     </update>
+
 </mapper>

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

@@ -2,26 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.ServerNodeMapper">
 
-    <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="false" keyProperty="id">
-        <!-- useGeneratedKeys="false" 否则报错ORA-00933: SQL command not properly ended -->
-        INSERT INTO sj_server_node (namespace_id, group_name, host_id, host_ip, host_port,
-                                    expire_at, node_type, ext_attrs, create_dt)
-        VALUES
-        <foreach collection="records" item="item" index="index" separator=",">
-            (
-                #{item.namespaceId,jdbcType=VARCHAR},
-                #{item.groupName,jdbcType=VARCHAR},
-                #{item.hostId,jdbcType=VARCHAR},
-                #{item.hostIp,jdbcType=VARCHAR},
-                #{item.hostPort,jdbcType=INTEGER},
-                #{item.expireAt,jdbcType=TIMESTAMP},
-                #{item.nodeType,jdbcType=TINYINT},
-                #{item.extAttrs,jdbcType=VARCHAR},
-                #{item.createDt,jdbcType=TIMESTAMP}
-            )
-        </foreach>
-    </insert>
-
     <update id="updateBatchExpireAt" parameterType="java.util.List">
         <foreach collection="list" item="item" open="BEGIN" separator=";" close=";END;">
             UPDATE sj_server_node

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

@@ -9,4 +9,5 @@
              WHERE id = #{item.id}
         </foreach>
     </update>
+
 </mapper>

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

@@ -2,28 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.JobSummaryMapper">
 
-    <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="true" keyProperty="id">
-        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
-            <foreach collection="list" item="item" separator=",">
-                (
-                    #{item.namespaceId},
-                    #{item.groupName},
-                    #{item.businessId},
-                    #{item.triggerAt},
-                    #{item.systemTaskType},
-                    #{item.successNum},
-                    #{item.failNum},
-                    #{item.failReason},
-                    #{item.stopNum},
-                    #{item.stopReason},
-                    #{item.cancelNum},
-                    #{item.cancelReason}
-                )
-            </foreach>
-    </insert>
-
     <update id="updateBatch" parameterType="java.util.List">
         UPDATE sj_job_summary rt,
                (

snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/RetryDeadLetterMapper.xml

@@ -1,27 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryDeadLetterMapper">
-
-  <insert id="insertBatch">
-      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
-          <foreach collection="retryDeadLetters" item="retryDeadLetter" separator=",">
-              (
-                  #{retryDeadLetter.namespaceId,jdbcType=VARCHAR},
-                  #{retryDeadLetter.uniqueId,jdbcType=VARCHAR},
-                  #{retryDeadLetter.groupName,jdbcType=VARCHAR},
-                  #{retryDeadLetter.sceneName,jdbcType=VARCHAR},
-                  #{retryDeadLetter.idempotentId,jdbcType=VARCHAR},
-                  #{retryDeadLetter.bizNo,jdbcType=VARCHAR},
-                  #{retryDeadLetter.executorName,jdbcType=VARCHAR},
-                  #{retryDeadLetter.argsStr,jdbcType=VARCHAR},
-                  #{retryDeadLetter.extAttrs,jdbcType=VARCHAR},
-                  #{retryDeadLetter.createDt,jdbcType=TIMESTAMP}
-              )
-          </foreach>
-  </insert>
-
-</mapper>

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

@@ -2,24 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetrySummaryMapper">
 
-    <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="true" keyProperty="id">
-        INSERT INTO sj_retry_summary (namespace_id, group_name, scene_name, trigger_at,
-                                      running_num, finish_num, max_count_num, suspend_num)
-        VALUES
-            <foreach collection="list" item="item" separator=",">
-                (
-                    #{item.namespaceId},
-                    #{item.groupName},
-                    #{item.sceneName},
-                    #{item.triggerAt},
-                    #{item.runningNum},
-                    #{item.finishNum},
-                    #{item.maxCountNum},
-                    #{item.suspendNum}
-                )
-            </foreach>
-    </insert>
-
     <update id="updateBatch" parameterType="java.util.List">
         UPDATE sj_retry_summary rt,
                (

snail-job-datasource/snail-job-mariadb-datasource/src/main/resources/mariadb/mapper/RetryTaskLogMapper.xml

@@ -1,19 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryTaskLogMapper">
-
-    <!-- 定义批量新增的 SQL 映射 -->
-    <insert id="insertBatch" parameterType="java.util.List">
-        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
-        <foreach collection="list" item="item" separator=",">
-            (
-                #{item.uniqueId}, #{item.groupName}, #{item.sceneName}, #{item.idempotentId},
-                #{item.bizNo}, #{item.executorName}, #{item.argsStr}, #{item.extAttrs},
-                #{item.taskType}, #{item.createDt}, #{item.namespaceId}
-            )
-        </foreach>
-    </insert>
-
-</mapper>

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

@@ -2,24 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryTaskLogMessageMapper">
 
-    <!-- 定义批量新增的 SQL 映射 -->
-    <insert id="insertBatch" parameterType="java.util.List">
-        INSERT INTO sj_retry_task_log_message (namespace_id, group_name, unique_id, log_num, message,
-                                               create_dt, real_time)
-        VALUES
-            <foreach collection="list" item="item" separator=",">
-                (
-                    #{item.namespaceId},
-                    #{item.groupName},
-                    #{item.uniqueId},
-                    #{item.logNum},
-                    #{item.message},
-                    #{item.createDt},
-                    #{item.realTime}
-                )
-            </foreach>
-    </insert>
-
     <update id="updateBatch" parameterType="java.util.List">
         UPDATE sj_retry_task_log_message rt,
                (

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

@@ -2,31 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryTaskMapper">
 
-    <!-- 定义批量新增的 SQL 映射 -->
-    <insert id="insertBatch" parameterType="java.util.List">
-        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
-            <foreach collection="list" item="item" separator=",">
-                (
-                     #{item.namespaceId},
-                     #{item.uniqueId},
-                     #{item.groupName},
-                     #{item.sceneName},
-                     #{item.idempotentId},
-                     #{item.bizNo},
-                     #{item.executorName},
-                     #{item.argsStr},
-                     #{item.extAttrs},
-                     #{item.nextTriggerAt},
-                     #{item.taskType},
-                     #{item.retryStatus},
-                     #{item.createDt}
-                )
-            </foreach>
-    </insert>
-
     <update id="updateBatchNextTriggerAtById" parameterType="java.util.List">
         UPDATE sj_retry_task_${partition} rt,
                (

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

@@ -2,25 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.ServerNodeMapper">
 
-    <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="true" keyProperty="id">
-        INSERT INTO sj_server_node (namespace_id, group_name, host_id, host_ip, host_port,
-                                 expire_at, node_type, ext_attrs, create_dt)
-        VALUES
-            <foreach collection="records" item="item" index="index" separator=",">
-                (
-                    #{item.namespaceId,jdbcType=VARCHAR},
-                    #{item.groupName,jdbcType=VARCHAR},
-                    #{item.hostId,jdbcType=VARCHAR},
-                    #{item.hostIp,jdbcType=VARCHAR},
-                    #{item.hostPort,jdbcType=INTEGER},
-                    #{item.expireAt,jdbcType=TIMESTAMP},
-                    #{item.nodeType,jdbcType=TINYINT},
-                    #{item.extAttrs,jdbcType=VARCHAR},
-                    #{item.createDt,jdbcType=TIMESTAMP}
-                )
-            </foreach>
-    </insert>
-
     <update id="updateBatchExpireAt" parameterType="java.util.List">
         UPDATE sj_server_node rt,
                (

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

@@ -2,28 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.JobSummaryMapper">
 
-    <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="true" keyProperty="id">
-        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
-            <foreach collection="list" item="item" separator=",">
-                (
-                    #{item.namespaceId},
-                    #{item.groupName},
-                    #{item.businessId},
-                    #{item.triggerAt},
-                    #{item.systemTaskType},
-                    #{item.successNum},
-                    #{item.failNum},
-                    #{item.failReason},
-                    #{item.stopNum},
-                    #{item.stopReason},
-                    #{item.cancelNum},
-                    #{item.cancelReason}
-                )
-            </foreach>
-    </insert>
-
     <update id="updateBatch" parameterType="java.util.List">
         UPDATE sj_job_summary rt,
                (

snail-job-datasource/snail-job-mysql-datasource/src/main/resources/mysql/mapper/RetryDeadLetterMapper.xml

@@ -1,27 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryDeadLetterMapper">
-
-  <insert id="insertBatch">
-      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
-          <foreach collection="retryDeadLetters" item="retryDeadLetter" separator=",">
-              (
-                  #{retryDeadLetter.namespaceId,jdbcType=VARCHAR},
-                  #{retryDeadLetter.uniqueId,jdbcType=VARCHAR},
-                  #{retryDeadLetter.groupName,jdbcType=VARCHAR},
-                  #{retryDeadLetter.sceneName,jdbcType=VARCHAR},
-                  #{retryDeadLetter.idempotentId,jdbcType=VARCHAR},
-                  #{retryDeadLetter.bizNo,jdbcType=VARCHAR},
-                  #{retryDeadLetter.executorName,jdbcType=VARCHAR},
-                  #{retryDeadLetter.argsStr,jdbcType=VARCHAR},
-                  #{retryDeadLetter.extAttrs,jdbcType=VARCHAR},
-                  #{retryDeadLetter.createDt,jdbcType=TIMESTAMP}
-              )
-          </foreach>
-  </insert>
-
-</mapper>

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

@@ -2,24 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetrySummaryMapper">
 
-    <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="true" keyProperty="id">
-        INSERT INTO sj_retry_summary (namespace_id, group_name, scene_name, trigger_at,
-                                      running_num, finish_num, max_count_num, suspend_num)
-        VALUES
-            <foreach collection="list" item="item" separator=",">
-                (
-                    #{item.namespaceId},
-                    #{item.groupName},
-                    #{item.sceneName},
-                    #{item.triggerAt},
-                    #{item.runningNum},
-                    #{item.finishNum},
-                    #{item.maxCountNum},
-                    #{item.suspendNum}
-                )
-            </foreach>
-    </insert>
-
     <update id="updateBatch" parameterType="java.util.List">
         UPDATE sj_retry_summary rt,
                (

snail-job-datasource/snail-job-mysql-datasource/src/main/resources/mysql/mapper/RetryTaskLogMapper.xml

@@ -1,19 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryTaskLogMapper">
-
-    <!-- 定义批量新增的 SQL 映射 -->
-    <insert id="insertBatch" parameterType="java.util.List">
-        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
-        <foreach collection="list" item="item" separator=",">
-            (
-                #{item.uniqueId}, #{item.groupName}, #{item.sceneName}, #{item.idempotentId},
-                #{item.bizNo}, #{item.executorName}, #{item.argsStr}, #{item.extAttrs},
-                #{item.taskType}, #{item.createDt}, #{item.namespaceId}
-            )
-        </foreach>
-    </insert>
-
-</mapper>

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

@@ -2,24 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryTaskLogMessageMapper">
 
-    <!-- 定义批量新增的 SQL 映射 -->
-    <insert id="insertBatch" parameterType="java.util.List">
-        INSERT INTO sj_retry_task_log_message (namespace_id, group_name, unique_id, log_num, message,
-                                               create_dt, real_time)
-        VALUES
-            <foreach collection="list" item="item" separator=",">
-                (
-                    #{item.namespaceId},
-                    #{item.groupName},
-                    #{item.uniqueId},
-                    #{item.logNum},
-                    #{item.message},
-                    #{item.createDt},
-                    #{item.realTime}
-                )
-            </foreach>
-    </insert>
-
     <update id="updateBatch" parameterType="java.util.List">
         UPDATE sj_retry_task_log_message rt,
                (

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

@@ -2,31 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryTaskMapper">
 
-    <!-- 定义批量新增的 SQL 映射 -->
-    <insert id="insertBatch" parameterType="java.util.List">
-        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
-            <foreach collection="list" item="item" separator=",">
-                (
-                     #{item.namespaceId},
-                     #{item.uniqueId},
-                     #{item.groupName},
-                     #{item.sceneName},
-                     #{item.idempotentId},
-                     #{item.bizNo},
-                     #{item.executorName},
-                     #{item.argsStr},
-                     #{item.extAttrs},
-                     #{item.nextTriggerAt},
-                     #{item.taskType},
-                     #{item.retryStatus},
-                     #{item.createDt}
-                )
-            </foreach>
-    </insert>
-
     <update id="updateBatchNextTriggerAtById" parameterType="java.util.List">
         UPDATE sj_retry_task_${partition} rt,
                (
@@ -39,4 +14,5 @@
            SET rt.next_trigger_at = tt.next_trigger_at
          WHERE rt.id = tt.id
     </update>
+
 </mapper>

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

@@ -2,25 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.ServerNodeMapper">
 
-    <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="true" keyProperty="id">
-        INSERT INTO sj_server_node (namespace_id, group_name, host_id, host_ip, host_port,
-                                 expire_at, node_type, ext_attrs, create_dt)
-        VALUES
-            <foreach collection="records" item="item" index="index" separator=",">
-                (
-                    #{item.namespaceId,jdbcType=VARCHAR},
-                    #{item.groupName,jdbcType=VARCHAR},
-                    #{item.hostId,jdbcType=VARCHAR},
-                    #{item.hostIp,jdbcType=VARCHAR},
-                    #{item.hostPort,jdbcType=INTEGER},
-                    #{item.expireAt,jdbcType=TIMESTAMP},
-                    #{item.nodeType,jdbcType=TINYINT},
-                    #{item.extAttrs,jdbcType=VARCHAR},
-                    #{item.createDt,jdbcType=TIMESTAMP}
-                )
-            </foreach>
-    </insert>
-
     <update id="updateBatchExpireAt" parameterType="java.util.List">
         UPDATE sj_server_node rt,
                (

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

@@ -1,24 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.JobLogMessageMapper">
-
-    <!-- 定义批量新增的 SQL 映射 -->
-    <insert id="insertBatch" parameterType="java.util.List">
-        INSERT INTO sj_job_log_message (namespace_id, group_name, job_id, task_batch_id, task_id,
-                                        log_num, message, create_dt, real_time)
-        <foreach collection="list" item="item" separator="UNION ALL">
-            SELECT
-                #{item.namespaceId},
-                #{item.groupName},
-                #{item.jobId},
-                #{item.taskBatchId},
-                #{item.taskId},
-                #{item.logNum},
-                #{item.message},
-                #{item.createDt},
-                #{item.realTime}
-            FROM DUAL
-        </foreach>
-    </insert>
-
-</mapper>

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

@@ -2,27 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.JobSummaryMapper">
 
-    <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="false" keyProperty="id">
-        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)
-        <foreach collection="list" item="item" separator="UNION ALL">
-            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
-        </foreach>
-    </insert>
-
     <update id="updateBatch" parameterType="java.util.List">
         <foreach collection="list" item="item" index="index" open="BEGIN" separator=";" close=";END;">
             UPDATE sj_job_summary

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

@@ -1,20 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryDeadLetterMapper">
-
-    <insert id="insertBatch"  parameterType="java.util.List" useGeneratedKeys="false" keyProperty="id">
-        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)
-        <foreach collection="retryDeadLetters" item="retryDeadLetter" separator="UNION ALL">
-            SELECT
-                #{retryDeadLetter.namespaceId,jdbcType=VARCHAR}, #{retryDeadLetter.uniqueId,jdbcType=VARCHAR},
-                #{retryDeadLetter.groupName,jdbcType=VARCHAR}, #{retryDeadLetter.sceneName,jdbcType=VARCHAR},
-                #{retryDeadLetter.idempotentId,jdbcType=VARCHAR}, #{retryDeadLetter.bizNo,jdbcType=VARCHAR},
-                #{retryDeadLetter.executorName,jdbcType=VARCHAR}, #{retryDeadLetter.argsStr,jdbcType=VARCHAR},
-                #{retryDeadLetter.extAttrs,jdbcType=VARCHAR}, #{retryDeadLetter.createDt,jdbcType=TIMESTAMP}
-            FROM DUAL
-        </foreach>
-    </insert>
-
-</mapper>

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

@@ -2,24 +2,7 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetrySummaryMapper">
 
-    <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="false" keyProperty="id">
-        INSERT INTO sj_retry_summary (namespace_id, group_name, scene_name, trigger_at,
-                                      running_num, finish_num, max_count_num, suspend_num)
-        <foreach collection="list" item="item" separator="UNION ALL">
-            SELECT
-                #{item.namespaceId},
-                #{item.groupName},
-                #{item.sceneName},
-                #{item.triggerAt},
-                #{item.runningNum},
-                #{item.finishNum},
-                #{item.maxCountNum},
-                #{item.suspendNum}
-            FROM DUAL
-        </foreach>
-    </insert>
-
-    <update id="updateBatch" parameterType="java.util.List">
+   <update id="updateBatch" parameterType="java.util.List">
         <foreach collection="list" item="item" index="index" open="BEGIN" separator=";" close=";END;">
             UPDATE sj_retry_summary
                SET running_num = #{item.runningNum},

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

@@ -1,18 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryTaskLogMapper">
-
-    <!-- 定义批量新增的 SQL 映射 -->
-    <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="false" keyProperty="id">
-        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)
-        <foreach collection="list" item="item" separator="UNION ALL">
-            SELECT
-                #{item.uniqueId}, #{item.groupName}, #{item.sceneName}, #{item.idempotentId},
-                #{item.bizNo}, #{item.executorName}, #{item.argsStr}, #{item.extAttrs},
-                #{item.taskType}, #{item.createDt}, #{item.namespaceId}
-            FROM DUAL
-        </foreach>
-    </insert>
-
-</mapper>

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

@@ -2,22 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryTaskLogMessageMapper">
 
-    <insert id="insertBatch" parameterType="java.util.List">
-        INSERT INTO sj_retry_task_log_message (namespace_id, group_name, unique_id, log_num, message,
-                                               create_dt, real_time)
-            <foreach collection="list" item="item" separator="UNION ALL">
-                SELECT
-                    #{item.namespaceId},
-                    #{item.groupName},
-                    #{item.uniqueId},
-                    #{item.logNum},
-                    #{item.message},
-                    #{item.createDt},
-                    #{item.realTime}
-                FROM DUAL
-            </foreach>
-    </insert>
-
     <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

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

@@ -2,19 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryTaskMapper">
 
-    <!-- 定义批量新增的 SQL 映射 -->
-    <insert id="insertBatch" parameterType="java.util.List">
-        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)
-        <foreach collection="list" item="item" separator="UNION ALL">
-            SELECT
-                #{item.namespaceId}, #{item.uniqueId}, #{item.groupName}, #{item.sceneName}, #{item.idempotentId},
-                #{item.bizNo}, #{item.executorName}, #{item.argsStr}, #{item.extAttrs}, #{item.nextTriggerAt},
-                #{item.taskType}, #{item.retryStatus}, #{item.createDt}
-            FROM DUAL
-        </foreach>
-    </insert>
-
     <update id="updateBatchNextTriggerAtById" parameterType="java.util.List">
         <foreach collection="list" item="item" index="index" open="BEGIN" separator=";" close=";END;">
             UPDATE sj_retry_task_${partition}
@@ -22,4 +9,5 @@
              WHERE id = #{item.id}
         </foreach>
     </update>
+
 </mapper>

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

@@ -2,25 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.ServerNodeMapper">
 
-    <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="false" keyProperty="id">
-        <!-- useGeneratedKeys="false" 否则报错ORA-00933: SQL command not properly ended -->
-        INSERT INTO sj_server_node (namespace_id, group_name, host_id, host_ip, host_port,
-                                    expire_at, node_type, ext_attrs, create_dt)
-        <foreach collection="records" item="item" index="index" separator="UNION ALL">
-            SELECT
-                #{item.namespaceId,jdbcType=VARCHAR},
-                #{item.groupName,jdbcType=VARCHAR},
-                #{item.hostId,jdbcType=VARCHAR},
-                #{item.hostIp,jdbcType=VARCHAR},
-                #{item.hostPort,jdbcType=INTEGER},
-                #{item.expireAt,jdbcType=TIMESTAMP},
-                #{item.nodeType,jdbcType=TINYINT},
-                #{item.extAttrs,jdbcType=VARCHAR},
-                #{item.createDt,jdbcType=TIMESTAMP}
-            FROM DUAL
-        </foreach>
-    </insert>
-
     <update id="updateBatchExpireAt" parameterType="java.util.List">
         <foreach collection="list" item="item" open="BEGIN" separator=";" close=";END;">
             UPDATE sj_server_node

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

@@ -1,25 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.JobLogMessageMapper">
-
-    <!-- 定义批量新增的 SQL 映射 -->
-    <insert id="insertBatch" parameterType="java.util.List">
-        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
-        <foreach collection="list" item="item" separator=",">
-            (
-                #{item.namespaceId},
-                #{item.groupName},
-                #{item.jobId},
-                #{item.taskBatchId},
-                #{item.taskId},
-                #{item.logNum},
-                #{item.message},
-                #{item.createDt},
-                #{item.realTime}
-            )
-        </foreach>
-    </insert>
-
-</mapper>

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

@@ -2,28 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.JobSummaryMapper">
 
-    <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="true" keyProperty="id">
-        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
-            <foreach collection="list" item="item" separator=",">
-                (
-                    #{item.namespaceId},
-                    #{item.groupName},
-                    #{item.businessId},
-                    #{item.triggerAt},
-                    #{item.systemTaskType},
-                    #{item.successNum},
-                    #{item.failNum},
-                    #{item.failReason},
-                    #{item.stopNum},
-                    #{item.stopReason},
-                    #{item.cancelNum},
-                    #{item.cancelReason}
-                )
-            </foreach>
-    </insert>
-
     <update id="updateBatch" parameterType="java.util.List">
         UPDATE sj_job_summary AS rt
            SET success_num = tt.success_num,

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

@@ -1,21 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryDeadLetterMapper">
-
-    <insert id="insertBatch">
-        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
-            <foreach collection="retryDeadLetters" item="retryDeadLetter" separator=",">
-                (
-                    #{retryDeadLetter.namespaceId,jdbcType=VARCHAR}, #{retryDeadLetter.uniqueId,jdbcType=VARCHAR},
-                    #{retryDeadLetter.groupName,jdbcType=VARCHAR}, #{retryDeadLetter.sceneName,jdbcType=VARCHAR},
-                    #{retryDeadLetter.idempotentId,jdbcType=VARCHAR}, #{retryDeadLetter.bizNo,jdbcType=VARCHAR},
-                    #{retryDeadLetter.executorName,jdbcType=VARCHAR}, #{retryDeadLetter.argsStr,jdbcType=VARCHAR},
-                    #{retryDeadLetter.extAttrs,jdbcType=VARCHAR}, #{retryDeadLetter.createDt,jdbcType=TIMESTAMP}
-                )
-            </foreach>
-    </insert>
-
-</mapper>

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

@@ -2,24 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetrySummaryMapper">
 
-    <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="true" keyProperty="id">
-        INSERT INTO sj_retry_summary (namespace_id, group_name, scene_name, trigger_at,
-                                   running_num, finish_num, max_count_num, suspend_num)
-        VALUES
-            <foreach collection="list" item="item" separator=",">
-                (
-                    #{item.namespaceId},
-                    #{item.groupName},
-                    #{item.sceneName},
-                    #{item.triggerAt},
-                    #{item.runningNum},
-                    #{item.finishNum},
-                    #{item.maxCountNum},
-                    #{item.suspendNum}
-                )
-        </foreach>
-    </insert>
-
     <update id="updateBatch" parameterType="java.util.List">
         UPDATE sj_retry_summary AS rt
            SET running_num = tt.running_num,

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

@@ -1,19 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryTaskLogMapper">
-
-    <!-- 定义批量新增的 SQL 映射 -->
-    <insert id="insertBatch" parameterType="java.util.List">
-        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
-        <foreach collection="list" item="item" separator=",">
-            (
-                #{item.uniqueId}, #{item.groupName}, #{item.sceneName}, #{item.idempotentId},
-                #{item.bizNo}, #{item.executorName}, #{item.argsStr}, #{item.extAttrs},
-                #{item.taskType}, #{item.createDt}, #{item.namespaceId}
-            )
-        </foreach>
-    </insert>
-
-</mapper>

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

@@ -2,23 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryTaskLogMessageMapper">
 
-    <insert id="insertBatch" parameterType="java.util.List">
-        INSERT INTO sj_retry_task_log_message (namespace_id, group_name, unique_id, log_num, message,
-                                            create_dt, real_time)
-        VALUES
-            <foreach collection="list" item="item" separator=",">
-                (
-                    #{item.namespaceId},
-                    #{item.groupName},
-                    #{item.uniqueId},
-                    #{item.logNum},
-                    #{item.message},
-                    #{item.createDt},
-                    #{item.realTime}
-                )
-            </foreach>
-    </insert>
-
     <update id="updateBatch" parameterType="java.util.List">
         UPDATE sj_retry_task_log_message rt,
                 (

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

@@ -2,21 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryTaskMapper">
 
-    <!-- 定义批量新增的 SQL 映射 -->
-    <insert id="insertBatch" parameterType="java.util.List">
-        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
-        <foreach collection="list" item="item" separator=",">
-            (
-                #{item.namespaceId}, #{item.uniqueId}, #{item.groupName},
-                #{item.sceneName}, #{item.idempotentId}, #{item.bizNo}, #{item.executorName}, #{item.argsStr},
-                #{item.extAttrs}, #{item.nextTriggerAt}, #{item.taskType}, #{item.retryStatus}, #{item.createDt}
-            )
-        </foreach>
-    </insert>
-
     <update id="updateBatchNextTriggerAtById" parameterType="java.util.List">
         UPDATE sj_retry_task_${partition} AS rt
            SET next_trigger_at = tt.next_trigger_at
@@ -29,4 +14,5 @@
                 ) AS tt
           WHERE rt.id = tt.id
     </update>
+
 </mapper>

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

@@ -2,25 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.ServerNodeMapper">
 
-    <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="true" keyProperty="id">
-        INSERT INTO sj_server_node (namespace_id, group_name, host_id, host_ip, host_port,
-                                 expire_at, node_type, ext_attrs, create_dt)
-        VALUES
-            <foreach collection="records" item="item" index="index" separator=",">
-                (
-                    #{item.namespaceId,jdbcType=VARCHAR},
-                    #{item.groupName,jdbcType=VARCHAR},
-                    #{item.hostId,jdbcType=VARCHAR},
-                    #{item.hostIp,jdbcType=VARCHAR},
-                    #{item.hostPort,jdbcType=INTEGER},
-                    #{item.expireAt,jdbcType=TIMESTAMP},
-                    #{item.nodeType,jdbcType=TINYINT},
-                    #{item.extAttrs,jdbcType=VARCHAR},
-                    #{item.createDt,jdbcType=TIMESTAMP}
-                )
-            </foreach>
-    </insert>
-
     <update id="updateBatchExpireAt" parameterType="java.util.List">
         UPDATE sj_server_node AS rt
            SET expire_at = tt.expire_at

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

@@ -1,24 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.JobLogMessageMapper">
-
-    <!-- 定义批量新增的 SQL 映射 -->
-    <insert id="insertBatch" parameterType="java.util.List">
-        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
-            <foreach collection="list" item="item" separator=",">
-                (
-                    #{item.namespaceId},
-                    #{item.groupName},
-                    #{item.jobId},
-                    #{item.taskBatchId},
-                    #{item.taskId},
-                    #{item.logNum},
-                    #{item.message},
-                    #{item.createDt},
-                    #{item.realTime}
-                )
-            </foreach>
-    </insert>
-</mapper>

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

@@ -2,28 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.JobSummaryMapper">
 
-    <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="true" keyProperty="id">
-        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
-            <foreach collection="list" item="item" separator=",">
-                (
-                    #{item.namespaceId},
-                    #{item.groupName},
-                    #{item.businessId},
-                    #{item.triggerAt},
-                    #{item.systemTaskType},
-                    #{item.successNum},
-                    #{item.failNum},
-                    #{item.failReason},
-                    #{item.stopNum},
-                    #{item.stopReason},
-                    #{item.cancelNum},
-                    #{item.cancelReason}
-                )
-            </foreach>
-    </insert>
-
     <update id="updateBatch" parameterType="java.util.List">
         UPDATE sj_job_summary
            SET success_num = src.success_num,

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

@@ -1,26 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryDeadLetterMapper">
-
-    <insert id="insertBatch">
-        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
-            <foreach collection="retryDeadLetters" item="retryDeadLetter" separator=",">
-                (
-                    #{retryDeadLetter.namespaceId,jdbcType=VARCHAR},
-                    #{retryDeadLetter.uniqueId,jdbcType=VARCHAR},
-                    #{retryDeadLetter.groupName,jdbcType=VARCHAR},
-                    #{retryDeadLetter.sceneName,jdbcType=VARCHAR},
-                    #{retryDeadLetter.idempotentId,jdbcType=VARCHAR},
-                    #{retryDeadLetter.bizNo,jdbcType=VARCHAR},
-                    #{retryDeadLetter.executorName,jdbcType=VARCHAR},
-                    #{retryDeadLetter.argsStr,jdbcType=VARCHAR},
-                    #{retryDeadLetter.extAttrs,jdbcType=VARCHAR},
-                    #{retryDeadLetter.createDt,jdbcType=TIMESTAMP}
-                )
-            </foreach>
-  </insert>
-
-</mapper>

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

@@ -2,24 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetrySummaryMapper">
 
-    <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="true" keyProperty="id">
-        INSERT INTO sj_retry_summary (namespace_id, group_name, scene_name, trigger_at,
-                                      running_num, finish_num, max_count_num, suspend_num)
-        VALUES
-        <foreach collection="list" item="item" separator=",">
-            (
-                #{item.namespaceId},
-                #{item.groupName},
-                #{item.sceneName},
-                #{item.triggerAt},
-                #{item.runningNum},
-                #{item.finishNum},
-                #{item.maxCountNum},
-                #{item.suspendNum}
-            )
-        </foreach>
-    </insert>
-
     <update id="updateBatch" parameterType="java.util.List">
         UPDATE sj_retry_summary
            SET running_num = src.running_num,
@@ -30,14 +12,14 @@
                 JOIN (
                 <foreach collection="list" item="item" index="index" separator="UNION ALL">
                     SELECT
-                    #{item.runningNum}  AS running_num,
-                    #{item.finishNum}   AS finish_num,
-                    #{item.maxCountNum} AS max_count_num,
-                    #{item.suspendNum}  AS suspend_num,
-                    #{item.triggerAt}   AS trigger_at,
-                    #{item.sceneName}   AS scene_name,
-                    #{item.namespaceId} AS namespace_id,
-                    #{item.groupName}   AS group_name
+                        #{item.runningNum}  AS running_num,
+                        #{item.finishNum}   AS finish_num,
+                        #{item.maxCountNum} AS max_count_num,
+                        #{item.suspendNum}  AS suspend_num,
+                        #{item.triggerAt}   AS trigger_at,
+                        #{item.sceneName}   AS scene_name,
+                        #{item.namespaceId} AS namespace_id,
+                        #{item.groupName}   AS group_name
                 </foreach>
                 ) AS src ON (dest.trigger_at = src.trigger_at
                             AND dest.group_name = src.group_name

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

@@ -1,19 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
-<mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryTaskLogMapper">
-
-    <!-- 定义批量新增的 SQL 映射 -->
-    <insert id="insertBatch" parameterType="java.util.List">
-        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
-        <foreach collection="list" item="item" separator=",">
-            (
-                #{item.uniqueId}, #{item.groupName}, #{item.sceneName}, #{item.idempotentId},
-                #{item.bizNo}, #{item.executorName}, #{item.argsStr}, #{item.extAttrs},
-                #{item.taskType}, #{item.createDt}, #{item.namespaceId}
-            )
-        </foreach>
-    </insert>
-
-</mapper>

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

@@ -2,24 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryTaskLogMessageMapper">
 
-    <!-- 定义批量新增的 SQL 映射 -->
-    <insert id="insertBatch" parameterType="java.util.List">
-        INSERT INTO sj_retry_task_log_message (namespace_id, group_name, unique_id, log_num, message,
-                                               create_dt, real_time)
-        VALUES
-            <foreach collection="list" item="item" separator=",">
-                (
-                    #{item.namespaceId},
-                    #{item.groupName},
-                    #{item.uniqueId},
-                    #{item.logNum},
-                    #{item.message},
-                    #{item.createDt},
-                    #{item.realTime}
-                )
-            </foreach>
-    </insert>
-
     <update id="updateBatch" parameterType="java.util.List">
         UPDATE sj_retry_task_log_message
            SET message = src.message, log_num = src.log_num

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

@@ -2,29 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.RetryTaskMapper">
 
-    <!-- 定义批量新增的 SQL 映射 -->
-    <insert id="insertBatch" parameterType="java.util.List">
-        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
-        <foreach collection="list" item="item" separator=",">
-            (
-                #{item.namespaceId},
-                #{item.uniqueId},
-                #{item.groupName},
-                #{item.sceneName},
-                #{item.idempotentId},
-                #{item.bizNo},
-                #{item.executorName},
-                #{item.argsStr},
-                #{item.extAttrs},
-                #{item.nextTriggerAt},
-                #{item.taskType},
-                #{item.retryStatus},
-                #{item.createDt}
-            )
-        </foreach>
-    </insert>
-
     <update id="updateBatchNextTriggerAtById" parameterType="java.util.List">
         UPDATE sj_retry_task_${partition}
            SET next_trigger_at = src.next_trigger_at
@@ -37,4 +14,5 @@
                 </foreach>
                 ) AS src ON target.id = src.id;
     </update>
+
 </mapper>

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

@@ -2,25 +2,6 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.aizuda.snailjob.template.datasource.persistence.mapper.ServerNodeMapper">
 
-    <insert id="insertBatch" parameterType="java.util.List" useGeneratedKeys="true" keyProperty="id">
-        INSERT INTO sj_server_node (namespace_id, group_name, host_id, host_ip, host_port,
-                                 expire_at, node_type, ext_attrs, create_dt)
-        VALUES
-            <foreach collection="records" item="item" index="index" separator=",">
-                (
-                    #{item.namespaceId,jdbcType=VARCHAR},
-                    #{item.groupName,jdbcType=VARCHAR},
-                    #{item.hostId,jdbcType=VARCHAR},
-                    #{item.hostIp,jdbcType=VARCHAR},
-                    #{item.hostPort,jdbcType=INTEGER},
-                    #{item.expireAt,jdbcType=TIMESTAMP},
-                    #{item.nodeType,jdbcType=TINYINT},
-                    #{item.extAttrs,jdbcType=VARCHAR},
-                    #{item.createDt,jdbcType=TIMESTAMP}
-                )
-            </foreach>
-    </insert>
-
     <update id="updateBatchExpireAt" parameterType="java.util.List">
         UPDATE sj_server_node
            SET expire_at = src.expire_at