org.redkale.source

类 PoolSource<DBChannel>

java.lang.Object

org.redkale.source.PoolSource<DBChannel>

类型参数:

DBChannel - 连接泛型

直接已知子类:

PoolJdbcSource, PoolTcpSource

public abstract class PoolSource<DBChannel>
extends Object

连接池类

详情见: https://redkale.org

作者:

zhangjx

字段概要

字段

限定符和类型	字段和说明
protected Properties	attributes
protected AtomicLong	closeCounter
protected int	connectTimeoutSeconds
protected AtomicLong	creatCounter
protected AtomicLong	cycleCounter
protected String	database
protected String	dbtype
protected String	encoding
protected Logger	logger
protected int	maxconns
protected String	password
protected Properties	props
protected int	readTimeoutSeconds
protected String	rwtype
protected AtomicLong	saveCounter
protected Semaphore	semaphore
protected InetSocketAddress	servaddr
protected String	url
protected String	username
protected AtomicLong	usingCounter
protected int	writeTimeoutSeconds

构造器概要

构造器

构造器和说明
PoolSource(String rwtype, Semaphore semaphore, Properties prop, Logger logger)

方法概要

限定符和类型	方法和说明
abstract void	change(Properties property)
abstract void	close()
long	getCloseCount()
int	getConnectTimeoutSeconds()
long	getCreatCount()
long	getCycleCount()
String	getDatabase()
String	getDbtype()
protected abstract int	getDefaultPort()
int	getMaxconns()
String	getPassword()
int	getReadTimeoutSeconds()
long	getSaveCount()
InetSocketAddress	getServaddr()
String	getUrl()
String	getUsername()
long	getUsingCount()
int	getWriteTimeoutSeconds()
abstract void	offerConnection(DBChannel conn)
protected void	parseAddressAndDbnameAndAttrs()
abstract DBChannel	poll()
abstract CompletableFuture<DBChannel>	pollAsync()

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

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

字段详细资料

closeCounter

protected final AtomicLong closeCounter

usingCounter

protected final AtomicLong usingCounter

creatCounter

protected final AtomicLong creatCounter

cycleCounter

protected final AtomicLong cycleCounter

saveCounter

protected final AtomicLong saveCounter

semaphore

protected final Semaphore semaphore

logger

protected final Logger logger

rwtype

protected final String rwtype

maxconns

protected final int maxconns

dbtype

protected final String dbtype

connectTimeoutSeconds

protected int connectTimeoutSeconds

readTimeoutSeconds

protected int readTimeoutSeconds

writeTimeoutSeconds

protected int writeTimeoutSeconds

url

protected String url

servaddr

protected InetSocketAddress servaddr

username

protected String username

password

protected String password

database

protected String database

encoding

protected String encoding

props

protected Properties props

attributes

protected Properties attributes

构造器详细资料

PoolSource

public PoolSource(String rwtype,
                  Semaphore semaphore,
                  Properties prop,
                  Logger logger)

方法详细资料

parseAddressAndDbnameAndAttrs

protected void parseAddressAndDbnameAndAttrs()

getDefaultPort

protected abstract int getDefaultPort()

change

public abstract void change(Properties property)

poll

public abstract DBChannel poll()

pollAsync

public abstract CompletableFuture<DBChannel> pollAsync()

offerConnection

public abstract void offerConnection(DBChannel conn)

close

public abstract void close()

getDbtype

public final String getDbtype()

getCloseCount

public final long getCloseCount()

getUsingCount

public final long getUsingCount()

getCreatCount

public final long getCreatCount()

getCycleCount

public final long getCycleCount()

getSaveCount

public final long getSaveCount()

getMaxconns

public final int getMaxconns()

getConnectTimeoutSeconds

public final int getConnectTimeoutSeconds()

getReadTimeoutSeconds

public final int getReadTimeoutSeconds()

getWriteTimeoutSeconds

public final int getWriteTimeoutSeconds()

getUrl

public final String getUrl()

getServaddr

public final InetSocketAddress getServaddr()

getUsername

public final String getUsername()

getPassword

public final String getPassword()

getDatabase

public final String getDatabase()