public abstract class AbstractCassandraQuery extends Object implements RepositoryQuery
RepositoryQuery
implementations for Cassandra.Modifier and Type | Field and Description |
---|---|
protected static Converter<?,?>[] |
DEFAULT_CONVERTERS |
protected static org.slf4j.Logger |
log |
protected RowToMapConverter |
rowToMapConverter |
Constructor and Description |
---|
AbstractCassandraQuery(CassandraQueryMethod method,
CassandraOperations operations)
|
Modifier and Type | Method and Description |
---|---|
protected ConfigurableConversionService |
createDefaultConversionService() |
protected abstract String |
createQuery(CassandraParameterAccessor accessor)
Creates a string query using the given
ParameterAccessor |
Object |
execute(Object[] parameters) |
Object |
getCollectionOfEntity(com.datastax.driver.core.ResultSet resultSet,
Class<?> declaredReturnType,
Class<?> returnedUnwrappedObjectType) |
ConversionService |
getConversionService() |
CassandraQueryMethod |
getQueryMethod() |
Object |
getSingleEntity(com.datastax.driver.core.ResultSet resultSet,
Class<?> type) |
void |
setConversionService(ConversionService conversionService) |
protected void |
warnIfMoreResults(Iterator<com.datastax.driver.core.Row> iterator) |
protected static final Converter<?,?>[] DEFAULT_CONVERTERS
protected static org.slf4j.Logger log
protected RowToMapConverter rowToMapConverter
public AbstractCassandraQuery(CassandraQueryMethod method, CassandraOperations operations)
method
- must not be null.template
- must not be null.protected ConfigurableConversionService createDefaultConversionService()
public CassandraQueryMethod getQueryMethod()
getQueryMethod
in interface RepositoryQuery
public Object execute(Object[] parameters)
execute
in interface RepositoryQuery
public Object getCollectionOfEntity(com.datastax.driver.core.ResultSet resultSet, Class<?> declaredReturnType, Class<?> returnedUnwrappedObjectType)
public Object getSingleEntity(com.datastax.driver.core.ResultSet resultSet, Class<?> type)
protected void warnIfMoreResults(Iterator<com.datastax.driver.core.Row> iterator)
public ConversionService getConversionService()
public void setConversionService(ConversionService conversionService)
protected abstract String createQuery(CassandraParameterAccessor accessor)
ParameterAccessor
accessor
- must not be null.Copyright © 2011-2015–2016 Pivotal Software, Inc.. All rights reserved.