新增MySQL和pg数据库的同步

This commit is contained in:
2025-08-27 16:45:30 +08:00
parent 306c93e9ad
commit 9e05905dba

View File

@@ -274,6 +274,7 @@ public class taskDbSync {
// 1. 获取源表所有数据
String selectSql = "SELECT * FROM " + sourceTable;
List<Map<String, Object>> dataList = sourceJdbc.queryForList(selectSql);
totalRows = dataList.size();
if (dataList.isEmpty()) {
System.out.println("源表 " + sourceTable + " 没有数据需要同步");
return;