<dependency> <groupId>com.ay.jdbc</groupId> <artifactId>cassandra-jdbc-driver</artifactId> </dependency> import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; public class CassandraJDBCExample { public static void main(String[] args) { String url = "jdbc:cassandra://localhost:9042/keyspace_name"; String username = "your_username"; String password = "your_password"; try (Connection connection = DriverManager.getConnection(url, username, password)) { } catch (SQLException e) { e.printStackTrace(); } } } import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; public class CassandraJDBCExample { public static void main(String[] args) { String url = "jdbc:cassandra://localhost:9042/keyspace_name"; String username = "your_username"; String password = "your_password"; try (Connection connection = DriverManager.getConnection(url, username, password)) { String query = "SELECT * FROM table_name"; try (Statement statement = connection.createStatement()) { ResultSet resultSet = statement.executeQuery(query); while (resultSet.next()) { } } } catch (SQLException e) { e.printStackTrace(); } } }


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