diff --git a/datai-system/src/main/java/com/datai/system/service/impl/SysDatasourceConfigServiceImpl.java b/datai-system/src/main/java/com/datai/system/service/impl/SysDatasourceConfigServiceImpl.java index cf463089..52c8488f 100644 --- a/datai-system/src/main/java/com/datai/system/service/impl/SysDatasourceConfigServiceImpl.java +++ b/datai-system/src/main/java/com/datai/system/service/impl/SysDatasourceConfigServiceImpl.java @@ -464,14 +464,14 @@ public class SysDatasourceConfigServiceImpl implements ISysDatasourceConfigServi throw new RuntimeException("数据源名称已存在:" + environmentCode); } - String masterPasswordDecrypted = decryptPassword(masterPassword); + String masterPasswordPlain = masterPassword; Connection connection = null; Statement statement = null; SysDatasourceConfig slaveConfig = null; try { - connection = DriverManager.getConnection(masterUrl, masterUsername, masterPasswordDecrypted); + connection = DriverManager.getConnection(masterUrl, masterUsername, masterPasswordPlain); statement = connection.createStatement(); String createDbSql = String.format("CREATE DATABASE `%s` CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci", slaveDbName); @@ -504,7 +504,7 @@ public class SysDatasourceConfigServiceImpl implements ISysDatasourceConfigServi log.info("[从库创建] 数据源配置写入成功, ID: {}", slaveConfig.getId()); String slaveJdbcUrl = buildJdbcUrl(slaveConfig); - dynamicDataSourceManager.addDynamicDataSource(slaveConfig.getDsName(), slaveJdbcUrl, slaveConfig.getUsername(), masterPasswordDecrypted); + dynamicDataSourceManager.addDynamicDataSource(slaveConfig.getDsName(), slaveJdbcUrl, slaveConfig.getUsername(), masterPasswordPlain); log.info("[从库创建] 数据源注册成功: {}", slaveConfig.getDsName()); switchDataSource(slaveConfig.getDsName());