diff --git a/src/main/java/Tools/SyncXtData2022.java b/src/main/java/Tools/SyncXtData2022.java index e160d1b..1d5b532 100644 --- a/src/main/java/Tools/SyncXtData2022.java +++ b/src/main/java/Tools/SyncXtData2022.java @@ -41,12 +41,16 @@ public class SyncXtData2022 { arp2.start(); String sql = "select tablename from pg_tables where schemaname='public'"; - List tableList = Db.use("source").find(sql); + List sourceTableList = Db.use("source").find(sql); - for (Record tableRecord : tableList) { - String tableName = tableRecord.getStr("tablename"); + for (Record sourceTable : sourceTableList) { + String tableName = sourceTable.getStr("tablename"); sql = "select a.attname as name from pg_class as c,pg_attribute as a where c.relname = '" + tableName + "' and a.attrelid = c.oid and a.attnum>0"; List colsListTarge = Db.use("target").find(sql); + if (colsListTarge.size() == 0) { + System.out.println("发现表:" + tableName + "不存在,跳过!"); + continue; + } List colsListSource = Db.use("source").find(sql); Set targetSet = new HashSet<>(); for (Record rCol : colsListTarge) {