com.impetus.client.cassandra.thrift

Class ThriftClient

java.lang.Object

com.impetus.kundera.client.ClientBase

com.impetus.client.cassandra.CassandraClientBase

com.impetus.client.cassandra.thrift.ThriftClient

All Implemented Interfaces:

Client<CassQuery>, ClientPropertiesSetter, Batcher

public class ThriftClient
extends CassandraClientBase
implements Client<CassQuery>, Batcher

Kundera Client implementation for Cassandra using Thrift library.

Author:

amresh.singh

Nested Class Summary

Nested classes/interfaces inherited from class com.impetus.client.cassandra.CassandraClientBase

CassandraClientBase.CQLClient

Field Summary

Fields inherited from class com.impetus.client.cassandra.CassandraClientBase

consistencyLevel, cqlClient, generator

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

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

Constructor Summary

Constructors

Constructor and Description
ThriftClient(ThriftClientFactory clientFactory, IndexManager indexManager, EntityReader reader, String persistenceUnit, net.dataforte.cassandra.pool.ConnectionPool pool, Map<String,Object> externalProperties, EntityManagerFactoryImpl.KunderaMetadata kunderaMetadata, TimestampGenerator generator) Instantiates a new thrift client.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Close.
void	delete(Object entity, Object pKey) Delete.
void	deleteByColumn(String schemaName, String tableName, String columnName, Object columnValue)
List	executeQuery(Class clazz, List<String> relationalField, boolean isNative, String cqlQuery) Query related methods.
<E> List<E>	find(Class<E> entityClass, Map<String,String> embeddedColumnMap) Finds a List of entities from database for given super columns.
List	find(Class entityClass, List<String> relationNames, boolean isWrapReq, EntityMetadata metadata, Object... rowIds) Finds a List of entities from database.
Object	find(Class entityClass, Object key) Finds an entity from database.
List<EnhanceEntity>	find(EntityMetadata m, List<String> relationNames, List<org.apache.cassandra.thrift.IndexClause> conditions, int maxResult, List<String> columns) Find.
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... keys) Finds a List of entities from database.
List	findByRange(byte[] minVal, byte[] maxVal, EntityMetadata m, boolean isWrapReq, List<String> relations, List<String> columns, List<org.apache.cassandra.thrift.IndexExpression> conditions, int maxResults) Find by range.
List<Object>	findByRelation(String colName, Object colValue, Class entityClazz)
Object[]	findIdsByColumn(String schemaName, String tableName, String pKeyName, String columnName, Object columnValue, Class entityClazz) Retrieves IDs for a given column.
<E> List<E>	getColumnsById(String schemaName, String tableName, String pKeyColumnName, String columnName, Object pKeyColumnValue, Class columnJavaType) Retrieves column for a given primary key.
protected ThriftClientFactory.Connection	getConnection() Gets the connection.
protected org.apache.cassandra.thrift.Cassandra.Client	getConnection(Object connection) Return cassandra client instance.
protected CassandraDataHandler	getDataHandler() Gets the data handler.
Generator	getIdGenerator()
String	getPersistenceUnit()
Class<CassQuery>	getQueryImplementor()
EntityReader	getReader()
protected List<RelationHolder>	getRelationHolders(Node node)
protected void	indexNode(Node node, EntityMetadata entityMetadata) Indexes a Node to database.
protected List<org.apache.cassandra.thrift.SuperColumn>	loadSuperColumns(String keyspace, String columnFamily, String rowId, String... superColumnNames) Loads super columns from database.
protected void	onPersist(EntityMetadata entityMetadata, Object entity, Object id, List<RelationHolder> rlHolders) Persists a Node to database.
void	persist(Node node) Persists and indexes a Node to database.
void	persistJoinTable(JoinTableData joinTableData) Persists a Join table record set into database.
protected void	releaseConnection(Object conn) Release connection.
List<SearchResult>	searchInInvertedIndex(String columnFamilyName, EntityMetadata m, Map<Boolean,List<org.apache.cassandra.thrift.IndexClause>> indexClauseMap) Search in inverted index.

Methods inherited from class com.impetus.client.cassandra.CassandraClientBase

