com.impetus.client.cassandra

Class CassandraClientBase

java.lang.Object

com.impetus.kundera.client.ClientBase

com.impetus.client.cassandra.CassandraClientBase

All Implemented Interfaces:

ClientPropertiesSetter

Direct Known Subclasses:

ThriftClient

public abstract class CassandraClientBase
extends ClientBase
implements ClientPropertiesSetter

Base Class for all Cassandra Clients Contains methods that are applicable to (but not specific to) different Cassandra clients.

Author:

amresh.singh

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	CassandraClientBase.CQLClient Use CqlClient class for crud when cql enable.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.cassandra.thrift.ConsistencyLevel	consistencyLevel The consistency level.
protected CassandraClientBase.CQLClient	cqlClient The cql client.
protected TimestampGenerator	generator The generator.

Fields inherited from class com.impetus.kundera.client.ClientBase

clientMetadata, externalProperties, indexManager, isUpdate, kunderaMetadata, persistenceUnit, showQuery

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	CassandraClientBase(String persistenceUnit, Map<String,Object> externalProperties, EntityManagerFactoryImpl.KunderaMetadata kunderaMetadata, TimestampGenerator generator) constructor using fields.

Method Summary

Methods

Modifier and Type	Method and Description
void	addBatch(Node node) Adds the batch.
protected void	addRelationsToThriftRow(EntityMetadata metadata, ThriftRow tf, List<RelationHolder> relations) Adds relation foreign key values as thrift column/ value to thrift row.
void	clear() Clear.
void	close() Close.
protected void	computeEntityViaColumns(EntityMetadata m, boolean isRelation, List<String> relations, List<Object> entities, Map<ByteBuffer,List<org.apache.cassandra.thrift.Column>> qResults) Compute entity via columns.
protected void	computeEntityViaSuperColumns(EntityMetadata m, boolean isRelation, List<String> relations, List<Object> entities, Map<ByteBuffer,List<org.apache.cassandra.thrift.SuperColumn>> qResults) Compute entity via super columns.
protected void	createIndexesOnColumns(EntityMetadata m, String tableName, List<org.apache.cassandra.thrift.Column> columns, Class columnType) Creates secondary indexes on columns if not already created.
protected List<String>	createInsertQuery(EntityMetadata entityMetadata, Object entity, org.apache.cassandra.thrift.Cassandra.Client cassandra_client, List<RelationHolder> rlHolders, Object ttlColumns) Return insert query string for given entity.
protected List<String>	createUpdateQueryForCounter(EntityMetadata entityMetadata, Object entity, org.apache.cassandra.thrift.Cassandra.Client cassandra_client, List<RelationHolder> rlHolders) Return update query string for given entity intended for counter column family.
protected abstract void	delete(Object entity, Object pKey) Delete.
protected void	deleteRecordFromCounterColumnFamily(Object pKey, String tableName, EntityMetadata metadata, org.apache.cassandra.thrift.ConsistencyLevel consistencyLevel) Deletes record for given primary key from counter column family.
<T> T	execute(String query, Object connection) Execute.
int	executeBatch() Execute batch.
protected Object	executeCQLQuery(String cqlQuery, boolean isCql3Enabled) Executes query string using cql3.
abstract List	executeQuery(Class clazz, List<String> relationalField, boolean isNative, String cqlQuery) Query related methods.
List	executeScalarQuery(String cqlQuery) Execute scalar query.
List	executeSelectQuery(Class clazz, List<String> relationalField, CassandraDataHandler dataHandler, boolean isNative, String cqlQuery) Executes Select CQL Query.
int	executeUpdateDeleteQuery(String cqlQuery) Executes Update/ Delete CQL query.
<E> List<E>	find(Class<E> entityClass, Map<String,String> superColumnMap, CassandraDataHandler dataHandler) Find.
abstract List	find(Class entityClass, List<String> relationNames, boolean isWrapReq, EntityMetadata metadata, Object... rowIds) Find.
Object	find(Class entityClass, Object rowId) Finds an entiry from database.
abstract List<EnhanceEntity>	find(EntityMetadata m, List<String> relationNames, List<org.apache.cassandra.thrift.IndexClause> conditions, int maxResult, List<String> columns) Find.
abstract List	find(List<org.apache.cassandra.thrift.IndexClause> ixClause, EntityMetadata m, boolean isRelation, List<String> relations, int maxResult, List<String> columns) Find.
<E> List<E>	findAll(Class<E> entityClass, String[] columnsToSelect, Object... rowIds) Finds a List of entities from database.
abstract List	findByRange(byte[] muinVal, byte[] maxVal, EntityMetadata m, boolean isWrapReq, List<String> relations, List<String> columns, List<org.apache.cassandra.thrift.IndexExpression> conditions, int maxResults) Find by range.
protected List<Object>	findByRelationQuery(EntityMetadata m, String columnName, Object columnValue, Class clazz, CassandraDataHandler dataHandler) Find List of objects based on value of column .
List	findByRowKeys(Class entityClass, List<String> relationNames, boolean isWrapReq, EntityMetadata metadata, Object... rowIds) Finds a List of entities from database.
protected <E> List<E>	findIdsByColumnUsingCql(String schemaName, String tableName, String pKeyName, String columnName, Object columnValue, Class entityClazz) Find join column values for inverse join column.
int	getBatchSize() Gets the batch size.
protected <E> List<E>	getColumnsByIdUsingCql(String schemaName, String tableName, String pKeyColumnName, String columnName, Object pKeyColumnValue, Class columnJavaType) Find inverse join column values for join column.
protected abstract Object	getConnection() Gets the connection.
protected abstract Object	getConnection(Object connection) Gets the connection.
org.apache.cassandra.thrift.ConsistencyLevel	getConsistencyLevel() Gets the consistency level.
org.apache.cassandra.thrift.CqlMetadata	getCqlMetadata() Gets the cql metadata.
protected String	getCqlVersion() Gets the cql version.
protected abstract CassandraDataHandler	getDataHandler() Gets the data handler.
Map<String,Object>	getExternalProperties() Gets the external properties.
org.apache.cassandra.thrift.Cassandra.Client	getRawClient(String schema) Returns raw cassandra client from thrift connection pool.
Map<String,Object>	getTtlValues() Gets the ttl values.
boolean	isCql3Enabled() Returns true in case of, composite Id and if cql3 opted and not a embedded entity.
boolean	isCql3Enabled(EntityMetadata metadata) Returns true in case of, composite Id and if cql3 opted and not a embedded entity.
protected boolean	isOpen() Checks if is open.
boolean	isTtlPerRequest() Checks if is ttl per request.
boolean	isTtlPerSession() Checks if is ttl per session.
protected abstract List<org.apache.cassandra.thrift.SuperColumn>	loadSuperColumns(String keyspace, String columnFamily, String rowId, String... superColumnNames) Load super columns.
protected void	onColumn(EntityMetadata m, boolean isRelation, List<String> relations, List<Object> entities, List<org.apache.cassandra.thrift.Column> columns, List<AbstractManagedType> subManagedType, ByteBuffer key) On column.
protected List<Object>	onCounterColumn(EntityMetadata m, boolean isRelation, List<String> relations, List<org.apache.cassandra.thrift.KeySlice> ks) On counter column.
protected String	onDeleteQuery(EntityMetadata metadata, String tableName, MetamodelImpl metaModel, Object keyObject) On delete query.
protected void	onSuperColumn(EntityMetadata m, boolean isRelation, List<String> relations, List<Object> entities, List<org.apache.cassandra.thrift.SuperColumn> superColumns, ByteBuffer key) On super column.
protected void	onWhereClause(EntityMetadata metadata, Object key, CQLTranslator translator, StringBuilder queryBuilder, MetamodelImpl metaModel, javax.persistence.metamodel.SingularAttribute attribute) On where clause.
protected void	persistJoinTableByCql(JoinTableData joinTableData, org.apache.cassandra.thrift.Cassandra.Client conn) Persist join table by cql.
void	populateClientProperties(Client client, Map<String,Object> properties)
protected List	populateEntitiesFromKeySlices(EntityMetadata m, boolean isWrapReq, List<String> relations, List<org.apache.cassandra.thrift.KeySlice> keys, CassandraDataHandler dataHandler) Populate entities from key slices.
protected org.apache.cassandra.thrift.Column	populateFkey(String rlName, Object rlValue, long timestamp) Populates foreign key as column.
protected Map<ByteBuffer,Map<String,List<org.apache.cassandra.thrift.Mutation>>>	prepareMutation(EntityMetadata entityMetadata, Object entity, Object id, List<RelationHolder> relationHolders, Map<ByteBuffer,Map<String,List<org.apache.cassandra.thrift.Mutation>>> mutationMap) Prepare mutation.
protected abstract void	releaseConnection(Object conn) Release connection.
abstract List<SearchResult>	searchInInvertedIndex(String columnFamilyName, EntityMetadata m, Map<Boolean,List<org.apache.cassandra.thrift.IndexClause>> indexClauseMap) Search in inverted index.
void	setConsistencyLevel(org.apache.cassandra.thrift.ConsistencyLevel cLevel) Sets the consistency level.
void	setCqlMetadata(org.apache.cassandra.thrift.CqlMetadata cqlMetadata) Sets the cql metadata.
void	setCqlVersion(String cqlVersion) Sets the cql version.
void	setTtlPerRequest(boolean ttlPerRequest) Sets the ttl per request.
void	setTtlPerSession(boolean ttlPerSession) Sets the ttl per session.
void	setTtlValues(Map<String,Object> ttlValues) Sets the ttl values.

