public abstract class AbstractReactiveCassandraQuery extends Object implements RepositoryQuery
RepositoryQuery
implementations for Cassandra.Constructor and Description |
---|
AbstractReactiveCassandraQuery(ReactiveCassandraQueryMethod method,
ReactiveCassandraOperations operations)
Create a new
AbstractReactiveCassandraQuery from the given CassandraQueryMethod and
CassandraOperations . |
Modifier and Type | Method and Description |
---|---|
protected abstract com.datastax.driver.core.Statement |
createQuery(CassandraParameterAccessor accessor)
Creates a string query using the given
ParameterAccessor |
Object |
execute(Object[] parameters) |
protected EntityInstantiators |
getEntityInstantiators() |
ReactiveCassandraQueryMethod |
getQueryMethod() |
protected ReactiveCassandraOperations |
getReactiveCassandraOperations() |
public AbstractReactiveCassandraQuery(ReactiveCassandraQueryMethod method, ReactiveCassandraOperations operations)
AbstractReactiveCassandraQuery
from the given CassandraQueryMethod
and
CassandraOperations
.method
- must not be null.operations
- must not be null.protected EntityInstantiators getEntityInstantiators()
public ReactiveCassandraQueryMethod getQueryMethod()
getQueryMethod
in interface RepositoryQuery
protected ReactiveCassandraOperations getReactiveCassandraOperations()
public Object execute(Object[] parameters)
execute
in interface RepositoryQuery
protected abstract com.datastax.driver.core.Statement createQuery(CassandraParameterAccessor accessor)
ParameterAccessor
accessor
- must not be null.Copyright © 2011–2017 Pivotal Software, Inc.. All rights reserved.