diff --git a/src/main/java/com/mini/capi/job/taskDbSync.java b/src/main/java/com/mini/capi/job/taskDbSync.java index bf45dc0..7f1da04 100644 --- a/src/main/java/com/mini/capi/job/taskDbSync.java +++ b/src/main/java/com/mini/capi/job/taskDbSync.java @@ -274,6 +274,7 @@ public class taskDbSync { // 1. 获取源表所有数据 String selectSql = "SELECT * FROM " + sourceTable; List> dataList = sourceJdbc.queryForList(selectSql); + totalRows = dataList.size(); if (dataList.isEmpty()) { System.out.println("源表 " + sourceTable + " 没有数据需要同步"); return;