com.impetus.kundera.client.cassandra.dsdriver

Class DSClient

java.lang.Object

com.impetus.kundera.client.ClientBase

com.impetus.client.cassandra.CassandraClientBase

com.impetus.kundera.client.cassandra.dsdriver.DSClient

All Implemented Interfaces:

Client<CassQuery>, ClientPropertiesSetter, Batcher

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

Kundera powered datastax java driver based client.

Author:

vivek.mishra

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
DSClient(DSClientFactory factory, String persistenceUnit, Map<String,Object> externalProperties, EntityManagerFactoryImpl.KunderaMetadata kunderaMetadata, EntityReader reader, TimestampGenerator generator) Instantiates a new DS client.

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	delete(Object entity, Object pKey)
void	deleteByColumn(String schemaName, String tableName, String columnName, Object columnValue)
<T> T	execute(String query, Object connection)
List	executeQuery(Class clazz, List<String> relationalField, boolean isNative, String cqlQuery)
int	executeUpdateDeleteQuery(String cqlQuery)
<E> List<E>	find(Class<E> entityClass, Map<String,String> embeddedColumnMap)
List	find(Class entityClass, List<String> relationNames, boolean isWrapReq, EntityMetadata metadata, Object... rowIds)
Object	find(Class entityClass, Object rowId) 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)
List	find(List<org.apache.cassandra.thrift.IndexClause> ixClause, EntityMetadata m, boolean isRelation, List<String> relations, int maxResult, List<String> columns)
<E> List<E>	findAll(Class<E> entityClass, String[] columnsToSelect, Object... rowIds)
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)
List<Object>	findByRelation(String colName, Object colValue, Class entityClazz)
Object[]	findIdsByColumn(String schemaName, String tableName, String pKeyName, String columnName, Object columnValue, Class entityClazz)
<E> List<E>	getColumnsById(String schemaName, String tableName, String pKeyColumnName, String columnName, Object pKeyColumnValue, Class columnJavaType)
protected Object	getConnection()
protected Object	getConnection(Object connection)
protected CassandraDataHandler	getDataHandler()
Generator	getIdGenerator()
String	getPersistenceUnit()
Class<CassQuery>	getQueryImplementor()
EntityReader	getReader()
protected List<org.apache.cassandra.thrift.SuperColumn>	loadSuperColumns(String keyspace, String columnFamily, String rowId, String... superColumnNames)
protected void	onPersist(EntityMetadata entityMetadata, Object entity, Object id, List<RelationHolder> rlHolders)
void	persistJoinTable(JoinTableData joinTableData)
protected void	releaseConnection(Object conn)
List<SearchResult>	searchInInvertedIndex(String columnFamilyName, EntityMetadata m, Map<Boolean,List<org.apache.cassandra.thrift.IndexClause>> indexClauseMap)

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

addBatch, addRelationsToThriftRow, clear, computeEntityViaColumns, computeEntityViaSuperColumns, createIndexesOnColumns, createInsertQuery, createUpdateQueryForCounter, deleteRecordFromCounterColumnFamily, executeBatch, executeCQLQuery, executeScalarQuery, executeSelectQuery, find, findByRelationQuery, findByRowKeys, findIdsByColumnUsingCql, getBatchSize, getColumnsByIdUsingCql, getConsistencyLevel, getCqlMetadata, getCqlVersion, getExternalProperties, getPersistQueries, 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, getAutoGenerator, getClientMetadata, getIndexManager, getRelationHolders, indexNode, persist, 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, persist, remove

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

addBatch, clear, executeBatch, getBatchSize

Constructor Detail

DSClient

public DSClient(DSClientFactory factory,
        String persistenceUnit,
        Map<String,Object> externalProperties,
        EntityManagerFactoryImpl.KunderaMetadata kunderaMetadata,
        EntityReader reader,
        TimestampGenerator generator)

Instantiates a new DS client.

Parameters:

factory - the factory

persistenceUnit - the persistence unit

externalProperties - the external properties

kunderaMetadata - the kundera metadata

reader - the reader

generator - the generator

Method Detail

onPersist

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

Specified by:

onPersist in class ClientBase

find

public Object find(Class entityClass,
          Object rowId)

Finds an entity from database.

Specified by:

find in interface Client<CassQuery>

Overrides:

find in class CassandraClientBase

Parameters:

entityClass - the entity class

rowId - the row id

Returns:

the object

findAll

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

Specified by:

findAll in interface Client<CassQuery>

Overrides:

findAll in class CassandraClientBase

find

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

Specified by:

find in interface Client<CassQuery>

persistJoinTable

public void persistJoinTable(JoinTableData joinTableData)

Specified by:

persistJoinTable in interface Client<CassQuery>

getColumnsById

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

Specified by:

getColumnsById in interface Client<CassQuery>

findIdsByColumn

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

Specified by:

findIdsByColumn in interface Client<CassQuery>

deleteByColumn

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

Specified by:

deleteByColumn in interface Client<CassQuery>

findByRelation

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

Specified by:

findByRelation 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>

find

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

Specified by:

find in class CassandraClientBase

loadSuperColumns

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

Specified by:

loadSuperColumns in class CassandraClientBase

executeQuery

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

Specified by:

executeQuery in class CassandraClientBase

find

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

Specified by:

find in class CassandraClientBase

findByRange

public 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

Specified by:

findByRange in class CassandraClientBase

Throws:

Exception

searchInInvertedIndex

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

Specified by:

searchInInvertedIndex in class CassandraClientBase

find

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

Specified by:

find in class CassandraClientBase

getDataHandler

protected CassandraDataHandler getDataHandler()

Specified by:

getDataHandler in class CassandraClientBase

delete

public void delete(Object entity,
          Object pKey)

Specified by:

delete in class CassandraClientBase

getConnection

protected Object getConnection()

Specified by:

getConnection in class CassandraClientBase

getConnection

protected Object getConnection(Object connection)

Specified by:

getConnection in class CassandraClientBase

releaseConnection

protected void releaseConnection(Object conn)

Specified by:

releaseConnection in class CassandraClientBase

execute

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

Overrides:

execute in class CassandraClientBase

executeUpdateDeleteQuery

public int executeUpdateDeleteQuery(String cqlQuery)

Overrides:

executeUpdateDeleteQuery in class CassandraClientBase

close

public void close()

Specified by:

close in interface Client<CassQuery>

Overrides:

close in class CassandraClientBase

getPersistenceUnit

public String getPersistenceUnit()

Specified by:

getPersistenceUnit in interface Client<CassQuery>

Overrides:

getPersistenceUnit in class ClientBase

getIdGenerator

public Generator getIdGenerator()

Specified by:

getIdGenerator in interface Client<CassQuery>