manager/c-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

新增MySQL和pg数据库的同步

Browse Source
This commit is contained in:
gaoxq
2025-08-27 17:17:47 +08:00
parent a0b51f56a5
commit fb465898f5
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/com/mini/capi/job/taskDbSync.java
View File

@@ -336,6 +336,8 @@ public class taskDbSync {
errorMsg = e.getMessage() != null ? e.getMessage() : e.getClass().getSimpleName(); errorMsg = e.getMessage() != null ? e.getMessage() : e.getClass().getSimpleName();
System.err.println("同步数据失败: " + errorMsg); System.err.println("同步数据失败: " + errorMsg);
} }
task.setLastSyncTime(LocalDateTime.now());
syncTaskService.updateById(task);
DbConfig sourceDbConfig = dbConfigService.getById(task.getSourceDbId()); DbConfig sourceDbConfig = dbConfigService.getById(task.getSourceDbId());
DbConfig targetDbConfig = dbConfigService.getById(task.getTargetDbId()); DbConfig targetDbConfig = dbConfigService.getById(task.getTargetDbId());
LocalDateTime endTime = LocalDateTime.now(); LocalDateTime endTime = LocalDateTime.now();