tyrex.resource.jdbc.xa
Class TyrexConnection

java.lang.Object
  |
  +--tyrex.resource.jdbc.xa.TyrexConnection

All Implemented Interfaces:

java.sql.Connection

Direct Known Subclasses:

ClientConnection

public abstract class TyrexConnection

extends java.lang.Object

implements java.sql.Connection

This class defines base methods for implementing java.sql.Connection so that an underlying java.sql.Connection may be pooled.

Subclasses are to implement isClosed(), close(), {@ #getUnderlyingConnection}.

Author:

Riad Mohammed

Fields inherited from interface java.sql.Connection

TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE

Constructor Summary

TyrexConnection()

Method Summary

void	clearWarnings()
void	close() Close this connection which may or may not close the underlying connection.
void	commit()
java.sql.Statement	createStatement()
java.sql.Statement	createStatement(int resultSetType, int resultSetConcurrency)
protected void	finalize() Close the connection when it is being garbage collected.
boolean	getAutoCommit()
java.lang.String	getCatalog()
java.sql.DatabaseMetaData	getMetaData()
int	getTransactionIsolation()
java.util.Map	getTypeMap()
java.sql.SQLWarning	getWarnings()
protected abstract void	internalClose() Method that actually closes the connection.
protected abstract java.sql.Connection	internalGetUnderlyingConnection() Return the underlying connection.
abstract boolean	isClosed() Return true if the connection is closed.
boolean	isReadOnly()
java.lang.String	nativeSQL(java.lang.String sql)
protected void	notifyError(java.sql.SQLException exception) Called when an exception is thrown by the underlying connection.
java.sql.CallableStatement	prepareCall(java.lang.String sql)
java.sql.CallableStatement	prepareCall(java.lang.String sql, int resultSetType, int resultSetConcurrency)
java.sql.PreparedStatement	prepareStatement(java.lang.String sql)
java.sql.PreparedStatement	prepareStatement(java.lang.String sql, int resultSetType, int resultSetConcurrency)
void	rollback()
void	setAutoCommit(boolean autoCommit)
void	setCatalog(java.lang.String catalog)
void	setReadOnly(boolean readOnly)
void	setTransactionIsolation(int level)
void	setTypeMap(java.util.Map map)

Methods inherited from class java.lang.Object

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

Constructor Detail

TyrexConnection

public TyrexConnection()

Method Detail

createStatement

public java.sql.Statement createStatement()
                                   throws java.sql.SQLException

Specified by:

createStatement in interface java.sql.Connection

createStatement

public java.sql.Statement createStatement(int resultSetType,
                                          int resultSetConcurrency)
                                   throws java.sql.SQLException

Specified by:

createStatement in interface java.sql.Connection

prepareStatement

public java.sql.PreparedStatement prepareStatement(java.lang.String sql)
                                            throws java.sql.SQLException

Specified by:

prepareStatement in interface java.sql.Connection

prepareStatement

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

Specified by:

prepareStatement in interface java.sql.Connection

prepareCall

public java.sql.CallableStatement prepareCall(java.lang.String sql)
                                       throws java.sql.SQLException

Specified by:

prepareCall in interface java.sql.Connection

prepareCall

public java.sql.CallableStatement prepareCall(java.lang.String sql,
                                              int resultSetType,
                                              int resultSetConcurrency)
                                       throws java.sql.SQLException

Specified by:

prepareCall in interface java.sql.Connection

nativeSQL

public java.lang.String nativeSQL(java.lang.String sql)
                           throws java.sql.SQLException

Specified by:

nativeSQL in interface java.sql.Connection

getMetaData

public java.sql.DatabaseMetaData getMetaData()
                                      throws java.sql.SQLException

Specified by:

getMetaData in interface java.sql.Connection

setCatalog

public void setCatalog(java.lang.String catalog)
                throws java.sql.SQLException

Specified by:

setCatalog in interface java.sql.Connection

getCatalog

public java.lang.String getCatalog()
                            throws java.sql.SQLException

Specified by:

getCatalog in interface java.sql.Connection

getWarnings

public java.sql.SQLWarning getWarnings()
                                throws java.sql.SQLException

Specified by:

getWarnings in interface java.sql.Connection

clearWarnings

public void clearWarnings()
                   throws java.sql.SQLException

Specified by:

clearWarnings in interface java.sql.Connection

getTypeMap

public java.util.Map getTypeMap()
                         throws java.sql.SQLException

Specified by:

getTypeMap in interface java.sql.Connection

setTypeMap

public void setTypeMap(java.util.Map map)
                throws java.sql.SQLException

Specified by:

setTypeMap in interface java.sql.Connection

setAutoCommit

public void setAutoCommit(boolean autoCommit)
                   throws java.sql.SQLException

Specified by:

setAutoCommit in interface java.sql.Connection

getAutoCommit

public boolean getAutoCommit()
                      throws java.sql.SQLException

Specified by:

getAutoCommit in interface java.sql.Connection

commit

public void commit()
            throws java.sql.SQLException

Specified by:

commit in interface java.sql.Connection

rollback

public void rollback()
              throws java.sql.SQLException

Specified by:

rollback in interface java.sql.Connection

setReadOnly

public void setReadOnly(boolean readOnly)
                 throws java.sql.SQLException

Specified by:

setReadOnly in interface java.sql.Connection

isReadOnly

public boolean isReadOnly()
                   throws java.sql.SQLException

Specified by:

isReadOnly in interface java.sql.Connection

setTransactionIsolation

public void setTransactionIsolation(int level)
                             throws java.sql.SQLException

Specified by:

setTransactionIsolation in interface java.sql.Connection

getTransactionIsolation

public int getTransactionIsolation()
                            throws java.sql.SQLException

Specified by:

getTransactionIsolation in interface java.sql.Connection

notifyError

protected void notifyError(java.sql.SQLException exception)

Called when an exception is thrown by the underlying connection.

The default implementation is to do nothing

Parameters:

except - The exception thrown by the underlying connection

close

public void close()
           throws java.sql.SQLException

Close this connection which may or may not close the underlying connection. And notify any listeners that the connection has been closed.

Specified by:

close in interface java.sql.Connection

Throws:

java.sql.SQLException - if there is a problem closing the connection

See Also:

internalClose()

internalClose

protected abstract void internalClose()
                               throws java.sql.SQLException

Method that actually closes the connection.

Throws:

java.sql.SQLException - if there is a problem closing the connection

See Also:

close()

isClosed

public abstract boolean isClosed()

Return true if the connection is closed.

Specified by:

isClosed in interface java.sql.Connection

Returns:

true if the connection is closed.

finalize

protected void finalize()
                 throws java.lang.Throwable

Close the connection when it is being garbage collected.

Overrides:

finalize in class java.lang.Object

internalGetUnderlyingConnection

protected abstract java.sql.Connection internalGetUnderlyingConnection()
                                                                throws java.sql.SQLException

Return the underlying connection.

The connection is not closed ie isClosed() returns false.

Returns:

the underlying connection

Throws:

java.sql.SQLException - if the connection cannot be retrieved.

See Also:

#getUnderlyingConnection