import java.sql.*;
public class CassandraJDBCDemo {
public static void main(String[] args) {
try {
Class.forName("com.datastax.cassandra.jdbc.CassandraDriver");
String url = "jdbc:cassandra://localhost:9042/keyspace_name";
String username = "your_username";
String password = "your_password";
Connection connection = DriverManager.getConnection(url, username, password);
Statement statement = connection.createStatement();
String query = "SELECT * FROM table_name";
ResultSet resultSet = statement.executeQuery(query);
while (resultSet.next()) {
String column1Value = resultSet.getString("column1_name");
int column2Value = resultSet.getInt("column2_name");
// ...
}
resultSet.close();
statement.close();
connection.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
