From a44aa592af65fab9a7ba742326b9c9b27d2bbbf5 Mon Sep 17 00:00:00 2001 From: gaoxq <376340421@qq.com> Date: Wed, 27 Aug 2025 11:52:29 +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/DbConfig.java | 68 ++++++++++++++----- .../com/mini/capi/biz/domain/SyncTask.java | 41 ++++++++++- src/main/java/com/mini/capi/mybatis/demo.java | 2 +- 3 files changed, 92 insertions(+), 19 deletions(-) diff --git a/src/main/java/com/mini/capi/biz/domain/DbConfig.java b/src/main/java/com/mini/capi/biz/domain/DbConfig.java index 0b4891a..04e13a7 100644 --- a/src/main/java/com/mini/capi/biz/domain/DbConfig.java +++ b/src/main/java/com/mini/capi/biz/domain/DbConfig.java @@ -15,7 +15,7 @@ import lombok.Setter; *

* * @author gaoxq - * @since 2025-08-26 + * @since 2025-08-27 */ @Getter @Setter @@ -24,39 +24,81 @@ public class DbConfig implements Serializable { private static final long serialVersionUID = 1L; + /** + * 记录创建时间 + */ @TableField("create_time") private LocalDateTime createTime; + /** + * 数据库配置唯一标识 + */ @TableId(value = "db_id", type = IdType.AUTO) private String dbId; + /** + * 数据库类型（如mysql、oracle、postgresql等） + */ @TableField("db_type") private String dbType; + /** + * 数据库名称 + */ @TableField("db_name") private String dbName; - @TableField("host") - private String host; + /** + * 数据库默认Schema（PostgresSQL特有，如public、ods、dw等，为空时默认用public） + */ + @TableField("db_schema") + private String dbSchema; - @TableField("port") - private Integer port; + /** + * 数据库主机地址 + */ + @TableField("db_host") + private String dbHost; - @TableField("username") - private String username; + /** + * 数据库端口号 + */ + @TableField("db_port") + private Integer dbPort; - @TableField("password") - private String password; + /** + * 数据库登录用户名 + */ + @TableField("link_username") + private String linkUsername; + /** + * 数据库登录密码 + */ + @TableField("link_password") + private String linkPassword; + + /** + * 数据库驱动类全路径 + */ @TableField("driver_class") private String driverClass; + /** + * 数据库连接URL模板 + */ @TableField("url_template") private String urlTemplate; + /** + * 是否激活（可用状态标识） + */ @TableField("is_active") private String isActive; + /** + * 记录最后更新时间 + */ @TableField("update_time") private LocalDateTime updateTime; @@ -83,12 +125,4 @@ public class DbConfig implements Serializable { */ @TableField("f_flow_state") private Integer fFlowState; - - - // 生成数据库连接URL - public String getJdbcUrl() { - return urlTemplate.replace("{host}", host) - .replace("{port}", port.toString()) - .replace("{dbName}", dbName); - } } 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 8bbcaa6..bd50579 100644 --- a/src/main/java/com/mini/capi/biz/domain/SyncTask.java +++ b/src/main/java/com/mini/capi/biz/domain/SyncTask.java @@ -15,7 +15,7 @@ import lombok.Setter; *

* * @author gaoxq - * @since 2025-08-26 + * @since 2025-08-27 */ @Getter @Setter @@ -24,42 +24,81 @@ public class SyncTask implements Serializable { private static final long serialVersionUID = 1L; + /** + * 记录创建时间 + */ @TableField("create_time") private LocalDateTime createTime; + /** + * 同步任务唯一标识 + */ @TableId(value = "task_id", type = IdType.AUTO) private String taskId; + /** + * 同步任务名称 + */ @TableField("task_name") private String taskName; + /** + * 源数据库配置ID，关联biz_db_config表 + */ @TableField("source_db_id") private String sourceDbId; + /** + * 目标数据库配置ID，关联biz_db_config表 + */ @TableField("target_db_id") private String targetDbId; + /** + * 源数据库表名 + */ @TableField("source_table") private String sourceTable; + /** + * 目标数据库表名 + */ @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; + /** + * 是否激活（任务启用状态标识） + */ @TableField("is_active") private String isActive; + /** + * 最后一次同步时间 + */ @TableField("last_sync_time") private LocalDateTime lastSyncTime; + /** + * 记录最后更新时间 + */ @TableField("update_time") private LocalDateTime updateTime; diff --git a/src/main/java/com/mini/capi/mybatis/demo.java b/src/main/java/com/mini/capi/mybatis/demo.java index 597fc2f..1db5c67 100644 --- a/src/main/java/com/mini/capi/mybatis/demo.java +++ b/src/main/java/com/mini/capi/mybatis/demo.java @@ -11,7 +11,7 @@ import java.util.Collections; public class demo { public static void main(String[] args) { - FastAutoGenerator.create("jdbc:mysql://192.168.31.189:33069/work?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC", "dream", "info_dream") + FastAutoGenerator.create("jdbc:mysql://crontab.club:33069/work?useUnicode=true&characterEncoding=utf8&serverTimezone=UTC", "dream", "info_dream") .globalConfig(builder -> { builder.author("gaoxq") .outputDir(System.getProperty("user.dir") + "/src/main/java")