public abstract class ReactiveAbstractN1qlBasedQuery extends Object implements RepositoryQuery
Modifier and Type | Field and Description |
---|---|
protected CouchbaseQueryMethod |
queryMethod |
Modifier | Constructor and Description |
---|---|
protected |
ReactiveAbstractN1qlBasedQuery(CouchbaseQueryMethod method,
RxJavaCouchbaseOperations operations) |
Modifier and Type | Method and Description |
---|---|
protected Object |
execute(com.couchbase.client.java.query.N1qlQuery query,
Class<?> typeToRead) |
Object |
execute(Object[] parameters) |
protected Object |
executeDependingOnType(com.couchbase.client.java.query.N1qlQuery query,
QueryMethod queryMethod,
Class<?> typeToRead) |
protected Object |
executeSingleProjection(com.couchbase.client.java.query.N1qlQuery query,
Class<?> typeToRead) |
protected RxJavaCouchbaseOperations |
getCouchbaseOperations() |
protected abstract com.couchbase.client.java.document.json.JsonValue |
getPlaceholderValues(ParameterAccessor accessor) |
CouchbaseQueryMethod |
getQueryMethod() |
protected com.couchbase.client.java.query.consistency.ScanConsistency |
getScanConsistency() |
protected abstract com.couchbase.client.java.query.Statement |
getStatement(ParameterAccessor accessor,
Object[] runtimeParameters,
ReturnedType returnedType) |
protected final CouchbaseQueryMethod queryMethod
protected ReactiveAbstractN1qlBasedQuery(CouchbaseQueryMethod method, RxJavaCouchbaseOperations operations)
protected abstract com.couchbase.client.java.query.Statement getStatement(ParameterAccessor accessor, Object[] runtimeParameters, ReturnedType returnedType)
protected abstract com.couchbase.client.java.document.json.JsonValue getPlaceholderValues(ParameterAccessor accessor)
public Object execute(Object[] parameters)
execute
in interface RepositoryQuery
protected Object executeDependingOnType(com.couchbase.client.java.query.N1qlQuery query, QueryMethod queryMethod, Class<?> typeToRead)
protected Object execute(com.couchbase.client.java.query.N1qlQuery query, Class<?> typeToRead)
protected Object executeSingleProjection(com.couchbase.client.java.query.N1qlQuery query, Class<?> typeToRead)
public CouchbaseQueryMethod getQueryMethod()
getQueryMethod
in interface RepositoryQuery
protected RxJavaCouchbaseOperations getCouchbaseOperations()
protected com.couchbase.client.java.query.consistency.ScanConsistency getScanConsistency()
Copyright © 2011–2020 Pivotal Software, Inc.. All rights reserved.