首页 > 代码库 > jdbc 连接 cassandra
jdbc 连接 cassandra
1、数据库创建
参考接上文cassandra入门 http://www.cnblogs.com/piaolingzxh/p/4197833.html
2、下载jdbc驱动源码，构建jar包
源码下载地址：https://bitbucket.org/openscg/cassandra2-jdbc/src，
当然，你也可以使用我构建好的，地址：http://download.csdn.net/detail/piaolingzxh/8320131
注：使用maven构建，
3、使用java连接cassandra
创建java项目，引入这些jar包，
至于为啥要引入这些包，可以参看下载的jdbc源码示例，examples\runTest.sh
jar包位置说明：下图这两个包直接使用jdbc驱动源码下lib\目录里的版本，其他的使用cassandra安装目录\lib下的版本
最后编写代码，运行
代码如下：
import java.sql.Connection;import java.sql.DriverManager;import java.sql.PreparedStatement;import java.sql.ResultSet;import java.sql.Statement;public class cassandra2 { public static void main(String[] a) { try { Class.forName("org.bigsql.cassandra2.jdbc.CassandraDriver"); Connection con = DriverManager .getConnection("jdbc:cassandra://127.0.0.1:9160/demo"); String query = "select * from demo.users"; Statement statement = con.createStatement(); ResultSet rs = statement.executeQuery(query); 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(); } }}运行结果
jdbc 连接 cassandra
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。