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

Class AbstractReactiveMongoQuery

java.lang.Object

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

All Implemented Interfaces:

RepositoryQuery

Direct Known Subclasses:

ReactivePartTreeMongoQuery, ReactiveStringBasedAggregation, ReactiveStringBasedMongoQuery, ReactiveVectorSearchAggregation

public abstract class AbstractReactiveMongoQuery
extends Object
implements RepositoryQuery

Base class for reactive RepositoryQuery implementations for MongoDB.

Since:

2.0

Author:

Mark Paluch, Christoph Strobl, Jorge Rodríguez

Constructor Summary

Constructors

Constructor	Description
AbstractReactiveMongoQuery(ReactiveMongoQueryMethod method, ReactiveMongoOperations operations, ValueExpressionDelegate delegate)	Creates a new AbstractReactiveMongoQuery from the given MongoQueryMethod and MongoOperations.

Method Summary

Modifier and Type	Method	Description
protected Mono<Query>	createCountQuery(ConvertingParameterAccessor accessor)	Creates a Query instance using the given ConvertingParameterAccessor.
protected abstract Mono<Query>	createQuery(ConvertingParameterAccessor accessor)	Creates a Query instance using the given ParameterAccessor
protected Mono<UpdateDefinition>	createUpdate(MongoParameterAccessor accessor)	Retrieves the update from the given accessor or creates one via by parsing the annotated statement extracted from Update.
protected Publisher<Object>	doExecute(ReactiveMongoQueryMethod method, ResultProcessor processor, ConvertingParameterAccessor accessor, @Nullable Class<?> typeToRead)	Execute the RepositoryQuery of the given method with the parameters provided by the accessor
Publisher<Object>	execute(Object[] parameters)
protected Mono<org.bson.codecs.configuration.CodecRegistry>	getCodecRegistry()
protected Mono<ParameterBindingDocumentCodec>	getParameterBindingCodec()	Obtain the ParameterBindingDocumentCodec used for parsing JSON expressions.
MongoQueryMethod	getQueryMethod()
protected Mono<ValueExpressionEvaluator>	getValueExpressionEvaluatorLater(ExpressionDependencies dependencies, MongoParameterAccessor accessor)	Obtain a publisher emitting the ValueExpressionEvaluator suitable to evaluate expressions backed by the given dependencies.
protected abstract boolean	isCountQuery()	Returns whether the query should get a count projection applied.
protected abstract boolean	isDeleteQuery()	Return weather the query should delete matching documents.
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 Mono<List<AggregationOperation>>	parseAggregationPipeline(String[] pipeline, MongoParameterAccessor accessor)	Parse the given aggregation pipeline stages applying values to placeholders to compute the actual list of operations.

Methods inherited from class java.lang.Object

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

Constructor Details

AbstractReactiveMongoQuery

public AbstractReactiveMongoQuery(ReactiveMongoQueryMethod method,
 ReactiveMongoOperations operations,
 ValueExpressionDelegate delegate)

Creates a new AbstractReactiveMongoQuery from the given MongoQueryMethod and MongoOperations.

Parameters:

method - must not be null.

operations - must not be null.

delegate - must not be null.

Since:

4.4.0

Method Details

getQueryMethod

public MongoQueryMethod getQueryMethod()

Specified by:

getQueryMethod in interface RepositoryQuery

execute

public Publisher<Object> execute(Object[] parameters)

Specified by:

execute in interface RepositoryQuery

doExecute

protected Publisher<Object> doExecute(ReactiveMongoQueryMethod method,
 ResultProcessor processor,
 ConvertingParameterAccessor accessor,
 @Nullable Class<?> typeToRead)

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

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.

createCountQuery

protected Mono<Query> createCountQuery(ConvertingParameterAccessor accessor)

Creates a Query instance using the given ConvertingParameterAccessor. Will delegate to createQuery(ConvertingParameterAccessor) by default but allows customization of the count query to be triggered.

Parameters:

accessor - must not be null.

Returns:

createUpdate

protected Mono<UpdateDefinition> createUpdate(MongoParameterAccessor accessor)

Retrieves the update from the given accessor or creates one via by parsing the annotated statement extracted from Update.

Parameters:

accessor - never null.

Returns:

the computed UpdateDefinition.

Throws:

IllegalStateException - if no update could be found.

Since:

3.4

parseAggregationPipeline

protected Mono<List<AggregationOperation>> parseAggregationPipeline(String[] pipeline,
 MongoParameterAccessor accessor)

Parse the given aggregation pipeline stages applying values to placeholders to compute the actual list of operations.

Parameters:

pipeline - must not be null.

accessor - must not be null.

Returns:

the parsed aggregation pipeline.

Since:

3.4

getParameterBindingCodec

protected Mono<ParameterBindingDocumentCodec> getParameterBindingCodec()

Obtain the ParameterBindingDocumentCodec used for parsing JSON expressions.

Returns:

never null.

Since:

3.4

getValueExpressionEvaluatorLater

protected Mono<ValueExpressionEvaluator> getValueExpressionEvaluatorLater(ExpressionDependencies dependencies,
 MongoParameterAccessor accessor)

Obtain a publisher emitting the ValueExpressionEvaluator suitable to evaluate expressions backed by the given dependencies.

Parameters:

dependencies - must not be null.

accessor - must not be null.

Returns:

a Mono emitting the ValueExpressionEvaluator when ready.

Since:

4.3

getCodecRegistry

protected Mono<org.bson.codecs.configuration.CodecRegistry> getCodecRegistry()

Returns:

a Mono emitting the CodecRegistry when ready.

Since:

2.4

createQuery

protected abstract Mono<Query> createQuery(ConvertingParameterAccessor accessor)

Creates a Query instance using the given ParameterAccessor

Parameters:

accessor - must not be null.

Returns:

isCountQuery

protected abstract boolean isCountQuery()

Returns whether the query should get a count projection applied.

Returns:

isExistsQuery

protected abstract boolean isExistsQuery()

Returns whether the query should get an exists projection applied.

Returns:

Since:

2.0.9

isDeleteQuery

protected abstract boolean isDeleteQuery()

Return weather the query should delete matching documents.

Returns:

Since:

1.5

isLimiting

protected abstract boolean isLimiting()

Return whether the query has an explicit limit set.

Returns:

Since:

2.0.4