org.firebirdsql.pool
Class PingablePooledConnection

java.lang.Object
  org.firebirdsql.pool.PingablePooledConnection

All Implemented Interfaces:

javax.sql.PooledConnection, PooledObject, org.firebirdsql.pool.XConnectionManager, org.firebirdsql.pool.XPingableConnection, XStatementManager

public class PingablePooledConnection

extends java.lang.Object

implements javax.sql.PooledConnection, PooledObject, org.firebirdsql.pool.XConnectionManager, org.firebirdsql.pool.XPingableConnection, XStatementManager

This class implements PooledConnection interface.

Author:

Roman Rokytskyy

Field Summary

protected java.sql.Connection

jdbcConnection

Constructor Summary

protected	PingablePooledConnection(java.sql.Connection connection, boolean statementPooling, int transactionIsolation, int maxStatements, boolean keepStatements)
protected	PingablePooledConnection(java.sql.Connection connection, java.lang.String pingStatement, int pingInterval, boolean statementPooling, int transactionIsolation, int maxStatements, boolean keepStatements)

Method Summary

void	addConnectionEventListener(javax.sql.ConnectionEventListener listener) Add connection listener to be notified about connection events.
void	close() Close this pooled connection.
void	connectionClosed(org.firebirdsql.pool.PooledConnectionHandler connection) Notify connection owner about invocation of the Connection.close() operation on PooledConnectionHandler instance.
void	connectionCommitted(org.firebirdsql.pool.PooledConnectionHandler connection) Notify this class that transaction was committed.
void	connectionErrorOccured(org.firebirdsql.pool.PooledConnectionHandler connection, java.sql.SQLException ex) Notify connection owner about the SQLException that happened during method invocation on the wrapped connection.
void	connectionRolledBack(org.firebirdsql.pool.PooledConnectionHandler connection) Notify this class that transaction was rolled back.
void	deallocate() Deallocate this object.
java.sql.Connection	getConnection() Get JDBC connection corresponding to this pooled connection instance.
long	getLastPingTime() Get the time when connection was pinged last time.
protected org.firebirdsql.logging.Logger	getLogChannel()
java.sql.PreparedStatement	getPreparedStatement(java.lang.String statement, int resultSetType, int resultSetConcurrency) Handle Connection.prepareStatement(String) method call.
protected void	internalClose() Close this connection.
boolean	isKeepStatements()
boolean	isStatementPooling()
boolean	isValid() Check if this pooled connection is still valid.
boolean	isValid(org.firebirdsql.pool.PooledConnectionHandler connection) Check if specified connection is still valid.
boolean	ping() Ping connection by executing a ping statement.
org.firebirdsql.pool.XCachablePreparedStatement	prepareStatement(java.lang.String statement, int resultSetType, int resultSetConcurrency, boolean cached) Prepare the specified statement and wrap it with cache notification wrapper.
void	removeConnectionEventListener(javax.sql.ConnectionEventListener listener) Remove connection listener from this pooled connection.
void	statementClosed(java.lang.String statement, java.lang.Object proxy) Handle Statement.close() method.

Methods inherited from class java.lang.Object

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

Field Detail

jdbcConnection

protected java.sql.Connection jdbcConnection

Constructor Detail

PingablePooledConnection

protected PingablePooledConnection(java.sql.Connection connection,
                                   boolean statementPooling,
                                   int transactionIsolation,
                                   int maxStatements,
                                   boolean keepStatements)
                            throws java.sql.SQLException

PingablePooledConnection

protected PingablePooledConnection(java.sql.Connection connection,
                                   java.lang.String pingStatement,
                                   int pingInterval,
                                   boolean statementPooling,
                                   int transactionIsolation,
                                   int maxStatements,
                                   boolean keepStatements)
                            throws java.sql.SQLException

Method Detail

getLogChannel

protected org.firebirdsql.logging.Logger getLogChannel()

getLastPingTime

public long getLastPingTime()

Description copied from interface: org.firebirdsql.pool.XConnectionManager

Get the time when connection was pinged last time.

Specified by:

getLastPingTime in interface org.firebirdsql.pool.XConnectionManager

Returns:

time when connection was pinged last time.

isStatementPooling

public boolean isStatementPooling()

isKeepStatements

public boolean isKeepStatements()

ping

public boolean ping()

Ping connection by executing a ping statement.

Specified by:

ping in interface org.firebirdsql.pool.XConnectionManager

Returns:

true if connection was successfully pinged.

isValid

public boolean isValid()

Check if this pooled connection is still valid.

Specified by:

isValid in interface PooledObject

Returns:

true if this pooled connection is still valid.

addConnectionEventListener

public void addConnectionEventListener(javax.sql.ConnectionEventListener listener)

Add connection listener to be notified about connection events.

Specified by:

addConnectionEventListener in interface javax.sql.PooledConnection

Parameters:

listener - listener to add.

removeConnectionEventListener

public void removeConnectionEventListener(javax.sql.ConnectionEventListener listener)

Remove connection listener from this pooled connection.

Specified by:

