import java.sql.*; public class CassandraJDBCExample { public static void main(String[] args) { try { Class.forName("com.ay.jdbc.cassandra.CassandraDriver"); Connection connection = DriverManager.getConnection("jdbc:ay-cassandra://localhost:9042/keyspace", "username", "password"); Statement statement = connection.createStatement(); ResultSet resultSet = statement.executeQuery("SELECT * FROM table"); while (resultSet.next()) { System.out.println(resultSet.getString("column1")); } resultSet.close(); statement.close(); connection.close(); } catch (Exception e) { e.printStackTrace(); } } }


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