org.redkale.source

类 PoolSource<DBChannel>

java.lang.Object

org.redkale.source.PoolSource<DBChannel>

类型参数:

DBChannel - 连接泛型

直接已知子类:

PoolJdbcSource, PoolTcpSource

public abstract class PoolSource<DBChannel>
extends java.lang.Object

连接池类

详情见: https://redkale.org

字段概要

字段

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

构造器概要

构造器

构造器和说明
PoolSource(java.lang.String rwtype, java.util.concurrent.Semaphore semaphore, java.util.Properties prop, java.util.logging.Logger logger)

方法概要

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

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

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

字段详细资料

closeCounter

protected final java.util.concurrent.atomic.AtomicLong closeCounter

usingCounter

protected final java.util.concurrent.atomic.AtomicLong usingCounter

creatCounter

protected final java.util.concurrent.atomic.AtomicLong creatCounter

cycleCounter

protected final java.util.concurrent.atomic.AtomicLong cycleCounter

saveCounter

protected final java.util.concurrent.atomic.AtomicLong saveCounter

semaphore

protected final java.util.concurrent.Semaphore semaphore

logger

protected final java.util.logging.Logger logger

rwtype

protected final java.lang.String rwtype

maxconns

protected final int maxconns

dbtype

protected final java.lang.String dbtype

connectTimeoutSeconds

protected int connectTimeoutSeconds

readTimeoutSeconds

protected int readTimeoutSeconds

writeTimeoutSeconds

protected int writeTimeoutSeconds

url

protected java.lang.String url

servaddr

protected java.net.InetSocketAddress servaddr

username

protected java.lang.String username

password

protected java.lang.String password

database

protected java.lang.String database

encoding

protected java.lang.String encoding

props

protected java.util.Properties props

attributes

protected java.util.Properties attributes

构造器详细资料

PoolSource

public PoolSource(java.lang.String rwtype,
                  java.util.concurrent.Semaphore semaphore,
                  java.util.Properties prop,
                  java.util.logging.Logger logger)

方法详细资料

parseAddressAndDbnameAndAttrs

protected void parseAddressAndDbnameAndAttrs()

getDefaultPort

protected abstract int getDefaultPort()

change

public abstract void change(java.util.Properties property)

poll

public abstract DBChannel poll()

pollAsync

public abstract java.util.concurrent.CompletableFuture<DBChannel> pollAsync()

offerConnection

public abstract void offerConnection(DBChannel conn)

close

public abstract void close()

getDbtype

public final java.lang.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 java.lang.String getUrl()

getServaddr

public final java.net.InetSocketAddress getServaddr()

getUsername

public final java.lang.String getUsername()

getPassword

public final java.lang.String getPassword()

getDatabase

public final java.lang.String getDatabase()