cassandra 之 jdbc 使用【java、scala】

1、數據庫創建

參考接上文cassandra入門 http://www.cnblogs.com/piaolingzxh/p/4197833.html

2、下載jdbc驅動源碼，構建jar包

源碼下載地址：https://bitbucket.org/openscg/cassandra2-jdbc/src，最新包可能會構建失敗，請下載2.1.1版的

當然，你也可以使用我構建好的，地址：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();
		}

	}
}

運行結果

　　

 

4、scala 連接cassandra

創建scala項目，引用jar包，（和使用java一樣）

創建scala類，輸入以下代碼，

import java.sql.DriverManager
import org.bigsql.cassandra2.jdbc.CassandraDriver

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
}
}

運行結果