Package org.synchronoss.cpo.jdbc.jta

Class JdbcCpoXaAdapter

java.lang.Object

org.synchronoss.cpo.core.jta.CpoBaseXaResource<JdbcCpoAdapter>

org.synchronoss.cpo.jdbc.jta.JdbcCpoXaAdapter

All Implemented Interfaces:

Serializable, AutoCloseable, XAResource, CpoAdapter, CpoTrxAdapter, CpoXaResource

public class JdbcCpoXaAdapter
extends CpoBaseXaResource<JdbcCpoAdapter>
implements CpoTrxAdapter

A JdbcCpoXaAdapter wraps the XAResource processing around a JdbcCpoTrxAdapter.

It manages a local and global CpoTrxAdapter and manages the association of XIDs to transactions

The XAResource interface is a Java mapping of the industry standard XA interface based on the X/Open CAE Specification (Distributed Transaction Processing: The XA Specification).

The XA interface defines the contract between a Resource Manager and a Transaction Manager in a distributed transaction processing (DTP) environment. A JDBC driver or a JMS provider implements this interface to support the association between a global transaction and a database or message service connection.

The XAResource interface can be supported by any transactional resource that is intended to be used by application programs in an environment where transactions are controlled by an external transaction manager. An example of such a resource is a database management system. An application may access data through multiple database connections. Each database connection is enlisted with the transaction manager as a transactional resource. The transaction manager obtains an XAResource for each connection participating in a global transaction. The transaction manager uses the start method to associate the global transaction with the resource, and it uses the end method to disassociate the transaction from the resource. The resource manager is responsible for associating the global transaction to all work performed on its data between the start and end method invocations.

At transaction commit time, the resource managers are informed by the transaction manager to prepare, commit, or rollback a transaction according to the two-phase commit protocol.

See Also:

• Serialized Form

Field Summary

Fields inherited from interface javax.transaction.xa.XAResource

TMENDRSCAN, TMFAIL, TMJOIN, TMNOFLAGS, TMONEPHASE, TMRESUME, TMSTARTRSCAN, TMSUCCESS, TMSUSPEND, XA_OK, XA_RDONLY

Constructor Summary

Constructors

Constructor	Description
JdbcCpoXaAdapter(JdbcCpoAdapterFactory jdbcCpoAdapterFactory)	Construct a JdbcCpoXaAdapter

Method Summary

Modifier and Type	Method	Description
void	close()	Closes the current transaction behind the CpoTrxAdapter.
void	closeResource(JdbcCpoAdapter jdbcCpoAdapter)
void	commit()	Commits the current transaction behind the CpoTrxAdapter
void	commitResource(JdbcCpoAdapter jdbcCpoAdapter)
JdbcCpoTrxAdapter	createNewResource()
<T> long	deleteBean(CpoQuery query, T bean)
<T> long	deleteBeans(CpoQuery query, List<T> beans)
<T, C> T	executeBean(CpoQuery query, C criteria, T result)
<T> long	existsBean(CpoQuery query, T bean)
int	getBatchSize()
List<CpoAttribute>	getCpoAttributes(String expression)
CpoMetaDescriptor	getCpoMetaDescriptor()
String	getDataSourceName()
int	getFetchSize()
<T> long	insertBean(CpoQuery query, T bean)
<T> long	insertBeans(CpoQuery query, List<T> beans)
boolean	isClosed()	Returns true if the TrxAdapter has been closed, false if it is still active
boolean	isSameRM(XAResource xaResource)
CpoOrderBy	newOrderBy(String attribute, boolean ascending)
CpoOrderBy	newOrderBy(String attribute, boolean ascending, String function)
CpoOrderBy	newOrderBy(String marker, String attribute, boolean ascending)
CpoOrderBy	newOrderBy(String marker, String attribute, boolean ascending, String function)
CpoWhere	newWhere()
<T> CpoWhere	newWhere(Logical logical, String attr, Comparison comp, T value)
<T> CpoWhere	newWhere(Logical logical, String attr, Comparison comp, T value, boolean not)
<T, C> T	retrieveBean(CpoQuery query, C criteria, T result)
<T> T	retrieveBean(CpoQuery query, T bean)
<T, C> Stream<T>	retrieveBeans(CpoQuery query, C criteria, T result)
void	rollback()	Rollback the current transaction behind the CpoTrxAdapter
void	rollbackResource(JdbcCpoAdapter jdbcCpoAdapter)
void	setBatchSize(int batchSize)
void	setFetchSize(int fetchSize)
<T> long	updateBean(CpoQuery query, T bean)
<T> long	updateBeans(CpoQuery query, List<T> beans)
<T> long	upsertBean(CpoQuery query, T bean)
<T> long	upsertBeans(CpoQuery query, List<T> beans)

