Class AbstractReactiveCouchbaseQuery

java.lang.Object

org.springframework.data.couchbase.repository.query.AbstractCouchbaseQueryBase<ReactiveCouchbaseOperations>

org.springframework.data.couchbase.repository.query.AbstractReactiveCouchbaseQuery

All Implemented Interfaces:

RepositoryQuery

Direct Known Subclasses:

ReactiveCouchbaseRepositoryQuery, ReactivePartTreeCouchbaseQuery, ReactiveStringBasedCouchbaseQuery

public abstract class AbstractReactiveCouchbaseQuery
extends AbstractCouchbaseQueryBase<ReactiveCouchbaseOperations>
implements RepositoryQuery

Base class for reactive RepositoryQuery implementations for Couchbase.

Since:

4.1

Author:

Michael Reiche

Constructor Summary

Constructors

Constructor	Description
AbstractReactiveCouchbaseQuery(ReactiveCouchbaseQueryMethod method, ReactiveCouchbaseOperations operations, ValueExpressionDelegate valueExpressionDelegate)	Creates a new AbstractReactiveCouchbaseQuery from the given ReactiveCouchbaseQueryMethod and CouchbaseOperations.

Method Summary

Modifier and Type	Method	Description
protected Object	doExecute(CouchbaseQueryMethod method, ResultProcessor processor, ParametersParameterAccessor accessor, @Nullable Class<?> typeToRead)	Execute the RepositoryQuery of the given method with the parameters provided by the accessor

Methods inherited from class AbstractCouchbaseQueryBase

createCountQuery, createQuery, execute, getOperations, getQueryMethod, isCountQuery, isDeleteQuery, isExistsQuery, isLimiting

Methods inherited from class Object

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

Methods inherited from interface RepositoryQuery

execute, getQueryMethod

Constructor Details

AbstractReactiveCouchbaseQuery

public AbstractReactiveCouchbaseQuery(ReactiveCouchbaseQueryMethod method,
 ReactiveCouchbaseOperations operations,
 ValueExpressionDelegate valueExpressionDelegate)

Creates a new AbstractReactiveCouchbaseQuery from the given ReactiveCouchbaseQueryMethod and CouchbaseOperations.

Parameters:

method - must not be null.

operations - must not be null.

valueExpressionDelegate - must not be null.

Method Details

doExecute

protected Object doExecute(CouchbaseQueryMethod method,
 ResultProcessor processor,
 ParametersParameterAccessor accessor,
 @Nullable Class<?> typeToRead)

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

Specified by:

doExecute in class AbstractCouchbaseQueryBase<ReactiveCouchbaseOperations>

Parameters:

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.