From 5c59e136837498f6f9209c30c847a3fe6f9c9fad Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=BB=84=E6=B5=B7?= <10402852@qq.com>
Date: Mon, 24 Apr 2023 16:35:00 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8F=98=E6=9B=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/Tools/SyncXtData2022.java | 10 +++++++---
 1 file changed, 7 insertions(+), 3 deletions(-)

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<Record> tableList = Db.use("source").find(sql);
+        List<Record> 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<Record> colsListTarge = Db.use("target").find(sql);
+            if (colsListTarge.size() == 0) {
+                System.out.println("发现表：" + tableName + "不存在，跳过！");
+                continue;
+            }
             List<Record> colsListSource = Db.use("source").find(sql);
             Set<String> targetSet = new HashSet<>();
             for (Record rCol : colsListTarge) {