public class XAManagedConnection extends BaseWrapperManagedConnection implements javax.transaction.xa.XAResource, javax.resource.spi.LocalTransaction
Modifier and Type | Field and Description |
---|---|
protected javax.transaction.xa.Xid |
currentXid
The Xid
|
protected javax.sql.XAConnection |
xaConnection
The XA connection
|
protected javax.transaction.xa.XAResource |
xaResource
The XAResource
|
con, destroyed, ignoreInManagedAutoCommitCalls, inLocalTransaction, inManagedTransaction, jdbcAutoCommit, jdbcReadOnly, jdbcTransactionIsolation, mcf, metadata, props, stateLock, underlyingAutoCommit, underlyingReadOnly
Constructor and Description |
---|
XAManagedConnection(XAManagedConnectionFactory mcf,
javax.sql.XAConnection xaConnection,
java.util.Properties props,
int transactionIsolation,
int psCacheSize)
Constructor
|
Modifier and Type | Method and Description |
---|---|
void |
begin() |
protected void |
broadcastConnectionError(java.sql.SQLException e) |
void |
commit() |
void |
commit(javax.transaction.xa.Xid xid,
boolean onePhase) |
void |
destroy()
Destroy
|
void |
end(javax.transaction.xa.Xid xid,
int flags) |
void |
forget(javax.transaction.xa.Xid xid) |
javax.resource.spi.LocalTransaction |
getLocalTransaction() |
int |
getTransactionTimeout() |
javax.transaction.xa.XAResource |
getXAResource() |
boolean |
isSameRM(javax.transaction.xa.XAResource other) |
boolean |
isXA()
Returns true if the underlying connection is handled by an XA resource manager
|
int |
prepare(javax.transaction.xa.Xid xid) |
javax.transaction.xa.Xid[] |
recover(int flag) |
void |
rollback() |
void |
rollback(javax.transaction.xa.Xid xid) |
boolean |
setTransactionTimeout(int seconds) |
void |
start(javax.transaction.xa.Xid xid,
int flags) |
addConnectionEventListener, associateConnection, broadcastConnectionError, checkException, checkState, checkValid, cleanup, getConnection, getConnection, getLog, getLogWriter, getMetaData, getProperties, lock, removeConnectionEventListener, setLogWriter, tryLock, unlock
protected final javax.sql.XAConnection xaConnection
protected final javax.transaction.xa.XAResource xaResource
protected javax.transaction.xa.Xid currentXid
public XAManagedConnection(XAManagedConnectionFactory mcf, javax.sql.XAConnection xaConnection, java.util.Properties props, int transactionIsolation, int psCacheSize) throws java.sql.SQLException
mcf
- The managed connection factoryxaConnection
- The XA connectionprops
- The propertiestransactionIsolation
- The transaction isolationpsCacheSize
- The prepared statement cache sizejava.sql.SQLException
- Thrown if an error occurspublic void begin() throws javax.resource.ResourceException
begin
in interface javax.resource.spi.LocalTransaction
javax.resource.ResourceException
public void commit() throws javax.resource.ResourceException
commit
in interface javax.resource.spi.LocalTransaction
javax.resource.ResourceException
public void rollback() throws javax.resource.ResourceException
rollback
in interface javax.resource.spi.LocalTransaction
javax.resource.ResourceException
protected void broadcastConnectionError(java.sql.SQLException e)
public javax.resource.spi.LocalTransaction getLocalTransaction() throws javax.resource.ResourceException
getLocalTransaction
in interface javax.resource.spi.ManagedConnection
javax.resource.ResourceException
public javax.transaction.xa.XAResource getXAResource() throws javax.resource.ResourceException
getXAResource
in interface javax.resource.spi.ManagedConnection
javax.resource.ResourceException
public void destroy() throws javax.resource.ResourceException
destroy
in interface javax.resource.spi.ManagedConnection
destroy
in class BaseWrapperManagedConnection
javax.resource.ResourceException
- Thrown if an error occurspublic void start(javax.transaction.xa.Xid xid, int flags) throws javax.transaction.xa.XAException
start
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public void end(javax.transaction.xa.Xid xid, int flags) throws javax.transaction.xa.XAException
end
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public int prepare(javax.transaction.xa.Xid xid) throws javax.transaction.xa.XAException
prepare
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public void commit(javax.transaction.xa.Xid xid, boolean onePhase) throws javax.transaction.xa.XAException
commit
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public void rollback(javax.transaction.xa.Xid xid) throws javax.transaction.xa.XAException
rollback
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public void forget(javax.transaction.xa.Xid xid) throws javax.transaction.xa.XAException
forget
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public javax.transaction.xa.Xid[] recover(int flag) throws javax.transaction.xa.XAException
recover
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public boolean isSameRM(javax.transaction.xa.XAResource other) throws javax.transaction.xa.XAException
isSameRM
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public int getTransactionTimeout() throws javax.transaction.xa.XAException
getTransactionTimeout
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public boolean setTransactionTimeout(int seconds) throws javax.transaction.xa.XAException
setTransactionTimeout
in interface javax.transaction.xa.XAResource
javax.transaction.xa.XAException
public boolean isXA()
isXA
in class BaseWrapperManagedConnection
Copyright © 2013 IronJacamar (http://www.ironjacamar.org)