Cassandra based EmployeeDb component

CassandraEmployeeDbComp.scala

trait CassandraEmployeeDbComp extends EmployeeDbComp {

  this: CakezCassandraCluster =>

  val employeeDb = new CassandraEmployeeDb

  class CassandraEmployeeDb extends EmployeeDb {

    def logger = LoggerFactory.getLogger(this.getClass)

    override def createEmployee(employee: Employee) = {
      logger.debug(s"Create employee with id: ${employee.empId} name: ${employee.name}")

      // cassandra based insert query
      val statement = QueryBuilder.insertInto("employee")
        .value("emp_id", employee.empId)
        .value("name", employee.name)
        .value("department", employee.department)
      session.execute(statement)
    }

    override def getEmployee(empId: Int): Employee = {
      logger.debug(s"get employee with ID: ${empId}")

      // cassandra based slect query
      val selectStmt = select().all()
        .from("employee")
        .where(QueryBuilder.eq("emp_id", empId))
        .limit(1)

      val resultSet = session.execute(selectStmt)
      val row = resultSet.one()

      Employee(row.getInt("emp_id"), row.getString("name"), row.getString("department"))
    }
  }

}