Methods inherited from class com.impetus.kundera.client.ClientBase

executeScript, getClientMetadata, getIndexManager, getPersistenceUnit, getRelationHolders, indexNode, onPersist, persist, remove, unIndexNode, useSecondryIndex

Methods inherited from class java.lang.Object

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

Field Detail

consistencyLevel

protected org.apache.cassandra.thrift.ConsistencyLevel consistencyLevel

The consistency level.

cqlClient

protected final CassandraClientBase.CQLClient cqlClient

The cql client.

generator

protected final TimestampGenerator generator

The generator.

Constructor Detail

CassandraClientBase

protected CassandraClientBase(String persistenceUnit,
                   Map<String,Object> externalProperties,
                   EntityManagerFactoryImpl.KunderaMetadata kunderaMetadata,
                   TimestampGenerator generator)

constructor using fields.

Parameters:

persistenceUnit - the persistence unit

externalProperties - the external properties

kunderaMetadata - the kundera metadata

generator - the generator

Method Detail

populateFkey

protected org.apache.cassandra.thrift.Column populateFkey(String rlName,
                                              Object rlValue,
                                              long timestamp)
                                                   throws PropertyAccessException

Populates foreign key as column.

Parameters:

rlName - relation name

rlValue - relation value

timestamp - the timestamp

