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);