com.easycode8.datasource.dynamic.core

类 DynamicDataSource

java.lang.Object

org.springframework.jdbc.datasource.AbstractDataSource

org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource

com.easycode8.datasource.dynamic.core.DynamicDataSource

所有已实现的接口:

Wrapper, CommonDataSource, DataSource, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean

public class DynamicDataSource
extends org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource
implements org.springframework.beans.factory.DisposableBean

字段概要

字段

限定符和类型	字段和说明
private org.springframework.boot.autoconfigure.jdbc.DataSourceProperties	dataSourceProperties
private List<DataSourceProvider>	dataSourceProviders
private DynamicConnectionProxyFactory	dynamicConnectionProxyFactory
private ConcurrentHashMap<String,DataSource>	dynamicDataSourceMap
private DynamicDataSourceProperties	dynamicDataSourceProperties
private static org.slf4j.Logger	LOGGER

从类继承的字段 org.springframework.jdbc.datasource.AbstractDataSource

logger

构造器概要

构造器

构造器和说明
DynamicDataSource(org.springframework.boot.autoconfigure.jdbc.DataSourceProperties dataSourceProperties, DynamicDataSourceProperties dynamicDataSourceProperties, List<DataSourceProvider> dataSourceProviders, DynamicConnectionProxyFactory dynamicConnectionProxyFactory)

方法概要

限定符和类型	方法和说明
protected void	add(String dataSourceKey, DataSource dataSource)
void	afterPropertiesSet()
private void	chooseDefaultDataSource()
protected void	closeDataSource(String dsName, DataSource dataSource)
void	destroy()
protected Object	determineCurrentLookupKey()
protected DataSource	determineTargetDataSource()
Connection	getConnection()
String	getCurrentDatabaseType() 获取当前动态数据源的数据库类型
protected ConcurrentHashMap<String,DataSource>	getDynamicDataSourceMap()
private void	loadAllDataSource()
protected void	remove(String key)

从类继承的方法 org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource

getConnection, isWrapperFor, resolveSpecifiedDataSource, resolveSpecifiedLookupKey, setDataSourceLookup, setDefaultTargetDataSource, setLenientFallback, setTargetDataSources, unwrap

从类继承的方法 org.springframework.jdbc.datasource.AbstractDataSource

getLoginTimeout, getLogWriter, getParentLogger, setLoginTimeout, setLogWriter

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

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

字段详细资料

LOGGER

private static final org.slf4j.Logger LOGGER

dynamicDataSourceMap

private ConcurrentHashMap<String,DataSource> dynamicDataSourceMap

dataSourceProperties

private final org.springframework.boot.autoconfigure.jdbc.DataSourceProperties dataSourceProperties

dynamicDataSourceProperties

private final DynamicDataSourceProperties dynamicDataSourceProperties

dataSourceProviders

private final List<DataSourceProvider> dataSourceProviders

dynamicConnectionProxyFactory

private final DynamicConnectionProxyFactory dynamicConnectionProxyFactory

构造器详细资料

DynamicDataSource

public DynamicDataSource(org.springframework.boot.autoconfigure.jdbc.DataSourceProperties dataSourceProperties,
                         DynamicDataSourceProperties dynamicDataSourceProperties,
                         List<DataSourceProvider> dataSourceProviders,
                         DynamicConnectionProxyFactory dynamicConnectionProxyFactory)

方法详细资料

determineCurrentLookupKey

protected Object determineCurrentLookupKey()

指定者:

determineCurrentLookupKey 在类中 org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource

determineTargetDataSource

protected DataSource determineTargetDataSource()

覆盖:

determineTargetDataSource 在类中 org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource

getConnection

public Connection getConnection()
                         throws SQLException

指定者:

getConnection 在接口中 DataSource

覆盖:

getConnection 在类中 org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource

抛出:

SQLException

afterPropertiesSet

public void afterPropertiesSet()

指定者:

afterPropertiesSet 在接口中 org.springframework.beans.factory.InitializingBean

覆盖:

afterPropertiesSet 在类中 org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource

destroy

public void destroy()
             throws Exception

指定者:

destroy 在接口中 org.springframework.beans.factory.DisposableBean

抛出:

Exception

add

protected void add(String dataSourceKey,
                   DataSource dataSource)

remove

protected void remove(String key)

getDynamicDataSourceMap

protected ConcurrentHashMap<String,DataSource> getDynamicDataSourceMap()

getCurrentDatabaseType

public String getCurrentDatabaseType()

获取当前动态数据源的数据库类型

返回:

closeDataSource

protected void closeDataSource(String dsName,
                               DataSource dataSource)

chooseDefaultDataSource

private void chooseDefaultDataSource()

loadAllDataSource

private void loadAllDataSource()