Учебники

Кассандра — Пакетная отчетность

Январь 4, 2019

Используя BATCH, вы можете выполнять несколько операторов модификации (вставка, обновление, удаление) одновременно. Его синтаксис выглядит следующим образом — 

BEGIN BATCH
<insert-stmt>/ <update-stmt>/ <delete-stmt>
APPLY BATCH

пример

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

emp_id emp_name emp_city emp_phone emp_sal
1 баран Хайдарабад 9848022338 50000
2 Робин Дели 9848022339 50000
3 рахман Chennai 9848022330 45000

В этом примере мы выполним следующие операции:

  • Вставьте новую строку со следующими данными (4, rajeev, pune, 9848022331, 30000).
  • Обновите зарплату сотрудника с идентификатором строки 3 до 50000.
  • Удалить город сотрудника с идентификатором строки 2.

Чтобы выполнить вышеуказанные операции за один раз, используйте следующую команду BATCH — 

cqlsh:tutorialspoint> BEGIN BATCH
... INSERT INTO emp (emp_id, emp_city, emp_name, emp_phone, emp_sal) values(  4,'Pune','rajeev',9848022331, 30000);
... UPDATE emp SET emp_sal = 50000 WHERE emp_id =3;
... DELETE emp_city FROM emp WHERE emp_id = 2;
... APPLY BATCH;

верификация

После внесения изменений проверьте таблицу с помощью инструкции SELECT. Он должен произвести следующий вывод — 

cqlsh:tutorialspoint> select * from emp;

 emp_id |  emp_city | emp_name |  emp_phone | emp_sal
--------+-----------+----------+------------+---------
      1 | Hyderabad | ram      | 9848022338 | 50000
      2 | null      | robin    | 9848022339 | 50000
      3 | Chennai   | rahman   | 9848022330 | 50000
      4 | Pune      | rajeev   | 9848022331 | 30000
    
(4 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 .

В этом примере мы выполним следующие операции:

  • Вставьте новую строку со следующими данными (4, rajeev, pune, 9848022331, 30000).
  • Обновите зарплату сотрудника с идентификатором строки 3 до 50000.
  • Удалите город сотрудника с идентификатором строки 2.

Вы должны сохранить запрос в строковой переменной и передать его в метод execute (), как показано ниже. 

String query1 = ” BEGIN BATCH INSERT INTO emp (emp_id, emp_city, emp_name,   emp_phone, emp_sal) values( 4,'Pune','rajeev',9848022331, 30000);
UPDATE emp SET emp_sal = 50000 WHERE emp_id =3;
DELETE emp_city FROM emp WHERE emp_id = 2;
APPLY BATCH;”;

Ниже приведена полная программа для одновременного выполнения нескольких операторов в таблице в Cassandra с использованием Java API. 

import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.Session;

public class Batch {

   public static void main(String args[]){
    
      //query
      String query =" BEGIN BATCH INSERT INTO emp (emp_id, emp_city,
         emp_name, emp_phone, emp_sal) values( 4,'Pune','rajeev',9848022331, 30000);"
    
         + "UPDATE emp SET emp_sal = 50000 WHERE emp_id =3;"
         + "DELETE emp_city FROM emp WHERE emp_id = 2;"
         + "APPLY BATCH;";

      //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("Changes done");
   }
}

Сохраните вышеупомянутую программу с именем класса, за которым следует .java, перейдите к месту, где она была сохранена. Скомпилируйте и выполните программу, как показано ниже. 

$javac Batch.java
$java Batch

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

44
Share: