hypertino / cassandra-binders   0.4.0

BSD 3-clause "New" or "Revised" License GitHub

Scala data binder for Cassandra 2.x

Scala versions: 2.12 2.11


Build Status Maven Central Join the chat at https://gitter.im/Hypertino/binders

This is a Scala data binder library for Cassandra based upon a DataStax Java Driver for Cassandra.


Here is the sample of Scala class that is initialized with Cassandra session and allows you to do select/insert of some user data.

class Db(session: com.datastax.driver.core.Session) {

  import ExecutionContext.Implicits.global

  implicit val cache = new SessionQueryCache[PlainConverter](session)

  // class for binding input/output parameters
  case class User(userId: Int, name: String)

  def insertUser(user: User): Future[Unit] = cql"insert into users(userid, name) values (?, ?)".bind(user).execute()

  // returns Future[Iterator[User]]
  def selectAllUsers: Future[Iterator[User]] = cql"select * from users".all[User]

  // if no user is found will throw NoRowsSelectedException
  def selectUser(userId: Int) = cql"select * from users where userId = $userId".one[User]

  // if no user is found will return None, otherwise Some(User)
  def selectUserIfFound(userId: Int) = cql"select * from users where userId = $userId".oneOption[User]

And this class could be used like this:

val cluster = Cluster.builder().addContactPoint("").build()
val session = cluster.connect("binder_test")

val db = new Db(session)

Await.result(db.insertUser(db.User(9, "John")), 10 seconds)

val users = Await.result(db.selectAllUsers, 10 seconds)


For the unit tests and sample application working local instance of Cassandra is required. Please see also sample project inside samples/ folder and schema in db/dbscript.cql


To use library, add this line to the build.sbt file:

libraryDependencies += "com.hypertino" %% "cassandra-binders" % "0.3-SNAPSHOT"


Product licensed under BSD 3-clause as stated in file LICENSE