removeConnectionEventListener in interface javax.sql.PooledConnection

Parameters:

listener - listener to remove.

close

public void close()
           throws java.sql.SQLException

Close this pooled connection. This operation closes physical connection to the database. Should not be called by applications directly.

Specified by:

close in interface javax.sql.PooledConnection

Throws:

java.sql.SQLException

internalClose

protected void internalClose()
                      throws java.sql.SQLException

Close this connection.

Throws:

java.sql.SQLException - if something went wrong.

deallocate

public void deallocate()

Deallocate this object.

Specified by:

deallocate in interface PooledObject

getConnection

public java.sql.Connection getConnection()
                                  throws java.sql.SQLException

Get JDBC connection corresponding to this pooled connection instance.

Specified by:

getConnection in interface javax.sql.PooledConnection

Returns:

instance of Connection

Throws:

java.sql.SQLException - if some error happened.

getPreparedStatement

public java.sql.PreparedStatement getPreparedStatement(java.lang.String statement,
                                                       int resultSetType,
                                                       int resultSetConcurrency)
                                                throws java.sql.SQLException

Handle Connection.prepareStatement(String) method call. This method check internal cache first and returns prepared statement if found. Otherwise, it prepares statement and caches it.

Specified by:

getPreparedStatement in interface org.firebirdsql.pool.XConnectionManager

Parameters:

statement - statement to prepare.

resultSetType - type of the result set.

resultSetConcurrency - result set concurrency.

Returns:

instance of PreparedStatement corresponding to the statement.

Throws:

java.sql.SQLException - if there was problem preparing statement.

prepareStatement

public org.firebirdsql.pool.XCachablePreparedStatement prepareStatement(java.lang.String statement,
                                                                        int resultSetType,
                                                                        int resultSetConcurrency,
                                                                        boolean cached)
                                                                 throws java.sql.SQLException

Prepare the specified statement and wrap it with cache notification wrapper.

Specified by:

prepareStatement in interface XStatementManager

Parameters:

statement - sattement to prepare.

resultSetType - type of result set

resultSetConcurrency - result set concurrency

cached - true if prepared statement will be cached.

Returns:

prepared and wrapped statement.

Throws:

java.sql.SQLException - if underlying connection threw this exception.

See Also:

Connection.prepareStatement(java.lang.String, int, int)

statementClosed

public void statementClosed(java.lang.String statement,
                            java.lang.Object proxy)
                     throws java.sql.SQLException

Handle Statement.close() method. This implementation dereferences proxy in cache.

Specified by:

statementClosed in interface XStatementManager

Parameters:

statement - SQL statement corresponding to the proxy.

proxy - proxy wrapping the connection.

Throws:

java.sql.SQLException - if prepared statement cannot be added to the pool.

connectionClosed

public void connectionClosed(org.firebirdsql.pool.PooledConnectionHandler connection)
                      throws java.sql.SQLException

Description copied from interface: org.firebirdsql.pool.XConnectionManager

Notify connection owner about invocation of the Connection.close() operation on PooledConnectionHandler instance.

Specified by:

connectionClosed in interface org.firebirdsql.pool.XConnectionManager

Parameters:

connection - instance of PooledConnectionHandler that initiated the call.

Throws:

java.sql.SQLException

connectionErrorOccured

public void connectionErrorOccured(org.firebirdsql.pool.PooledConnectionHandler connection,
                                   java.sql.SQLException ex)

Description copied from interface: org.firebirdsql.pool.XConnectionManager

Notify connection owner about the SQLException that happened during method invocation on the wrapped connection.

Specified by:

connectionErrorOccured in interface org.firebirdsql.pool.XConnectionManager

Parameters:

connection - instance of PooledConnectionHandler that catched exception.

ex - instance of SQLException that was thrown.

isValid

public boolean isValid(org.firebirdsql.pool.PooledConnectionHandler connection)

Description copied from interface: org.firebirdsql.pool.XConnectionManager

Check if specified connection is still valid.

Specified by:

isValid in interface org.firebirdsql.pool.XConnectionManager

Parameters:

connection - instance of PooledConnectionHandler to check.

Returns:

true if connection owner is still valid, false otherwise.

connectionCommitted

public void connectionCommitted(org.firebirdsql.pool.PooledConnectionHandler connection)
                         throws java.sql.SQLException

Notify this class that transaction was committed.

Specified by:

connectionCommitted in interface org.firebirdsql.pool.XConnectionManager

Parameters:

connection - connection that was commited.

Throws:

java.sql.SQLException

See Also:

XConnectionManager#connectionCommitted(PooledConnectionHandler)

connectionRolledBack

public void connectionRolledBack(org.firebirdsql.pool.PooledConnectionHandler connection)
                          throws java.sql.SQLException

Notify this class that transaction was rolled back.

Specified by:

connectionRolledBack in interface org.firebirdsql.pool.XConnectionManager

Parameters:

connection - connection that was commited.

Throws:

java.sql.SQLException

See Also:

XConnectionManager#connectionRolledBack(PooledConnectionHandler)