p96170835
/
diboot
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

增加获取jdbcUrl的接口

This commit is contained in:
Zhaoyang 2020-03-21 17:01:16 +08:00
parent f5a12b8da1
commit a08e02b0fb
1 changed files with 15 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
diboot-core/src/main/java/com/diboot/core/util/ContextHelper.java
View File

@ -215,6 +215,20 @@ public class ContextHelper implements ApplicationContextAware {
return PK_NID_ENTITY_CACHE.get(entity.getName());
}
/***
* 获取JdbcUrl
* @return
*/
public static String getJdbcUrl() {
Environment environment = getApplicationContext().getEnvironment();
String jdbcUrl = environment.getProperty("spring.datasource.url");
if(jdbcUrl == null){
String master = environment.getProperty("spring.datasource.dynamic.primary");
jdbcUrl = environment.getProperty("spring.datasource.dynamic.datasource."+master+".url");
}
return jdbcUrl;
}
/**
* 获取数据库类型
* @return
@ -223,12 +237,7 @@ public class ContextHelper implements ApplicationContextAware {
if(DATABASE_TYPE != null){
return DATABASE_TYPE;
}
Environment environment = getApplicationContext().getEnvironment();
String jdbcUrl = environment.getProperty("spring.datasource.url");
if(jdbcUrl == null){
String master = environment.getProperty("spring.datasource.dynamic.primary");
jdbcUrl = environment.getProperty("spring.datasource.dynamic.datasource."+master+".url");
}
String jdbcUrl = getJdbcUrl();
if(jdbcUrl != null){
DbType dbType = JdbcUtils.getDbType(jdbcUrl);
DATABASE_TYPE = dbType.getDb();