addBatch, addRelationsToThriftRow, clear, computeEntityViaColumns, computeEntityViaSuperColumns, createIndexesOnColumns, createInsertQuery, createUpdateQueryForCounter, deleteRecordFromCounterColumnFamily, execute, executeBatch, executeCQLQuery, executeScalarQuery, executeSelectQuery, executeUpdateDeleteQuery, find, findByRelationQuery, findByRowKeys, findIdsByColumnUsingCql, getBatchSize, getColumnsByIdUsingCql, getConsistencyLevel, getCqlMetadata, getCqlVersion, getExternalProperties, getRawClient, getTtlValues, isCql3Enabled, isCql3Enabled, isOpen, isTtlPerRequest, isTtlPerSession, onColumn, onCounterColumn, onDeleteQuery, onSuperColumn, onWhereClause, persistJoinTableByCql, populateClientProperties, populateEntitiesFromKeySlices, populateFkey, prepareMutation, setConsistencyLevel, setCqlMetadata, setCqlVersion, setTtlPerRequest, setTtlPerSession, setTtlValues

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

executeScript, getClientMetadata, getIndexManager, remove, unIndexNode, useSecondryIndex

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.impetus.kundera.client.Client

executeScript, getIndexManager, remove

Methods inherited from interface com.impetus.kundera.persistence.api.Batcher

addBatch, clear, executeBatch, getBatchSize

Constructor Detail

ThriftClient

public ThriftClient(ThriftClientFactory clientFactory,
            IndexManager indexManager,
            EntityReader reader,
            String persistenceUnit,
            net.dataforte.cassandra.pool.ConnectionPool pool,
            Map<String,Object> externalProperties,
            EntityManagerFactoryImpl.KunderaMetadata kunderaMetadata,
            TimestampGenerator generator)

Instantiates a new thrift client.

Parameters:

clientFactory - the client factory

indexManager - the index manager

reader - the reader

persistenceUnit - the persistence unit

pool - the pool

externalProperties - the external properties

kunderaMetadata - the kundera metadata

generator - the generator

Method Detail

persist

public void persist(Node node)

Persists and indexes a Node to database.

Specified by:

persist in interface Client<CassQuery>

Overrides:

persist in class ClientBase

Parameters:

node - the node

onPersist

protected void onPersist(EntityMetadata entityMetadata,
             Object entity,
             Object id,
             List<RelationHolder> rlHolders)

Persists a Node to database.

Specified by:

onPersist in class ClientBase

Parameters:

entityMetadata - the entity metadata

entity - the entity

id - the id

rlHolders - the rl holders

persistJoinTable

public void persistJoinTable(JoinTableData joinTableData)

Persists a Join table record set into database.

Specified by:

persistJoinTable in interface Client<CassQuery>

Parameters:

joinTableData - the join table data

indexNode

protected void indexNode(Node node,
             EntityMetadata entityMetadata)

Indexes a Node to database.

Overrides:

indexNode in class ClientBase

Parameters:

node - the node

entityMetadata - the entity metadata

find

public Object find(Class entityClass,
          Object key)

Finds an entity from database.

Specified by:

find in interface Client<CassQuery>

Overrides:

find in class CassandraClientBase

Parameters:

entityClass - the entity class

key - the key

Returns:

the object

findAll

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

Finds a List of entities from database.

Specified by:

findAll in interface Client<CassQuery>

Overrides:

findAll in class CassandraClientBase

Type Parameters:

E - the element type

Parameters:

entityClass - the entity class

columnsToSelect - the columns to select

keys - the keys

Returns:

the list

find

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

Finds a List of entities from database.

Specified by:

find in class CassandraClientBase

Parameters:

entityClass - the entity class

relationNames - the relation names

isWrapReq - the is wrap req

metadata - the metadata

rowIds - the row ids

Returns:

the list

find

public <E> List<E> find(Class<E> entityClass,
               Map<String,String> embeddedColumnMap)

Finds a List of entities from database for given super columns.

Specified by:

find in interface Client<CassQuery>

Type Parameters:

E - the element type

Parameters:

entityClass - the entity class

embeddedColumnMap - the embedded column map

Returns:

the list

