Package org.synchronoss.cpo.cassandra

Class CassandraCpoAdapter

java.lang.Object

org.synchronoss.cpo.core.cache.CpoAdapterCache

org.synchronoss.cpo.core.CpoBaseAdapter<ClusterDataSource>

org.synchronoss.cpo.cassandra.CassandraCpoAdapter

All Implemented Interfaces:

Serializable, CpoAdapter

public class CassandraCpoAdapter
extends CpoBaseAdapter<ClusterDataSource>

CassandraCpoAdapter is the Cassandra implementation of CpoAdapter, a set of routines that are responsible for managing value beans from a Cassandra datasource.

Author:

dberry

See Also:

• Serialized Form

Method Summary

Modifier and Type	Method	Description
<T> long	existsBean(CpoQuery query, T bean)
List<CpoAttribute>	getCpoAttributes(String expression)	Get the cpo attributes for this expression
CpoMetaDescriptor	getCpoMetaDescriptor()	getCpoMetaDescriptor returns the CpoMetaDescriptor associated with this CpoAdapter
static CassandraCpoAdapter	getInstance(CassandraCpoMetaDescriptor metaDescriptor, DataSourceInfo<ClusterDataSource> cdsiTrx)	Creates a CassandraCpoAdapter.
static CassandraCpoAdapter	getInstance(CassandraCpoMetaDescriptor metaDescriptor, DataSourceInfo<ClusterDataSource> cdsiWrite, DataSourceInfo<ClusterDataSource> cdsiRead)	Creates a CassandraCpoAdapter.

Methods inherited from class org.synchronoss.cpo.core.CpoBaseAdapter

deleteBean, deleteBeans, executeBean, getBatchSize, getDataSourceName, getFetchSize, insertBean, insertBeans, newOrderBy, newOrderBy, newOrderBy, newOrderBy, newWhere, newWhere, newWhere, retrieveBean, retrieveBean, retrieveBeans, setBatchSize, setFetchSize, updateBean, updateBeans, upsertBean, upsertBeans

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

Method Details

getInstance

public static CassandraCpoAdapter getInstance(CassandraCpoMetaDescriptor metaDescriptor,
 DataSourceInfo<ClusterDataSource> cdsiTrx)
                                       throws CpoException

Creates a CassandraCpoAdapter.

Parameters:

metaDescriptor - This datasource that identifies the cpo metadata datasource

cdsiTrx - The datasource that identifies the transaction database for read and write transactions.

Returns:

The CassandraCpoAdapter

Throws:

CpoException - An exception occurred

getInstance

public static CassandraCpoAdapter getInstance(CassandraCpoMetaDescriptor metaDescriptor,
 DataSourceInfo<ClusterDataSource> cdsiWrite,
 DataSourceInfo<ClusterDataSource> cdsiRead)
                                       throws CpoException

Creates a CassandraCpoAdapter.

Parameters:

metaDescriptor - This datasource that identifies the cpo metadata datasource

cdsiWrite - The datasource that identifies the transaction database for write transactions.

cdsiRead - The datasource that identifies the transaction database for read-only transactions.

Returns:

The CassandraCpoAdapter

Throws:

CpoException - An exception occurred

existsBean

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

Specified by:

existsBean in interface CpoAdapter

Specified by:

existsBean in class CpoBaseAdapter<ClusterDataSource>

Throws:

CpoException

getCpoMetaDescriptor

public CpoMetaDescriptor getCpoMetaDescriptor()

getCpoMetaDescriptor returns the CpoMetaDescriptor associated with this CpoAdapter

Returns:

The CpoMetaDescriptor

getCpoAttributes

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

Get the cpo attributes for this expression

Parameters:

expression - A string expression

Returns:

A List of CpoAttribute

Throws:

CpoException - An exception occurred