Jassandra is a Java Cassandra client.

2.2.0 released, with support to Cassandra 1.0.8, and passed all existing test cases. Check it out!

There are three downloads from this project: * 2.2.0 it supports Cassandra 1.0.8 * 2.1.0 it supports Cassandra 0.7.0 * 1.3.1 it supports 0.6.1 to 0.6.4.

中文（简体）

It's designed to be simple and intuitive, esp. for the developers coming from JDBC background.

Latest Updates

• 2012.03.10: 2.2.0 released: support 1.0.8.
• 2011.06.06: 2.1.0 released: with support for empty key range, binary keys and other bug fixes.
• 2011.03.05: 2.0.0 released: with support for Cassandra 0.7.0, and passed all existing test cases.
• 2011.01.28: 2.0.0 RC 1 released: with support for Cassandra 0.7.0, and passed all existing test cases.
• 2010.08.31: 2.0.0 beta 1 released: with support for Cassandra 0.7.0 beta 1.
• 2010.08.08: 1.3.1 released: performance improvements (Issue 35) and tested against Cassandra 0.6.4.
• 2010.07.11: 1.3.0 released: please check Migration Guide for guideline to migrate to new version.

Quick Links

• Download: http://code.google.com/p/jassandra/downloads/list
• Changelog: http://code.google.com/p/jassandra/wiki/changlog
• Dependencies: click here.

Documentation

• ConnectionUri gives how to specify the connection uri for failover and load balance.
• Java Doc: click here

Future Plan

1. Keep update to date with latest version of Cassandra.
2. API improvements: make the library more simple and intuitive.
3. Support more interface (currently, only Thrift is build-in)

Links

1. Cassandra: this is where all start with
2. Hector: include extensive jmx counters, failover and connection pooling.

Sample Code

Here is a quick sample: ``` public void testSample() throws JassandraException { final String userName = "jsmith";

// 1. Gets a connection
Properties info = new Properties();
info.put(DriverManager.CONSISTENCY_LEVEL,
    ConsistencyLevel.ONE.toString());

IConnection connection = DriverManager.getConnection(
    "thrift://localhost:9160", info);
try {
  // 2. Get a KeySpace by name
  IKeySpace keySpace = connection.getKeySpace("Keyspace1");

  // 3. Get a ColumnFamily by name
  IColumnFamily cf = keySpace.getColumnFamily("Standard2");

  // 4. Insert like this
  long now = System.currentTimeMillis();
  ByteArray nameFirst = ByteArray.ofASCII("first");
  ByteArray nameLast = ByteArray.ofASCII("last");
  ByteArray nameAge = ByteArray.ofASCII("age");
  ByteArray valueLast = ByteArray.ofUTF8("Smith");
  IColumn colFirst = new Column(nameFirst, ByteArray.ofUTF8("John"),
      now);
  cf.insert(userName, colFirst);

  IColumn colLast = new Column(nameLast, valueLast, now);
  cf.insert(userName, colLast);

  IColumn colAge = new Column(nameAge, ByteArray.ofLong(42), now);
  cf.insert(userName, colAge);

  // 5. Select like this
  ICriteria criteria = cf.createCriteria();
  criteria.keyList(Lists.newArrayList(userName))
      .columnRange(nameAge, nameLast, 10);
  Map<String, List<IColumn>> map = criteria.select();
  List<IColumn> list = map.get(userName);
  Assert.assertEquals(3, list.size());
  Assert.assertEquals(valueLast, list.get(2).getValue());

  // 6. Delete like this
  cf.delete(userName, colFirst);
  map = criteria.select();
  Assert.assertEquals(2, map.get(userName).size());

  // 7. Get count like this
  criteria = cf.createCriteria();
  criteria.keyList(Lists.newArrayList(userName));
  int count = criteria.count();
  Assert.assertEquals(2, count);
} finally {
  // 8. Don't forget to close the connection.
  connection.close();
}

} ```