Кассандра - Удалить данные

Удаление данных из таблицы

Вы можете удалить данные из таблицы с помощью команды DELETE. Его синтаксис следующий -

DELETE FROM <identifier> WHERE <condition>;

пример

Предположим, в Кассандре есть стол под названием emp имея следующие данные -

emp_id	emp_name	emp_city	emp_phone	emp_sal
1	баран	Хайдарабад	9848022338	50000
2	Робин	Хайдарабад	9848022339	40000
3	рахман	Ченнаи	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. Следуйте инструкциям ниже, чтобы удалить данные из таблицы с помощью java API.

Шаг 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

В нормальных условиях он должен выдавать следующий результат -

Data deleted