diff --git a/server/src/main/java/com/yao2san/simdif/service/synchronizer/MysqlDatasourceSynchronizer.java b/server/src/main/java/com/yao2san/simdif/service/synchronizer/MysqlDatasourceSynchronizer.java
index 8000d2796a69e5f0f2fbfee527cff8342f8b86cb..6260a3cb65472ac1b48fdc647aab974b1ac3264c 100644
--- a/server/src/main/java/com/yao2san/simdif/service/synchronizer/MysqlDatasourceSynchronizer.java
+++ b/server/src/main/java/com/yao2san/simdif/service/synchronizer/MysqlDatasourceSynchronizer.java
@@ -23,7 +23,7 @@ import java.util.Map;
 @Slf4j
 public class MysqlDatasourceSynchronizer extends AbstractDatasourceSynchronizer {
 
-    private static final String SQL_QUERY_TABLE = "select * from information_schema.tables where table_schema = ?";
+    private static final String SQL_QUERY_TABLE = "select * from information_schema.tables where table_schema = ? and table_type = 'BASE TABLE'";
     private static final String SQL_QUERY_COLUMN = "select *  from information_schema.columns where table_schema = ? and table_name=?";
     private static final String SQL_QUERY_INDEX = "select * " +
             "from (SELECT t.TABLE_SCHEMA, " +
diff --git a/server/src/main/java/com/yao2san/simdif/service/synchronizer/PgsqlDatasourceSynchronizer.java b/server/src/main/java/com/yao2san/simdif/service/synchronizer/PgsqlDatasourceSynchronizer.java
index 1d46a5bb9a8e8a6d1d721c2d63d555e6fb625eb2..f6653c9ee17fad20891991ffab992e337c760eea 100644
--- a/server/src/main/java/com/yao2san/simdif/service/synchronizer/PgsqlDatasourceSynchronizer.java
+++ b/server/src/main/java/com/yao2san/simdif/service/synchronizer/PgsqlDatasourceSynchronizer.java
@@ -27,11 +27,10 @@ public class PgsqlDatasourceSynchronizer extends AbstractDatasourceSynchronizer
 
     private static final String SQL_QUERY_TABLE = "select t.*, " +
             "       cast(obj_description(relfilenode, 'pg_class') AS VARCHAR) AS \"TABLE_COMMENT\" " +
-            "from information_schema.tables t, " +
-            "     pg_class pc " +
-            "where table_catalog=? " +
+            "from information_schema.tables t join pg_class pc on t.table_name = pc.relname " +
+            "join pg_namespace ns on ns.oid = pc.relnamespace and ns.nspname = t.table_schema " +
+            "where t.table_catalog=? " +
             "  and table_schema =? " +
-            "  and t.table_name = pc.relname " +
             "  and t.table_type = 'BASE TABLE' " +
             "  AND t.table_name NOT LIKE 'pg_%' " +
             "  AND t.table_name NOT LIKE 'sql_%'" +