net.sohelp.boot.admin.core.db.datasource

类 SohelpDynamicDatasource

java.lang.Object

net.sohelp.boot.admin.core.db.datasource.SohelpDynamicDatasource

@Component
public class SohelpDynamicDatasource
extends Object

动态数据源进行封装 ，集成MagicApi动态数据源

从以下版本开始:

2024/3/30 11:44

作者:

AaronFung

构造器概要

构造器

构造器和说明
SohelpDynamicDatasource()

方法概要

限定符和类型	方法和说明
void	delete(String keyName) 关闭数据源
boolean	exist(String key) 根据数据源名称判断数据源是否存在
String	getDatabaseName() 获取默认数据库名字
String	getDatabaseName(String key)
String	getDatabaseType() 获取默认数据源类型
String	getDatabaseType(String key) 根据数据源获取数据库类型
DataSource	getDatasource(String key) 根据数据源Key获取数据源
org.springframework.jdbc.core.JdbcTemplate	getJdbcTemplate(String key) 根据数据源获取JdbcTemplate接口
org.mybatis.spring.SqlSessionTemplate	getSessionTemplate(String key) 根据数据源K获取SqlSessionTemplate接口
org.apache.ibatis.session.SqlSessionFactory	getSqlSessionFactory(DataSource datasource) 根据Datasource初始化SqlSessionFactory
Map<String,String>	getTableComment(String key) 根据数据源获取表备注说明
Map<String,Map<String,Map<String,Object>>>	getTableField(String key) 获取表字段信息
Map<String,Map<String,Object>>	getTableField(String key, String tableName) 获取表结构信息
String	getTypeByDbName(String dbName) 根据数据库名字获取数据库类型
List<String>	list() 获取已启动数据源列表
void	refresh() 初始化数据源
void	reloadTable(String datasource, String tableName) 根据数据源和表名重新加载表结构
void	removeTableCache(String key) 根据数据源删除表缓存
void	start(String key) 启动数据源

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

SohelpDynamicDatasource

public SohelpDynamicDatasource()

方法详细资料

removeTableCache

@Comment(value="\u6839\u636e\u6570\u636e\u6e90\u5220\u9664\u8868\u7f13\u5b58")
public void removeTableCache(String key)
                                                                                                      throws SQLException

根据数据源删除表缓存

参数:

key -

抛出:

SQLException

exist

@Comment(value="\u6839\u636e\u6570\u636e\u6e90\u540d\u79f0\u5224\u65ad\u6570\u636e\u6e90\u662f\u5426\u5b58\u5728")
public boolean exist(String key)

根据数据源名称判断数据源是否存在

参数:

key - 数据源Key

返回:

getDatabaseName

@Comment(value="\u6839\u636e\u6570\u636e\u6e90\u83b7\u53d6\u6570\u636e\u5e93\u540d\u79f0")
public String getDatabaseName(String key)
                                                                                                                   throws SQLException

参数:

key - 数据源Key

返回:

抛出:

SQLException

getTableComment

@Comment(value="\u6839\u636e\u6570\u636e\u6e90\u83b7\u53d6\u8868\u5907\u6ce8\u8bf4\u660e")
public Map<String,String> getTableComment(String key)
                                                                                                                               throws SQLException

根据数据源获取表备注说明

参数:

key - 数据源

返回:

抛出:

SQLException

getTableField

@Comment(value="\u83b7\u53d6\u8868\u7ed3\u6784\u4fe1\u606f")
public Map<String,Map<String,Object>> getTableField(String key,
                                                                                                                  String tableName)
                                                                                                           throws SQLException

获取表结构信息

参数:

key - 数据源

tableName - 表名

返回:

抛出:

SQLException

getTableField

@Comment(value="\u83b7\u53d6\u8868\u5b57\u6bb5\u4fe1\u606f")
public Map<String,Map<String,Map<String,Object>>> getTableField(String key)
                                                                                                                       throws SQLException

获取表字段信息

参数:

