StringBasedReactiveCosmosQuery Class

public class StringBasedReactiveCosmosQuery
extends AbstractReactiveCosmosQuery

Cosmos query class to handle the annotated queries. This overrides the execution and runs the query directly

Constructor Summary

Constructor Description
StringBasedReactiveCosmosQuery(ReactiveCosmosQueryMethod queryMethod, ReactiveCosmosOperations dbOperations)

Constructor

Method Summary

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

Creates a query.

Object execute(Object[] parameters)

Executes the AbstractReactiveCosmosQuery with the given parameters.

protected boolean isCountQuery()

Return whether this is a count query.

protected boolean isDeleteQuery()

Return whether this is a deletion query.

protected boolean isExistsQuery()

Return whether this is an exists query.

Methods inherited from AbstractReactiveCosmosQuery

Methods inherited from java.lang.Object

Constructor Details

StringBasedReactiveCosmosQuery

public StringBasedReactiveCosmosQuery(ReactiveCosmosQueryMethod queryMethod, ReactiveCosmosOperations dbOperations)

Constructor

Parameters:

queryMethod - the query method
dbOperations - the reactive cosmos operations

Method Details

createQuery

protected CosmosQuery createQuery(ReactiveCosmosParameterAccessor accessor)

Creates a query.

Overrides:

StringBasedReactiveCosmosQuery.createQuery(ReactiveCosmosParameterAccessor accessor)

Parameters:

accessor

execute

public Object execute(Object[] parameters)

Executes the AbstractReactiveCosmosQuery with the given parameters.

Overrides:

StringBasedReactiveCosmosQuery.execute(Object[] parameters)

Parameters:

parameters

isCountQuery

protected boolean isCountQuery()

Return whether this is a count query.

Overrides:

StringBasedReactiveCosmosQuery.isCountQuery()

isDeleteQuery

protected boolean isDeleteQuery()

Return whether this is a deletion query.

Overrides:

StringBasedReactiveCosmosQuery.isDeleteQuery()

isExistsQuery

protected boolean isExistsQuery()

Return whether this is an exists query.

Overrides:

StringBasedReactiveCosmosQuery.isExistsQuery()

Applies to