jrun.sql
Class ConnectionXAResource

jrun.sql.ConnectionXAResource

public class ConnectionXAResource

A JRun-specific implementation of the JTA XAResource. This XAResource is associated with one and only one JRunConnection object. It may be associated with multiple transactions executed on that Connection during the Connection's lifetime.

Author:

PS Neville

Constructor Summary

ConnectionXAResource(JRunConnection con)

Method Summary

void	commit(javax.transaction.xa.Xid xid, boolean onePhase)
void	end(javax.transaction.xa.Xid xid, int flags)
void	forget(javax.transaction.xa.Xid xid)
void	forget(javax.transaction.xa.Xid xid, int flag)
javax.transaction.xa.Xid	getActive()
JRunDataSource	getDataSource()
JRunConnection	getJRunConnection()
int	getTransactionTimeout()
boolean	isActive()
boolean	isSameRM(javax.transaction.xa.XAResource xares) Return true only if the underlying Connections are equal.
int	prepare(javax.transaction.xa.Xid xid)
javax.transaction.xa.Xid[]	recover(int flag) Provide the TM with an array of transaction id's that are in the prepared state.
void	rollback(javax.transaction.xa.Xid xid)
void	setJRunConnection(JRunConnection scon)
void	setJRunDataSource(JRunDataSource ds)
boolean	setTransactionTimeout(int seconds)
void	start(javax.transaction.xa.Xid xid, int flags)

Constructor Detail

ConnectionXAResource

public ConnectionXAResource(JRunConnection con)

Method Detail

getJRunConnection

public JRunConnection getJRunConnection()

setJRunConnection

public void setJRunConnection(JRunConnection scon)

getDataSource

public JRunDataSource getDataSource()

setJRunDataSource

public void setJRunDataSource(JRunDataSource ds)

isActive

public boolean isActive()

getActive

public javax.transaction.xa.Xid getActive()
                                   throws javax.transaction.xa.XAException

commit

public void commit(javax.transaction.xa.Xid xid,
                   boolean onePhase)
            throws javax.transaction.xa.XAException

end

public void end(javax.transaction.xa.Xid xid,
                int flags)
         throws javax.transaction.xa.XAException

forget

public void forget(javax.transaction.xa.Xid xid)
            throws javax.transaction.xa.XAException

forget

public void forget(javax.transaction.xa.Xid xid,
                   int flag)
            throws javax.transaction.xa.XAException

prepare

public int prepare(javax.transaction.xa.Xid xid)
            throws javax.transaction.xa.XAException

recover

public javax.transaction.xa.Xid[] recover(int flag)
                                   throws javax.transaction.xa.XAException

Provide the TM with an array of transaction id's that are in the prepared state.

rollback

public void rollback(javax.transaction.xa.Xid xid)
              throws javax.transaction.xa.XAException

start

public void start(javax.transaction.xa.Xid xid,
                  int flags)
           throws javax.transaction.xa.XAException

isSameRM

public boolean isSameRM(javax.transaction.xa.XAResource xares)
                 throws javax.transaction.xa.XAException

Return true only if the underlying Connections are equal.

getTransactionTimeout

public int getTransactionTimeout()
                          throws javax.transaction.xa.XAException

setTransactionTimeout

public boolean setTransactionTimeout(int seconds)
                              throws javax.transaction.xa.XAException