From 36e9c3d094a9e678c5cf22b656819e1516e25690 Mon Sep 17 00:00:00 2001
From: fengshuonan <sn93@qq.com>
Date: Wed, 7 May 2025 11:08:33 +0800
Subject: [PATCH] =?UTF-8?q?=E3=80=908.3.4=E3=80=91=E3=80=90sys=5Fconfig?=
 =?UTF-8?q?=E3=80=91=E6=9B=B4=E6=96=B0config=E6=A8=A1=E5=9D=97=E6=9F=A5?=
 =?UTF-8?q?=E8=AF=A2=E8=A1=A8=E6=95=B0=E6=8D=AE=E7=9A=84sql?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../modular/factory/SysConfigDataFactory.java | 45 ++++++++++++++++---
 .../sqladapter/PgsqlSysConfigData.java        |  2 +-
 2 files changed, 41 insertions(+), 6 deletions(-)

diff --git a/kernel-d-config/config-business/src/main/java/cn/stylefeng/roses/kernel/config/modular/factory/SysConfigDataFactory.java b/kernel-d-config/config-business/src/main/java/cn/stylefeng/roses/kernel/config/modular/factory/SysConfigDataFactory.java
index 1826daf7d..4f889194d 100644
--- a/kernel-d-config/config-business/src/main/java/cn/stylefeng/roses/kernel/config/modular/factory/SysConfigDataFactory.java
+++ b/kernel-d-config/config-business/src/main/java/cn/stylefeng/roses/kernel/config/modular/factory/SysConfigDataFactory.java
@@ -24,17 +24,52 @@ public class SysConfigDataFactory {
      */
     public static SysConfigDataApi getSysConfigDataApi(String jdbcUrl) {
         DbTypeEnum dbType = DatabaseTypeUtil.getDbType(jdbcUrl);
+
+        // mysql数据库
         if (DbTypeEnum.MYSQL.equals(dbType)) {
             return new MysqlSysConfigData();
-        } else if (DbTypeEnum.PG_SQL.equals(dbType)) {
+        }
+
+        // pgsql数据库
+        else if (DbTypeEnum.PG_SQL.equals(dbType)) {
             return new PgsqlSysConfigData();
-        } else if (DbTypeEnum.MS_SQL.equals(dbType)) {
+        }
+
+        // sql server数据库
+        else if (DbTypeEnum.MS_SQL.equals(dbType)) {
             return new MssqlSysConfigData();
-        } else if (DbTypeEnum.ORACLE.equals(dbType)) {
-            return new OracleSysConfigData();
-        } else if (DbTypeEnum.DM.equals(dbType)) {
+        }
+
+        // oracle数据库
+        else if (DbTypeEnum.ORACLE.equals(dbType)) {
             return new OracleSysConfigData();
         }
+
+        // 达梦数据库
+        else if (DbTypeEnum.DM.equals(dbType)) {
+            return new OracleSysConfigData();
+        }
+
+        // 海量数据库
+        else if (DbTypeEnum.VAST_DATA.equals(dbType)) {
+            return new PgsqlSysConfigData();
+        }
+
+        // 人大进仓数据库
+        else if (DbTypeEnum.KING_BASE.equals(dbType)) {
+            return new PgsqlSysConfigData();
+        }
+
+        // 华为OpenGauss
+        else if (DbTypeEnum.OPEN_GAUSS.equals(dbType)) {
+            return new PgsqlSysConfigData();
+        }
+
+        // 瀚高数据库
+        else if (DbTypeEnum.HIGH_GO.equals(dbType)) {
+            return new PgsqlSysConfigData();
+        }
+
         return new MysqlSysConfigData();
     }
 
diff --git a/kernel-d-config/config-business/src/main/java/cn/stylefeng/roses/kernel/config/modular/sqladapter/PgsqlSysConfigData.java b/kernel-d-config/config-business/src/main/java/cn/stylefeng/roses/kernel/config/modular/sqladapter/PgsqlSysConfigData.java
index 715aabd9b..5fd538a05 100644
--- a/kernel-d-config/config-business/src/main/java/cn/stylefeng/roses/kernel/config/modular/sqladapter/PgsqlSysConfigData.java
+++ b/kernel-d-config/config-business/src/main/java/cn/stylefeng/roses/kernel/config/modular/sqladapter/PgsqlSysConfigData.java
@@ -28,7 +28,7 @@ public class PgsqlSysConfigData implements SysConfigDataApi {
 
     @Override
     public String getConfigListSql() {
-        return "select config_code, config_value from sys_config where status_flag = ? and del_flag = ?";
+        return "SELECT config_code, config_value FROM public.sys_config WHERE status_flag = ? AND del_flag = ?";
     }
 
 }