scala-cassandra 介绍
scala-cassandra 实现了对 Cassandra 的
DataStax Java 驱动程序的 Scala 封装。
示例代码：
class ScalaCassandraSpec extends Specification {
CQL.init()
CQL.startup("metastore")
Meta.createTable()
"Meta objects" should {
"be able to store & retrieve their binary state" in {
//we use a Thrift object here for portability of the data stored
val tMeta = new TMeta()
//setting up some randomness so we can confirm what we are writing is what we get back
val MetaUUID = UUID.randomUUID()
val dataum = Random.alphanumeric.take(1000000).mkString
tMeta.setId(MetaUUID.toString)
tMeta.setDatum(dataum)
Meta.save(tMeta) //Saved to C*
val someNewTMeta = Meta(MetaUUID)
someNewTMeta.getId() must_== MetaUUID.toString
someNewTMeta.getDatum() must_== dataum
}
}
}