Cassandra之jdbc-cassandra使用笔记,
最近要弄java程序访问cassandra进行读取数据,上网搜索之。。。
之前有过jdbc-mysql的使用,有这样的com.mysql.jdbc.Driver包,想必cassandra也应该有吧。
网上的少数几篇文章有简明的讲解,可参考这位仁兄写的也不错jdbc链接cassandra
我这边主要记录下具体的过程
我用的是
org.apache.cassandra.cql.jdbc.CassandraDriver
这个driver包 下载链接地址
有了这个包我们直接引入就可以调用其api,直接操作cassandra了。
自测用了一个比较普遍的代码
try {
//CassandraDriver Class.forName("org.apache.cassandra.cql.jdbc.CassandraDriver");
//直接调用getConnection去连接cassandra,如果是有用户名密码,需要跟上参数user/passwd如下。keyspace是数据库对应的space
Connection con = DriverManager.getConnection("jdbc:cassandra://127.0.0.1/keyspace", "user", "passwd");
//测试一条简单的查询语句
String t = "SELECT * FROM table_name";
Statement statement = con.createStatement();
ResultSet rs = statement.executeQuery(t);//执行查询语句
while (rs.next()) {//打印查询到数据条目内容
System.out.print(rs.getString(1) + ":" + rs.getString(2) + "\t"
+ rs.getString(3) + "\t" + rs.getString(4) + "\t"
+ rs.getString(5) + "\t" + rs.getString(6) + "\t"
+ "\n");
}
rs.close();
statement.close();
} catch (Exception e) {
e.printStackTrace();
}以上是主要的测试主体程序,当然还需要import一些包。
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Statement;当然到这里可能还不行,运行不成功,因为他还得需要一些依赖库。
大概就是以上这些了,费劲啊找的,统一下载地址 点这里 进不去可能需要翻一下wall了。
java程序直接引入那些包就行了。
maven控制的要加入pom文件dependency
<dependency>
<groupId>org.apache-extras.cassandra-jdbc</groupId>
<artifactId>cassandra-jdbc</artifactId>
<version>1.2.5</version>
</dependency>
<dependency>
<groupId>org.apache.cassandra</groupId>
<artifactId>cassandra-clientutil</artifactId>
<version>1.2.5</version>
</dependency>等一大堆.......
本站文章为和通数据库网友分享或者投稿,欢迎任何形式的转载,但请务必注明出处.
同时文章内容如有侵犯了您的权益,请联系QQ:970679559,我们会在尽快处理。