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

Class AbstractN1qlBasedQuery

java.lang.Object

org.springframework.data.couchbase.repository.query.AbstractN1qlBasedQuery

All Implemented Interfaces:

RepositoryQuery

Direct Known Subclasses:

PartTreeN1qlBasedQuery

public abstract class AbstractN1qlBasedQuery
extends Object
implements RepositoryQuery

Abstract base for all Couchbase RepositoryQuery. It is in charge of inspecting the parameters and choosing the correct N1QLQuery implementation to use.

Author:

Simon Baslé, 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	AbstractN1qlBasedQuery(CouchbaseQueryMethod queryMethod, CouchbaseOperations couchbaseOperations)

Method Summary

Modifier and Type	Method	Description
protected static N1QLQuery	buildQuery(N1QLExpression expression, com.couchbase.client.java.json.JsonValue queryPlaceholderValues, com.couchbase.client.java.query.QueryScanConsistency scanConsistency)
Object	execute(Object[] parameters)
protected List<?>	executeCollection(N1QLQuery query, Class<?> typeToRead)
protected Object	executeDependingOnType(N1QLQuery query, N1QLQuery countQuery, QueryMethod queryMethod, Pageable pageable, Class<?> typeToRead)
protected Object	executeEntity(N1QLQuery query, Class<?> typeToRead)
protected Object	executePaged(N1QLQuery query, N1QLQuery countQuery, Pageable pageable, Class<?> typeToRead)
protected Object	executeSingleProjection(N1QLQuery query)
protected Object	executeSliced(N1QLQuery query, N1QLQuery countQuery, Pageable pageable, Class<?> typeToRead)
protected Object	executeStream(N1QLQuery query, Class<?> typeToRead)
protected CouchbaseOperations	getCouchbaseOperations()
protected abstract N1QLExpression	getCount(ParameterAccessor accessor, Object[] runtimeParameters)	The statement for a count() query.
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()
protected abstract boolean	useGeneratedCountQuery()

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

AbstractN1qlBasedQuery

protected AbstractN1qlBasedQuery(CouchbaseQueryMethod queryMethod,
 CouchbaseOperations couchbaseOperations)

Method Details

buildQuery

protected static N1QLQuery buildQuery(N1QLExpression expression,
 com.couchbase.client.java.json.JsonValue queryPlaceholderValues,
 com.couchbase.client.java.query.QueryScanConsistency scanConsistency)

getCount

protected abstract N1QLExpression getCount(ParameterAccessor accessor,
 Object[] runtimeParameters)

The statement for a count() query. This must aggregate using count with the alias CountFragment.COUNT_ALIAS.

See Also:

• CountFragment

useGeneratedCountQuery

protected abstract boolean useGeneratedCountQuery()

Returns:

true if the count statement should also be used when the return type of the QueryMethod is a primitive type.

getExpression

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

getPlaceholderValues

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

getScanConsistency

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

execute

public Object execute(Object[] parameters)

Specified by:

execute in interface RepositoryQuery

executeDependingOnType

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

executeCollection

protected List<?> executeCollection(N1QLQuery query,
 Class<?> typeToRead)

executeEntity

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

executeStream

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

executePaged

protected Object executePaged(N1QLQuery query,
 N1QLQuery countQuery,
 Pageable pageable,
 Class<?> typeToRead)

executeSliced

protected Object executeSliced(N1QLQuery query,
 N1QLQuery countQuery,
 Pageable pageable,
 Class<?> typeToRead)

executeSingleProjection

protected Object executeSingleProjection(N1QLQuery query)

getQueryMethod

public CouchbaseQueryMethod getQueryMethod()

Specified by:

getQueryMethod in interface RepositoryQuery

getCouchbaseOperations

protected CouchbaseOperations getCouchbaseOperations()