Returns:

the column

Throws:

PropertyAccessException - the property access exception

onCounterColumn

protected List<Object> onCounterColumn(EntityMetadata m,
                           boolean isRelation,
                           List<String> relations,
                           List<org.apache.cassandra.thrift.KeySlice> ks)

On counter column.

Parameters:

m - the m

isRelation - the is relation

relations - the relations

ks - the ks

Returns:

the list

computeEntityViaColumns

protected void computeEntityViaColumns(EntityMetadata m,
                           boolean isRelation,
                           List<String> relations,
                           List<Object> entities,
                           Map<ByteBuffer,List<org.apache.cassandra.thrift.Column>> qResults)

Compute entity via columns.

Parameters:

m - the m

isRelation - the is relation

relations - the relations

entities - the entities

qResults - the q results

onColumn

protected void onColumn(EntityMetadata m,
            boolean isRelation,
            List<String> relations,
            List<Object> entities,
            List<org.apache.cassandra.thrift.Column> columns,
            List<AbstractManagedType> subManagedType,
            ByteBuffer key)

On column.

Parameters:

m - the m

isRelation - the is relation

relations - the relations

entities - the entities

columns - the columns

subManagedType - the sub managed type

key - the key

computeEntityViaSuperColumns

protected void computeEntityViaSuperColumns(EntityMetadata m,
                                boolean isRelation,
                                List<String> relations,
                                List<Object> entities,
                                Map<ByteBuffer,List<org.apache.cassandra.thrift.SuperColumn>> qResults)

Compute entity via super columns.

Parameters:

m - the m

isRelation - the is relation

relations - the relations

entities - the entities

qResults - the q results

onSuperColumn

protected void onSuperColumn(EntityMetadata m,
                 boolean isRelation,
                 List<String> relations,
                 List<Object> entities,
                 List<org.apache.cassandra.thrift.SuperColumn> superColumns,
                 ByteBuffer key)

On super column.

Parameters:

m - the m

isRelation - the is relation

relations - the relations

entities - the entities

superColumns - the super columns

key - the key

addRelationsToThriftRow

protected void addRelationsToThriftRow(EntityMetadata metadata,
                           ThriftRow tf,
                           List<RelationHolder> relations)

Adds relation foreign key values as thrift column/ value to thrift row.

Parameters:

metadata - the metadata

tf - the tf

relations - the relations

deleteRecordFromCounterColumnFamily

protected void deleteRecordFromCounterColumnFamily(Object pKey,
                                       String tableName,
                                       EntityMetadata metadata,
                                       org.apache.cassandra.thrift.ConsistencyLevel consistencyLevel)

Deletes record for given primary key from counter column family.

Parameters:

pKey - the key

tableName - the table name

metadata - the metadata

consistencyLevel - the consistency level

createIndexesOnColumns

protected void createIndexesOnColumns(EntityMetadata m,
                          String tableName,
                          List<org.apache.cassandra.thrift.Column> columns,
                          Class columnType)

Creates secondary indexes on columns if not already created.

Parameters:

m - the m

tableName - Column family name

columns - List of columns

columnType - the column type

find

public Object find(Class entityClass,
          Object rowId)

Finds an entiry from database.

Parameters:

entityClass - the entity class

rowId - the row id

Returns:

the object

findAll

public <E> List<E> findAll(Class<E> entityClass,
                  String[] columnsToSelect,
                  Object... rowIds)

Finds a List of entities from database.

Type Parameters:

E - the element type

Parameters:

entityClass - the entity class

columnsToSelect - TODO

rowIds - the row ids

Returns:

the list

isCql3Enabled

public boolean isCql3Enabled(EntityMetadata metadata)

Returns true in case of, composite Id and if cql3 opted and not a embedded entity.

Parameters:

metadata - the metadata

Returns:

true, if is cql3 enabled

isCql3Enabled

public boolean isCql3Enabled()

Returns true in case of, composite Id and if cql3 opted and not a embedded entity.

Returns:

true, if is cql3 enabled

find

public <E> List<E> find(Class<E> entityClass,
               Map<String,String> superColumnMap,
               CassandraDataHandler dataHandler)

Find.

Type Parameters:

E - the element type

Parameters:

entityClass - the entity class

superColumnMap - the super column map

dataHandler - the data handler

Returns:

the list

executeSelectQuery

public List executeSelectQuery(Class clazz,
                      List<String> relationalField,
                      CassandraDataHandler dataHandler,
                      boolean isNative,
                      String cqlQuery)

Executes Select CQL Query.

Parameters:

clazz - the clazz

relationalField - the relational field

dataHandler - the data handler

isNative - the is native

cqlQuery - the cql query

Returns:

the list

executeScalarQuery

public List executeScalarQuery(String cqlQuery)

Execute scalar query.

Parameters:

dataHandler - the data handler

cqlQuery - the cql query

Returns:

the list

executeUpdateDeleteQuery

public int executeUpdateDeleteQuery(String cqlQuery)

Executes Update/ Delete CQL query.

Parameters:

cqlQuery - the cql query

Returns:

the int

getExternalProperties

public Map<String,Object> getExternalProperties()

Gets the external properties.

Returns:

the external properties

populateEntitiesFromKeySlices

protected List populateEntitiesFromKeySlices(EntityMetadata m,
                                 boolean isWrapReq,
                                 List<String> relations,
                                 List<org.apache.cassandra.thrift.KeySlice> keys,
                                 CassandraDataHandler dataHandler)
                                      throws Exception

Populate entities from key slices.

Parameters:

m - the m

isWrapReq - the is wrap req

relations - the relations

keys - the keys

dataHandler - the data handler

Returns:

the list

Throws:

Exception - the exception

createInsertQuery

protected List<String> createInsertQuery(EntityMetadata entityMetadata,
                             Object entity,
                             org.apache.cassandra.thrift.Cassandra.Client cassandra_client,
                             List<RelationHolder> rlHolders,
                             Object ttlColumns)

Return insert query string for given entity.

Parameters:

entityMetadata - the entity metadata

entity - the entity

cassandra_client - the cassandra_client

rlHolders - the rl holders

ttlColumns - TTL values for each columns

Returns:

the list

createUpdateQueryForCounter

protected List<String> createUpdateQueryForCounter(EntityMetadata entityMetadata,
                                       Object entity,
                                       org.apache.cassandra.thrift.Cassandra.Client cassandra_client,
                                       List<RelationHolder> rlHolders)

Return update query string for given entity intended for counter column family.

Parameters:

entityMetadata - the entity metadata

entity - the entity

cassandra_client - the cassandra_client

rlHolders - the rl holders

Returns:

the list

getCqlVersion

protected String getCqlVersion()

Gets the cql version.

Returns:

the cqlVersion

setCqlVersion

public void setCqlVersion(String cqlVersion)

Sets the cql version.

Parameters:

cqlVersion - the cqlVersion to set

setConsistencyLevel

public void setConsistencyLevel(org.apache.cassandra.thrift.ConsistencyLevel cLevel)

Sets the consistency level.

Parameters:

cLevel - the new consistency level

close

public void close()

Close.

isOpen

protected final boolean isOpen()

Checks if is open.

Returns:

true, if is open

getConsistencyLevel

public org.apache.cassandra.thrift.ConsistencyLevel getConsistencyLevel()

Gets the consistency level.

Returns:

the consistency level

onDeleteQuery

protected String onDeleteQuery(EntityMetadata metadata,
                   String tableName,
                   MetamodelImpl metaModel,
                   Object keyObject)

On delete query.

Parameters:

metadata - the metadata

tableName - TODO

metaModel - the meta model

keyObject - the compound key object

Returns:

the string

onWhereClause

protected void onWhereClause(EntityMetadata metadata,
                 Object key,
                 CQLTranslator translator,
                 StringBuilder queryBuilder,
                 MetamodelImpl metaModel,
                 javax.persistence.metamodel.SingularAttribute attribute)

On where clause.

Parameters:

metadata - the metadata

key - the compound key object

translator - the translator

queryBuilder - the query builder

metaModel - the meta model

attribute - the attribute

find

public abstract List find(Class entityClass,
        List<String> relationNames,
        boolean isWrapReq,
        EntityMetadata metadata,
        Object... rowIds)

Find.

Parameters:

entityClass - the entity class

relationNames - the relation names

isWrapReq - the is wrap req

metadata - the metadata

rowIds - the row ids

Returns:

the list

loadSuperColumns

protected abstract List<org.apache.cassandra.thrift.SuperColumn> loadSuperColumns(String keyspace,
                                                             String columnFamily,
                                                             String rowId,
                                                             String... superColumnNames)

