java实现cassandra的增删改查
Posted
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了java实现cassandra的增删改查相关的知识，希望对你有一定的参考价值。
需要导入jar:
cassandra-driver-core-3.0.0-beta1-bb1bce4-SNAPSHOT-shaded.jar
guava-18.0.jar
log4j-1.2.17.jar
metrics-core-3.1.0.jar
slf4j-api-1.7.7.jar
slf4j-log4j12-1.7.5.jar
代码：
Cluster cluster = Cluster.builder().addContactPoint("192.168.1.103").build();
Session session = cluster.connect();
String cql = "select * from demodb.afttre;";
ResultSet resultSet = session.execute(cql);
Iterator<Row> iterator = resultSet.iterator();
while (iterator.hasNext()) {
Row row = iterator.next();
System.out.println(row.getObject("month"));
}
session.close();
cluster.close();以上是关于java实现cassandra的增删改查的主要内容，如果未能解决你的问题，请参考以下文章