com.impetus.client.cassandra

Class CassandraClientBase.CQLClient

java.lang.Object

com.impetus.client.cassandra.CassandraClientBase.CQLClient

Enclosing class:

CassandraClientBase

protected class CassandraClientBase.CQLClient
extends Object

Use CqlClient class for crud when cql enable.

Author:

Kuldeep Mishra

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	CassandraClientBase.CQLClient()

Method Summary

Methods

Modifier and Type	Method and Description
List	executeQuery(Class clazz, List<String> relationalField, CassandraDataHandler dataHandler, boolean isCql3Enabled, boolean isNative, String cqlQuery) Execute query and Return list of Objects.
List<Object>	find(MetamodelImpl metaModel, EntityMetadata metadata, Object rowId, List<String> relationNames) Finds entity on the basis of rowid and return list of objects.
protected List<Object>	findByRelationQuery(EntityMetadata m, String columnName, Object columnValue, Class clazz, CassandraDataHandler dataHandler) Find List of objects based on value of column .
void	persist(EntityMetadata entityMetadata, Object entity, org.apache.cassandra.thrift.Cassandra.Client conn, List<RelationHolder> rlHolders, Object ttlColumns) Persist.

Methods inherited from class java.lang.Object

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

Constructor Detail

CassandraClientBase.CQLClient

protected CassandraClientBase.CQLClient()

Method Detail

persist

public void persist(EntityMetadata entityMetadata,
           Object entity,
           org.apache.cassandra.thrift.Cassandra.Client conn,
           List<RelationHolder> rlHolders,
           Object ttlColumns)
             throws UnsupportedEncodingException,
                    org.apache.cassandra.thrift.InvalidRequestException,
                    org.apache.thrift.TException,
                    org.apache.cassandra.thrift.UnavailableException,
                    org.apache.cassandra.thrift.TimedOutException,
                    org.apache.cassandra.thrift.SchemaDisagreementException

Persist.

Parameters:

entityMetadata - the entity metadata

entity - the entity

conn - the conn

rlHolders - the rl holders

ttlColumns - the ttl columns

Throws:

UnsupportedEncodingException - the unsupported encoding exception

org.apache.cassandra.thrift.InvalidRequestException - the invalid request exception

org.apache.thrift.TException - the t exception

org.apache.cassandra.thrift.UnavailableException - the unavailable exception

org.apache.cassandra.thrift.TimedOutException - the timed out exception

org.apache.cassandra.thrift.SchemaDisagreementException - the schema disagreement exception

executeQuery

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

Execute query and Return list of Objects.

Parameters:

clazz - the clazz

relationalField - the relational field

dataHandler - the data handler

isCql3Enabled - the is cql3 enabled

isNative - the is native

cqlQuery - the cql query

Returns:

the list

find

public List<Object> find(MetamodelImpl metaModel,
                EntityMetadata metadata,
                Object rowId,
                List<String> relationNames)

Finds entity on the basis of rowid and return list of objects.

Parameters:

metaModel - the meta model

metadata - the metadata

rowId - the row id

relationNames - the relation names

Returns:

the list

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