Uses of Class
org.springframework.data.cassandra.core.query.Query
Package
Description
Apache Cassandra core support.
Apache Cassandra legacy asynchronous support for easier migration.
Apache Cassandra specific query and update support.
-
Uses of Query in org.springframework.data.cassandra.core
Modifier and TypeMethodDescriptionReturns the number of rows for the given entity class applyingQuery
.long
Returns the number of rows for the given entity class applyingQuery
.long
reactor.core.publisher.Mono<Long>
Returns the number of rows for the given entity class applyingQuery
.reactor.core.publisher.Mono<Long>
StatementBuilder<com.datastax.oss.driver.api.querybuilder.select.Select>
StatementFactory.count
(Query query, CassandraPersistentEntity<?> persistentEntity) Create a COUNT statement by mappingQuery
toSelect
.StatementBuilder<com.datastax.oss.driver.api.querybuilder.select.Select>
StatementFactory.count
(Query query, CassandraPersistentEntity<?> entity, com.datastax.oss.driver.api.core.CqlIdentifier tableName) Create a COUNT statement by mappingQuery
toSelect
.Remove entities (rows)/columns from the table byQuery
.boolean
Remove entities (rows)/columns from the table byQuery
.boolean
reactor.core.publisher.Mono<Boolean>
Remove entities (rows)/columns from the table byQuery
.reactor.core.publisher.Mono<Boolean>
StatementBuilder<com.datastax.oss.driver.api.querybuilder.delete.Delete>
StatementFactory.delete
(Query query, CassandraPersistentEntity<?> persistentEntity) Create a DELETE statement by mappingQuery
toDelete
.StatementBuilder<com.datastax.oss.driver.api.querybuilder.delete.Delete>
StatementFactory.delete
(Query query, CassandraPersistentEntity<?> persistentEntity, com.datastax.oss.driver.api.core.CqlIdentifier tableName) Create a DELETE statement by mappingQuery
toDelete
.Determine whether the result forentityClass
Query
yields at least one row.boolean
Determine whether the result forentityClass
Query
yields at least one row.boolean
reactor.core.publisher.Mono<Boolean>
Determine whether the result forentityClass
Query
yields at least one row.reactor.core.publisher.Mono<Boolean>
Define theQuery
filtering elements to delete.Set theQuery
to use as a filter.Filter rows with the givenQuery
.Define theQuery
used to filter elements in the delete.Set theQuery
used as a filter in theSELECT
statement.Filter rows to update by the givenQuery
.<T> CompletableFuture<List<T>>
Execute aSELECT
query and convert the resulting items to aList
of entities.<T> CompletableFuture<Void>
Execute aSELECT
query and convert the resulting items notifyingConsumer
for each entity.<T> CompletableFuture<List<T>>
<T> CompletableFuture<Void>
<T> List<T>
Execute aSELECT
query and convert the resulting items to aList
of entities.<T> List<T>
<T> reactor.core.publisher.Flux<T>
Execute aSELECT
query and convert the resulting items to a stream of entities.<T> reactor.core.publisher.Flux<T>
StatementBuilder<com.datastax.oss.driver.api.querybuilder.select.Select>
StatementFactory.select
(Query query, CassandraPersistentEntity<?> persistentEntity) Create a SELECT statement by mappingQuery
toSelect
.StatementBuilder<com.datastax.oss.driver.api.querybuilder.select.Select>
StatementFactory.select
(Query query, CassandraPersistentEntity<?> persistentEntity, com.datastax.oss.driver.api.core.CqlIdentifier tableName) Create a SELECT statement by mappingQuery
toSelect
.<T> CompletableFuture<T>
Execute aSELECT
query and convert the resulting item to an entity.<T> CompletableFuture<T>
<T> T
Execute aSELECT
query and convert the resulting item to an entity.<T> T
<T> reactor.core.publisher.Mono<T>
Execute aSELECT
query and convert the resulting item to an entity.<T> reactor.core.publisher.Mono<T>
<T> CompletableFuture<org.springframework.data.domain.Slice<T>>
Execute aSELECT
query with paging and convert the result set to aSlice
of entities.<T> CompletableFuture<org.springframework.data.domain.Slice<T>>
<T> org.springframework.data.domain.Slice<T>
Execute aSELECT
query with paging and convert the result set to aSlice
of entities.<T> org.springframework.data.domain.Slice<T>
<T> reactor.core.publisher.Mono<org.springframework.data.domain.Slice<T>>
Execute aSELECT
query with paging and convert the result set to aSlice
of entities.<T> reactor.core.publisher.Mono<org.springframework.data.domain.Slice<T>>
<T> Stream<T>
Execute aSELECT
query and convert the resulting items to aIterator
of entities.<T> Stream<T>
Update the queried entities and return true if the update was applied.boolean
Update the queried entities and return true if the update was applied.boolean
reactor.core.publisher.Mono<Boolean>
Update the queried entities and return true if the update was applied.reactor.core.publisher.Mono<Boolean>
StatementBuilder<com.datastax.oss.driver.api.querybuilder.update.Update>
StatementFactory.update
(Query query, Update update, CassandraPersistentEntity<?> persistentEntity) -
Uses of Query in org.springframework.data.cassandra.core.legacy
Modifier and TypeMethodDescriptionorg.springframework.util.concurrent.ListenableFuture<Long>
Deprecated, for removal: This API element is subject to removal in a future version.Returns the number of rows for the given entity class applyingQuery
.org.springframework.util.concurrent.ListenableFuture<Long>
Deprecated, for removal: This API element is subject to removal in a future version.org.springframework.util.concurrent.ListenableFuture<Boolean>
Deprecated, for removal: This API element is subject to removal in a future version.Remove entities (rows)/columns from the table byQuery
.org.springframework.util.concurrent.ListenableFuture<Boolean>
Deprecated, for removal: This API element is subject to removal in a future version.org.springframework.util.concurrent.ListenableFuture<Boolean>
Deprecated, for removal: This API element is subject to removal in a future version.Determine whether the result forentityClass
Query
yields at least one row.org.springframework.util.concurrent.ListenableFuture<Boolean>
Deprecated, for removal: This API element is subject to removal in a future version.<T> org.springframework.util.concurrent.ListenableFuture<List<T>>
Deprecated, for removal: This API element is subject to removal in a future version.Execute aSELECT
query and convert the resulting items to aList
of entities.<T> org.springframework.util.concurrent.ListenableFuture<Void>
Deprecated, for removal: This API element is subject to removal in a future version.Execute aSELECT
query and convert the resulting items notifyingConsumer
for each entity.<T> org.springframework.util.concurrent.ListenableFuture<List<T>>
Deprecated, for removal: This API element is subject to removal in a future version.<T> org.springframework.util.concurrent.ListenableFuture<Void>
Deprecated, for removal: This API element is subject to removal in a future version.<T> org.springframework.util.concurrent.ListenableFuture<T>
Deprecated, for removal: This API element is subject to removal in a future version.Execute aSELECT
query and convert the resulting item to an entity.<T> org.springframework.util.concurrent.ListenableFuture<T>
Deprecated, for removal: This API element is subject to removal in a future version.<T> org.springframework.util.concurrent.ListenableFuture<org.springframework.data.domain.Slice<T>>
Deprecated, for removal: This API element is subject to removal in a future version.Execute aSELECT
query with paging and convert the result set to aSlice
of entities.<T> org.springframework.util.concurrent.ListenableFuture<org.springframework.data.domain.Slice<T>>
Deprecated, for removal: This API element is subject to removal in a future version.org.springframework.util.concurrent.ListenableFuture<Boolean>
Deprecated, for removal: This API element is subject to removal in a future version.Update the queried entities and return true if the update was applied.org.springframework.util.concurrent.ListenableFuture<Boolean>
Deprecated, for removal: This API element is subject to removal in a future version. -
Uses of Query in org.springframework.data.cassandra.core.query
Modifier and TypeMethodDescriptionQuery.and
(CriteriaDefinition criteriaDefinition) Add the givenCriteriaDefinition
to the currentQuery
.static Query
Query.empty()
Static factory method to create an emptyQuery
.Query.limit
(long limit) Limit the number of returned rows tolimit
.Query.pageRequest
(org.springframework.data.domain.Pageable pageable) Create aQuery
initialized with aPageRequest
to fetch the first page of results or advance in paging along with sorting.Query.pagingState
(ByteBuffer pagingState) Set thepaging state
to skip rows.static Query
Query.query
(Iterable<? extends CriteriaDefinition> criteriaDefinitions) Static factory method to create aQuery
using the providedCriteriaDefinition
.static Query
Query.query
(CriteriaDefinition... criteriaDefinitions) Static factory method to create aQuery
using the providedCriteriaDefinition
.Query.queryOptions
(QueryOptions queryOptions) Set theQueryOptions
.Query.sort
(org.springframework.data.domain.Sort sort) Add aSort
to theQuery
instance.Query.withAllowFiltering()
Allow filtering withthis
Query
.Modifier and TypeMethodDescriptionprotected boolean
Query.querySettingsEquals
(Query that) Tests whether the settings of the givenQuery
are equal to this query.