org.redkale.source

类 PoolJdbcSource

java.lang.Object

org.redkale.source.PoolSource<Connection>

org.redkale.source.PoolJdbcSource

public class PoolJdbcSource
extends PoolSource<Connection>

详情见: https://redkale.org

作者:

zhangjx

字段概要

字段

限定符和类型	字段和说明
protected ConnectionEventListener	listener
protected URL	persistxml
protected ArrayBlockingQueue<PooledConnection>	queue
protected ConnectionPoolDataSource	source
protected String	unitName

从类继承的字段 org.redkale.source.PoolSource

attributes, closeCounter, connectTimeoutSeconds, creatCounter, cycleCounter, database, dbtype, encoding, logger, maxconns, password, props, readTimeoutSeconds, rwtype, saveCounter, semaphore, servaddr, url, username, usingCounter, writeTimeoutSeconds

构造器概要

构造器

构造器和说明
PoolJdbcSource(String unitName, URL persistxml, String rwtype, ArrayBlockingQueue aqueue, Semaphore semaphore, Properties prop, Logger logger)

方法概要

限定符和类型	方法和说明
void	change(Properties property)
void	close()
protected int	getDefaultPort()
void	offerConnection(Connection conn)
Connection	poll()
CompletableFuture<Connection>	pollAsync()

从类继承的方法 org.redkale.source.PoolSource

getCloseCount, getConnectTimeoutSeconds, getCreatCount, getCycleCount, getDatabase, getDbtype, getMaxconns, getPassword, getReadTimeoutSeconds, getSaveCount, getServaddr, getUrl, getUsername, getUsingCount, getWriteTimeoutSeconds, parseAddressAndDbnameAndAttrs

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

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

字段详细资料

source

protected final ConnectionPoolDataSource source

queue

protected final ArrayBlockingQueue<PooledConnection> queue

listener

protected final ConnectionEventListener listener

unitName

protected final String unitName

persistxml

protected final URL persistxml

构造器详细资料

PoolJdbcSource

public PoolJdbcSource(String unitName,
                      URL persistxml,
                      String rwtype,
                      ArrayBlockingQueue aqueue,
                      Semaphore semaphore,
                      Properties prop,
                      Logger logger)

方法详细资料

getDefaultPort

protected int getDefaultPort()

指定者:

getDefaultPort 在类中 PoolSource<Connection>

change

public void change(Properties property)

指定者:

change 在类中 PoolSource<Connection>

offerConnection

public void offerConnection(Connection conn)

指定者:

offerConnection 在类中 PoolSource<Connection>

poll

public Connection poll()

指定者:

poll 在类中 PoolSource<Connection>

pollAsync

public CompletableFuture<Connection> pollAsync()

指定者:

pollAsync 在类中 PoolSource<Connection>

close

public void close()

指定者:

close 在类中 PoolSource<Connection>