CassandraClientPool

Pooled Cassandra client and abstracted common operations.

• Startup/shutdown:

CassandraClientManager.initialize("< config file name >");

CassandraClientManager.shutdown();

• Create key space:

CassandraUtilities.createKeyspace("keyspace_test");

• Create column family:

CassandraUtilities.createColumnFamily("keyspace_test", "column_family_test");

• Store data:

CassandraUtilities.storeData("keyspace_test", "column_family_test", "row_key_test",
  "column_test", "column_value_test");

• Retrieve all rows in a column family:

Rows<String, String> rows = CassandraUtilities.queryAllRows(
  "keyspace_test", "column_family_test");
Iterator<Row<String, String>> rowIter = rows.iterator();

// Iterate over rows
while (rowIter.hasNext()) {
  Row<String, String> row = rowIter.next();
  
  // Get row key
  row.getKey();
  
  ColumnList<String> columns = row.getColumns();
  
  //Get column names
  columns.getColumnNames();
  
  Iterator<Column<String>> columnIter = columns.iterator();
  
  // Iterate over columns
  while (columnIter.hasNext()) {
    Column<String> column = columnIter.next();
    
    // Get column name
    column.getName();
    
    // Get column value
    column.getStringValue();
  }
}

• Retrieve a particular row:

ColumnList<String> columns = CassandraUtilities.queryRow(
  "keyspace_test", "column_family_test", "row_key_test");

• Retrieve a particular column of a particular row:

Column<String> column = CassandraUtilities.queryRowByColumn(
  "keyspace_test", "column_family_test", "row_key_test", "column_test");