From 4229657c5b6be8a1da9e59a40e2426cf6b0995c2 Mon Sep 17 00:00:00 2001
From: 云 <2163098428@qq.com>
Date: 星期日, 25 十月 2026 12:01:55 +0800
Subject: [PATCH] feat(hrm): 新增人事管理模块功能
---
yudao-module-infra/src/main/java/cn/iocoder/yudao/module/infra/service/db/DataSourceConfigServiceImpl.java | 12 ++++++++++++
1 files changed, 12 insertions(+), 0 deletions(-)
diff --git a/yudao-module-infra/src/main/java/cn/iocoder/yudao/module/infra/service/db/DataSourceConfigServiceImpl.java b/yudao-module-infra/src/main/java/cn/iocoder/yudao/module/infra/service/db/DataSourceConfigServiceImpl.java
index 0f31b15..58f2d43 100644
--- a/yudao-module-infra/src/main/java/cn/iocoder/yudao/module/infra/service/db/DataSourceConfigServiceImpl.java
+++ b/yudao-module-infra/src/main/java/cn/iocoder/yudao/module/infra/service/db/DataSourceConfigServiceImpl.java
@@ -27,6 +27,7 @@
import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.filterList;
import static cn.iocoder.yudao.module.infra.enums.ErrorCodeConstants.DATA_SOURCE_CONFIG_IMPORT_LIST_IS_EMPTY;
import static cn.iocoder.yudao.module.infra.enums.ErrorCodeConstants.DATA_SOURCE_CONFIG_IMPORT_NAME_EXISTS;
+import static cn.iocoder.yudao.module.infra.enums.ErrorCodeConstants.DATA_SOURCE_CONFIG_DB_TYPE_UNSUPPORTED;
import static cn.iocoder.yudao.module.infra.enums.ErrorCodeConstants.DATA_SOURCE_CONFIG_NOT_EXISTS;
import static cn.iocoder.yudao.module.infra.enums.ErrorCodeConstants.DATA_SOURCE_CONFIG_NOT_OK;
@@ -105,9 +106,19 @@
}
private void validateConnectionOK(DataSourceConfigDO config) {
+ validateDatabaseTypeSupported(config.getUrl());
boolean success = JdbcUtils.isConnectionOK(config.getUrl(), config.getUsername(), config.getPassword());
if (!success) {
throw exception(DATA_SOURCE_CONFIG_NOT_OK);
+ }
+ }
+
+ /**
+ * 榛樿杞婚噺鍖呭彧鎼哄甫 MySQL 椹卞姩銆傛彁鍓嶇粰鍑烘槑纭彁绀猴紝閬垮厤缂哄皯椹卞姩鏃惰〃鐜版垚鍚硦鐨勮繛鎺ュけ璐ャ��
+ */
+ private void validateDatabaseTypeSupported(String url) {
+ if (!StrUtil.startWithIgnoreCase(url, "jdbc:mysql:")) {
+ throw exception(DATA_SOURCE_CONFIG_DB_TYPE_UNSUPPORTED, url);
}
}
@@ -137,6 +148,7 @@
.build();
importDataSourceConfigs.forEach(importConfig -> {
try {
+ validateDatabaseTypeSupported(importConfig.getUrl());
DataSourceConfigDO existConfig = dataSourceConfigMapper.selectByName(importConfig.getName());
if (existConfig == null) {
// 鏂板
--
Gitblit v1.9.3