public abstract class AbstractCouchbaseQueryBase<CouchbaseOperationsType> extends Object implements RepositoryQuery
RepositoryQuery
implementation for Couchbase. CouchbaseOperationsType is either CouchbaseOperations or
ReactiveCouchbaseOperationsConstructor and Description |
---|
AbstractCouchbaseQueryBase(CouchbaseQueryMethod method,
CouchbaseOperationsType operations,
SpelExpressionParser expressionParser,
QueryMethodEvaluationContextProvider evaluationContextProvider)
Creates a new
AbstractCouchbaseQuery from the given ReactiveCouchbaseQueryMethod and
CouchbaseOperations . |
Modifier and Type | Method and Description |
---|---|
protected abstract Query |
createCountQuery(ParametersParameterAccessor accessor)
Creates a
Query instance using the given ParametersParameterAccessor . |
protected abstract Query |
createQuery(ParametersParameterAccessor accessor)
Creates a
Query instance using the given ParameterAccessor |
protected abstract Object |
doExecute(CouchbaseQueryMethod method,
ResultProcessor processor,
ParametersParameterAccessor accessor,
Class<?> typeToRead)
Execute the
RepositoryQuery of the given method with the parameters provided by the
accessor |
Object |
execute(Object[] parameters)
Execute the query with the provided parameters
|
CouchbaseOperationsType |
getOperations() |
CouchbaseQueryMethod |
getQueryMethod() |
protected boolean |
isCountQuery() |
protected boolean |
isDeleteQuery() |
protected boolean |
isExistsQuery() |
protected abstract boolean |
isLimiting()
Return whether the query has an explicit limit set.
|
public AbstractCouchbaseQueryBase(CouchbaseQueryMethod method, CouchbaseOperationsType operations, SpelExpressionParser expressionParser, QueryMethodEvaluationContextProvider evaluationContextProvider)
AbstractCouchbaseQuery
from the given ReactiveCouchbaseQueryMethod
and
CouchbaseOperations
.method
- must not be null.operations
- must not be null.expressionParser
- must not be null.evaluationContextProvider
- must not be null.public CouchbaseQueryMethod getQueryMethod()
getQueryMethod
in interface RepositoryQuery
public CouchbaseOperationsType getOperations()
public Object execute(Object[] parameters)
execute
in interface RepositoryQuery
RepositoryQuery.execute(java.lang.Object[])
protected abstract Object doExecute(CouchbaseQueryMethod method, ResultProcessor processor, ParametersParameterAccessor accessor, @Nullable Class<?> typeToRead)
RepositoryQuery
of the given method with the parameters provided by the
accessor
method
- the ReactiveCouchbaseQueryMethod
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 abstract Query createCountQuery(ParametersParameterAccessor accessor)
Query
instance using the given ParametersParameterAccessor
. Will delegate to
createQuery(ParametersParameterAccessor)
by default but allows customization of the count query to be
triggered.accessor
- must not be null.protected abstract Query createQuery(ParametersParameterAccessor accessor)
Query
instance using the given ParameterAccessor
accessor
- must not be null.protected boolean isCountQuery()
protected boolean isExistsQuery()
protected boolean isDeleteQuery()
protected abstract boolean isLimiting()
Copyright © 2011–2022 Pivotal Software, Inc.. All rights reserved.