import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
Connection connection = null;
try {
Class.forName("org.apache.cassandra.cql.jdbc.CassandraDriver");
String url = "jdbc:cassandra://localhost:9042/keyspace_name";
connection = DriverManager.getConnection(url, "username", "password");
e.printStackTrace();
}
Statement statement = null;
try {
statement = connection.createStatement();
ResultSet resultSet = statement.executeQuery("SELECT * FROM table_name");
while (resultSet.next()) {
String columnValue = resultSet.getString("column_name");
System.out.println(columnValue);
}
} catch (SQLException e) {
e.printStackTrace();
}
try {
if (statement != null)
statement.close();
if (connection != null)
connection.close();
} catch (SQLException e) {
e.printStackTrace();
}