key - 数据源

返回:

抛出:

SQLException

getDatabaseType

@Comment(value="\u6839\u636e\u6570\u636e\u6e90\u83b7\u53d6\u6570\u636e\u5e93\u7c7b\u578b")
public String getDatabaseType(String key)
                                                                                                                   throws SQLException

根据数据源获取数据库类型

参数:

key - 数据源Key

返回:

抛出:

SQLException

getTypeByDbName

@Comment(value="\u6839\u636e\u6570\u636e\u5e93\u540d\u5b57\u83b7\u53d6\u6570\u636e\u5e93\u7c7b\u578b")
public String getTypeByDbName(String dbName)
                                                                                                                               throws SQLException

根据数据库名字获取数据库类型

参数:

dbName - 数据库名称

返回:

抛出:

SQLException

getDatasource

@Comment(value="\u6839\u636e\u6570\u636e\u6e90Key\u83b7\u53d6\u6570\u636e\u6e90")
public DataSource getDatasource(String key)

根据数据源Key获取数据源

参数:

key - 数据源Key

返回:

reloadTable

@Comment(value="\u6839\u636e\u6570\u636e\u6e90\u548c\u8868\u540d\u91cd\u65b0\u52a0\u8f7d\u8868\u7ed3\u6784")
public void reloadTable(String datasource,
                                                                                                                                      String tableName)

根据数据源和表名重新加载表结构

参数:

datasource - 数据源

tableName - 表名

getDatabaseName

@Comment(value="\u83b7\u53d6\u9ed8\u8ba4\u6570\u636e\u5e93\u540d\u5b57")
public String getDatabaseName()
                                                                                                 throws SQLException

获取默认数据库名字

返回:

抛出:

SQLException

getDatabaseType

@Comment(value="\u83b7\u53d6\u9ed8\u8ba4\u6570\u636e\u6e90\u7c7b\u578b")
public String getDatabaseType()
                                                                                                 throws SQLException

获取默认数据源类型

返回:

抛出:

SQLException

list

@Comment(value="\u83b7\u53d6\u5df2\u542f\u52a8\u6570\u636e\u6e90\u5217\u8868")
public List<String> list()

获取已启动数据源列表

返回:

getJdbcTemplate

@Comment(value="\u6839\u636e\u6570\u636e\u6e90\u83b7\u53d6JdbcTemplate\u63a5\u53e3")
public org.springframework.jdbc.core.JdbcTemplate getJdbcTemplate(String key)

根据数据源获取JdbcTemplate接口

参数:

key - 数据源Key

返回:

getSqlSessionFactory

@Comment(value="\u6839\u636eDatasource\u521d\u59cb\u5316SqlSessionFactory")
public org.apache.ibatis.session.SqlSessionFactory getSqlSessionFactory(DataSource datasource)
                                                                                                                                              throws SQLException

根据Datasource初始化SqlSessionFactory

参数:

datasource - 数据源

返回:

抛出:

Exception

SQLException

getSessionTemplate

@Comment(value="\u6839\u636e\u6570\u636e\u6e90K\u83b7\u53d6SqlSessionTemplate\u63a5\u53e3")
public org.mybatis.spring.SqlSessionTemplate getSessionTemplate(String key)
                                                                                                                                                      throws SQLException

根据数据源K获取SqlSessionTemplate接口

参数:

key - 数据源Key

返回:

抛出:

Exception

SQLException

refresh

@PostConstruct
 @Comment(value="\u521d\u59cb\u5316\u6570\u636e\u6e90")
public void refresh()
                                                                                      throws SQLException

初始化数据源

抛出:

SQLException

start

@Comment(value="\u542f\u52a8\u6570\u636e\u6e90")
public void start(String key)
                                                             throws Exception

启动数据源

参数:

key - 数据源Key

抛出:

Exception

delete

@Comment(value="\u5173\u95ed\u6570\u636e\u6e90")
public void delete(String keyName)

关闭数据源

参数:

keyName - 数据源Key