import com.ayasoftware.cassandra.jdbc.CassandraConnection; import java.sql.Connection; import java.sql.DriverManager; public class CassandraExample { public static void main(String[] args) { Connection connection = null; try { Class.forName("com.ayasoftware.cassandra.jdbc.CassandraDriver"); connection = DriverManager.getConnection("jdbc:cassandra://hostname:port/database", "username", "password"); } catch (Exception e) { e.printStackTrace(); } finally { try { if (connection != null) { connection.close(); } } catch (Exception e) { e.printStackTrace(); } } } } import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.Statement; public class CassandraExample { public static void main(String[] args) { Connection connection = null; try { Statement statement = connection.createStatement(); ResultSet resultSet = statement.executeQuery("SELECT * FROM table_name"); while (resultSet.next()) { String column1 = resultSet.getString("column1"); int column2 = resultSet.getInt("column2"); // ... } resultSet.close(); statement.close(); } catch (Exception e) { e.printStackTrace(); } finally { } } } import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; public class CassandraExample { public static void main(String[] args) { Connection connection = null; try { PreparedStatement preparedStatement = connection.prepareStatement("INSERT INTO table_name (column1, column2) VALUES (?, ?)"); preparedStatement.setString(1, "value1"); preparedStatement.setInt(2, 123); preparedStatement.executeUpdate(); preparedStatement.close(); } catch (Exception e) { e.printStackTrace(); } finally { } } } import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; public class CassandraExample { public static void main(String[] args) { Connection connection = null; try { PreparedStatement preparedStatement = connection.prepareStatement("UPDATE table_name SET column1 = ? WHERE column2 = ?"); preparedStatement.setString(1, "new_value"); preparedStatement.setInt(2, 123); preparedStatement.executeUpdate(); preparedStatement.close(); } catch (Exception e) { e.printStackTrace(); } finally { } } } import java.sql.Connection; import java.sql.DriverManager; import java.sql.PreparedStatement; public class CassandraExample { public static void main(String[] args) { Connection connection = null; try { PreparedStatement preparedStatement = connection.prepareStatement("DELETE FROM table_name WHERE column2 = ?"); preparedStatement.setInt(1, 123); preparedStatement.executeUpdate(); preparedStatement.close(); } catch (Exception e) { e.printStackTrace(); } finally { } } }


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