public interface CassandraAdminOperations extends CassandraOperations
Modifier and Type | Method and Description |
---|---|
void |
alterTable(CqlIdentifier tableName,
Class<?> entityClass,
boolean dropRemovedAttributeColumns)
Add columns to the given table from the given class.
|
void |
createTable(boolean ifNotExists,
CqlIdentifier tableName,
Class<?> entityClass,
Map<String,Object> optionsByName)
Create a table with the name given and fields corresponding to the given class.
|
void |
dropTable(CqlIdentifier tableName)
Drops the named table.
|
com.datastax.driver.core.TableMetadata |
getTableMetadata(String keyspace,
CqlIdentifier tableName) |
void |
replaceTable(CqlIdentifier tableName,
Class<?> entityClass,
Map<String,Object> optionsByName)
Drops the existing table with the given name and creates a new one; basically a
#dropTable(String) followed
by a #createTable(boolean, String, Class, Map) . |
count, delete, delete, delete, delete, deleteAll, deleteAsynchronously, deleteAsynchronously, deleteAsynchronously, deleteAsynchronously, deleteAsynchronously, deleteAsynchronously, deleteAsynchronously, deleteAsynchronously, deleteById, exists, getConverter, getTableName, insert, insert, insert, insert, insertAsynchronously, insertAsynchronously, insertAsynchronously, insertAsynchronously, insertAsynchronously, insertAsynchronously, insertAsynchronously, insertAsynchronously, select, select, selectAll, selectBySimpleIds, selectOne, selectOne, selectOneAsynchronously, selectOneAsynchronously, selectOneAsynchronously, selectOneAsynchronously, selectOneById, update, update, update, update, updateAsynchronously, updateAsynchronously, updateAsynchronously, updateAsynchronously, updateAsynchronously, updateAsynchronously, updateAsynchronously, updateAsynchronously
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, executeAsynchronously, executeAsynchronously, executeAsynchronously, executeAsynchronously, executeAsynchronously, getResultSetUninterruptibly, getResultSetUninterruptibly, getResultSetUninterruptibly, 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, queryForListAsynchronously, queryForListAsynchronously, queryForListOfMap, queryForListOfMap, queryForListOfMapAsynchronously, queryForListOfMapAsynchronously, queryForListOfMapAsynchronously, queryForMap, queryForMap, queryForMapAsynchronously, queryForMapAsynchronously, queryForMapAsynchronously, queryForObject, queryForObject, queryForObject, queryForObject, queryForObjectAsynchronously, queryForObjectAsynchronously, queryForObjectAsynchronously, queryForObjectAsynchronously, queryForObjectAsynchronously, queryForObjectAsynchronously, truncate, truncate
void createTable(boolean ifNotExists, CqlIdentifier tableName, Class<?> entityClass, Map<String,Object> optionsByName)
ifNotExists
is true, this is a no-op and false is returned. If the
table doesn't exist, parameter ifNotExists
is ignored, the table is created and true is
returned.ifNotExists
- If true, will only create the table if it doesn't exist, else the create operation will be
ignored and the method will return false.tableName
- The name of the table.entityClass
- The class whose fields determine the columns created.optionsByName
- Table options, given by the string option name and the appropriate option value.void alterTable(CqlIdentifier tableName, Class<?> entityClass, boolean dropRemovedAttributeColumns)
tableName
- The name of the existing table.entityClass
- The class whose fields determine the columns added.dropRemovedAttributeColumns
- Whether to drop columns that exist on the table but that don't have
corresponding fields in the class. If true, this effectively becomes a synchronziation operation.void replaceTable(CqlIdentifier tableName, Class<?> entityClass, Map<String,Object> optionsByName)
#dropTable(String)
followed
by a #createTable(boolean, String, Class, Map)
.tableName
- The name of the table.entityClass
- The class whose fields determine the new table's columns.optionsByName
- Table options, given by the string option name and the appropriate option value.void dropTable(CqlIdentifier tableName)
tableName
- The name of the table.com.datastax.driver.core.TableMetadata getTableMetadata(String keyspace, CqlIdentifier tableName)
keyspace
- tableName
- Copyright © 2011-2015–2015 Pivotal Software, Inc.. All rights reserved.