com.mybatisflex.core.datasource

Class FlexDataSource

java.lang.Object

com.mybatisflex.core.datasource.AbstractDataSource

com.mybatisflex.core.datasource.FlexDataSource

All Implemented Interfaces:

Wrapper, CommonDataSource, DataSource

public class FlexDataSource
extends AbstractDataSource

Author:

michael

Constructor Summary

Constructors

Constructor and Description
FlexDataSource(String dataSourceKey, DataSource dataSource)
FlexDataSource(String dataSourceKey, DataSource dataSource, boolean needDecryptDataSource)

Method Summary

Modifier and Type	Method and Description
void	addDataSource(String dataSourceKey, DataSource dataSource)
void	addDataSource(String dataSourceKey, DataSource dataSource, boolean needDecryptDataSource)
Connection	getConnection()
Connection	getConnection(String username, String password)
protected DataSource	getDataSource()
Map<String,DataSource>	getDataSourceMap()
DbType	getDbType(String dataSourceKey)
Map<String,DbType>	getDbTypeHashMap()
DataSource	getDefaultDataSource()
String	getDefaultDataSourceKey()
DbType	getDefaultDbType()
String	getUrl() 方便用于 DbTypeUtil.getDbType(DataSource)
boolean	isWrapperFor(Class<?> iface)
Connection	proxy(Connection connection, String xid)
void	removeDatasource(String dataSourceKey)
void	setDefaultDataSource(String dataSourceKey) 设置默认数据源（提供动态可控性）
<T> T	unwrap(Class<T> iface)

Methods inherited from class com.mybatisflex.core.datasource.AbstractDataSource

getLoginTimeout, getLogWriter, getParentLogger, setLoginTimeout, setLogWriter

Methods inherited from class java.lang.Object

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

Constructor Detail

FlexDataSource

public FlexDataSource(String dataSourceKey,
                      DataSource dataSource)

FlexDataSource

public FlexDataSource(String dataSourceKey,
                      DataSource dataSource,
                      boolean needDecryptDataSource)

Method Detail

setDefaultDataSource

public void setDefaultDataSource(String dataSourceKey)

设置默认数据源（提供动态可控性）

addDataSource

public void addDataSource(String dataSourceKey,
                          DataSource dataSource)

addDataSource

public void addDataSource(String dataSourceKey,
                          DataSource dataSource,
                          boolean needDecryptDataSource)

removeDatasource

public void removeDatasource(String dataSourceKey)

getDataSourceMap

public Map<String,DataSource> getDataSourceMap()

getDbTypeHashMap

public Map<String,DbType> getDbTypeHashMap()

getDefaultDataSourceKey

public String getDefaultDataSourceKey()

getDefaultDataSource

public DataSource getDefaultDataSource()

getDefaultDbType

public DbType getDefaultDbType()

getDbType

public DbType getDbType(String dataSourceKey)

getConnection

public Connection getConnection()
                         throws SQLException

Throws:

SQLException

getConnection

public Connection getConnection(String username,
                                String password)
                         throws SQLException

Throws:

SQLException

proxy

public Connection proxy(Connection connection,
                        String xid)

getUrl

public String getUrl()

方便用于 DbTypeUtil.getDbType(DataSource)

unwrap

public <T> T unwrap(Class<T> iface)
             throws SQLException

Specified by:

unwrap in interface Wrapper

Overrides:

unwrap in class AbstractDataSource

Throws:

SQLException

isWrapperFor

public boolean isWrapperFor(Class<?> iface)
                     throws SQLException

Specified by:

isWrapperFor in interface Wrapper

Overrides:

isWrapperFor in class AbstractDataSource

Throws:

SQLException

getDataSource

protected DataSource getDataSource()