public abstract class AbstractReactiveCassandraQuery extends CassandraRepositoryQuerySupport
RepositoryQuery
implementations for Cassandra.CassandraRepositoryQuerySupport
log
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 reactor.core.publisher.Mono<com.datastax.oss.driver.api.core.cql.SimpleStatement> |
createQuery(CassandraParameterAccessor accessor)
Creates a string query using the given
ParameterAccessor |
Object |
execute(Object[] parameters) |
ReactiveCassandraQueryMethod |
getQueryMethod() |
protected ReactiveCassandraOperations |
getReactiveCassandraOperations() |
protected abstract boolean |
isCountQuery()
Returns whether the query should get a count projection applied.
|
protected abstract boolean |
isExistsQuery()
Returns whether the query should get an exists projection applied.
|
protected abstract boolean |
isLimiting()
Return whether the query has an explicit limit set.
|
protected abstract boolean |
isModifyingQuery()
Returns whether the query is a modifying query.
|
getEntityInstantiators, getQueryStatementCreator
public AbstractReactiveCassandraQuery(ReactiveCassandraQueryMethod method, ReactiveCassandraOperations operations)
AbstractReactiveCassandraQuery
from the given CassandraQueryMethod
and
CassandraOperations
.method
- must not be null.operations
- must not be null.public ReactiveCassandraQueryMethod getQueryMethod()
getQueryMethod
in interface RepositoryQuery
getQueryMethod
in class CassandraRepositoryQuerySupport
protected abstract reactor.core.publisher.Mono<com.datastax.oss.driver.api.core.cql.SimpleStatement> createQuery(CassandraParameterAccessor accessor)
ParameterAccessor
accessor
- must not be null.protected ReactiveCassandraOperations getReactiveCassandraOperations()
protected abstract boolean isCountQuery()
protected abstract boolean isExistsQuery()
protected abstract boolean isLimiting()
protected abstract boolean isModifyingQuery()
Copyright © 2011–2022 Pivotal Software, Inc.. All rights reserved.