bash
cassandra
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;
public class CassandraJDBCTest {
public static void main(String[] args) throws Exception {
String url = "jdbc:cassandra://localhost:9042/keyspace";
String user = "your_username";
String password = "your_password";
Class.forName("org.apache.cassandra.jdbc.CassandraDriver");
Connection conn = DriverManager.getConnection(url, user, password);
Statement stmt = conn.createStatement();
String sql = "SELECT * FROM table_name";
ResultSet rs = stmt.executeQuery(sql);
while (rs.next()) {
String column1 = rs.getString("column1");
int column2 = rs.getInt("column2");
System.out.println("column1: " + column1 + ", column2: " + column2);
}
rs.close();
stmt.close();
conn.close();
}
}
bash
javac CassandraJDBCTest.java
bash
java CassandraJDBCTest