Methods inherited from class org.synchronoss.cpo.core.jta.CpoBaseXaResource

accept, apply, close, closeAssociated, commit, end, forget, getTransactionTimeout, prepare, recover, rollback, setTransactionTimeout, start

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.synchronoss.cpo.core.CpoAdapter

deleteBean, deleteBean, deleteBeans, deleteBeans, executeBean, executeBean, existsBean, existsBean, insertBean, insertBean, insertBeans, insertBeans, retrieveBean, retrieveBean, retrieveBeans, retrieveBeans, retrieveBeans, updateBean, updateBean, updateBeans, updateBeans, upsertBean, upsertBean, upsertBeans, upsertBeans

Constructor Details

JdbcCpoXaAdapter

public JdbcCpoXaAdapter(JdbcCpoAdapterFactory jdbcCpoAdapterFactory)
                 throws CpoException

Construct a JdbcCpoXaAdapter

Parameters:

jdbcCpoAdapterFactory - - The adapter factory to use to create the JdbcCpoXaAdapter

Throws:

CpoException - - An error getting the JdbcCpoXaAdapter

Method Details

commit

public void commit()
            throws CpoException

Commits the current transaction behind the CpoTrxAdapter

Specified by:

commit in interface CpoTrxAdapter

Throws:

CpoException

rollback

public void rollback()
              throws CpoException

Rollback the current transaction behind the CpoTrxAdapter

Specified by:

rollback in interface CpoTrxAdapter

Throws:

CpoException

close

public void close()
           throws CpoException

Closes the current transaction behind the CpoTrxAdapter. All subsequent calls to the CpoTrxAdapter will throw an exception.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface CpoTrxAdapter

Throws:

CpoException

isClosed

public boolean isClosed()
                 throws CpoException

Returns true if the TrxAdapter has been closed, false if it is still active

Specified by:

isClosed in interface CpoTrxAdapter

Throws:

CpoException

insertBean

public <T> long insertBean(CpoQuery query,
 T bean)
                    throws CpoException

Specified by:

insertBean in interface CpoAdapter

Throws:

CpoException

insertBeans

public <T> long insertBeans(CpoQuery query,
 List<T> beans)
                     throws CpoException

Specified by:

insertBeans in interface CpoAdapter

Throws:

CpoException

deleteBean

public <T> long deleteBean(CpoQuery query,
 T bean)
                    throws CpoException

Specified by:

deleteBean in interface CpoAdapter

Throws:

CpoException

deleteBeans

public <T> long deleteBeans(CpoQuery query,
 List<T> beans)
                     throws CpoException

Specified by:

deleteBeans in interface CpoAdapter

Throws:

CpoException

updateBean

public <T> long updateBean(CpoQuery query,
 T bean)
                    throws CpoException

Specified by:

updateBean in interface CpoAdapter

Throws:

CpoException

updateBeans

public <T> long updateBeans(CpoQuery query,
 List<T> beans)
                     throws CpoException

Specified by:

updateBeans in interface CpoAdapter

Throws:

CpoException

upsertBean

public <T> long upsertBean(CpoQuery query,
 T bean)
                    throws CpoException

Specified by:

upsertBean in interface CpoAdapter

Throws:

CpoException

upsertBeans

public <T> long upsertBeans(CpoQuery query,
 List<T> beans)
                     throws CpoException

Specified by:

upsertBeans in interface CpoAdapter

Throws:

