fuhouyin/dynamic-datasource
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

perf(close-datasource): 在分组数据库map删除后删除datasource (#618)

Browse Source 
baomidou/dynamic-datasource#614
This commit is contained in:
冰彦糖 2024-01-10 09:41:37 +08:00 committed by GitHub
parent f4951da719
commit 700d8c904c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dynamic-datasource-spring/src/main/java/com/baomidou/dynamic/datasource/DynamicRoutingDataSource.java
View File

@ -194,7 +194,6 @@ public class DynamicRoutingDataSource extends AbstractRoutingDataSource implemen
} }
if (dataSourceMap.containsKey(ds)) { if (dataSourceMap.containsKey(ds)) {
DataSource dataSource = dataSourceMap.remove(ds); DataSource dataSource = dataSourceMap.remove(ds);
closeDataSource(ds, dataSource, graceDestroy);
if (ds.contains(UNDERLINE)) { if (ds.contains(UNDERLINE)) {
String group = ds.split(UNDERLINE)[0]; String group = ds.split(UNDERLINE)[0];
if (groupDataSources.containsKey(group)) { if (groupDataSources.containsKey(group)) {
@ -204,6 +203,7 @@ public class DynamicRoutingDataSource extends AbstractRoutingDataSource implemen
} }
} }
} }
closeDataSource(ds, dataSource, graceDestroy);
log.info("dynamic-datasource - remove the database named [{}] success", ds); log.info("dynamic-datasource - remove the database named [{}] success", ds);
} else { } else {
log.warn("dynamic-datasource - could not find a database named [{}]", ds); log.warn("dynamic-datasource - could not find a database named [{}]", ds);