通过scala连接cassandra集群

Question

我是scala和cassandra的新手.我知道使用hector将cassandra与java连接起来.但我不知道如何通过scala连接cassandra.我想要一个简单的例子.

Answer 1

我正在使用datastax java驱动程序.它的开发仍然在github上运行.我早些看了赫克托耳,但似乎很快就死了.这里的文档很有帮助:http://www.datastax.com/documentation/developer/java-driver/1.0/webhelp/index.html#java-driver/quick_start/qsQuickstart_c.html.我将第一个例子翻译成了scala.另外,请查看类型安全激活器中的akka​​-cassandra示例.干杯.

object Hello extends App {

  import com.datastax.driver.core.Cluster;
  import com.datastax.driver.core.Host;
  import com.datastax.driver.core.Metadata;
  import scala.collection.JavaConversions._

  var cluster: Cluster = null
  private var session: Session = null

  def connect(node: String) {
    cluster = Cluster.builder().addContactPoint(node).build()
    val metadata = cluster.getMetadata()
    printf("Connected to cluster: %s\n",
      metadata.getClusterName())
    metadata.getAllHosts() map {
      case host =>
        printf("Datatacenter: %s; Host: %s; Rack: %s\n",
          host.getDatacenter(), host.getAddress(), host.getRack())
    }
  }

  def close() {
    cluster.shutdown()
  }

  this.connect("127.0.0.1");
  this.close();
}