CpoException

existsBean

public <T> long existsBean(CpoQuery query,
 T bean)
                    throws CpoException

Specified by:

existsBean in interface CpoAdapter

Throws:

CpoException

executeBean

public <T,
C> T executeBean(CpoQuery query,
 C criteria,
 T result)
                     throws CpoException

Specified by:

executeBean in interface CpoAdapter

Throws:

CpoException

retrieveBean

public <T> T retrieveBean(CpoQuery query,
 T bean)
                   throws CpoException

Specified by:

retrieveBean in interface CpoAdapter

Throws:

CpoException

retrieveBean

public <T,
C> T retrieveBean(CpoQuery query,
 C criteria,
 T result)
                      throws CpoException

Specified by:

retrieveBean in interface CpoAdapter

Throws:

CpoException

retrieveBeans

public <T,
C> Stream<T> retrieveBeans(CpoQuery query,
 C criteria,
 T result)
                               throws CpoException

Specified by:

retrieveBeans in interface CpoAdapter

Throws:

CpoException

newOrderBy

public CpoOrderBy newOrderBy(String attribute,
 boolean ascending)
                      throws CpoException

Specified by:

newOrderBy in interface CpoAdapter

Throws:

CpoException

newOrderBy

public CpoOrderBy newOrderBy(String marker,
 String attribute,
 boolean ascending)
                      throws CpoException

Specified by:

newOrderBy in interface CpoAdapter

Throws:

CpoException

newOrderBy

public CpoOrderBy newOrderBy(String attribute,
 boolean ascending,
 String function)
                      throws CpoException

Specified by:

newOrderBy in interface CpoAdapter

Throws:

CpoException

newOrderBy

public CpoOrderBy newOrderBy(String marker,
 String attribute,
 boolean ascending,
 String function)
                      throws CpoException

Specified by:

newOrderBy in interface CpoAdapter

Throws:

CpoException

newWhere

public CpoWhere newWhere()
                  throws CpoException

Specified by:

newWhere in interface CpoAdapter

Throws:

CpoException

newWhere

public <T> CpoWhere newWhere(Logical logical,
 String attr,
 Comparison comp,
 T value)
                      throws CpoException

Specified by:

newWhere in interface CpoAdapter

Throws:

CpoException

newWhere

public <T> CpoWhere newWhere(Logical logical,
 String attr,
 Comparison comp,
 T value,
 boolean not)
                      throws CpoException

Specified by:

newWhere in interface CpoAdapter

Throws:

CpoException

getCpoMetaDescriptor

public CpoMetaDescriptor getCpoMetaDescriptor()

Specified by:

getCpoMetaDescriptor in interface CpoAdapter

getDataSourceName

public String getDataSourceName()

Specified by:

getDataSourceName in interface CpoAdapter

getFetchSize

public int getFetchSize()

Specified by:

getFetchSize in interface CpoAdapter

setFetchSize

public void setFetchSize(int fetchSize)

Specified by:

setFetchSize in interface CpoAdapter

getBatchSize

public int getBatchSize()

Specified by:

getBatchSize in interface CpoAdapter

setBatchSize

public void setBatchSize(int batchSize)

Specified by:

setBatchSize in interface CpoAdapter

getCpoAttributes

public List<CpoAttribute> getCpoAttributes(String expression)
                                    throws CpoException

Specified by:

getCpoAttributes in interface CpoAdapter

Throws:

CpoException

isSameRM

public boolean isSameRM(XAResource xaResource)
                 throws XAException

Specified by:

isSameRM in interface XAResource

Throws:

XAException

commitResource

public void commitResource(JdbcCpoAdapter jdbcCpoAdapter)
                    throws XAException

Throws:

XAException

rollbackResource

public void rollbackResource(JdbcCpoAdapter jdbcCpoAdapter)
                      throws XAException

Throws:

XAException

createNewResource

public JdbcCpoTrxAdapter createNewResource()
                                    throws XAException

Throws:

XAException

closeResource

public void closeResource(JdbcCpoAdapter jdbcCpoAdapter)
                   throws XAException

Throws:

XAException