【8.3.4】【sys_config】更新config模块查询表数据的sql

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();
     }
 

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 = ?";
     }
 
 }