public class ReactiveStringBasedCassandraQuery extends AbstractReactiveCassandraQuery
AbstractReactiveCassandraQuery
implementation.
A ReactiveStringBasedCassandraQuery
expects a query method to be annotated with
Query
with a CQL query. String-based queries support named,
index-based and expression parameters that are resolved during query execution.
Query
,
AbstractReactiveCassandraQuery
log
Constructor and Description |
---|
ReactiveStringBasedCassandraQuery(ReactiveCassandraQueryMethod queryMethod,
ReactiveCassandraOperations operations,
ExpressionParser expressionParser,
ReactiveQueryMethodEvaluationContextProvider evaluationContextProvider)
Create a new
ReactiveStringBasedCassandraQuery for the given CassandraQueryMethod ,
ReactiveCassandraOperations , SpelExpressionParser , and
QueryMethodEvaluationContextProvider . |
ReactiveStringBasedCassandraQuery(String query,
ReactiveCassandraQueryMethod method,
ReactiveCassandraOperations operations,
ExpressionParser expressionParser,
ReactiveQueryMethodEvaluationContextProvider evaluationContextProvider)
Create a new
ReactiveStringBasedCassandraQuery for the given query , CassandraQueryMethod ,
ReactiveCassandraOperations , SpelExpressionParser , and
QueryMethodEvaluationContextProvider . |
Modifier and Type | Method and Description |
---|---|
reactor.core.publisher.Mono<com.datastax.oss.driver.api.core.cql.SimpleStatement> |
createQuery(CassandraParameterAccessor parameterAccessor)
Creates a string query using the given
ParameterAccessor |
protected org.springframework.data.cassandra.repository.query.StringBasedQuery |
getStringBasedQuery() |
protected boolean |
isCountQuery()
Returns whether the query should get a count projection applied.
|
protected boolean |
isExistsQuery()
Returns whether the query should get an exists projection applied.
|
protected boolean |
isLimiting()
Return whether the query has an explicit limit set.
|
protected boolean |
isModifyingQuery()
Returns whether the query is a modifying query.
|
execute, getQueryMethod, getReactiveCassandraOperations
getEntityInstantiators, getQueryStatementCreator
public ReactiveStringBasedCassandraQuery(ReactiveCassandraQueryMethod queryMethod, ReactiveCassandraOperations operations, ExpressionParser expressionParser, ReactiveQueryMethodEvaluationContextProvider evaluationContextProvider)
ReactiveStringBasedCassandraQuery
for the given CassandraQueryMethod
,
ReactiveCassandraOperations
, SpelExpressionParser
, and
QueryMethodEvaluationContextProvider
.queryMethod
- ReactiveCassandraQueryMethod
on which this query is based.operations
- ReactiveCassandraOperations
used to perform data access in Cassandra.expressionParser
- SpelExpressionParser
used to parse expressions in the query.evaluationContextProvider
- QueryMethodEvaluationContextProvider
used to access the potentially shared
StandardEvaluationContext
.ReactiveCassandraQueryMethod
,
ReactiveCassandraOperations
public ReactiveStringBasedCassandraQuery(String query, ReactiveCassandraQueryMethod method, ReactiveCassandraOperations operations, ExpressionParser expressionParser, ReactiveQueryMethodEvaluationContextProvider evaluationContextProvider)
ReactiveStringBasedCassandraQuery
for the given query
, CassandraQueryMethod
,
ReactiveCassandraOperations
, SpelExpressionParser
, and
QueryMethodEvaluationContextProvider
.method
- ReactiveCassandraQueryMethod
on which this query is based.operations
- ReactiveCassandraOperations
used to perform data access in Cassandra.expressionParser
- SpelExpressionParser
used to parse expressions in the query.evaluationContextProvider
- QueryMethodEvaluationContextProvider
used to access the potentially shared
StandardEvaluationContext
.ReactiveCassandraQueryMethod
,
ReactiveCassandraOperations
protected org.springframework.data.cassandra.repository.query.StringBasedQuery getStringBasedQuery()
public reactor.core.publisher.Mono<com.datastax.oss.driver.api.core.cql.SimpleStatement> createQuery(CassandraParameterAccessor parameterAccessor)
AbstractReactiveCassandraQuery
ParameterAccessor
createQuery
in class AbstractReactiveCassandraQuery
parameterAccessor
- must not be null.protected boolean isCountQuery()
AbstractReactiveCassandraQuery
isCountQuery
in class AbstractReactiveCassandraQuery
protected boolean isExistsQuery()
AbstractReactiveCassandraQuery
isExistsQuery
in class AbstractReactiveCassandraQuery
protected boolean isLimiting()
AbstractReactiveCassandraQuery
isLimiting
in class AbstractReactiveCassandraQuery
protected boolean isModifyingQuery()
AbstractReactiveCassandraQuery
isModifyingQuery
in class AbstractReactiveCassandraQuery
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.