tyrex.resource.jdbc.xa

Class TyrexConnection

public abstract class TyrexConnection extends Object implements 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 TyrexConnection, TyrexConnection, {@ #getUnderlyingConnection}.

Author: Riad Mohammed

Constructor Summary
	TyrexConnection()

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

Constructor Detail

TyrexConnection

public TyrexConnection()

Method Detail

clearWarnings

public void clearWarnings()

close

public void close()

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

Throws: SQLException if there is a problem closing the connection

commit

public void commit()

createStatement

public Statement createStatement()

createStatement

public Statement createStatement(int resultSetType, int resultSetConcurrency)

createStatement

public Statement createStatement(int resultSetType, int resultSetConcurrency, int resultSetHoldability)

finalize

protected void finalize()

Close the connection when it is being garbage collected.

getAutoCommit

public boolean getAutoCommit()

getCatalog

public String getCatalog()

getHoldability

public int getHoldability()

getMetaData

public DatabaseMetaData getMetaData()

getTransactionIsolation

public int getTransactionIsolation()

getTypeMap

public Map getTypeMap()

getWarnings

public SQLWarning getWarnings()

internalClose

protected abstract void internalClose()

Method that actually closes the connection.

Throws: SQLException if there is a problem closing the connection

internalGetUnderlyingConnection

protected abstract Connection internalGetUnderlyingConnection()

Return the underlying connection.

The connection is not closed ie TyrexConnection returns false.

Returns: the underlying connection

Throws: SQLException if the connection cannot be retrieved.

isClosed

public abstract boolean isClosed()

Return true if the connection is closed.

Returns: true if the connection is closed.

isReadOnly

public boolean isReadOnly()

nativeSQL

public String nativeSQL(String sql)

notifyError

protected void notifyError(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

prepareCall

public CallableStatement prepareCall(String sql)

prepareCall

public CallableStatement prepareCall(String sql, int resultSetType, int resultSetConcurrency)

prepareCall

public CallableStatement prepareCall(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)

prepareStatement

public PreparedStatement prepareStatement(String sql)

prepareStatement

public PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency)

prepareStatement

public PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability)

prepareStatement

public PreparedStatement prepareStatement(String sql, int autoGeneratedKeys)

prepareStatement

public PreparedStatement prepareStatement(String sql, int[] columnIndexes)

prepareStatement

public PreparedStatement prepareStatement(String sql, String[] columnNames)

releaseSavepoint

public void releaseSavepoint(Savepoint savepoint)

rollback

public void rollback()

rollback

public void rollback(Savepoint savepoint)

setAutoCommit

public void setAutoCommit(boolean autoCommit)

setCatalog

public void setCatalog(String catalog)

setHoldability

public void setHoldability(int holdability)

setReadOnly

public void setReadOnly(boolean readOnly)

setSavepoint

public Savepoint setSavepoint()

setSavepoint

public Savepoint setSavepoint(String name)

setTransactionIsolation

public void setTransactionIsolation(int level)

setTypeMap

public void setTypeMap(Map map)