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,
SpelExpressionParser expressionParser,
QueryMethodEvaluationContextProvider evaluationContextProvider)
Create a new
ReactiveStringBasedCassandraQuery for the given CassandraQueryMethod ,
ReactiveCassandraOperations , SpelExpressionParser ,
and QueryMethodEvaluationContextProvider . |
ReactiveStringBasedCassandraQuery(String query,
ReactiveCassandraQueryMethod method,
ReactiveCassandraOperations operations,
SpelExpressionParser expressionParser,
QueryMethodEvaluationContextProvider evaluationContextProvider)
Create a new
ReactiveStringBasedCassandraQuery for the given query , CassandraQueryMethod ,
ReactiveCassandraOperations , SpelExpressionParser ,
and QueryMethodEvaluationContextProvider . |
Modifier and Type | Method and Description |
---|---|
com.datastax.driver.core.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.
|
execute, getQueryMethod, getReactiveCassandraOperations
getEntityInstantiators, getQueryStatementCreator
public ReactiveStringBasedCassandraQuery(ReactiveCassandraQueryMethod queryMethod, ReactiveCassandraOperations operations, SpelExpressionParser expressionParser, QueryMethodEvaluationContextProvider 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, SpelExpressionParser expressionParser, QueryMethodEvaluationContextProvider 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 com.datastax.driver.core.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
Copyright © 2011–2018 Pivotal Software, Inc.. All rights reserved.