Load super columns.

Parameters:

keyspace - the keyspace

columnFamily - the column family

rowId - the row id

superColumnNames - the super column names

Returns:

the list

executeQuery

public abstract List executeQuery(Class clazz,
                List<String> relationalField,
                boolean isNative,
                String cqlQuery)

Query related methods.

Parameters:

clazz - the clazz

relationalField - the relational field

isNative - the is native

cqlQuery - the cql query

Returns:

the list

find

public abstract List find(List<org.apache.cassandra.thrift.IndexClause> ixClause,
        EntityMetadata m,
        boolean isRelation,
        List<String> relations,
        int maxResult,
        List<String> columns)

Find.

Parameters:

ixClause - the ix clause

m - the m

isRelation - the is relation

relations - the relations

maxResult - the max result

columns - the columns

Returns:

the list

findByRange

public abstract List findByRange(byte[] muinVal,
               byte[] maxVal,
               EntityMetadata m,
               boolean isWrapReq,
               List<String> relations,
               List<String> columns,
               List<org.apache.cassandra.thrift.IndexExpression> conditions,
               int maxResults)
                          throws Exception

Find by range.

Parameters:

muinVal - the muin val

maxVal - the max val

m - the m

isWrapReq - the is wrap req

relations - the relations

columns - the columns

conditions - the conditions

maxResults - the max results

Returns:

the list

Throws:

Exception - the exception

searchInInvertedIndex

public abstract List<SearchResult> searchInInvertedIndex(String columnFamilyName,
                                       EntityMetadata m,
                                       Map<Boolean,List<org.apache.cassandra.thrift.IndexClause>> indexClauseMap)

Search in inverted index.

Parameters:

columnFamilyName - the column family name

m - the m

indexClauseMap - the index clause map

Returns:

the list

find

public abstract List<EnhanceEntity> find(EntityMetadata m,
                       List<String> relationNames,
                       List<org.apache.cassandra.thrift.IndexClause> conditions,
                       int maxResult,
                       List<String> columns)

Find.

Parameters:

m - the m

relationNames - the relation names

conditions - the conditions

maxResult - the max result

columns - the columns

Returns:

the list

getDataHandler

protected abstract CassandraDataHandler getDataHandler()

Gets the data handler.

Returns:

the data handler

delete

protected abstract void delete(Object entity,
          Object pKey)

Delete.

Specified by:

delete in class ClientBase

Parameters:

entity - the entity

pKey - the key

addBatch

public void addBatch(Node node)

Adds the batch.

Parameters:

node - the node

getBatchSize

public int getBatchSize()

Gets the batch size.

Returns:

the batch size

clear

public void clear()

Clear.

executeBatch

public int executeBatch()

Execute batch.

Returns:

the int

prepareMutation

protected Map<ByteBuffer,Map<String,List<org.apache.cassandra.thrift.Mutation>>> prepareMutation(EntityMetadata entityMetadata,
                                                                                     Object entity,
                                                                                     Object id,
                                                                                     List<RelationHolder> relationHolders,
                                                                                     Map<ByteBuffer,Map<String,List<org.apache.cassandra.thrift.Mutation>>> mutationMap)

Prepare mutation.

Parameters:

entityMetadata - the entity metadata

entity - the entity

id - the id

relationHolders - the relation holders

mutationMap - the mutation map

Returns:

the map

populateClientProperties

public void populateClientProperties(Client client,
                            Map<String,Object> properties)

Specified by:

populateClientProperties in interface ClientPropertiesSetter

getRawClient

public org.apache.cassandra.thrift.Cassandra.Client getRawClient(String schema)

Returns raw cassandra client from thrift connection pool.

Parameters:

schema - schema or keyspace.

Returns:

raw cassandra client.

executeCQLQuery

protected Object executeCQLQuery(String cqlQuery,
                     boolean isCql3Enabled)

Executes query string using cql3.

