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 getColumnDefinitions(JdbcTemplate sourceJdbc, String tableName) throws SQLException { List 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 @@ - - - @@ -25,7 +22,7 @@ - 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