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