com.oceanbase.jdbc.internal.util.pool

类 Pool

java.lang.Object

com.oceanbase.jdbc.internal.util.pool.Pool

所有已实现的接口:

PoolMBean, AutoCloseable

public class Pool
extends Object
implements AutoCloseable, PoolMBean

构造器概要

构造器

构造器和说明
Pool(UrlParser urlParser, int poolIndex, ScheduledThreadPoolExecutor poolExecutor) Create pool from configuration.

方法概要

限定符和类型	方法和说明
void	close() Close pool and underlying connections.
boolean	equals(Object obj)
long	getActiveConnections()
OceanBaseConnection	getConnection() Retrieve new connection.
OceanBaseConnection	getConnection(String username, String password) Get new connection from pool if user and password correspond to pool.
long	getConnectionRequests()
GlobalStateInfo	getGlobalInfo()
long	getIdleConnections()
OceanBasePooledConnection	getPooledConnection()
String	getPoolTag()
long	getTotalConnections()
UrlParser	getUrlParser()
int	hashCode()
void	resetStaticGlobal() JMX method to remove state (will be reinitialized on next connection creation).
List<Long>	testGetConnectionIdleThreadIds() For testing purpose only.

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

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

构造器详细资料

Pool

public Pool(UrlParser urlParser,
            int poolIndex,
            ScheduledThreadPoolExecutor poolExecutor)

Create pool from configuration.

参数:

urlParser - configuration parser

poolIndex - pool index to permit distinction of thread name

poolExecutor - pools common executor

方法详细资料

getPooledConnection

public OceanBasePooledConnection getPooledConnection()
                                              throws SQLException

抛出:

SQLException

getConnection

public OceanBaseConnection getConnection()
                                  throws SQLException

Retrieve new connection. If possible return idle connection, if not, stack connection query, ask for a connection creation, and loop until a connection become idle / a new connection is created.

返回:

a connection object

抛出:

SQLException - if no connection is created when reaching timeout (connectTimeout option)

getConnection

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

Get new connection from pool if user and password correspond to pool. If username and password are different from pool, will return a dedicated connection.

参数:

username - username

password - password

返回:

connection

抛出:

SQLException - if any error occur during connection

getUrlParser

public UrlParser getUrlParser()

close

public void close()
           throws InterruptedException

Close pool and underlying connections.

指定者:

close 在接口中 AutoCloseable

抛出:

InterruptedException - if interrupted

getPoolTag

public String getPoolTag()

equals

public boolean equals(Object obj)

覆盖:

equals 在类中 Object

hashCode

public int hashCode()

覆盖:

hashCode 在类中 Object

getGlobalInfo

public GlobalStateInfo getGlobalInfo()

getActiveConnections

public long getActiveConnections()

指定者:

getActiveConnections 在接口中 PoolMBean

getTotalConnections

public long getTotalConnections()

指定者:

getTotalConnections 在接口中 PoolMBean

getIdleConnections

public long getIdleConnections()

指定者:

getIdleConnections 在接口中 PoolMBean

getConnectionRequests

public long getConnectionRequests()

指定者:

getConnectionRequests 在接口中 PoolMBean

testGetConnectionIdleThreadIds

public List<Long> testGetConnectionIdleThreadIds()

For testing purpose only.

返回:

current thread id's

resetStaticGlobal

public void resetStaticGlobal()

JMX method to remove state (will be reinitialized on next connection creation).

指定者:

resetStaticGlobal 在接口中 PoolMBean