From a97619d459ba8d95fc67e83d5d8350245a6139ce Mon Sep 17 00:00:00 2001 From: gaoxq <376340421@qq.com> Date: Wed, 27 Aug 2025 13:05:59 +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 --- src/main/java/com/mini/capi/job/taskDbSync.java | 3 --- 1 file changed, 3 deletions(-) diff --git a/src/main/java/com/mini/capi/job/taskDbSync.java b/src/main/java/com/mini/capi/job/taskDbSync.java index 7ab272e..3ff719f 100644 --- a/src/main/java/com/mini/capi/job/taskDbSync.java +++ b/src/main/java/com/mini/capi/job/taskDbSync.java @@ -56,8 +56,6 @@ public class taskDbSync { JdbcTemplate targetJdbc = DataSourceConfig.createJdbcTemplate(targetDbConfig); // 3. 执行表同步逻辑(异步执行) syncTableData(task, sourceJdbc, targetJdbc); - // 同步成功日志 - System.out.println("任务 " + task.getTaskId() + "(" + task.getSourceTable() + "→" + task.getTargetTable() + ")已提交至后台执行"); } catch (Exception e) { // 捕获任务执行异常,记录错误信息(仅后台打印,不阻塞接口) String errorMsg = "任务 " + task.getTaskId() + " 同步失败: " + e.getMessage(); @@ -84,7 +82,6 @@ public class taskDbSync { // 确保源表和目标表名转为小写 String sourceTable = task.getSourceTable().toLowerCase(); String targetTable = task.getTargetTable().toLowerCase(); - // 1. 检查并创建目标表 if (!tableExists(targetJdbc, targetTable)) { createTargetTable(sourceJdbc, targetJdbc, sourceTable, targetTable);