Package | Description |
---|---|
org.mule.modules.cassandradb | |
org.mule.modules.cassandradb.api | |
org.mule.modules.cassandradb.utils.builders |
Modifier and Type | Method and Description |
---|---|
boolean |
CassandraDBConnector.addNewColumn(String table,
String keyspaceName,
AlterColumnInput input)
Adds a new column
|
boolean |
CassandraDBConnector.createKeyspace(CreateKeyspaceInput input)
Creates a new keyspace
|
boolean |
CassandraDBConnector.createTable(CreateTableInput input)
Creates a table(column family) in a specific keyspace; If no keyspace is specified the keyspace used for login will be used
|
void |
CassandraDBConnector.deleteColumnsValue(String table,
String keyspaceName,
Map<String,Object> payload)
Deletes values from an object specified by the where clause
|
void |
CassandraDBConnector.deleteRows(String table,
String keyspaceName,
Map<String,Object> payload)
Deletes an entire record
|
boolean |
CassandraDBConnector.dropKeyspace(String keyspaceName)
Drops the entire keyspace
|
boolean |
CassandraDBConnector.dropTable(String tableName,
String keyspaceName)
Drops an entire table form the specified keyspace or from the keyspace used for login if none is specified as an operation parameter
|
List<Map<String,Object>> |
CassandraDBConnector.executeCQLQuery(CQLQueryInput input)
Executes the raw input query provided
|
List<String> |
CassandraDBConnector.getTableNamesFromKeyspace(String keyspaceName)
Returns all the table names from the specified keyspace
|
void |
CassandraDBConnector.insert(String table,
String keyspaceName,
Map<String,Object> entity)
Executes the insert entity operation
|
List<Map<String,Object>> |
CassandraDBConnector.select(String query,
List<Object> parameters)
Executes a select query
|
void |
CassandraDBConnector.update(String table,
String keyspaceName,
Map<String,Object> entity)
Executes the update entity operation
|
Modifier and Type | Method and Description |
---|---|
boolean |
CassandraClient.createTable(CreateTableInput input) |
void |
CassandraClient.delete(String keySpace,
String table,
List<String> entity,
Map<String,Object> whereClause)
DELETE command can be used to:
- remove one or more columns from one or more rows in a table;
- remove the entire row (one or more);
- if column_name refers to a collection (a list or map), the parameter in parentheses indicates the term in the collection
to be deleted
|
List<Map<String,Object>> |
CassandraClient.executeCQLQuery(String cqlQuery,
List<Object> params) |
void |
CassandraClient.insert(String keySpace,
String table,
Map<String,Object> entity) |
List<Map<String,Object>> |
CassandraClient.select(String query,
List<Object> params) |
void |
CassandraClient.update(String keySpace,
String table,
Map<String,Object> entity,
Map<String,Object> whereClause)
Update the table @param table using the keySpace @param keySpace
|
Modifier and Type | Method and Description |
---|---|
static com.datastax.driver.core.schemabuilder.SchemaStatement |
HelperStatements.createTable(String keyspace,
CreateTableInput input) |
Copyright © 2010–2019. All rights reserved.