Cassandra (3) Scala client

今天要用 IntelliJ 寫個 Scala 的 Cassandra client。使用 IntelliJ 的 sbt 專案可以輕鬆下載一些要用的 libs。

1. 修改 build.sbt:

新增一個 sbt 專案叫 CasssandraTest，加入下列 Dependencies：

name := "CasssandraTest"

version := "0.1"

scalaVersion := "2.12.6"

libraryDependencies += "com.datastax.cassandra" % "cassandra-driver-core" % "3.5.1"
libraryDependencies += "org.slf4j" % "slf4j-simple" % "1.6.4"
libraryDependencies += "org.apache.logging.log4j" % "log4j-core" % "2.11.1"

主要是用 datastax 的 cassandra driver 去和 server 聯繫。 如果不確定 libraryDependencies 可以去 mvn repository 查。

2. 撰寫程式：

有了 library 後剩下的事情就只是拿來用而已。

連到定義好的 keysapce 中並添加一筆資料：

package com.cooper
import com.datastax.driver.core._

object ProjectMain extends App {
  val cluster: Cluster = Cluster.builder().addContactPoint("192.168.0.128").build()
  val session = cluster.connect("my_keyspace")

  session.execute("SELECT * FROM my_keyspace.employees").forEach(println)

  session.execute(
    """INSERT INTO my_keyspace.employees (first_name, last_name)
      |VALUES (
      |'ooo',
      |'xxx');""".stripMargin)

  session.execute("SELECT * FROM my_keyspace.employees").forEach(println)

  session.close()
  cluster.close()
}