java实现cassandra的增删改查，javacassandra
需要导入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
代码：
| 1 2 3 4 5 6 7 8 9 10 11 |
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();
|
本文转自 yntmdr 51CTO博客，原文链接：http://blog.51cto.com/yntmdr/1738347，如需转载请自行联系原作者
本站文章为和通数据库网友分享或者投稿，欢迎任何形式的转载，但请务必注明出处.
同时文章内容如有侵犯了您的权益，请联系QQ：970679559，我们会在尽快处理。