参考接上文cassandra入门 http://www.cnblogs.com/piaolingzxh/p/4197833.htmlhtml
源码下载地址:https://bitbucket.org/openscg/cassandra2-jdbc/src,最新包可能会构建失败,请下载2.1.1版的java
固然,你也能够使用我构建好的,地址:http://download.csdn.net/detail/piaolingzxh/8320131sql
注:使用maven构建,数据库
至于为啥要引入这些包,能够参看下载的jdbc源码示例,examples\runTest.shmaven
jar包位置说明:下图这两个包直接使用jdbc驱动源码下lib\目录里的版本,其余的使用cassandra安装目录\lib下的版本.net
代码以下:scala
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(); } } }
建立scala项目,引用jar包,(和使用java同样)3d
建立scala类,输入如下代码,htm
import java.sql.DriverManager
import org.bigsql.cassandra2.jdbc.CassandraDriverblog
object cassandra {
import java.sql.{ Connection, DriverManager, ResultSet }
def main(args: Array[String]): Unit = {
classOf[org.bigsql.cassandra2.jdbc.CassandraDriver]
val db = DriverManager.getConnection("jdbc:cassandra://127.0.0.1:9160/demo")
val st = db.createStatement
val res = st.executeQuery("select * from demo.users")
while (res.next) {
for (i <- 1 to res.getMetaData.getColumnCount) {
val r = res.getString(i).toString
print("\t" + r)
}
println
}
db.close
}
}
运行结果