ldeyun/RUOYI-geek
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

多提交了一个文件

Browse Source
This commit is contained in:
dftre 2024-07-18 10:52:31 +08:00
parent 769e4574ff
commit ac9ef6ec1a
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
ruoyi-framework/src/main/java/com/ruoyi/framework/config/SqlSessionFactoryConfig.java
View File

@ -1,7 +1,6 @@
package com.ruoyi.framework.config; package com.ruoyi.framework.config;
import java.util.HashMap; import java.util.HashMap;
import java.util.List;
import java.util.Map; import java.util.Map;
import javax.sql.DataSource; import javax.sql.DataSource;
@ -26,12 +25,11 @@ public class SqlSessionFactoryConfig {
DynamicDataSourceProperties dataSourceProperties; DynamicDataSourceProperties dataSourceProperties;
@Bean(name = "sqlSessionTemplate") @Bean(name = "sqlSessionTemplate")
public DynamicSqlSessionTemplate sqlSessionTemplate(Environment env,List<SqlSessionFactory> sqlSessionFactoryList) throws Exception { public DynamicSqlSessionTemplate sqlSessionTemplate(Environment env) throws Exception {
Map<Object, SqlSessionFactory> sqlSessionFactoryMap = new HashMap<>(); Map<Object, SqlSessionFactory> sqlSessionFactoryMap = new HashMap<>();
Map<String, DataSource> targetDataSources = dataSourceProperties.getTargetDataSources(); Map<String, DataSource> targetDataSources = dataSourceProperties.getTargetDataSources();
for (Map.Entry<String, DataSource> entry : targetDataSources.entrySet()) { for (Map.Entry<String, DataSource> entry : targetDataSources.entrySet()) {
SqlSessionFactory sessionFactory = createSqlSessionFactory.createSqlSessionFactory(env, entry.getValue()); SqlSessionFactory sessionFactory = createSqlSessionFactory.createSqlSessionFactory(env, entry.getValue());
sqlSessionFactoryList.add(sessionFactory);
sqlSessionFactoryMap.put(entry.getKey(), sessionFactory); sqlSessionFactoryMap.put(entry.getKey(), sessionFactory);
// 应对热重载的特殊处理 // 应对热重载的特殊处理
Object ret = com.atomikos.icatch.config.Configuration.removeResource(entry.getKey()); Object ret = com.atomikos.icatch.config.Configuration.removeResource(entry.getKey());