import com.ayasoftware.ca.jdbc.CassandraDriver;
import java.sql.*;
Class.forName("com.ayasoftware.ca.jdbc.CassandraDriver");
String url = "jdbc:cassandra://localhost:9042/keyspace";
Connection connection = DriverManager.getConnection(url);
try {
Statement statement = connection.createStatement();
ResultSet resultSet = statement.executeQuery("SELECT * FROM table");
while (resultSet.next()) {
String columnValue = resultSet.getString("column_name");
}
resultSet.close();
statement.close();
} catch (SQLException e) {
e.printStackTrace();
}
try {
Statement statement = connection.createStatement();
String insertQuery = "INSERT INTO table (column1, column2) VALUES ('value1', 'value2')";
int rowsAffected = statement.executeUpdate(insertQuery);
statement.close();
} catch (SQLException e) {
e.printStackTrace();
}
try {
Statement statement = connection.createStatement();
String updateQuery = "UPDATE table SET column1 = 'newValue' WHERE column2 = 'value2'";
int rowsAffected = statement.executeUpdate(updateQuery);
statement.close();
} catch (SQLException e) {
e.printStackTrace();
}
try {
Statement statement = connection.createStatement();
String deleteQuery = "DELETE FROM table WHERE column1 = 'value1'";
int rowsAffected = statement.executeUpdate(deleteQuery);
statement.close();
} catch (SQLException e) {
e.printStackTrace();
}
