Package com.aoindustries.sql

Class AOConnectionPool

java.lang.Object

java.lang.Thread

com.aoindustries.io.AOPool<Connection,SQLException,SQLException>

com.aoindustries.sql.AOConnectionPool

All Implemented Interfaces:

Runnable

public final class AOConnectionPool
extends AOPool<Connection,SQLException,SQLException>

Reusable connection pooling with dynamic flaming tiger feature.

Author:

AO Industries, Inc.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class com.aoindustries.io.AOPool

DEFAULT_CONNECT_TIMEOUT, DEFAULT_DELAY_TIME, DEFAULT_MAX_CONNECTION_AGE, DEFAULT_MAX_IDLE_TIME, DEFAULT_SOCKET_SO_LINGER, logger, UNLIMITED_MAX_CONNECTION_AGE

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
AOConnectionPool(String driver, String url, String user, String password, int numConnections, long maxConnectionAge, Logger logger)

Method Summary

Modifier and Type	Method	Description
protected void	close(Connection conn)
Connection	getConnection()	Gets a read/write connection to the database with a transaction level of Connection.TRANSACTION_READ_COMMITTED and a maximum connections of 1.
Connection	getConnection(boolean readOnly)	Gets a connection to the database with a transaction level of Connection.TRANSACTION_READ_COMMITTED and a maximum connections of 1.
Connection	getConnection(int isolationLevel, boolean readOnly)	Gets a connection to the database with a maximum connections of 1.
Connection	getConnection(int isolationLevel, boolean readOnly, int maxConnections)
protected Connection	getConnectionObject()	Creates a new connection.
protected boolean	isClosed(Connection conn)
protected SQLException	newException(String message, Throwable cause)
protected SQLException	newInterruptedException(String message, Throwable cause)
protected void	printConnectionStats(Appendable out, boolean isXhtml)	Prints additional connection pool details.
protected void	resetConnection(Connection conn)
String	toString()

Methods inherited from class com.aoindustries.io.AOPool

close, getConcurrency, getConnection, getConnectionCount, getConnects, getLogger, getMaxConcurrency, getMaxConnectionAge, getPoolSize, getTotalTime, getTransactionCount, printStatisticsHTML, printStatisticsHTML, releaseConnection, run

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

AOConnectionPool

public AOConnectionPool(String driver,
                        String url,
                        String user,
                        String password,
                        int numConnections,
                        long maxConnectionAge,
                        Logger logger)

Method Detail

close

protected void close(Connection conn)
              throws SQLException

Specified by:

close in class AOPool<Connection,SQLException,SQLException>

Throws:

SQLException

getConnection

public Connection getConnection()
                         throws SQLException

Gets a read/write connection to the database with a transaction level of Connection.TRANSACTION_READ_COMMITTED and a maximum connections of 1.

Overrides:

getConnection in class AOPool<Connection,SQLException,SQLException>

Returns:

The read/write connection to the database

Throws:

SQLException

See Also:

AOPool.getConnection(int)

getConnection

public Connection getConnection(boolean readOnly)
                         throws SQLException

Gets a connection to the database with a transaction level of Connection.TRANSACTION_READ_COMMITTED and a maximum connections of 1.

Parameters:

readOnly - The read-only flag

Returns:

The connection to the database

Throws:

SQLException

getConnection

public Connection getConnection(int isolationLevel,
                                boolean readOnly)
                         throws SQLException

Gets a connection to the database with a maximum connections of 1.

Parameters:

isolationLevel - The transaction isolation level

readOnly - The read-only flag

Returns:

The connection to the database

Throws:

SQLException

getConnection

public Connection getConnection(int isolationLevel,
                                boolean readOnly,
                                int maxConnections)
                         throws SQLException

Throws:

SQLException

getConnectionObject

protected Connection getConnectionObject()
                                  throws SQLException

Description copied from class: AOPool

Creates a new connection.

Specified by:

getConnectionObject in class AOPool<Connection,SQLException,SQLException>

Throws:

SQLException

isClosed

protected boolean isClosed(Connection conn)
                    throws SQLException

Specified by:

isClosed in class AOPool<Connection,SQLException,SQLException>

Throws:

SQLException

printConnectionStats

protected void printConnectionStats(Appendable out,
                                    boolean isXhtml)
                             throws IOException

Description copied from class: AOPool

Prints additional connection pool details. Must have opened the <tbody>.

Overrides:

printConnectionStats in class AOPool<Connection,SQLException,SQLException>

Throws:

IOException

resetConnection

protected void resetConnection(Connection conn)
                        throws SQLException

Specified by:

resetConnection in class AOPool<Connection,SQLException,SQLException>

Throws:

SQLException

newException

protected SQLException newException(String message,
                                    Throwable cause)

Specified by:

newException in class AOPool<Connection,SQLException,SQLException>

newInterruptedException

protected SQLException newInterruptedException(String message,
                                               Throwable cause)

Specified by:

newInterruptedException in class AOPool<Connection,SQLException,SQLException>

toString

public String toString()

Overrides:

toString in class Thread