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

Class ReactivePartTreeCassandraQuery

java.lang.Object

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

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

org.springframework.data.cassandra.repository.query.ReactivePartTreeCassandraQuery

All Implemented Interfaces:

RepositoryQuery

public class ReactivePartTreeCassandraQuery
extends AbstractReactiveCassandraQuery

Reactive PartTree RepositoryQuery implementation for Cassandra.

Since:

2.0

Author:

Mark Paluch

See Also:

• AbstractReactiveCassandraQuery

Field Summary

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

log

Constructor Summary

Constructors

Constructor	Description
ReactivePartTreeCassandraQuery(ReactiveCassandraQueryMethod queryMethod, ReactiveCassandraOperations operations)	Create a new ReactivePartTreeCassandraQuery from the given ReactiveCassandraQueryMethod and ReactiveCassandraOperations.

Method Summary

Modifier and Type	Method	Description
protected reactor.core.publisher.Mono<com.datastax.oss.driver.api.core.cql.SimpleStatement>	createQuery(CassandraParameterAccessor parameterAccessor)	Creates a string query using the given ParameterAccessor
protected MappingContext<? extends CassandraPersistentEntity<?>,CassandraPersistentProperty>	getMappingContext()	Returns the MappingContext used by this query to access mapping meta-data used to store (map) objects to Cassandra tables.
protected StatementFactory	getStatementFactory()	Returns the StatementFactory used by this query to construct and run Cassandra CQL statements.
protected PartTree	getTree()	Return the PartTree backing the query.
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, getQueryStatementCreator

Methods inherited from class java.lang.Object

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

Constructor Details

ReactivePartTreeCassandraQuery

public ReactivePartTreeCassandraQuery(ReactiveCassandraQueryMethod queryMethod,
 ReactiveCassandraOperations operations)

Create a new ReactivePartTreeCassandraQuery from the given ReactiveCassandraQueryMethod and ReactiveCassandraOperations.

Parameters:

queryMethod - must not be null.

operations - must not be null.

Method Details

getMappingContext

protected MappingContext<? extends CassandraPersistentEntity<?>,CassandraPersistentProperty> getMappingContext()

Returns the MappingContext used by this query to access mapping meta-data used to store (map) objects to Cassandra tables.

Overrides:

getMappingContext in class CassandraRepositoryQuerySupport

Returns:

the MappingContext used by this query.

See Also:

• CassandraMappingContext

getStatementFactory

protected StatementFactory getStatementFactory()

Returns the StatementFactory used by this query to construct and run Cassandra CQL statements.

Returns:

the StatementFactory used by this query to construct and run Cassandra CQL statements.

See Also:

• StatementFactory

getTree

protected PartTree getTree()

Return the PartTree backing the query.

Returns:

the tree

createQuery

protected 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.