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(); } } }


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