Package org.springframework.data.cassandra.repository.query

Class ReactiveStringBasedCassandraQuery

java.lang.Object

org.springframework.data.cassandra.repository.query.CassandraRepositoryQuerySupport

org.springframework.data.cassandra.repository.query.AbstractReactiveCassandraQuery

org.springframework.data.cassandra.repository.query.ReactiveStringBasedCassandraQuery

All Implemented Interfaces:

org.springframework.data.repository.query.RepositoryQuery

public class ReactiveStringBasedCassandraQuery
extends AbstractReactiveCassandraQuery

String-based 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.

Since:

2.0

Author:

Mark Paluch

See Also:

• Query
• AbstractReactiveCassandraQuery

Field Summary

Fields inherited from class org.springframework.data.cassandra.repository.query.CassandraRepositoryQuerySupport

log

Constructor Summary

Constructors

Constructor	Description
ReactiveStringBasedCassandraQuery(String query, ReactiveCassandraQueryMethod method, ReactiveCassandraOperations operations, ExpressionParser expressionParser, org.springframework.data.repository.query.ReactiveQueryMethodEvaluationContextProvider evaluationContextProvider)	Create a new ReactiveStringBasedCassandraQuery for the given query, CassandraQueryMethod, ReactiveCassandraOperations, SpelExpressionParser, and QueryMethodEvaluationContextProvider.
ReactiveStringBasedCassandraQuery(ReactiveCassandraQueryMethod queryMethod, ReactiveCassandraOperations operations, ExpressionParser expressionParser, org.springframework.data.repository.query.ReactiveQueryMethodEvaluationContextProvider evaluationContextProvider)	Create a new ReactiveStringBasedCassandraQuery for the given CassandraQueryMethod, ReactiveCassandraOperations, SpelExpressionParser, and QueryMethodEvaluationContextProvider.

Method Summary

Modifier and Type	Method	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.

Methods inherited from class org.springframework.data.cassandra.repository.query.AbstractReactiveCassandraQuery

execute, getQueryMethod, getReactiveCassandraOperations

Methods inherited from class org.springframework.data.cassandra.repository.query.CassandraRepositoryQuerySupport

getEntityInstantiators, getMappingContext, getQueryStatementCreator

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ReactiveStringBasedCassandraQuery

public ReactiveStringBasedCassandraQuery(ReactiveCassandraQueryMethod queryMethod,
 ReactiveCassandraOperations operations,
 ExpressionParser expressionParser,
 org.springframework.data.repository.query.ReactiveQueryMethodEvaluationContextProvider evaluationContextProvider)

Create a new ReactiveStringBasedCassandraQuery for the given CassandraQueryMethod, ReactiveCassandraOperations, SpelExpressionParser, and QueryMethodEvaluationContextProvider.

Parameters:

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.

See Also:

• ReactiveCassandraQueryMethod
• ReactiveCassandraOperations

ReactiveStringBasedCassandraQuery

public ReactiveStringBasedCassandraQuery(String query,
 ReactiveCassandraQueryMethod method,
 ReactiveCassandraOperations operations,
 ExpressionParser expressionParser,
 org.springframework.data.repository.query.ReactiveQueryMethodEvaluationContextProvider evaluationContextProvider)

Create a new ReactiveStringBasedCassandraQuery for the given query, CassandraQueryMethod, ReactiveCassandraOperations, SpelExpressionParser, and QueryMethodEvaluationContextProvider.

Parameters:

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.

See Also:

• ReactiveCassandraQueryMethod
• ReactiveCassandraOperations

Method Details

getStringBasedQuery

protected org.springframework.data.cassandra.repository.query.StringBasedQuery getStringBasedQuery()

createQuery

public reactor.core.publisher.Mono<com.datastax.oss.driver.api.core.cql.SimpleStatement> createQuery(CassandraParameterAccessor parameterAccessor)

Description copied from class: AbstractReactiveCassandraQuery

Creates a string query using the given ParameterAccessor

Specified by:

createQuery in class AbstractReactiveCassandraQuery

Parameters:

parameterAccessor - must not be null.

isCountQuery

protected boolean isCountQuery()

Description copied from class: AbstractReactiveCassandraQuery

Returns whether the query should get a count projection applied.

Specified by:

isCountQuery in class AbstractReactiveCassandraQuery

Returns:

a boolean value indicating whether the query is a count projection.

isExistsQuery

protected boolean isExistsQuery()

Description copied from class: AbstractReactiveCassandraQuery

Returns whether the query should get an exists projection applied.

Specified by:

isExistsQuery in class AbstractReactiveCassandraQuery

Returns:

a boolean value indicating whether the query is an exists projection.

isLimiting

protected boolean isLimiting()

Description copied from class: AbstractReactiveCassandraQuery

Return whether the query has an explicit limit set.

Specified by:

isLimiting in class AbstractReactiveCassandraQuery

Returns:

a boolean value indicating whether the query has an explicit limit set.

isModifyingQuery

protected boolean isModifyingQuery()

Description copied from class: AbstractReactiveCassandraQuery

Returns whether the query is a modifying query.

Specified by:

isModifyingQuery in class AbstractReactiveCassandraQuery

Returns:

a boolean value indicating whether the query is a modifying query.