DBChannel
- 连接泛型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() |
protected final java.util.concurrent.atomic.AtomicLong closeCounter
protected final java.util.concurrent.atomic.AtomicLong usingCounter
protected final java.util.concurrent.atomic.AtomicLong creatCounter
protected final java.util.concurrent.atomic.AtomicLong cycleCounter
protected final java.util.concurrent.atomic.AtomicLong saveCounter
protected final java.util.concurrent.Semaphore semaphore
protected final java.util.logging.Logger logger
protected final java.lang.String rwtype
protected final int maxconns
protected final java.lang.String dbtype
protected int connectTimeoutSeconds
protected int readTimeoutSeconds
protected int writeTimeoutSeconds
protected java.lang.String url
protected java.net.InetSocketAddress servaddr
protected java.lang.String username
protected java.lang.String password
protected java.lang.String database
protected java.lang.String encoding
protected java.util.Properties props
protected java.util.Properties attributes
public PoolSource(java.lang.String rwtype, java.util.concurrent.Semaphore semaphore, java.util.Properties prop, java.util.logging.Logger logger)
protected void parseAddressAndDbnameAndAttrs()
protected abstract int getDefaultPort()
public abstract void change(java.util.Properties property)
public abstract DBChannel poll()
public abstract java.util.concurrent.CompletableFuture<DBChannel> pollAsync()
public abstract void offerConnection(DBChannel conn)
public abstract void close()
public final java.lang.String getDbtype()
public final long getCloseCount()
public final long getUsingCount()
public final long getCreatCount()
public final long getCycleCount()
public final long getSaveCount()
public final int getMaxconns()
public final int getConnectTimeoutSeconds()
public final int getReadTimeoutSeconds()
public final int getWriteTimeoutSeconds()
public final java.lang.String getUrl()
public final java.net.InetSocketAddress getServaddr()
public final java.lang.String getUsername()
public final java.lang.String getPassword()
public final java.lang.String getDatabase()