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

代碼：

<code>Cluster cluster = Cluster.builder().addContactPoint(</code><code>"192.168.1.103"</code><code>).build();</code>

<code>Session session = cluster.connect();</code>

<code>String cql = </code><code>"select * from demodb.afttre;"</code><code>;</code>

<code>ResultSet resultSet = session.execute(cql);</code>

<code>Iterator&lt;Row&gt; iterator = resultSet.iterator();</code>

<code>while</code> <code>(iterator.hasNext()) {</code>

<code>Row row = iterator.next();</code>

<code>System.out.println(row.getObject(</code><code>"month"</code><code>));</code>

<code>}</code>

<code>session.close();</code>

<code>cluster.close();</code>

本文轉自 yntmdr 51CTO部落格，原文連結：http://blog.51cto.com/yntmdr/1738347，如需轉載請自行聯系原作者