小编faz*_*zal的帖子

我已尝试使用以下代码在本地系统上连接CASSANDRA数据库.

这是我的代码:

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class DBConnect {


public static void main(String[] args) throws Exception{

Connection con = null;
try {
Class.forName("org.apache.cassandra.cql.jdbc.CassandraDriver");
con = DriverManager.getConnection("jdbc:cassandra://localhost:9160/mykeyspace");

   String query = "select * from users";

   Statement stmt = con.createStatement();
   ResultSet result = stmt.executeQuery(query);

   while (result.next()) {
    System.out.println(result.getString("user_id"));
    System.out.println(result.getString("fname"));
    System.out.println(result.getString("lname"));
   }

  } catch (ClassNotFoundException e) {
   e.printStackTrace();
  } catch (SQLException e) {
   e.printStackTrace();
  } finally {
   if (con != null) {
    try {
     con.close();
    } catch …