欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

使用java操作cassandra  

程序员文章站 2022-03-20 17:25:02
...

    cassandra的java驱动有很多,这里使用datastax的驱动。在maven的pom.xml中加入依赖:

<dependency>
	<groupId>com.datastax.cassandra</groupId>
	<artifactId>cassandra-driver-core</artifactId>
	<version>3.1.0</version>
</dependency>

    1.连接cassandra集群(单机也是这样)

Cluster cluster = Cluster.builder().addContactPoint("127.0.0.1").withPort(9042).build();

    2.获取连接

Session session = cluster.connect();

   3.执行cql查询

ResultSet rs = session.execute("select release_version from system.local");

   4.获取返回值

Row row = rs.one();
System.out.println(row.getString("release_version"));

    5.关闭连接

session.close();

    6.关闭集群

cluster.close();

    就是这么简单,总体操作和jdbc操作mysql流程差不多,而且它里面的api和jdbc也很类似。