Вы можете удалить данные из таблицы, используя команду DELETE . Его синтаксис выглядит следующим образом —
DELETE FROM <identifier> WHERE <condition>;
пример
Предположим, что в Кассандре есть таблица с именем emp, имеющая следующие данные:
emp_id | emp_name | emp_city | emp_phone | emp_sal |
---|---|---|---|---|
1 | баран | Хайдарабад | 9848022338 | 50000 |
2 | Робин | Хайдарабад | 9848022339 | 40000 |
3 | рахман | Chennai | 9848022330 | 45000 |
Следующая инструкция удаляет столбец emp_sal последней строки —
cqlsh:tutorialspoint> DELETE emp_sal FROM emp WHERE emp_id=3;
верификация
Используйте оператор SELECT, чтобы проверить, были ли данные удалены или нет. Если вы проверите таблицу emp с помощью SELECT, она выдаст следующий вывод:
cqlsh:tutorialspoint> select * from emp; emp_id | emp_city | emp_name | emp_phone | emp_sal --------+-----------+----------+------------+--------- 1 | Hyderabad | ram | 9848022338 | 50000 2 | Delhi | robin | 9848022339 | 50000 3 | Chennai | rahman | 9848022330 | null (3 rows)
Поскольку мы удалили зарплату Рахмана, вместо зарплаты вы увидите нулевое значение.
Удаление всей строки
Следующая команда удаляет всю строку из таблицы.
cqlsh:tutorialspoint> DELETE FROM emp WHERE emp_id=3;
верификация
Используйте оператор SELECT, чтобы проверить, были ли данные удалены или нет. Если вы проверите таблицу emp с помощью SELECT, она выдаст следующий вывод:
cqlsh:tutorialspoint> select * from emp; emp_id | emp_city | emp_name | emp_phone | emp_sal --------+-----------+----------+------------+--------- 1 | Hyderabad | ram | 9848022338 | 50000 2 | Delhi | robin | 9848022339 | 50000 (2 rows)
Так как мы удалили последнюю строку, в таблице осталось только две строки.
Удаление данных с использованием Java API
Вы можете удалить данные в таблице, используя метод execute () класса Session. Следуйте приведенным ниже инструкциям, чтобы удалить данные из таблицы с помощью API Java.
Шаг 1: Создайте объект кластера
Создайте экземпляр класса Cluster.builder пакета com.datastax.driver.core , как показано ниже.
//Creating Cluster.Builder object Cluster.Builder builder1 = Cluster.builder();
Добавьте контактную точку (IP-адрес узла), используя метод addContactPoint () объекта Cluster.Builder . Этот метод возвращает Cluster.Builder .
//Adding contact point to the Cluster.Builder object Cluster.Builder builder2 = build.addContactPoint( "127.0.0.1" );
Используя новый объект компоновщика, создайте объект кластера. Для этого у вас есть метод build () в классе Cluster.Builder . Используйте следующий код для создания объекта кластера.
//Building a cluster Cluster cluster = builder.build();
Вы можете построить кластерный объект, используя одну строку кода, как показано ниже.
Cluster cluster = Cluster.builder().addContactPoint("127.0.0.1").build();
Шаг 2. Создание объекта сеанса
Создайте экземпляр объекта Session, используя метод connect () класса Cluster, как показано ниже.
Session session = cluster.connect();
Этот метод создает новый сеанс и инициализирует его. Если у вас уже есть пространство ключей, то вы можете установить его на существующее, передав этому методу имя KeySpace в строковом формате, как показано ниже.
Session session = cluster.connect(“ Your keyspace name ”);
Здесь мы используем KeySpace под названием tp . Поэтому создайте объект сеанса, как показано ниже.
Session session = cluster.connect(“tp”);
Шаг 3: Выполнить запрос
Вы можете выполнять CQL-запросы, используя метод execute () класса Session. Передайте запрос либо в строковом формате, либо в виде объекта класса Statement в метод execute (). Все, что вы передадите этому методу в строковом формате, будет выполнено в cqlsh .
В следующем примере мы удаляем данные из таблицы с именем emp. Вы должны сохранить запрос в строковой переменной и передать его в метод execute (), как показано ниже.
String query1 = ”DELETE FROM emp WHERE emp_id=3; ”; session.execute(query);
Ниже приведена полная программа для удаления данных из таблицы в Cassandra с использованием Java API.
import com.datastax.driver.core.Cluster; import com.datastax.driver.core.Session; public class Delete_Data { public static void main(String args[]){ //query String query = "DELETE FROM emp WHERE emp_id=3;"; //Creating Cluster object Cluster cluster = Cluster.builder().addContactPoint("127.0.0.1").build(); //Creating Session object Session session = cluster.connect("tp"); //Executing the query session.execute(query); System.out.println("Data deleted"); } }
Сохраните вышеупомянутую программу с именем класса, за которым следует .java, перейдите к месту, где она была сохранена. Скомпилируйте и выполните программу, как показано ниже.
$javac Delete_Data.java $java Delete_Data
В нормальных условиях он должен выдавать следующий результат: