Package | Description |
---|---|
org.springframework.data.cassandra.core |
Apache Cassandra core support.
|
org.springframework.data.cassandra.core.query |
Apache Cassandra specific query and update support.
|
Modifier and Type | Method and Description |
---|---|
StatementBuilder<com.datastax.oss.driver.api.querybuilder.select.Select> |
StatementFactory.count(Query query,
CassandraPersistentEntity<?> persistentEntity)
Create a COUNT statement by mapping
Query to Select . |
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 mapping
Query to Select . |
ListenableFuture<Long> |
AsyncCassandraTemplate.count(Query query,
Class<?> entityClass) |
reactor.core.publisher.Mono<Long> |
ReactiveCassandraTemplate.count(Query query,
Class<?> entityClass) |
reactor.core.publisher.Mono<Long> |
ReactiveCassandraOperations.count(Query query,
Class<?> entityClass)
Returns the number of rows for the given entity class applying
Query . |
long |
CassandraOperations.count(Query query,
Class<?> entityClass)
Returns the number of rows for the given entity class applying
Query . |
long |
CassandraTemplate.count(Query query,
Class<?> entityClass) |
ListenableFuture<Long> |
AsyncCassandraOperations.count(Query query,
Class<?> entityClass)
Returns the number of rows for the given entity class applying
Query . |
StatementBuilder<com.datastax.oss.driver.api.querybuilder.delete.Delete> |
StatementFactory.delete(Query query,
CassandraPersistentEntity<?> persistentEntity)
Create a DELETE statement by mapping
Query to Delete . |
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 mapping
Query to Delete . |
ListenableFuture<Boolean> |
AsyncCassandraTemplate.delete(Query query,
Class<?> entityClass) |
reactor.core.publisher.Mono<Boolean> |
ReactiveCassandraTemplate.delete(Query query,
Class<?> entityClass) |
reactor.core.publisher.Mono<Boolean> |
ReactiveCassandraOperations.delete(Query query,
Class<?> entityClass)
Remove entities (rows)/columns from the table by
Query . |
boolean |
CassandraOperations.delete(Query query,
Class<?> entityClass)
Remove entities (rows)/columns from the table by
Query . |
boolean |
CassandraTemplate.delete(Query query,
Class<?> entityClass) |
ListenableFuture<Boolean> |
AsyncCassandraOperations.delete(Query query,
Class<?> entityClass)
Remove entities (rows)/columns from the table by
Query . |
ListenableFuture<Boolean> |
AsyncCassandraTemplate.exists(Query query,
Class<?> entityClass) |
reactor.core.publisher.Mono<Boolean> |
ReactiveCassandraTemplate.exists(Query query,
Class<?> entityClass) |
reactor.core.publisher.Mono<Boolean> |
ReactiveCassandraOperations.exists(Query query,
Class<?> entityClass)
Determine whether the result for
entityClass Query yields at least one row. |
boolean |
CassandraOperations.exists(Query query,
Class<?> entityClass)
Determine whether the result for
entityClass Query yields at least one row. |
boolean |
CassandraTemplate.exists(Query query,
Class<?> entityClass) |
ListenableFuture<Boolean> |
AsyncCassandraOperations.exists(Query query,
Class<?> entityClass)
Determine whether the result for
entityClass Query yields at least one row. |
ExecutableDeleteOperation.TerminatingDelete |
ExecutableDeleteOperation.DeleteWithQuery.matching(Query query)
Define the
Query filtering elements to delete. |
ReactiveDeleteOperation.TerminatingDelete |
ReactiveDeleteOperation.DeleteWithQuery.matching(Query query)
Define the
Query used to filter elements in the delete. |
ReactiveUpdateOperation.TerminatingUpdate |
ReactiveUpdateOperation.UpdateWithQuery.matching(Query query)
Filter rows to update by the given
Query . |
ExecutableUpdateOperation.TerminatingUpdate |
ExecutableUpdateOperation.UpdateWithQuery.matching(Query query)
Filter rows with the given
Query . |
ExecutableSelectOperation.TerminatingSelect<T> |
ExecutableSelectOperation.SelectWithQuery.matching(Query query)
Set the
Query to use as a filter. |
ReactiveSelectOperation.TerminatingSelect<T> |
ReactiveSelectOperation.SelectWithQuery.matching(Query query)
Set the
Query used as a filter in the SELECT statement. |
StatementBuilder<com.datastax.oss.driver.api.querybuilder.select.Select> |
StatementFactory.select(Query query,
CassandraPersistentEntity<?> persistentEntity)
Create a SELECT statement by mapping
Query to Select . |
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 mapping
Query to Select . |
<T> ListenableFuture<List<T>> |
AsyncCassandraTemplate.select(Query query,
Class<T> entityClass) |
<T> reactor.core.publisher.Flux<T> |
ReactiveCassandraTemplate.select(Query query,
Class<T> entityClass) |
<T> reactor.core.publisher.Flux<T> |
ReactiveCassandraOperations.select(Query query,
Class<T> entityClass)
Execute a
SELECT query and convert the resulting items to a stream of entities. |
<T> List<T> |
CassandraOperations.select(Query query,
Class<T> entityClass)
Execute a
SELECT query and convert the resulting items to a List of entities. |
<T> List<T> |
CassandraTemplate.select(Query query,
Class<T> entityClass) |
<T> ListenableFuture<List<T>> |
AsyncCassandraOperations.select(Query query,
Class<T> entityClass)
Execute a
SELECT query and convert the resulting items to a List of entities. |
<T> ListenableFuture<Void> |
AsyncCassandraTemplate.select(Query query,
Consumer<T> entityConsumer,
Class<T> entityClass) |
<T> ListenableFuture<Void> |
AsyncCassandraOperations.select(Query query,
Consumer<T> entityConsumer,
Class<T> entityClass)
Execute a
SELECT query and convert the resulting items notifying Consumer for each entity. |
<T> ListenableFuture<T> |
AsyncCassandraTemplate.selectOne(Query query,
Class<T> entityClass) |
<T> reactor.core.publisher.Mono<T> |
ReactiveCassandraTemplate.selectOne(Query query,
Class<T> entityClass) |
<T> reactor.core.publisher.Mono<T> |
ReactiveCassandraOperations.selectOne(Query query,
Class<T> entityClass)
Execute a
SELECT query and convert the resulting item to an entity. |
<T> T |
CassandraOperations.selectOne(Query query,
Class<T> entityClass)
Execute a
SELECT query and convert the resulting item to an entity. |
<T> T |
CassandraTemplate.selectOne(Query query,
Class<T> entityClass) |
<T> ListenableFuture<T> |
AsyncCassandraOperations.selectOne(Query query,
Class<T> entityClass)
Execute a
SELECT query and convert the resulting item to an entity. |
<T> ListenableFuture<Slice<T>> |
AsyncCassandraTemplate.slice(Query query,
Class<T> entityClass) |
<T> reactor.core.publisher.Mono<Slice<T>> |
ReactiveCassandraTemplate.slice(Query query,
Class<T> entityClass) |
<T> reactor.core.publisher.Mono<Slice<T>> |
ReactiveCassandraOperations.slice(Query query,
Class<T> entityClass)
Execute a
SELECT query with paging and convert the result set to a Slice of entities. |
<T> Slice<T> |
CassandraOperations.slice(Query query,
Class<T> entityClass)
Execute a
SELECT query with paging and convert the result set to a Slice of entities. |
<T> Slice<T> |
CassandraTemplate.slice(Query query,
Class<T> entityClass) |
<T> ListenableFuture<Slice<T>> |
AsyncCassandraOperations.slice(Query query,
Class<T> entityClass)
Execute a
SELECT query with paging and convert the result set to a Slice of entities. |
<T> Stream<T> |
CassandraOperations.stream(Query query,
Class<T> entityClass)
Execute a
SELECT query and convert the resulting items to a Iterator of entities. |
<T> Stream<T> |
CassandraTemplate.stream(Query query,
Class<T> entityClass) |
StatementBuilder<com.datastax.oss.driver.api.querybuilder.update.Update> |
StatementFactory.update(Query query,
Update update,
CassandraPersistentEntity<?> persistentEntity)
|
ListenableFuture<Boolean> |
AsyncCassandraTemplate.update(Query query,
Update update,
Class<?> entityClass) |
reactor.core.publisher.Mono<Boolean> |
ReactiveCassandraTemplate.update(Query query,
Update update,
Class<?> entityClass) |
reactor.core.publisher.Mono<Boolean> |
ReactiveCassandraOperations.update(Query query,
Update update,
Class<?> entityClass)
Update the queried entities and return true if the update was applied.
|
boolean |
CassandraOperations.update(Query query,
Update update,
Class<?> entityClass)
Update the queried entities and return true if the update was applied.
|
boolean |
CassandraTemplate.update(Query query,
Update update,
Class<?> entityClass) |
ListenableFuture<Boolean> |
AsyncCassandraOperations.update(Query query,
Update update,
Class<?> entityClass)
Update the queried entities and return true if the update was applied.
|
Modifier and Type | Method and Description |
---|---|
Query |
Query.and(CriteriaDefinition criteriaDefinition)
Add the given
CriteriaDefinition to the current Query . |
Query |
Query.columns(Columns columns)
|
static Query |
Query.empty()
Static factory method to create an empty
Query . |
Query |
Query.limit(long limit)
Limit the number of returned rows to
limit . |
Query |
Query.pageRequest(Pageable pageable)
Create a
Query initialized with a PageRequest to fetch the first page of results or advance in
paging along with sorting. |
Query |
Query.pagingState(ByteBuffer pagingState)
Set the
paging state to skip rows. |
static Query |
Query.query(CriteriaDefinition... criteriaDefinitions)
Static factory method to create a
Query using the provided CriteriaDefinition . |
static Query |
Query.query(Iterable<? extends CriteriaDefinition> criteriaDefinitions)
Static factory method to create a
Query using the provided CriteriaDefinition . |
Query |
Query.queryOptions(QueryOptions queryOptions)
Set the
QueryOptions . |
Query |
Query.sort(Sort sort)
|
Query |
Query.withAllowFiltering()
Allow filtering with
this Query . |
Modifier and Type | Method and Description |
---|---|
protected boolean |
Query.querySettingsEquals(Query that)
Tests whether the settings of the given
Query are equal to this query. |
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.