public interface CassandraOperations extends CqlOperations
Modifier and Type | Method and Description |
---|---|
long |
count(Class<?> type) |
<T> void |
delete(List<T> entities)
Remove the given object from the table by id.
|
<T> void |
delete(List<T> entities,
QueryOptions options) |
<T> void |
delete(T entity)
Remove the given object from the table by id.
|
<T> void |
delete(T entity,
QueryOptions options) |
<T> void |
deleteAll(Class<T> clazz)
Deletes all entities of a given class.
|
<T> void |
deleteAsynchronously(List<T> entities)
Remove the given object from the table by id.
|
<T> void |
deleteAsynchronously(List<T> entities,
QueryOptions options) |
<T> void |
deleteAsynchronously(T entity)
Remove the given object from the table by id.
|
<T> void |
deleteAsynchronously(T entity,
QueryOptions options) |
void |
deleteById(Class<?> type,
Object id) |
boolean |
exists(Class<?> type,
Object id) |
CassandraConverter |
getConverter()
Returns the underlying
CassandraConverter . |
CqlIdentifier |
getTableName(Class<?> entityClass)
The table name used for the specified class by this template.
|
<T> List<T> |
insert(List<T> entities)
Insert the given list of objects to the table by annotation table name.
|
<T> List<T> |
insert(List<T> entities,
WriteOptions options) |
<T> T |
insert(T entity)
Insert the given object to the table by id.
|
<T> T |
insert(T entity,
WriteOptions options) |
<T> List<T> |
insertAsynchronously(List<T> entities)
Insert the given object to the table by id.
|
<T> List<T> |
insertAsynchronously(List<T> entities,
WriteOptions options) |
<T> T |
insertAsynchronously(T entity)
Insert the given object to the table by id.
|
<T> T |
insertAsynchronously(T entity,
WriteOptions options) |
<T> List<T> |
select(com.datastax.driver.core.querybuilder.Select select,
Class<T> type)
Execute the Select Query and convert to the list of entities
|
<T> List<T> |
select(String cql,
Class<T> type)
Execute query and convert ResultSet to the list of entities
|
<T> List<T> |
selectAll(Class<T> type) |
<T> List<T> |
selectBySimpleIds(Class<T> type,
Iterable<?> ids) |
<T> T |
selectOne(com.datastax.driver.core.querybuilder.Select select,
Class<T> type)
Execute Select query and convert ResultSet to the entity
|
<T> T |
selectOne(String cql,
Class<T> type)
Execute CQL and convert ResultSet to the entity
|
<T> T |
selectOneById(Class<T> type,
Object id) |
<T> List<T> |
update(List<T> entities)
Insert the given object to the table by id.
|
<T> List<T> |
update(List<T> entities,
WriteOptions options) |
<T> T |
update(T entity)
Insert the given object to the table by id.
|
<T> T |
update(T entity,
WriteOptions options) |
<T> List<T> |
updateAsynchronously(List<T> entities)
Insert the given object to the table by id.
|
<T> List<T> |
updateAsynchronously(List<T> entities,
WriteOptions options) |
<T> T |
updateAsynchronously(T entity)
Insert the given object to the table by id.
|
<T> T |
updateAsynchronously(T entity,
WriteOptions options) |
count, count, describeRing, describeRing, execute, execute, execute, execute, execute, execute, execute, execute, execute, execute, execute, execute, execute, execute, execute, execute, execute, execute, execute, executeAsynchronously, executeAsynchronously, executeAsynchronously, executeAsynchronously, executeAsynchronously, executeAsynchronously, executeAsynchronously, executeAsynchronously, executeAsynchronously, executeAsynchronously, executeAsynchronously, executeAsynchronously, executeAsynchronously, executeAsynchronously, executeAsynchronously, executeAsynchronously, getSession, ingest, ingest, ingest, ingest, ingest, ingest, process, process, processList, processListOfMap, processMap, processOne, processOne, query, query, query, query, query, query, query, query, query, query, query, query, query, query, query, query, query, query, query, query, query, query, query, query, query, query, query, query, query, query, queryAsynchronously, queryAsynchronously, queryAsynchronously, queryAsynchronously, queryAsynchronously, queryAsynchronously, queryAsynchronously, queryAsynchronously, queryAsynchronously, queryAsynchronously, queryAsynchronously, queryAsynchronously, queryAsynchronously, queryAsynchronously, queryAsynchronously, queryAsynchronously, queryAsynchronously, queryForList, queryForList, queryForListOfMap, queryForListOfMap, queryForMap, queryForMap, queryForObject, queryForObject, queryForObject, queryForObject, truncate, truncate
CqlIdentifier getTableName(Class<?> entityClass)
entityClass
- must not be null.<T> List<T> select(String cql, Class<T> type)
query
- must not be null.type
- must not be null, mapped entity type.<T> List<T> select(com.datastax.driver.core.querybuilder.Select select, Class<T> type)
select
- must not be null.type
- must not be null, mapped entity type.<T> T selectOne(String cql, Class<T> type)
query
- must not be null.type
- must not be null, mapped entity type.<T> T selectOne(com.datastax.driver.core.querybuilder.Select select, Class<T> type)
query
- must not be null.type
- must not be null, mapped entity type.long count(Class<?> type)
<T> T insert(T entity)
entity
- <T> T insert(T entity, WriteOptions options)
entity
- tableName
- options
- <T> List<T> insert(List<T> entities)
entities
- <T> List<T> insert(List<T> entities, WriteOptions options)
entities
- tableName
- options
- <T> T insertAsynchronously(T entity)
object
- <T> T insertAsynchronously(T entity, WriteOptions options)
entity
- tableName
- options
- <T> List<T> insertAsynchronously(List<T> entities)
object
- <T> List<T> insertAsynchronously(List<T> entities, WriteOptions options)
entities
- tableName
- options
- <T> T update(T entity)
object
- <T> T update(T entity, WriteOptions options)
entity
- tableName
- options
- <T> List<T> update(List<T> entities)
object
- <T> List<T> update(List<T> entities, WriteOptions options)
entities
- tableName
- options
- <T> T updateAsynchronously(T entity)
object
- <T> T updateAsynchronously(T entity, WriteOptions options)
entity
- tableName
- options
- <T> List<T> updateAsynchronously(List<T> entities)
object
- <T> List<T> updateAsynchronously(List<T> entities, WriteOptions options)
entities
- tableName
- options
- <T> void delete(T entity)
object
- <T> void delete(T entity, QueryOptions options)
entity
- tableName
- options
- <T> void delete(List<T> entities)
object
- <T> void delete(List<T> entities, QueryOptions options)
entities
- tableName
- options
- <T> void deleteAll(Class<T> clazz)
<T> void deleteAsynchronously(T entity)
object
- <T> void deleteAsynchronously(T entity, QueryOptions options)
entity
- tableName
- options
- <T> void deleteAsynchronously(List<T> entities)
object
- <T> void deleteAsynchronously(List<T> entities, QueryOptions options)
entities
- tableName
- options
- CassandraConverter getConverter()
CassandraConverter
.Copyright © 2011-2014–2015 Pivotal Software, Inc.. All rights reserved.