public class ReactiveStringBasedAggregation extends AbstractReactiveMongoQuery
RepositoryQuery
to use a plain JSON String to create an
aggregation
pipeline to actually execute.Constructor and Description |
---|
ReactiveStringBasedAggregation(ReactiveMongoQueryMethod method,
ReactiveMongoOperations reactiveMongoOperations,
SpelExpressionParser expressionParser,
QueryMethodEvaluationContextProvider evaluationContextProvider) |
Modifier and Type | Method and Description |
---|---|
protected Query |
createQuery(ConvertingParameterAccessor accessor)
Creates a
Query instance using the given ParameterAccessor |
protected 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.
|
createCountQuery, execute, getQueryMethod
public ReactiveStringBasedAggregation(ReactiveMongoQueryMethod method, ReactiveMongoOperations reactiveMongoOperations, SpelExpressionParser expressionParser, QueryMethodEvaluationContextProvider evaluationContextProvider)
method
- must not be null.reactiveMongoOperations
- must not be null.expressionParser
- must not be null.evaluationContextProvider
- must not be null.protected Object doExecute(ReactiveMongoQueryMethod method, ResultProcessor processor, ConvertingParameterAccessor accessor, Class<?> typeToRead)
AbstractReactiveMongoQuery
RepositoryQuery
of the given method with the parameters provided by the
accessor
doExecute
in class AbstractReactiveMongoQuery
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.protected Query createQuery(ConvertingParameterAccessor accessor)
AbstractReactiveMongoQuery
Query
instance using the given ParameterAccessor
createQuery
in class AbstractReactiveMongoQuery
accessor
- must not be null.protected boolean isCountQuery()
AbstractReactiveMongoQuery
isCountQuery
in class AbstractReactiveMongoQuery
protected boolean isExistsQuery()
AbstractReactiveMongoQuery
isExistsQuery
in class AbstractReactiveMongoQuery
protected boolean isDeleteQuery()
AbstractReactiveMongoQuery
isDeleteQuery
in class AbstractReactiveMongoQuery
protected boolean isLimiting()
AbstractReactiveMongoQuery
isLimiting
in class AbstractReactiveMongoQuery
Copyright © 2011–2020 Pivotal Software, Inc.. All rights reserved.