Package com.alibaba.druid.pool.ha

Class HighAvailableDataSource

java.lang.Object

com.alibaba.druid.pool.WrapperAdapter

com.alibaba.druid.pool.ha.HighAvailableDataSource

All Implemented Interfaces:

Wrapper, CommonDataSource, DataSource

public class HighAvailableDataSource
extends WrapperAdapter
implements DataSource

DataSource class which contains multiple DataSource objects.

Author:

DigitalSonic

Constructor Summary

Constructors

Constructor	Description
HighAvailableDataSource()

Method Summary

Modifier and Type	Method	Description
void	addBlackList(String name)
void	close()
void	destroy()
Map<String,DataSource>	getAvailableDataSourceMap()
Connection	getConnection()
Connection	getConnection(String username, String password)
String	getConnectionProperties()
Properties	getConnectProperties()
String	getDataSourceFile()
Map<String,DataSource>	getDataSourceMap()
DataSourceSelector	getDataSourceSelector()
String	getDriverClassName()
String	getFilters()
int	getInitialSize()
int	getLoginTimeout()
PrintWriter	getLogWriter()
int	getMaxActive()
long	getMaxEvictableIdleTimeMillis()
int	getMaxPoolPreparedStatementPerConnectionSize()
long	getMaxWait()
long	getMinEvictableIdleTimeMillis()
int	getMinIdle()
NodeListener	getNodeListener()
Logger	getParentLogger()
long	getPhyTimeoutMillis()
int	getPoolPurgeIntervalSeconds()
String	getPropertyPrefix()
List<Filter>	getProxyFilters()
int	getQueryTimeout()
long	getRemoveAbandonedTimeoutMillis()
String	getSelector()
long	getTimeBetweenConnectErrorMillis()
long	getTimeBetweenEvictionRunsMillis()
int	getTransactionQueryTimeout()
String	getValidationQuery()
int	getValidationQueryTimeout()
void	init()
boolean	isAllowEmptyPoolWhenUpdate()
boolean	isInBlackList(String name)
boolean	isLogAbandoned()
boolean	isPoolPreparedStatements()
boolean	isRemoveAbandoned()
boolean	isSharePreparedStatements()
boolean	isTestOnBorrow()
boolean	isTestOnReturn()
boolean	isTestWhileIdle()
void	removeBlackList(String name)
void	setAllowEmptyPoolWhenUpdate(boolean allowEmptyPoolWhenUpdate)
void	setConnectionProperties(String connectionProperties)
void	setConnectProperties(Properties connectProperties)
void	setDataSourceFile(String dataSourceFile)
void	setDataSourceMap(Map<String,DataSource> dataSourceMap)
void	setDataSourceSelector(DataSourceSelector dataSourceSelector)
void	setDriverClassName(String driverClassName)
void	setFilters(String filters)
void	setInitialSize(int initialSize)
void	setLogAbandoned(boolean logAbandoned)
void	setLoginTimeout(int seconds)
void	setLogWriter(PrintWriter out)
void	setMaxActive(int maxActive)
void	setMaxEvictableIdleTimeMillis(long maxEvictableIdleTimeMillis)
void	setMaxPoolPreparedStatementPerConnectionSize(int maxPoolPreparedStatementPerConnectionSize)
void	setMaxWait(long maxWait)
void	setMinEvictableIdleTimeMillis(long minEvictableIdleTimeMillis)
void	setMinIdle(int minIdle)
void	setNodeListener(NodeListener nodeListener)
void	setPhyTimeoutMillis(long phyTimeoutMillis)
void	setPoolPreparedStatements(boolean poolPreparedStatements)
void	setPoolPurgeIntervalSeconds(int poolPurgeIntervalSeconds)
void	setPropertyPrefix(String propertyPrefix)
void	setProxyFilters(List<Filter> proxyFilters)
void	setQueryTimeout(int queryTimeout)
void	setRemoveAbandoned(boolean removeAbandoned)
void	setRemoveAbandonedTimeoutMillis(long removeAbandonedTimeoutMillis)
void	setSelector(String name)
void	setSharePreparedStatements(boolean sharePreparedStatements)
void	setTargetDataSource(String targetName)
void	setTestOnBorrow(boolean testOnBorrow)
void	setTestOnReturn(boolean testOnReturn)
void	setTestWhileIdle(boolean testWhileIdle)
void	setTimeBetweenConnectErrorMillis(long timeBetweenConnectErrorMillis)
void	setTimeBetweenEvictionRunsMillis(long timeBetweenEvictionRunsMillis)
void	setTransactionQueryTimeout(int transactionQueryTimeout)
void	setValidationQuery(String validationQuery)
void	setValidationQueryTimeout(int validationQueryTimeout)

Methods inherited from class com.alibaba.druid.pool.WrapperAdapter

isWrapperFor, unwrap

Methods inherited from class java.lang.Object

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

Methods inherited from interface javax.sql.CommonDataSource

createShardingKeyBuilder

Methods inherited from interface javax.sql.DataSource

createConnectionBuilder

Methods inherited from interface java.sql.Wrapper

isWrapperFor, unwrap

Constructor Detail

HighAvailableDataSource

public HighAvailableDataSource()

Method Detail

init

public void init()

close

public void close()

destroy

public void destroy()

setTargetDataSource

public void setTargetDataSource(String targetName)

getConnection

public Connection getConnection()
                         throws SQLException

Specified by:

getConnection in interface DataSource

Throws:

SQLException

getDataSourceFile

public String getDataSourceFile()

setDataSourceFile

public void setDataSourceFile(String dataSourceFile)

getPropertyPrefix

public String getPropertyPrefix()

setPropertyPrefix

public void setPropertyPrefix(String propertyPrefix)

setDataSourceMap

public void setDataSourceMap(Map<String,DataSource> dataSourceMap)

getDataSourceMap

public Map<String,DataSource> getDataSourceMap()

getAvailableDataSourceMap

public Map<String,DataSource> getAvailableDataSourceMap()

addBlackList

public void addBlackList(String name)

removeBlackList

public void removeBlackList(String name)

isInBlackList

public boolean isInBlackList(String name)

setSelector

public void setSelector(String name)

getSelector

public String getSelector()

getConnection

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

Specified by:

getConnection in interface DataSource

Throws:

SQLException

setLoginTimeout

public void setLoginTimeout(int seconds)

Specified by:

setLoginTimeout in interface CommonDataSource

Specified by:

setLoginTimeout in interface DataSource

getLoginTimeout

public int getLoginTimeout()

Specified by:

getLoginTimeout in interface CommonDataSource

Specified by:

getLoginTimeout in interface DataSource

getParentLogger

public Logger getParentLogger()
                       throws SQLFeatureNotSupportedException

Specified by:

getParentLogger in interface CommonDataSource

Throws:

SQLFeatureNotSupportedException

setConnectionProperties

public void setConnectionProperties(String connectionProperties)

setConnectProperties

public void setConnectProperties(Properties connectProperties)

isAllowEmptyPoolWhenUpdate

public boolean isAllowEmptyPoolWhenUpdate()

setAllowEmptyPoolWhenUpdate

public void setAllowEmptyPoolWhenUpdate(boolean allowEmptyPoolWhenUpdate)

getPoolPurgeIntervalSeconds

public int getPoolPurgeIntervalSeconds()

setPoolPurgeIntervalSeconds

public void setPoolPurgeIntervalSeconds(int poolPurgeIntervalSeconds)

getNodeListener

public NodeListener getNodeListener()

setNodeListener

public void setNodeListener(NodeListener nodeListener)

getDataSourceSelector

public DataSourceSelector getDataSourceSelector()

setDataSourceSelector

public void setDataSourceSelector(DataSourceSelector dataSourceSelector)

getLogWriter

public PrintWriter getLogWriter()
                         throws SQLException

Specified by:

getLogWriter in interface CommonDataSource

Specified by:

getLogWriter in interface DataSource

Throws:

SQLException

setLogWriter

public void setLogWriter(PrintWriter out)
                  throws SQLException

Specified by:

setLogWriter in interface CommonDataSource

Specified by:

setLogWriter in interface DataSource

Throws:

SQLException

getDriverClassName

