org.mule.modules.cassandradb.api

Class CassandraClient

java.lang.Object

org.mule.modules.cassandradb.api.CassandraClient

public final class CassandraClient
extends Object

Constructor Summary

Constructors

Constructor and Description
CassandraClient()

Method Summary

Modifier and Type	Method and Description
boolean	addNewColumn(String tableName, String customKeyspaceName, String columnName, com.datastax.driver.core.DataType columnType)
static CassandraClient	buildCassandraClient(ConnectionParameters connectionParameters) Connect to Cassandra Cluster specified by provided host IP address and port number.
boolean	changeColumnType(String tableName, String customKeyspaceName, AlterColumnInput input)
void	close()
static void	connectWithAdvancedParams(ConnectionParameters connectionParameters, com.datastax.driver.core.Cluster.Builder clusterBuilder)
static void	connectWithBasicParams(ConnectionParameters connectionParameters, com.datastax.driver.core.Cluster.Builder clusterBuilder)
boolean	createKeyspace(CreateKeyspaceInput input)
boolean	createTable(CreateTableInput input)
void	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
boolean	dropColumn(String tableName, String customKeyspaceName, String columnName)
boolean	dropKeyspace(String keyspaceName)
boolean	dropTable(String tableName, String customKeyspaceName)
List<Map<String,Object>>	executeCQLQuery(String cqlQuery, List<Object> params)
com.datastax.driver.core.TableMetadata	fetchTableMetadata(String keyspaceUsed, String tableName) Fetches table metadata using DataStax java driver, based on the keyspace provided
List<com.datastax.driver.core.KeyspaceMetadata>	getKeyspaces()
String	getLoggedKeyspace()
List<String>	getTableNamesFromKeyspace(String customKeyspaceName)
void	insert(String keySpace, String table, Map<String,Object> entity)
boolean	renameColumn(String tableName, String customKeyspaceName, String oldColumnName, String newColumnName)
List<Map<String,Object>>	select(String query, List<Object> params)
void	update(String keySpace, String table, Map<String,Object> entity, Map<String,Object> whereClause) Update the table @param table using the keySpace @param keySpace

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CassandraClient

public CassandraClient()

Method Detail

buildCassandraClient

public static CassandraClient buildCassandraClient(ConnectionParameters connectionParameters)
                                            throws org.mule.api.ConnectionException

Connect to Cassandra Cluster specified by provided host IP address and port number.

Parameters:

connectionParameters - the connection parameters

Returns:

CassandraClient created

Throws:

org.mule.api.ConnectionException - if any error occurs when trying to connect

connectWithBasicParams

public static void connectWithBasicParams(ConnectionParameters connectionParameters,
                                          com.datastax.driver.core.Cluster.Builder clusterBuilder)
                                   throws org.mule.api.ConnectionException

Throws:

org.mule.api.ConnectionException

connectWithAdvancedParams

public static void connectWithAdvancedParams(ConnectionParameters connectionParameters,
                                             com.datastax.driver.core.Cluster.Builder clusterBuilder)
                                      throws org.mule.api.ConnectionException

Throws:

org.mule.api.ConnectionException

createKeyspace

public boolean createKeyspace(CreateKeyspaceInput input)

dropKeyspace

public boolean dropKeyspace(String keyspaceName)

createTable

public boolean createTable(CreateTableInput input)
                    throws CassandraDBException

Throws:

CassandraDBException

changeColumnType

public boolean changeColumnType(String tableName,
                                String customKeyspaceName,
                                AlterColumnInput input)

addNewColumn

public boolean addNewColumn(String tableName,
                            String customKeyspaceName,
                            String columnName,
                            com.datastax.driver.core.DataType columnType)

dropColumn

public boolean dropColumn(String tableName,
                          String customKeyspaceName,
                          String columnName)

renameColumn

public boolean renameColumn(String tableName,
                            String customKeyspaceName,
                            String oldColumnName,
                            String newColumnName)

dropTable

public boolean dropTable(String tableName,
                         String customKeyspaceName)

executeCQLQuery

public List<Map<String,Object>> executeCQLQuery(String cqlQuery,
                                                List<Object> params)
                                         throws CassandraDBException

Throws:

CassandraDBException

getTableNamesFromKeyspace

public List<String> getTableNamesFromKeyspace(String customKeyspaceName)

fetchTableMetadata

public com.datastax.driver.core.TableMetadata fetchTableMetadata(String keyspaceUsed,
                                                                 String tableName)

Fetches table metadata using DataStax java driver, based on the keyspace provided

Parameters:

keyspaceUsed - the Keyspace to fetch from

tableName - the Table from keyspace

Returns:

the table metadata as returned by the driver.

insert

public void insert(String keySpace,
                   String table,
                   Map<String,Object> entity)
            throws CassandraDBException

Throws:

CassandraDBException

update

public void update(String keySpace,
                   String table,
                   Map<String,Object> entity,
                   Map<String,Object> whereClause)
            throws CassandraDBException

Update the table @param table using the keySpace @param keySpace

Throws:

CassandraDBException

delete

public void delete(String keySpace,
                   String table,
                   List<String> entity,
                   Map<String,Object> whereClause)
            throws CassandraDBException

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

Parameters:

keySpace - Keyspace to delete from

table - Table to delete from

entity - Entity to be removed

whereClause - WHERE clause condition

Throws:

CassandraDBException - if something goes wrong

select

public List<Map<String,Object>> select(String query,
                                       List<Object> params)
                                throws CassandraDBException

Throws:

CassandraDBException

getKeyspaces

public List<com.datastax.driver.core.KeyspaceMetadata> getKeyspaces()

getLoggedKeyspace

public String getLoggedKeyspace()

close

public void close()