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

Class AbstractReactiveCassandraQuery

java.lang.Object

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

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

All Implemented Interfaces:

org.springframework.data.repository.query.RepositoryQuery

Direct Known Subclasses:

ReactivePartTreeCassandraQuery, ReactiveStringBasedCassandraQuery

public abstract class AbstractReactiveCassandraQuery
extends CassandraRepositoryQuerySupport

Base class for reactive RepositoryQuery implementations for Cassandra.

Since:

2.0

Author:

Mark Paluch, Hleb Albau

See Also:

• CassandraRepositoryQuerySupport

Field Summary

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

log

Constructor Summary

Constructors

Constructor	Description
AbstractReactiveCassandraQuery(ReactiveCassandraQueryMethod method, ReactiveCassandraOperations operations)	Create a new AbstractReactiveCassandraQuery from the given CassandraQueryMethod and CassandraOperations.

Method Summary

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

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

AbstractReactiveCassandraQuery

public AbstractReactiveCassandraQuery(ReactiveCassandraQueryMethod method,
 ReactiveCassandraOperations operations)

Create a new AbstractReactiveCassandraQuery from the given CassandraQueryMethod and CassandraOperations.

Parameters:

method - must not be null.

operations - must not be null.

Method Details

getQueryMethod

public ReactiveCassandraQueryMethod getQueryMethod()

Specified by:

getQueryMethod in interface org.springframework.data.repository.query.RepositoryQuery

Overrides:

getQueryMethod in class CassandraRepositoryQuerySupport

execute

public Object execute(Object[] parameters)

createQuery

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

Parameters:

accessor - must not be null.

getReactiveCassandraOperations

protected ReactiveCassandraOperations getReactiveCassandraOperations()

isCountQuery

protected abstract boolean isCountQuery()

Returns whether the query should get a count projection applied.

Returns:

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

Since:

2.1

isExistsQuery

protected abstract boolean isExistsQuery()

Returns whether the query should get an exists projection applied.

Returns:

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

Since:

2.1

isLimiting

protected abstract boolean isLimiting()

Return whether the query has an explicit limit set.

Returns:

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

Since:

2.0.4

isModifyingQuery

protected abstract boolean isModifyingQuery()

Returns whether the query is a modifying query.

Returns:

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

Since:

2.2