Interface FluentQuery.ReactiveFluentQuery<T>
- All Superinterfaces:
FluentQuery<T>
- Enclosing interface:
- FluentQuery<T>
Reactive extension
FluentQuery
allowing to materialize results from the underlying query.- Since:
- 2.6
- Author:
- Mark Paluch
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.springframework.data.repository.query.FluentQuery
FluentQuery.FetchableFluentQuery<T>, FluentQuery.ReactiveFluentQuery<T>
-
Method Summary
Modifier and TypeMethodDescriptionreactor.core.publisher.Flux<T>
all()
Get all matching elements.Define the target type the result should be mapped to.reactor.core.publisher.Mono<Long>
count()
Get the number of matching elements.reactor.core.publisher.Mono<Boolean>
exists()
Check for the presence of matching elements.reactor.core.publisher.Mono<T>
first()
Get the first or no result.default FluentQuery.ReactiveFluentQuery<T>
limit
(int limit) Define the query limit.reactor.core.publisher.Mono<T>
one()
Get exactly zero or one result.Get a page of matching elements forPageable
.default FluentQuery.ReactiveFluentQuery<T>
Define which properties or property paths to include in the query.project
(Collection<String> properties) Define which properties or property paths to include in the query.scroll
(ScrollPosition scrollPosition) Get all matching elements asWindow
to start result scrolling or resume scrolling atscrollPosition
.Define the sort order.
-
Method Details
-
sortBy
Description copied from interface:FluentQuery
Define the sort order.- Specified by:
sortBy
in interfaceFluentQuery<T>
- Parameters:
sort
- theSort
specification to sort the results by, may beSort.unsorted()
, must not be null.- Returns:
- a new instance of
FluentQuery
.
-
limit
Description copied from interface:FluentQuery
Define the query limit.- Specified by:
limit
in interfaceFluentQuery<T>
- Parameters:
limit
- the limit to apply to the query to limit results. Must not be negative.- Returns:
- a new instance of
FluentQuery
.
-
as
Description copied from interface:FluentQuery
Define the target type the result should be mapped to. Skip this step if you are only interested in the original domain type.- Specified by:
as
in interfaceFluentQuery<T>
- Type Parameters:
R
- result type.- Parameters:
resultType
- must not benull
.- Returns:
- a new instance of
FluentQuery
.
-
project
Description copied from interface:FluentQuery
Define which properties or property paths to include in the query.- Specified by:
project
in interfaceFluentQuery<T>
- Parameters:
properties
- must not benull
.- Returns:
- a new instance of
FluentQuery
.
-
project
Description copied from interface:FluentQuery
Define which properties or property paths to include in the query.- Specified by:
project
in interfaceFluentQuery<T>
- Parameters:
properties
- must not benull
.- Returns:
- a new instance of
FluentQuery
.
-
one
reactor.core.publisher.Mono<T> one()Get exactly zero or one result.- Returns:
null
if no match found.- Throws:
IncorrectResultSizeDataAccessException
- if more than one match found.
-
first
reactor.core.publisher.Mono<T> first()Get the first or no result.- Returns:
null
if no match found.
-
all
reactor.core.publisher.Flux<T> all()Get all matching elements.- Returns:
-
scroll
Get all matching elements asWindow
to start result scrolling or resume scrolling atscrollPosition
.- Parameters:
scrollPosition
- must not be null.- Returns:
- Throws:
IllegalArgumentException
- ifscrollPosition
is null.UnsupportedOperationException
- if not supported by the underlying implementation.- Since:
- 3.1
-
page
Get a page of matching elements forPageable
.- Parameters:
pageable
- the pageable to request a paged result, can bePageable.unpaged()
, must not be null. The givenPageable
will override any previously specifiedsort
if theSort
object is notSort.isUnsorted()
. Any potentially specifiedlimit(int)
will be overridden byPageable.getPageSize()
.- Returns:
-
count
reactor.core.publisher.Mono<Long> count()Get the number of matching elements.- Returns:
- total number of matching elements.
-
exists
reactor.core.publisher.Mono<Boolean> exists()Check for the presence of matching elements.- Returns:
- true if at least one matching element exists.
-