com.viaoa.ds.jdbc.connection

Class ConnectionPool

java.lang.Object

com.viaoa.ds.jdbc.connection.ConnectionPool

All Implemented Interfaces:

Runnable

public class ConnectionPool
extends Object
implements Runnable

Maintains a dynamic pool of connections to database. These connections are then internally managed by OADataSource.

Constructor Summary

Constructors

Constructor and Description
ConnectionPool(DBMetaData dbmd) Create new Pool that is used for a OADataSourceJDBC.

Method Summary

Modifier and Type	Method and Description
void	close()
void	closeAllConnections() Close all connections and remove from Connection Pool.
protected OAConnection	createNewOAConnection()
Connection	getConnection(boolean bExclusive) Returns an unused JDBC connection, null if maxConnections has been reached and all current connections are used.
void	getInfo(Vector<Object> vec) Called by OADataSource.getInfo to return information about database connections.
protected OAConnection	getOAConnection(boolean bForStatement, boolean bExclusive)
PreparedStatement	getPreparedStatement(String sql, boolean bHasAutoGenerated) Returns a JDBC PreparedStatment that can be used for direct JDBC calls.
Statement	getStatement(String message) Returns a JDBC Statement that can be used for direct JDBC calls.
protected OAConnection	getStatementConnection()
boolean	isDatabaseAvailable() Returns true if database is still connected.
void	open()
void	releaseConnection(Connection connection)
void	releasePreparedStatement(PreparedStatement statement, boolean bCanBeReused) Release a PreparedStatement obtained from getPreparedStatement.
void	releaseStatement(Statement statement) Release a Statment obtained from getStatement.
void	run() Low priority Thread used to close extra connections that are not being used.

Methods inherited from class java.lang.Object

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

Constructor Detail

ConnectionPool

public ConnectionPool(DBMetaData dbmd)

Create new Pool that is used for a OADataSourceJDBC.

Method Detail

open

public void open()

close

public void close()

run

public void run()

Low priority Thread used to close extra connections that are not being used. Runs every 10 minutes.

Specified by:

run in interface Runnable

isDatabaseAvailable

public boolean isDatabaseAvailable()

Returns true if database is still connected.

closeAllConnections

public void closeAllConnections()

Close all connections and remove from Connection Pool.

getConnection

public Connection getConnection(boolean bExclusive)
                         throws Exception

Returns an unused JDBC connection, null if maxConnections has been reached and all current connections are used.

Throws:

Exception

getOAConnection

protected OAConnection getOAConnection(boolean bForStatement,
                                       boolean bExclusive)
                                throws Exception

Throws:

Exception

createNewOAConnection

protected OAConnection createNewOAConnection()
                                      throws Exception

Throws:

Exception

releaseConnection

public void releaseConnection(Connection connection)

getStatementConnection

protected OAConnection getStatementConnection()
                                       throws Exception

Throws:

Exception

getStatement

public Statement getStatement(String message)
                       throws Exception

Returns a JDBC Statement that can be used for direct JDBC calls.

Parameters:

message - reason/description for using statement. This is used by getInfo(),

Throws:

Exception

releaseStatement

public void releaseStatement(Statement statement)

Release a Statment obtained from getStatement.

getPreparedStatement

public PreparedStatement getPreparedStatement(String sql,
                                              boolean bHasAutoGenerated)
                                       throws Exception

Returns a JDBC PreparedStatment that can be used for direct JDBC calls.

Parameters:

sql - to assign to prepared statement.

bHasAutoGenerated - true if this is an insert that will have a generated pkey

Throws:

Exception

releasePreparedStatement

public void releasePreparedStatement(PreparedStatement statement,
                                     boolean bCanBeReused)

Release a PreparedStatement obtained from getPreparedStatement.

getInfo

public void getInfo(Vector<Object> vec)

Called by OADataSource.getInfo to return information about database connections.