From 416924f80efd8c90d55b34dd24f396a1dd63027c Mon Sep 17 00:00:00 2001
From: gaoxq <376340421@qq.com>
Date: Wed, 27 Aug 2025 12:53:41 +0800
Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9EMySQL=E5=92=8Cpg=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E5=BA=93=E7=9A=84=E5=90=8C=E6=AD=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/mini/capi/biz/domain/SyncTask.java     | 18 ------------------
 .../java/com/mini/capi/job/taskDbSync.java     |  2 +-
 src/main/java/com/mini/capi/mybatis/demo.java  |  5 +++--
 src/main/resources/mapper/SyncTaskMapper.xml   |  5 +----
 4 files changed, 5 insertions(+), 25 deletions(-)

diff --git a/src/main/java/com/mini/capi/biz/domain/SyncTask.java b/src/main/java/com/mini/capi/biz/domain/SyncTask.java
index bd50579..6b353f4 100644
--- a/src/main/java/com/mini/capi/biz/domain/SyncTask.java
+++ b/src/main/java/com/mini/capi/biz/domain/SyncTask.java
@@ -66,24 +66,6 @@ public class SyncTask implements Serializable {
     @TableField("target_table")
     private String targetTable;
 
-    /**
-     * 同步类型（如全量同步、增量同步等）
-     */
-    @TableField("sync_type")
-    private String syncType;
-
-    /**
-     * 增量同步字段（用于增量同步时的判断依据）
-     */
-    @TableField("increment_column")
-    private String incrementColumn;
-
-    /**
-     * 定时任务表达式（ cron表达式 ）
-     */
-    @TableField("cron_expression")
-    private String cronExpression;
-
     /**
      * 是否激活（任务启用状态标识）
      */
diff --git a/src/main/java/com/mini/capi/job/taskDbSync.java b/src/main/java/com/mini/capi/job/taskDbSync.java
index 065c9a8..4281d4a 100644
--- a/src/main/java/com/mini/capi/job/taskDbSync.java
+++ b/src/main/java/com/mini/capi/job/taskDbSync.java
@@ -160,7 +160,7 @@ public class taskDbSync {
     }
 
     /**
-     * 获取PostgreSQL兼容的字段定义
+     * 获取PostgresSQL兼容的字段定义
      */
     private List<String> getColumnDefinitions(JdbcTemplate sourceJdbc, String tableName) throws SQLException {
         List<String> definitions = new ArrayList<>();
diff --git a/src/main/java/com/mini/capi/mybatis/demo.java b/src/main/java/com/mini/capi/mybatis/demo.java
index 1db5c67..c94e183 100644
--- a/src/main/java/com/mini/capi/mybatis/demo.java
+++ b/src/main/java/com/mini/capi/mybatis/demo.java
@@ -29,7 +29,7 @@ public class demo {
                             .pathInfo(Collections.singletonMap(OutputFile.xml, System.getProperty("user.dir") + "/src/main/resources/mapper"));
                 })
                 .strategyConfig(builder -> {
-                    builder.addInclude("biz_sync_task,biz_db_config")
+                    builder.addInclude("biz_sync_task")
                             .addTablePrefix("biz_")
                             .entityBuilder()
                             .enableLombok()
@@ -45,7 +45,8 @@ public class demo {
                             .formatServiceImplFileName("%sServiceImpl")
                             .mapperBuilder()
                             .enableBaseResultMap()
-                            .enableBaseColumnList();
+                            .enableBaseColumnList()
+                            .enableFileOverride(); // 开启mapper接口和xml文件覆盖
                 })
                 .templateEngine(new FreemarkerTemplateEngine())
                 .execute();
diff --git a/src/main/resources/mapper/SyncTaskMapper.xml b/src/main/resources/mapper/SyncTaskMapper.xml
index 0a4bc9c..293f042 100644
--- a/src/main/resources/mapper/SyncTaskMapper.xml
+++ b/src/main/resources/mapper/SyncTaskMapper.xml
@@ -11,9 +11,6 @@
         <result column="target_db_id" property="targetDbId" />
         <result column="source_table" property="sourceTable" />
         <result column="target_table" property="targetTable" />
-        <result column="sync_type" property="syncType" />
-        <result column="increment_column" property="incrementColumn" />
-        <result column="cron_expression" property="cronExpression" />
         <result column="is_active" property="isActive" />
         <result column="last_sync_time" property="lastSyncTime" />
         <result column="update_time" property="updateTime" />
@@ -25,7 +22,7 @@
 
     <!-- 通用查询结果列 -->
     <sql id="Base_Column_List">
-        create_time, task_id, task_name, source_db_id, target_db_id, source_table, target_table, sync_type, increment_column, cron_expression, is_active, last_sync_time, update_time, f_tenant_id, f_flow_id, f_flow_task_id, f_flow_state
+        create_time, task_id, task_name, source_db_id, target_db_id, source_table, target_table, is_active, last_sync_time, update_time, f_tenant_id, f_flow_id, f_flow_task_id, f_flow_state
     </sql>
 
 </mapper>