import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class CassandraJdbcExample {
public static void main(String[] args) {
try {
Class.forName("com.datastax.oss.driver.api.core.CqlSessionBuilder");
Connection connection = DriverManager.getConnection("jdbc:cassandra://localhost:9042/keyspace");
PreparedStatement preparedStatement = connection.prepareStatement("SELECT * FROM table");
ResultSet resultSet = preparedStatement.executeQuery();
while (resultSet.next()) {
String columnName = resultSet.getString("column_name");
int columnValue = resultSet.getInt("column_value");
System.out.println(columnName + ": " + columnValue);
}
resultSet.close();
preparedStatement.close();
connection.close();
e.printStackTrace();
}
}
}