Package com.azure.spring.data.cosmos.repository.query

Class AbstractReactiveCosmosQuery

java.lang.Object

com.azure.spring.data.cosmos.repository.query.AbstractReactiveCosmosQuery

All Implemented Interfaces:

org.springframework.data.repository.query.RepositoryQuery

Direct Known Subclasses:

PartTreeReactiveCosmosQuery, StringBasedReactiveCosmosQuery

public abstract class AbstractReactiveCosmosQuery
extends Object
implements org.springframework.data.repository.query.RepositoryQuery

Abstract class for reactive cosmos query.

Field Summary

Fields

Modifier and Type	Field	Description
protected final ReactiveCosmosOperations	operations	Reactive Cosmos operations

Constructor Summary

Constructors

Constructor	Description
AbstractReactiveCosmosQuery(ReactiveCosmosQueryMethod method, ReactiveCosmosOperations operations)	Initialization

Method Summary

Modifier and Type	Method	Description
protected abstract CosmosQuery	createQuery(ReactiveCosmosParameterAccessor accessor)	Creates a query.
Object	execute(Object[] parameters)	Executes the AbstractReactiveCosmosQuery with the given parameters.
protected ReactiveCosmosQueryExecution	getExecution(org.springframework.data.repository.query.ReturnedType returnedType)	Determines the appropriate execution path for a reactive query
ReactiveCosmosQueryMethod	getQueryMethod()	Get method of query
protected abstract boolean	isCountQuery()	Return whether this is a count query.
protected abstract boolean	isDeleteQuery()	Return whether this is a deletion query.
protected abstract boolean	isExistsQuery()	Return whether this is an exists query.
protected boolean	isPageQuery()	Return whether this is a page query.

Methods inherited from class java.lang.Object

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

Field Details

operations

protected final ReactiveCosmosOperations operations

Reactive Cosmos operations

Constructor Details

AbstractReactiveCosmosQuery

public AbstractReactiveCosmosQuery(ReactiveCosmosQueryMethod method,
 ReactiveCosmosOperations operations)

Initialization

Parameters:

method - ReactiveCosmosQueryMethod

operations - ReactiveCosmosOperations

Method Details

execute

public Object execute(Object[] parameters)

Executes the AbstractReactiveCosmosQuery with the given parameters.

Specified by:

execute in interface org.springframework.data.repository.query.RepositoryQuery

Parameters:

parameters - must not be null.

Returns:

execution result. Can be null.

getExecution

protected ReactiveCosmosQueryExecution getExecution(org.springframework.data.repository.query.ReturnedType returnedType)

Determines the appropriate execution path for a reactive query

Parameters:

returnedType - The return type of the method

Returns:

the execution type needed to handle the query

Throws:

IllegalArgumentException - if execution requires paging

getQueryMethod

public ReactiveCosmosQueryMethod getQueryMethod()

Get method of query

Specified by:

getQueryMethod in interface org.springframework.data.repository.query.RepositoryQuery

Returns:

ReactiveCosmosQueryMethod

createQuery

protected abstract CosmosQuery createQuery(ReactiveCosmosParameterAccessor accessor)

Creates a query.

Parameters:

accessor - Reactive Cosmos parameter accessor.

Returns:

a Cosmos query.

isDeleteQuery

protected abstract boolean isDeleteQuery()

Return whether this is a deletion query.

Returns:

whether this is a deletion query.

isExistsQuery

protected abstract boolean isExistsQuery()

Return whether this is an exists query.

Returns:

whether this is an exists query.

isCountQuery

protected abstract boolean isCountQuery()

Return whether this is a count query.

Returns:

whether this is a count query.

isPageQuery

protected boolean isPageQuery()

Return whether this is a page query.

Returns:

whether this is a page query.