import java.sql.*; public class CassandraJdbcExample { public static void main(String[] args) { try { Class.forName("com.github.adejanovski.cassandra.jdbc.CassandraDriver"); Connection connection = DriverManager.getConnection("jdbc:apache:cassandra://localhost:9042/mykeyspace", "username", "password"); Statement statement = connection.createStatement(); ResultSet resultSet = statement.executeQuery("SELECT * FROM mytable"); while (resultSet.next()) { String name = resultSet.getString("name"); int age = resultSet.getInt("age"); System.out.println("Name: " + name + ", Age: " + age); } resultSet.close(); statement.close(); connection.close(); } catch (Exception e) { e.printStackTrace(); } } }


上一篇:
下一篇:
切换中文