赵岩的博客

报这个问题，log4j:WARN No appenders could be found for logger (com.datastax.driver.core.FrameCompressor).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
Exception in thread “main” com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: /222.197.221.227:9042 (com.datastax.driver.core.ConnectionException: [/222.197.221.227:9042] Unexpected error during transport initialization (com.datastax.driver.core.TransportException: [/222.197.221.227:9042] Connection has been closed)))
at com.datastax.driver.core.ControlConnection.reconnectInternal(ControlConnection.java:196)
at com.datastax.driver.core.ControlConnection.connect(ControlConnection.java:80)
at com.datastax.driver.core.Cluster$Manager.init(Cluster.java:1145)
at com.datastax.driver.core.Cluster.init(Cluster.java:149)
at com.datastax.driver.core.Cluster.connect(Cluster.java:225)
at com.zhaoyanblog.CassandraMain.main(CassandraMain.java:27)
下边是代码：
public class CassandraMain{
public static void main(String[] args)
{
QueryOptions options = new QueryOptions();
options.setConsistencyLevel(ConsistencyLevel.QUORUM);

Cluster cluster = Cluster.builder()
.addContactPoint(“222.197.221.227”)
.build();

Session session = cluster.connect();
session.execute(“CREATE KEYSPACE kp WITH replication = {‘class’: ‘SimpleStrategy’, ‘replication_factor’: 1};”);

// 閽堝keyspace鐨剆ession锛屽悗闈㈣〃鍚嶅墠闈笉鐢ㄥ姞keyspace
Session kpSession = cluster.connect(“kp”);
kpSession.execute(“CREATE TABLE tbl(a INT, b INT, c INT, PRIMARY KEY(a));”);

RegularStatement insert = QueryBuilder.insertInto(“kp”, “tbl”).values(new String[] {“a”, “b”, “c”}, new Object[] {1, 2, 3});
kpSession.execute(insert);

RegularStatement insert2 = QueryBuilder.insertInto(“kp”, “tbl”).values(new String[] {“a”, “b”, “c”}, new Object[] {3, 2, 1});
kpSession.execute(insert2);

RegularStatement delete = QueryBuilder.delete().from(“kp”, “tbl”).where(QueryBuilder.eq(“a”, 1));
kpSession.execute(delete);

RegularStatement update = QueryBuilder.update(“kp”, “tbl”).with(QueryBuilder.set(“b”, 6)).where(QueryBuilder.eq(“a”, 3));
kpSession.execute(update);

RegularStatement select = QueryBuilder.select().from(“kp”, “tbl”).where(QueryBuilder.eq(“a”, 3));
ResultSet rs = kpSession.execute(select);
Iterator iterator = rs.iterator();
while (iterator.hasNext())
{
Row row = iterator.next();
System.out.println(“a=” + row.getInt(“a”));
System.out.println(“b=” + row.getInt(“b”));
System.out.println(“c=” + row.getInt(“c”));
}
kpSession.close();
session.close();
cluster.close();
}

}