Package | Description |
---|---|
org.springframework.data.cassandra.core |
Apache Cassandra core support.
|
org.springframework.data.cassandra.core.query |
Modifier and Type | Method and Description |
---|---|
com.datastax.driver.core.RegularStatement |
StatementFactory.delete(Query query,
CassandraPersistentEntity<?> entity)
Create a DELETE statement by mapping
Query to Delete . |
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 |
CassandraTemplate.delete(Query query,
Class<?> entityClass) |
boolean |
CassandraOperations.delete(Query query,
Class<?> entityClass)
Remove entities (rows)/columns from the table by
Query . |
ListenableFuture<Boolean> |
AsyncCassandraTemplate.delete(Query query,
Class<?> entityClass) |
ListenableFuture<Boolean> |
AsyncCassandraOperations.delete(Query query,
Class<?> entityClass)
Remove entities (rows)/columns from the table by
Query . |
com.datastax.driver.core.RegularStatement |
StatementFactory.select(Query query,
CassandraPersistentEntity<?> entity)
Create a SELECT statement by mapping
Query to Select . |
<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> |
CassandraTemplate.select(Query query,
Class<T> entityClass) |
<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> ListenableFuture<List<T>> |
AsyncCassandraTemplate.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> 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 |
CassandraTemplate.selectOne(Query query,
Class<T> entityClass) |
<T> T |
CassandraOperations.selectOne(Query query,
Class<T> entityClass)
Execute a
SELECT query and convert the resulting item to an entity. |
<T> ListenableFuture<T> |
AsyncCassandraTemplate.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> Stream<T> |
CassandraTemplate.stream(Query query,
Class<T> entityClass) |
<T> Stream<T> |
CassandraOperations.stream(Query query,
Class<T> entityClass)
Execute a
SELECT query and convert the resulting items to a Iterator of entities. |
com.datastax.driver.core.RegularStatement |
StatementFactory.update(Query query,
Update updateObj,
CassandraPersistentEntity<?> entity)
|
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 |
CassandraTemplate.update(Query query,
Update update,
Class<?> entityClass) |
boolean |
CassandraOperations.update(Query query,
Update update,
Class<?> entityClass)
Update the queried entities and return true if the update was applied.
|
ListenableFuture<Boolean> |
AsyncCassandraTemplate.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.pagingState(com.datastax.driver.core.PagingState pagingState)
Set the
PagingState 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–2017 Pivotal Software, Inc.. All rights reserved.