org.teiid.dqp.internal.process

Class TransactionServerImpl

java.lang.Object

org.teiid.dqp.internal.process.TransactionServerImpl

All Implemented Interfaces:

TransactionService

public class TransactionServerImpl
extends Object
implements TransactionService

Note that the begin methods do not leave the transaction associated with the calling thread. This is by design and requires explicit resumes for association.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	TransactionServerImpl.TransactionMapping

Field Summary

Fields

Modifier and Type	Field and Description
protected TransactionManager	transactionManager
protected TransactionServerImpl.TransactionMapping	transactions

Constructor Summary

Constructors

Constructor and Description
TransactionServerImpl()

Method Summary

Modifier and Type	Method and Description
TransactionContext	begin(String threadId) Local Transaction
void	begin(TransactionContext context) Request level transaction
void	cancelTransactions(String threadId, boolean requestOnly)
void	commit(String threadId) Local Transaction
void	commit(String threadId, XidImpl xid, boolean onePhase, boolean singleTM) Global Transaction
void	commit(TransactionContext context) Request level transaction
void	end(String threadId, XidImpl xid, int flags, boolean singleTM) Global Transaction
void	forget(String threadId, XidImpl xid, boolean singleTM) Global Transaction
TransactionContext	getOrCreateTransactionContext(String threadId)
Collection<TransactionMetadata>	getTransactions()
boolean	isDetectTransactions()
int	prepare(String threadId, XidImpl xid, boolean singleTM) Global Transaction
Xid[]	recover(int flag, boolean singleTM) Global Transaction
void	resume(TransactionContext context)
void	rollback(String threadId) Local Transaction
void	rollback(String threadId, XidImpl xid, boolean singleTM) Global Transaction
void	rollback(TransactionContext context) Request level transaction
void	setDetectTransactions(boolean detectTransactions)
void	setTransactionManager(TransactionManager transactionManager)
void	setXaImporter(XAImporter xaImporter)
void	start(String threadId, XidImpl xid, int flags, int timeout, boolean singleTM) Global Transaction
void	suspend(TransactionContext context)
void	terminateTransaction(String threadId)

Methods inherited from class java.lang.Object

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

Field Detail

transactions

protected TransactionServerImpl.TransactionMapping transactions

transactionManager

protected TransactionManager transactionManager

Constructor Detail

TransactionServerImpl

public TransactionServerImpl()

Method Detail

setDetectTransactions

public void setDetectTransactions(boolean detectTransactions)

isDetectTransactions

public boolean isDetectTransactions()

setXaImporter

public void setXaImporter(XAImporter xaImporter)

setTransactionManager

public void setTransactionManager(TransactionManager transactionManager)

prepare

public int prepare(String threadId,
                   XidImpl xid,
                   boolean singleTM)
            throws XATransactionException

Global Transaction

Specified by:

prepare in interface TransactionService

Throws:

XATransactionException

commit

public void commit(String threadId,
                   XidImpl xid,
                   boolean onePhase,
                   boolean singleTM)
            throws XATransactionException

Global Transaction

Specified by:

commit in interface TransactionService

Throws:

XATransactionException

rollback

public void rollback(String threadId,
                     XidImpl xid,
                     boolean singleTM)
              throws XATransactionException

Global Transaction

Specified by:

rollback in interface TransactionService

Throws:

XATransactionException

recover

public Xid[] recover(int flag,
                     boolean singleTM)
              throws XATransactionException

Global Transaction

Specified by:

recover in interface TransactionService

Throws:

XATransactionException

forget

public void forget(String threadId,
                   XidImpl xid,
                   boolean singleTM)
            throws XATransactionException

Global Transaction

Specified by:

forget in interface TransactionService

Throws:

XATransactionException

start

public void start(String threadId,
                  XidImpl xid,
                  int flags,
                  int timeout,
                  boolean singleTM)
           throws XATransactionException

Global Transaction

Specified by:

start in interface TransactionService

Throws:

XATransactionException

end

public void end(String threadId,
                XidImpl xid,
                int flags,
                boolean singleTM)
         throws XATransactionException

Global Transaction

Specified by:

end in interface TransactionService

Throws:

XATransactionException

suspend

public void suspend(TransactionContext context)
             throws XATransactionException

Specified by:

suspend in interface TransactionService

Throws:

XATransactionException

resume

public void resume(TransactionContext context)
            throws XATransactionException

Specified by:

resume in interface TransactionService

Throws:

XATransactionException

begin

public TransactionContext begin(String threadId)
                         throws XATransactionException

Local Transaction

Specified by:

begin in interface TransactionService

Throws:

XATransactionException

commit

public void commit(String threadId)
            throws XATransactionException

Local Transaction

Specified by:

commit in interface TransactionService

Throws:

XATransactionException

rollback

public void rollback(String threadId)
              throws XATransactionException

Local Transaction

Specified by:

rollback in interface TransactionService

Throws:

XATransactionException

getOrCreateTransactionContext

public TransactionContext getOrCreateTransactionContext(String threadId)

Specified by:

getOrCreateTransactionContext in interface TransactionService

begin

public void begin(TransactionContext context)
           throws XATransactionException

Request level transaction

Specified by:

begin in interface TransactionService

Throws:

XATransactionException

commit

public void commit(TransactionContext context)
            throws XATransactionException

Request level transaction

Specified by:

commit in interface TransactionService

Throws:

XATransactionException

rollback

public void rollback(TransactionContext context)
              throws XATransactionException

Request level transaction

Specified by:

rollback in interface TransactionService

Throws:

XATransactionException

cancelTransactions

public void cancelTransactions(String threadId,
                               boolean requestOnly)
                        throws XATransactionException

Specified by:

cancelTransactions in interface TransactionService

Throws:

XATransactionException

getTransactions

public Collection<TransactionMetadata> getTransactions()

Specified by:

getTransactions in interface TransactionService

terminateTransaction

public void terminateTransaction(String threadId)
                          throws AdminException

Specified by:

terminateTransaction in interface TransactionService

Throws:

AdminException