Class EmbedXAConnection

java.lang.Object

org.apache.derby.jdbc.EmbedPooledConnection

org.apache.derby.jdbc.EmbedXAConnection

All Implemented Interfaces:

PooledConnection, XAConnection, BrokeredConnectionControl

class EmbedXAConnection
extends EmbedPooledConnection
implements XAConnection

Field Summary

Fields

Modifier and Type	Field	Description
private EmbedXAResource	xaRes

Fields inherited from class EmbedPooledConnection

currentConnectionHandle, dataSource, defaultIsolationLevel, isActive, realConnection

Constructor Summary

Constructors

Constructor	Description
EmbedXAConnection(BasicEmbeddedDataSource40 ds, ResourceAdapter ra, String u, String p, boolean requestPassword)

Method Summary

Modifier and Type	Method	Description
void	checkAutoCommit(boolean autoCommit)	Allow control over setting auto commit mode.
void	checkClose()	Check if the brokered connection can be closed.
void	checkCommit()	Allow control over calling commit.
int	checkHoldCursors(int holdability, boolean downgrade)	Are held cursors allowed.
void	checkRollback()	Allow control over calling rollback.
void	checkSavepoint()	Allow control over creating a Savepoint (JDBC 3.0)
Connection	getConnection()	Create an object handle for a database connection.
EngineConnection	getRealConnection()	Override getRealConnection to create a a local connection when we are not associated with an XA transaction.
final XAResource	getXAResource()
private boolean	isGlobal()	Check if this connection is part of a global XA transaction.
boolean	isInGlobalTransaction()	Is this a global transaction
CallableStatement	wrapStatement(CallableStatement cs, String sql)	Wrap and control a PreparedStatement
PreparedStatement	wrapStatement(PreparedStatement ps, String sql, Object generatedKeys)	Wrap and control a PreparedStatement
Statement	wrapStatement(Statement s)	Wrap and control a Statement

Methods inherited from class EmbedPooledConnection

addConnectionEventListener, addStatementEventListener, checkActive, close, closingConnection, getLanguageConnection, getNewCurrentConnectionHandle, getPassword, getUsername, isActive, isIsolationLevelSetUsingSQLorJDBC, notifyError, notifyException, onStatementClose, onStatementErrorOccurred, openRealConnection, removeConnectionEventListener, removeStatementEventListener, resetIsolationLevelFlag, resetRealConnection, toString

Methods inherited from class Object

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

Methods inherited from interface PooledConnection

addConnectionEventListener, addStatementEventListener, close, removeConnectionEventListener, removeStatementEventListener

Field Details

xaRes

private EmbedXAResource xaRes

Constructor Details

EmbedXAConnection

EmbedXAConnection(BasicEmbeddedDataSource40 ds,
 ResourceAdapter ra,
 String u,
 String p,
 boolean requestPassword)
           throws SQLException

Throws:

SQLException

Method Details

isInGlobalTransaction

public boolean isInGlobalTransaction()

Description copied from interface: BrokeredConnectionControl

Is this a global transaction

Specified by:

isInGlobalTransaction in interface BrokeredConnectionControl

Overrides:

isInGlobalTransaction in class EmbedPooledConnection

Returns:

true if this is a global XA transaction

See Also:

• BrokeredConnectionControl.isInGlobalTransaction()

isGlobal

private boolean isGlobal()

Check if this connection is part of a global XA transaction.

Returns:

true if the transaction is global, false if the transaction is local

getXAResource

public final XAResource getXAResource()
                               throws SQLException

Specified by:

getXAResource in interface XAConnection

Throws:

SQLException

checkAutoCommit

public void checkAutoCommit(boolean autoCommit)
                     throws SQLException

Allow control over setting auto commit mode.

Specified by:

checkAutoCommit in interface BrokeredConnectionControl

Overrides:

checkAutoCommit in class EmbedPooledConnection

Throws:

SQLException

checkHoldCursors

public int checkHoldCursors(int holdability,
 boolean downgrade)
                     throws SQLException

Are held cursors allowed. If the connection is attached to a global transaction then downgrade the result set holdabilty to CLOSE_CURSORS_AT_COMMIT if downgrade is true, otherwise throw an exception. If the connection is in a local transaction then the passed in holdabilty is returned.

Specified by:

checkHoldCursors in interface BrokeredConnectionControl

Overrides:

checkHoldCursors in class EmbedPooledConnection

Parameters:

downgrade - true to downgrade the holdability, false to throw an exception.

Throws:

SQLException

checkSavepoint

public void checkSavepoint()
                    throws SQLException

Allow control over creating a Savepoint (JDBC 3.0)

Specified by:

checkSavepoint in interface BrokeredConnectionControl

Overrides:

checkSavepoint in class EmbedPooledConnection

Throws:

SQLException

checkRollback

public void checkRollback()
                   throws SQLException

Allow control over calling rollback.

Specified by:

checkRollback in interface BrokeredConnectionControl

Overrides:

checkRollback in class EmbedPooledConnection

Throws:

SQLException

checkCommit

public void checkCommit()
                 throws SQLException

Allow control over calling commit.

Specified by:

checkCommit in interface BrokeredConnectionControl

Overrides:

checkCommit in class EmbedPooledConnection

Throws:

SQLException

checkClose

public void checkClose()
                throws SQLException

Description copied from interface: BrokeredConnectionControl

Check if the brokered connection can be closed.

Specified by:

checkClose in interface BrokeredConnectionControl

Overrides:

checkClose in class EmbedPooledConnection

Throws:

SQLException - if it is not allowed to call close on the brokered connection

See Also:

• BrokeredConnectionControl.checkClose()

getConnection

public Connection getConnection()
                         throws SQLException

Description copied from class: EmbedPooledConnection

Create an object handle for a database connection.

Specified by:

getConnection in interface PooledConnection

Overrides:

getConnection in class EmbedPooledConnection

Returns:

a Connection object

Throws:

SQLException - - if a database-access error occurs.

wrapStatement

public Statement wrapStatement(Statement s)
                        throws SQLException

Wrap and control a Statement

Specified by:

wrapStatement in interface BrokeredConnectionControl

Overrides:

wrapStatement in class EmbedPooledConnection

Throws:

SQLException

wrapStatement

public PreparedStatement wrapStatement(PreparedStatement ps,
 String sql,
 Object generatedKeys)
                                throws SQLException

Wrap and control a PreparedStatement

Specified by:

wrapStatement in interface BrokeredConnectionControl

Overrides:

wrapStatement in class EmbedPooledConnection

Parameters:

ps - PreparedStatment to be wrapped

sql - String

generatedKeys - Object

Returns:

returns the wrapped PreparedStatement

Throws:

SQLException

wrapStatement

public CallableStatement wrapStatement(CallableStatement cs,
 String sql)
                                throws SQLException

Wrap and control a PreparedStatement

Specified by:

wrapStatement in interface BrokeredConnectionControl

Overrides:

wrapStatement in class EmbedPooledConnection

Parameters:

cs - CallableStatment to be wrapped

sql - String

Returns:

returns the wrapped CallableStatement

Throws:

SQLException

getRealConnection

public EngineConnection getRealConnection()
                                   throws SQLException

Override getRealConnection to create a a local connection when we are not associated with an XA transaction. This can occur if the application has a Connection object (conn) and the following sequence occurs. conn = xac.getConnection(); xac.start(xid, ...) // do work with conn xac.end(xid, ...); // do local work with conn // need to create new connection here.

Specified by:

getRealConnection in interface BrokeredConnectionControl

Overrides:

getRealConnection in class EmbedPooledConnection

Throws:

SQLException