Parameters:

cqlQuery - the cql query

isCql3Enabled - the is cql3 enabled

Returns:

the object

findByRelationQuery

protected List<Object> findByRelationQuery(EntityMetadata m,
                               String columnName,
                               Object columnValue,
                               Class clazz,
                               CassandraDataHandler dataHandler)

Find List of objects based on value of column .

Parameters:

m - the m

columnName - the column name

columnValue - the column value

clazz - the clazz

dataHandler - the data handler

Returns:

the list

getConnection

protected abstract Object getConnection()

Gets the connection.

Returns:

the connection

getConnection

protected abstract Object getConnection(Object connection)

Gets the connection.

Parameters:

connection - the connection

Returns:

the connection

releaseConnection

protected abstract void releaseConnection(Object conn)

Release connection.

Parameters:

conn - the conn

isTtlPerRequest

public boolean isTtlPerRequest()

Checks if is ttl per request.

Returns:

the ttlPerRequest

setTtlPerRequest

public void setTtlPerRequest(boolean ttlPerRequest)

Sets the ttl per request.

Parameters:

ttlPerRequest - the ttlPerRequest to set

isTtlPerSession

public boolean isTtlPerSession()

Checks if is ttl per session.

Returns:

the ttlPerSession

setTtlPerSession

public void setTtlPerSession(boolean ttlPerSession)

Sets the ttl per session.

Parameters:

ttlPerSession - the ttlPerSession to set

getTtlValues

public Map<String,Object> getTtlValues()

Gets the ttl values.

Returns:

the ttlValues

setTtlValues

public void setTtlValues(Map<String,Object> ttlValues)

Sets the ttl values.

Parameters:

ttlValues - the ttlValues to set

findByRowKeys

public final List findByRowKeys(Class entityClass,
                 List<String> relationNames,
                 boolean isWrapReq,
                 EntityMetadata metadata,
                 Object... rowIds)

Finds a List of entities from database.

Parameters:

entityClass - the entity class

relationNames - the relation names

isWrapReq - the is wrap req

metadata - the metadata

rowIds - the row ids

Returns:

the list

execute

public <T> T execute(String query,
            Object connection)

Execute.

Type Parameters:

T - the generic type

Parameters:

query - the query

connection - the connection

Returns:

the t

persistJoinTableByCql

protected void persistJoinTableByCql(JoinTableData joinTableData,
                         org.apache.cassandra.thrift.Cassandra.Client conn)

Persist join table by cql.

Parameters:

joinTableData - the join table data

conn - the conn

getColumnsByIdUsingCql

protected <E> List<E> getColumnsByIdUsingCql(String schemaName,
                                 String tableName,
                                 String pKeyColumnName,
                                 String columnName,
                                 Object pKeyColumnValue,
                                 Class columnJavaType)

Find inverse join column values for join column.

Type Parameters:

E - the element type

Parameters:

schemaName - the schema name

tableName - the table name

pKeyColumnName - the key column name

columnName - the column name

pKeyColumnValue - the key column value

columnJavaType - the column java type

Returns:

the columns by id using cql

findIdsByColumnUsingCql

protected <E> List<E> findIdsByColumnUsingCql(String schemaName,
                                  String tableName,
                                  String pKeyName,
                                  String columnName,
                                  Object columnValue,
                                  Class entityClazz)

Find join column values for inverse join column.

Type Parameters:

E - the element type

Parameters:

schemaName - the schema name

tableName - the table name

pKeyName - the key name

columnName - the column name

columnValue - the column value

entityClazz - the entity clazz

Returns:

the list

getCqlMetadata

public org.apache.cassandra.thrift.CqlMetadata getCqlMetadata()

Gets the cql metadata.

Returns:

the cql metadata

setCqlMetadata

public void setCqlMetadata(org.apache.cassandra.thrift.CqlMetadata cqlMetadata)

Sets the cql metadata.

Parameters:

cqlMetadata - the new cql metadata