From c1acd03939c37e4a717e01d4e01751603cddf1de Mon Sep 17 00:00:00 2001
From: bouyei <453840293@qq.com>
Date: Fri, 3 Apr 2026 01:46:57 +0000
Subject: [PATCH] =?UTF-8?q?pg=E7=9A=84schemaname=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Signed-off-by: bouyei <453840293@qq.com>
---
 .../qiantong/qdata/common/database/dialect/PostgreDialect.java  | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/qdata-framework/qdata-common/src/main/java/tech/qiantong/qdata/common/database/dialect/PostgreDialect.java b/qdata-framework/qdata-common/src/main/java/tech/qiantong/qdata/common/database/dialect/PostgreDialect.java
index 0f307d19..b0e6c020 100644
--- a/qdata-framework/qdata-common/src/main/java/tech/qiantong/qdata/common/database/dialect/PostgreDialect.java
+++ b/qdata-framework/qdata-common/src/main/java/tech/qiantong/qdata/common/database/dialect/PostgreDialect.java
@@ -82,7 +82,7 @@ public class PostgreDialect extends AbstractDbDialect {
 
     @Override
     public String generateCheckTableExistsSQL(DbQueryProperty dbQueryProperty, String tableName) {
-        return "SELECT COUNT(*) FROM pg_catalog.pg_tables WHERE schemaname = '" + dbQueryProperty.getDbName() + "' AND tablename = '" + tableName + "';";
+        return "SELECT COUNT(*) FROM pg_catalog.pg_tables WHERE schemaname = '" + dbQueryProperty.getSid() + "' AND tablename = '" + tableName + "';";
     }
 
     @Override
-- 
Gitee