Package org.springframework.data.couchbase.repository.query

Class ReactiveAbstractN1qlBasedQuery

java.lang.Object

org.springframework.data.couchbase.repository.query.ReactiveAbstractN1qlBasedQuery

All Implemented Interfaces:

RepositoryQuery

Direct Known Subclasses:

ReactivePartTreeN1qlBasedQuery

public abstract class ReactiveAbstractN1qlBasedQuery
extends Object
implements RepositoryQuery

Since:

3.0

Author:

Subhashni Balakrishnan, Mark Paluch, Johannes Jasper

Field Summary

Fields

Modifier and Type	Field	Description
protected final CouchbaseQueryMethod	queryMethod

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ReactiveAbstractN1qlBasedQuery(CouchbaseQueryMethod method, ReactiveCouchbaseOperations operations)

Method Summary

Modifier and Type	Method	Description
Object	execute(Object[] parameters)
protected Object	execute(N1QLQuery query, Class<?> typeToRead)
protected Object	executeDependingOnType(N1QLQuery query, QueryMethod queryMethod, Class<?> typeToRead)
protected Object	executeSingleProjection(N1QLQuery query, Class<?> typeToRead)
protected ReactiveCouchbaseOperations	getCouchbaseOperations()
protected abstract N1QLExpression	getExpression(ParameterAccessor accessor, Object[] runtimeParameters, ReturnedType returnedType)
protected abstract com.couchbase.client.java.json.JsonValue	getPlaceholderValues(ParameterAccessor accessor)
CouchbaseQueryMethod	getQueryMethod()
protected com.couchbase.client.java.query.QueryScanConsistency	getScanConsistency()

Methods inherited from class java.lang.Object

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

Field Details

queryMethod

protected final CouchbaseQueryMethod queryMethod

Constructor Details

ReactiveAbstractN1qlBasedQuery

protected ReactiveAbstractN1qlBasedQuery(CouchbaseQueryMethod method,
 ReactiveCouchbaseOperations operations)

Method Details

getExpression

protected abstract N1QLExpression getExpression(ParameterAccessor accessor,
 Object[] runtimeParameters,
 ReturnedType returnedType)

getPlaceholderValues

protected abstract com.couchbase.client.java.json.JsonValue getPlaceholderValues(ParameterAccessor accessor)

execute

public Object execute(Object[] parameters)

Specified by:

execute in interface RepositoryQuery

executeDependingOnType

protected Object executeDependingOnType(N1QLQuery query,
 QueryMethod queryMethod,
 Class<?> typeToRead)

execute

protected Object execute(N1QLQuery query,
 Class<?> typeToRead)

executeSingleProjection

protected Object executeSingleProjection(N1QLQuery query,
 Class<?> typeToRead)

getQueryMethod

public CouchbaseQueryMethod getQueryMethod()

Specified by:

getQueryMethod in interface RepositoryQuery

getCouchbaseOperations

protected ReactiveCouchbaseOperations getCouchbaseOperations()

getScanConsistency

protected com.couchbase.client.java.query.QueryScanConsistency getScanConsistency()