com.impetus.client.cassandra.query

Class CassQuery

java.lang.Object

com.impetus.kundera.query.QueryImpl

com.impetus.client.cassandra.query.CassQuery

All Implemented Interfaces:

Query

public class CassQuery
extends QueryImpl

The Class CassQuery.

Author:

vivek.mishra Query implementation for Cassandra.

Field Summary

Fields inherited from class com.impetus.kundera.query.QueryImpl

firstResult, isSingleResult, kunderaMetadata, kunderaQuery, maxResult, persistenceDelegeator, ttl

Constructor Summary

Constructors

Constructor and Description
CassQuery(KunderaQuery kunderaQuery, PersistenceDelegator persistenceDelegator, EntityManagerFactoryImpl.KunderaMetadata kunderaMetadata) Instantiates a new cass query.

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
String	createDeleteQuery(KunderaQuery kunderaQuery) Create Delete query from a given JPA query.
String	createUpdateQuery(KunderaQuery kunderaQuery) Create Update CQL query from a given JPA query.
protected List	findUsingLucene(EntityMetadata m, Client client)
protected EntityReader	getReader()
Iterator	iterate()
protected int	onExecuteUpdate() On executeUpdate.
protected List<Object>	populateEntities(EntityMetadata m, Client client)
protected List<Object>	recursivelyPopulateEntities(EntityMetadata m, Client client) (non-Javadoc).

Methods inherited from class com.impetus.kundera.query.QueryImpl

addToRelationStack, applyTTL, executeUpdate, fetch, getColumns, getEntityMetadata, getFetchSize, getFirstResult, getFlushMode, getHints, getJPAQuery, getKunderaQuery, getLockMode, getMaxResults, getParameter, getParameter, getParameter, getParameter, getParameters, getParameterValue, getParameterValue, getParameterValue, getResultList, getSingleResult, handlePostEvent, isBound, onDeleteOrUpdate, onReturnResults, onUpdateDeleteEvent, onValidateSingleResult, populateUsingLucene, setFetchSize, setFirstResult, setFlushMode, setHint, setLockMode, setMaxResults, setParameter, setParameter, setParameter, setParameter, setParameter, setParameter, setParameter, setParameter, setParameter, setRelationEntities, unwrap

Methods inherited from class java.lang.Object

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

Constructor Detail

CassQuery

public CassQuery(KunderaQuery kunderaQuery,
         PersistenceDelegator persistenceDelegator,
         EntityManagerFactoryImpl.KunderaMetadata kunderaMetadata)

Instantiates a new cass query.

Parameters:

kunderaQuery - the kundera query

persistenceDelegator - the persistence delegator

kunderaMetadata - the kundera metadata

Method Detail

populateEntities

protected List<Object> populateEntities(EntityMetadata m,
                            Client client)

Specified by:

populateEntities in class QueryImpl

findUsingLucene

protected List findUsingLucene(EntityMetadata m,
                   Client client)

Specified by:

findUsingLucene in class QueryImpl

recursivelyPopulateEntities

protected List<Object> recursivelyPopulateEntities(EntityMetadata m,
                                       Client client)

(non-Javadoc).

Specified by:

recursivelyPopulateEntities in class QueryImpl

Parameters:

m - the m

client - the client

Returns:

the list

See Also:

com.impetus.kundera.query.QueryImpl#recursivelyPopulateEntities(com.impetus .kundera.metadata.model.EntityMetadata, com.impetus.kundera.client.Client)

onExecuteUpdate

protected int onExecuteUpdate()

On executeUpdate.

Specified by:

onExecuteUpdate in class QueryImpl

Returns:

zero

getReader

protected EntityReader getReader()

Specified by:

getReader in class QueryImpl

close

public void close()

Specified by:

close in interface Query

Specified by:

close in class QueryImpl

iterate

public Iterator iterate()

Specified by:

iterate in interface Query

Specified by:

iterate in class QueryImpl

createUpdateQuery

public String createUpdateQuery(KunderaQuery kunderaQuery)

Create Update CQL query from a given JPA query.

Parameters:

kunderaQuery - the kundera query

Returns:

the string

createDeleteQuery

public String createDeleteQuery(KunderaQuery kunderaQuery)

Create Delete query from a given JPA query.

Parameters:

kunderaQuery - the kundera query

Returns:

the string