datastax java driver for cassandra 入门

安装&启动cassandra

​​http://www.datastax.com/2012/01/getting-started-with-cassandra​​

安装maven插件

通过maven引入jar包

​​http://www.datastax.com/doc-source/developer/java-driver/#quick_start/qsSimpleClientCreate_t.html​​

package com.example.cassandra;


 import com.datastax.driver.core.Cluster;
 import com.datastax.driver.core.Host;
 import com.datastax.driver.core.Metadata;


 public class SimpleClient {
     private Cluster cluster;


     public void connect(String node) {
         cluster = Cluster.builder().addContactPoint(node).build();
         Metadata metadata = cluster.getMetadata();
         System.out.printf("Connected to cluster: %s\n",
                 metadata.getClusterName());
         for (Host host : metadata.getAllHosts()) {
             System.out.printf("Datatacenter: %s; Host: %s; Rack: %s\n",
                     host.getDatacenter(), host.getAddress(), host.getRack());
         }
     }


     public void close() {
         cluster.shutdown();
     }


     public static void main(String[] args) {
         SimpleClient client = new SimpleClient();
         client.connect("192.168.2.14");
         client.close();
     }
 }