import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.Statement; public class CassandraJdbcExample { public static void main(String[] args) { try { Class.forName("com.github.cassandra.jdbc.CassandraDriver"); Connection connection = DriverManager.getConnection("jdbc:c*:DataSourceURL"); Statement statement = connection.createStatement(); ResultSet resultSet = statement.executeQuery("SELECT * FROM my_table"); while (resultSet.next()) { String data = resultSet.getString("data"); System.out.println(data); } resultSet.close(); statement.close(); connection.close(); } catch (Exception e) { e.printStackTrace(); } } } Connection connection = DriverManager.getConnection("jdbc:c*:DataSourceURL?cassandra.host=myhost&cassandra.port=9042&cassandra.keyspace=mykeyspace");


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