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 0f307d19acc221fad6ea57f3eb2eb026ebf751c2..b0e6c02020143c2517f285241070e0e0a7a67cbf 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