public String getDriverClassName()

setDriverClassName

public void setDriverClassName(String driverClassName)

getConnectProperties

public Properties getConnectProperties()

getInitialSize

public int getInitialSize()

setInitialSize

public void setInitialSize(int initialSize)

getMaxActive

public int getMaxActive()

setMaxActive

public void setMaxActive(int maxActive)

getMinIdle

public int getMinIdle()

setMinIdle

public void setMinIdle(int minIdle)

getMaxWait

public long getMaxWait()

setMaxWait

public void setMaxWait(long maxWait)

getValidationQuery

public String getValidationQuery()

setValidationQuery

public void setValidationQuery(String validationQuery)

getValidationQueryTimeout

public int getValidationQueryTimeout()

setValidationQueryTimeout

public void setValidationQueryTimeout(int validationQueryTimeout)

isTestOnBorrow

public boolean isTestOnBorrow()

setTestOnBorrow

public void setTestOnBorrow(boolean testOnBorrow)

isTestOnReturn

public boolean isTestOnReturn()

setTestOnReturn

public void setTestOnReturn(boolean testOnReturn)

isTestWhileIdle

public boolean isTestWhileIdle()

setTestWhileIdle

public void setTestWhileIdle(boolean testWhileIdle)

isPoolPreparedStatements

public boolean isPoolPreparedStatements()

setPoolPreparedStatements

public void setPoolPreparedStatements(boolean poolPreparedStatements)

isSharePreparedStatements

public boolean isSharePreparedStatements()

setSharePreparedStatements

public void setSharePreparedStatements(boolean sharePreparedStatements)

getMaxPoolPreparedStatementPerConnectionSize

public int getMaxPoolPreparedStatementPerConnectionSize()

setMaxPoolPreparedStatementPerConnectionSize

public void setMaxPoolPreparedStatementPerConnectionSize(int maxPoolPreparedStatementPerConnectionSize)

getQueryTimeout

public int getQueryTimeout()

setQueryTimeout

public void setQueryTimeout(int queryTimeout)

getTransactionQueryTimeout

public int getTransactionQueryTimeout()

setTransactionQueryTimeout

public void setTransactionQueryTimeout(int transactionQueryTimeout)

getTimeBetweenEvictionRunsMillis

public long getTimeBetweenEvictionRunsMillis()

setTimeBetweenEvictionRunsMillis

public void setTimeBetweenEvictionRunsMillis(long timeBetweenEvictionRunsMillis)

getMinEvictableIdleTimeMillis

public long getMinEvictableIdleTimeMillis()

setMinEvictableIdleTimeMillis

public void setMinEvictableIdleTimeMillis(long minEvictableIdleTimeMillis)

getMaxEvictableIdleTimeMillis

public long getMaxEvictableIdleTimeMillis()

setMaxEvictableIdleTimeMillis

public void setMaxEvictableIdleTimeMillis(long maxEvictableIdleTimeMillis)

getPhyTimeoutMillis

public long getPhyTimeoutMillis()

setPhyTimeoutMillis

public void setPhyTimeoutMillis(long phyTimeoutMillis)

getTimeBetweenConnectErrorMillis

public long getTimeBetweenConnectErrorMillis()

setTimeBetweenConnectErrorMillis

public void setTimeBetweenConnectErrorMillis(long timeBetweenConnectErrorMillis)

isRemoveAbandoned

public boolean isRemoveAbandoned()

setRemoveAbandoned

public void setRemoveAbandoned(boolean removeAbandoned)

getRemoveAbandonedTimeoutMillis

public long getRemoveAbandonedTimeoutMillis()

setRemoveAbandonedTimeoutMillis

public void setRemoveAbandonedTimeoutMillis(long removeAbandonedTimeoutMillis)

isLogAbandoned

public boolean isLogAbandoned()

setLogAbandoned

public void setLogAbandoned(boolean logAbandoned)

getConnectionProperties

public String getConnectionProperties()

getFilters

public String getFilters()

setFilters

public void setFilters(String filters)

getProxyFilters

public List<Filter> getProxyFilters()

setProxyFilters

public void setProxyFilters(List<Filter> proxyFilters)