AbstractReactiveCosmosQuery Class

  • java.lang.Object
    • com.azure.spring.data.cosmos.repository.query.AbstractReactiveCosmosQuery

Implements

org.springframework.data.repository.query.RepositoryQuery

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

Abstract class for reactive cosmos query.

Field Summary

Modifier and Type Field and Description
protected final ReactiveCosmosOperations operations

Reactive Cosmos operations

Constructor Summary

Constructor Description
AbstractReactiveCosmosQuery(ReactiveCosmosQueryMethod method, ReactiveCosmosOperations operations)

Initialization

Method Summary

Modifier and Type Method and Description
protected abstract CosmosQuery createQuery(ReactiveCosmosParameterAccessor accessor)

Creates a query.

Object execute(Object[] parameters)

Executes the AbstractReactiveCosmosQuery with the given parameters.

protected ReactiveCosmosQueryExecution getExecution(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 java.lang.Object

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

createQuery

protected abstract CosmosQuery createQuery(ReactiveCosmosParameterAccessor accessor)

Creates a query.

Parameters:

accessor - Reactive Cosmos parameter accessor.

Returns:

a Cosmos query.

execute

public Object execute(Object[] parameters)

Executes the AbstractReactiveCosmosQuery with the given parameters.

Parameters:

parameters - must not be null.

Returns:

execution result. Can be null.

getExecution

protected ReactiveCosmosQueryExecution getExecution(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

getQueryMethod

public ReactiveCosmosQueryMethod getQueryMethod()

Get method of query

Returns:

ReactiveCosmosQueryMethod

isCountQuery

protected abstract boolean isCountQuery()

Return whether this is a count query.

Returns:

whether this is a count 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.

isPageQuery

protected boolean isPageQuery()

Return whether this is a page query.

Returns:

whether this is a page query.

Applies to