loadSuperColumns

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

Loads super columns from database.

Specified by:

loadSuperColumns in class CassandraClientBase

Parameters:

keyspace - the keyspace

columnFamily - the column family

rowId - the row id

superColumnNames - the super column names

Returns:

the list

getColumnsById

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

Retrieves column for a given primary key.

Specified by:

getColumnsById in interface Client<CassQuery>

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

findIdsByColumn

public Object[] findIdsByColumn(String schemaName,
                       String tableName,
                       String pKeyName,
                       String columnName,
                       Object columnValue,
                       Class entityClazz)

Retrieves IDs for a given column.

Specified by:

findIdsByColumn in interface Client<CassQuery>

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 object[]

findByRelation

public List<Object> findByRelation(String colName,
                          Object colValue,
                          Class entityClazz)

Specified by:

findByRelation in interface Client<CassQuery>

delete

public void delete(Object entity,
          Object pKey)

Description copied from class: CassandraClientBase

Delete.

Specified by:

delete in class CassandraClientBase

Parameters:

entity - the entity

pKey - the key

deleteByColumn

public void deleteByColumn(String schemaName,
                  String tableName,
                  String columnName,
                  Object columnValue)

Specified by:

deleteByColumn in interface Client<CassQuery>

getReader

public EntityReader getReader()

Specified by:

getReader in interface Client<CassQuery>

getQueryImplementor

public Class<CassQuery> getQueryImplementor()

Specified by:

getQueryImplementor in interface Client<CassQuery>

getPersistenceUnit

public String getPersistenceUnit()

Specified by:

getPersistenceUnit in interface Client<CassQuery>

Overrides:

getPersistenceUnit in class ClientBase

getRelationHolders

protected List<RelationHolder> getRelationHolders(Node node)

Overrides:

getRelationHolders in class ClientBase

close

public void close()

Description copied from class: CassandraClientBase

Close.

Specified by:

close in interface Client<CassQuery>

Overrides:

close in class CassandraClientBase

executeQuery

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

Query related methods.

Specified by:

executeQuery in class CassandraClientBase

Parameters:

clazz - the clazz

relationalField - the relational field

isNative - the is native

cqlQuery - the cql query

Returns:

the list

find

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

Description copied from class: CassandraClientBase

Find.

Specified by:

find in class CassandraClientBase

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

find

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

Description copied from class: CassandraClientBase

Find.

Specified by:

find in class CassandraClientBase

Parameters:

m - the m

relationNames - the relation names

conditions - the conditions

maxResult - the max result

columns - the columns

Returns:

the list

findByRange

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

Description copied from class: CassandraClientBase

Find by range.

Specified by:

findByRange in class CassandraClientBase

Parameters:

minVal - 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 List<SearchResult> searchInInvertedIndex(String columnFamilyName,
                                       EntityMetadata m,
                                       Map<Boolean,List<org.apache.cassandra.thrift.IndexClause>> indexClauseMap)

Description copied from class: CassandraClientBase

Search in inverted index.

Specified by:

searchInInvertedIndex in class CassandraClientBase

Parameters:

columnFamilyName - the column family name

m - the m

indexClauseMap - the index clause map

Returns:

the list

getDataHandler

protected CassandraDataHandler getDataHandler()

Description copied from class: CassandraClientBase

Gets the data handler.

Specified by:

getDataHandler in class CassandraClientBase

Returns:

the data handler

getConnection

protected ThriftClientFactory.Connection getConnection()

Description copied from class: CassandraClientBase

Gets the connection.

Specified by:

getConnection in class CassandraClientBase

Returns:

the connection

getConnection

protected org.apache.cassandra.thrift.Cassandra.Client getConnection(Object connection)

Return cassandra client instance.

Specified by:

getConnection in class CassandraClientBase

Parameters:

connection - the connection

Returns:

the connection

releaseConnection

protected void releaseConnection(Object conn)

Description copied from class: CassandraClientBase

Release connection.

Specified by:

releaseConnection in class CassandraClientBase

Parameters:

conn - the conn

getIdGenerator

public Generator getIdGenerator()

Specified by:

getIdGenerator in interface Client<CassQuery>