Package org.springframework.data.mongodb.repository.query

Class ReactiveStringBasedAggregation

java.lang.Object

org.springframework.data.mongodb.repository.query.AbstractReactiveMongoQuery

org.springframework.data.mongodb.repository.query.ReactiveStringBasedAggregation

All Implemented Interfaces:

RepositoryQuery

public class ReactiveStringBasedAggregation
extends AbstractReactiveMongoQuery

A reactive RepositoryQuery to use a plain JSON String to create an aggregation pipeline to actually execute.

Since:

2.2

Author:

Christoph Strobl, Mark Paluch

Constructor Summary

Constructors

Constructor	Description
ReactiveStringBasedAggregation(ReactiveMongoQueryMethod method, ReactiveMongoOperations reactiveMongoOperations, ExpressionParser expressionParser, ReactiveQueryMethodEvaluationContextProvider evaluationContextProvider)

Method Summary

Modifier and Type	Method	Description
protected reactor.core.publisher.Mono<Query>	createQuery(ConvertingParameterAccessor accessor)	Creates a Query instance using the given ParameterAccessor
protected org.reactivestreams.Publisher<Object>	doExecute(ReactiveMongoQueryMethod method, ResultProcessor processor, ConvertingParameterAccessor accessor, Class<?> typeToRead)	Execute the RepositoryQuery of the given method with the parameters provided by the accessor
protected boolean	isCountQuery()	Returns whether the query should get a count projection applied.
protected boolean	isDeleteQuery()	Return weather the query should delete matching documents.
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.

Methods inherited from class org.springframework.data.mongodb.repository.query.AbstractReactiveMongoQuery

createCountQuery, createUpdate, execute, getCodecRegistry, getParameterBindingCodec, getQueryMethod, getSpelEvaluatorFor, parseAggregationPipeline

Methods inherited from class java.lang.Object

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

Constructor Details

ReactiveStringBasedAggregation

public ReactiveStringBasedAggregation(ReactiveMongoQueryMethod method,
 ReactiveMongoOperations reactiveMongoOperations,
 ExpressionParser expressionParser,
 ReactiveQueryMethodEvaluationContextProvider evaluationContextProvider)

Parameters:

method - must not be null.

reactiveMongoOperations - must not be null.

expressionParser - must not be null.

evaluationContextProvider - must not be null.

Method Details

doExecute

protected org.reactivestreams.Publisher<Object> doExecute(ReactiveMongoQueryMethod method,
 ResultProcessor processor,
 ConvertingParameterAccessor accessor,
 Class<?> typeToRead)

Description copied from class: AbstractReactiveMongoQuery

Execute the RepositoryQuery of the given method with the parameters provided by the accessor

Overrides:

doExecute in class AbstractReactiveMongoQuery

Parameters:

method - the ReactiveMongoQueryMethod invoked. Never null.

processor - ResultProcessor for post procession. Never null.

accessor - for providing invocation arguments. Never null.

typeToRead - the desired component target type. Can be null.

createQuery

protected reactor.core.publisher.Mono<Query> createQuery(ConvertingParameterAccessor accessor)

Description copied from class: AbstractReactiveMongoQuery

Creates a Query instance using the given ParameterAccessor

Specified by:

createQuery in class AbstractReactiveMongoQuery

Parameters:

accessor - must not be null.

Returns:

isCountQuery

protected boolean isCountQuery()

Description copied from class: AbstractReactiveMongoQuery

Returns whether the query should get a count projection applied.

Specified by:

isCountQuery in class AbstractReactiveMongoQuery

Returns:

isExistsQuery

protected boolean isExistsQuery()

Description copied from class: AbstractReactiveMongoQuery

Returns whether the query should get an exists projection applied.

Specified by:

isExistsQuery in class AbstractReactiveMongoQuery

Returns:

isDeleteQuery

protected boolean isDeleteQuery()

Description copied from class: AbstractReactiveMongoQuery

Return weather the query should delete matching documents.

Specified by:

isDeleteQuery in class AbstractReactiveMongoQuery

Returns:

isLimiting

protected boolean isLimiting()

Description copied from class: AbstractReactiveMongoQuery

Return whether the query has an explicit limit set.

Specified by:

isLimiting in class AbstractReactiveMongoQuery

Returns: