Package org.springframework.data.r2dbc.repository.query

Class AbstractR2dbcQuery

java.lang.Object

org.springframework.data.r2dbc.repository.query.AbstractR2dbcQuery

All Implemented Interfaces:

RepositoryQuery

Direct Known Subclasses:

PartTreeR2dbcQuery, StringBasedR2dbcQuery

public abstract class AbstractR2dbcQuery
extends Object
implements RepositoryQuery

Base class for reactive RepositoryQuery implementations for R2DBC.

Author:

Mark Paluch, Stephen Cohen, Christoph Strobl

Constructor Summary

Constructors

Constructor	Description
AbstractR2dbcQuery(R2dbcQueryMethod method, R2dbcEntityOperations entityOperations, R2dbcConverter converter)	Creates a new AbstractR2dbcQuery from the given R2dbcQueryMethod and R2dbcEntityOperations.

Method Summary

Modifier and Type	Method	Description
protected abstract reactor.core.publisher.Mono<PreparedOperation<?>>	createQuery(RelationalParameterAccessor accessor)	Creates a BindableQuery instance using the given ParameterAccessor
Object	execute(Object[] parameters)
R2dbcQueryMethod	getQueryMethod()
protected abstract boolean	isCountQuery()	Returns whether the query should get a count projection applied.
protected abstract boolean	isExistsQuery()	Returns whether the query should get an exists projection applied.
protected abstract boolean	isModifyingQuery()	Returns whether this query is a modifying one.

Methods inherited from class java.lang.Object

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

Constructor Details

AbstractR2dbcQuery

public AbstractR2dbcQuery(R2dbcQueryMethod method,
 R2dbcEntityOperations entityOperations,
 R2dbcConverter converter)

Creates a new AbstractR2dbcQuery from the given R2dbcQueryMethod and R2dbcEntityOperations.

Parameters:

method - must not be null.

entityOperations - must not be null.

converter - must not be null.

Since:

1.4

Method Details

getQueryMethod

public R2dbcQueryMethod getQueryMethod()

Specified by:

getQueryMethod in interface RepositoryQuery

execute

public Object execute(Object[] parameters)

Specified by:

execute in interface RepositoryQuery

isModifyingQuery

protected abstract boolean isModifyingQuery()

Returns whether this query is a modifying one.

Returns:

Since:

1.1

isCountQuery

protected abstract boolean isCountQuery()

Returns whether the query should get a count projection applied.

Returns:

Since:

1.2

isExistsQuery

protected abstract boolean isExistsQuery()

Returns whether the query should get an exists projection applied.

Returns:

Since:

1.2

createQuery

protected abstract reactor.core.publisher.Mono<PreparedOperation<?>> createQuery(RelationalParameterAccessor accessor)

Creates a BindableQuery instance using the given ParameterAccessor

Parameters:

accessor - must not be null.

Returns:

a mono emitting a BindableQuery.