Manipulación de datos en Cassandra

En este artículo, describiremos los siguientes comandos DML en Cassandra que nos ayudan a insertar, actualizar, eliminar, consultar datos, etc. En CQL existen los siguientes comandos de manipulación de datos. Discutamos uno por uno.

1. Insert 
2. Update 
3. Delete
4. Batch 

Tomemos un ejemplo:

Nombre de la tabla: Employee_info

CREATE TABLE Employee_info
 (
  E_id int,
  E_name text,
  E_city text,
  PRIMARY KEY(E_id)
 ); 

Comandos DML:

Figura – Comandos de manipulación de datos

1. INSERTAR:
en la familia de columnas, hay muchas filas que contienen columnas que el usuario puede especificar de antemano. Pero hay una situación en la que un usuario quiere agregar más columnas después de crear una tabla, entonces podemos haber usado los comandos de manipulación de datos.’ La palabra clave INSERT’ se utiliza para insertar datos.

Hay 2 formatos para insertar datos.

• Formato-1:

  Sintaxis:

  INSERT INTO table_name (field _name1, field_name2, field_name3…)
              VALUES ('field_value1', 'field_value2', 'field_value3'…)
              USING  update_parameter[optional] ; 

  Por ejemplo:

  INSERT INTO Employee_info(E_id, E_name, E_city) 
              VALUES (107, ‘Ashish’, ‘Delhi’);
  INSERT INTO Employee_info(E_id, E_name, E_city) 
         VALUES (110, ‘Rana’, ‘Noida’); 

  Para consultar datos o leer datos, se utiliza la siguiente consulta ‘SELECCIONAR’.

  Select * 
  from Employee_info; 

  Producción:

  E_id	nombre_e	E_ciudad
  107	Cenizo	Delhi
  110	rana	Noida

• Formato-2: Al usar JSON también podemos insertar datos.

  Sintaxis:

  INSERT INTO table_name JSON '{"field_name1":"field_value1", 
                                     "field_name2":"field_value2", 
                                     "field_name3":"field_value3", ...}' 

  Por ejemplo:

  INSERT INTO Employee_info JSON ’(“E_id” :”107”, 
                                        “E_name” : “Ashish”, 
                                         “E_city” : “Delhi”)’ ; 

  Salida: usando JSON para insertar datos en la tabla.

  E_id	nombre_e	E_ciudad
  107	Cenizo	Delhi

2. ACTUALIZAR:
para actualizar los datos existentes con datos nuevos, podemos usar el comando de manipulación de datos ‘ACTUALIZAR’ en Cassandra.

Sintaxis:

UPDATE table_name USING  update _parameter
       SET field_name1 = field_value1,
           field_name2 = field_value2,
           field_name3> = field_value3,
                    .....
WHERE field_name = field_value; 

Por ejemplo:

UPDATE student USING TTL 500
SET E_name= ‘Ashish Rana’,
E_city= ‘Mumbai’,
WHERE E_id=107; 

Producción:

E_id	nombre_e	E_ciudad
107	ashish rana	Bombay
110	rana	Noida

Nota: Las
sentencias UPDATE e INSERT admiten el siguiente parámetro.

1. TIMESTAMP
2. TTL (Time To Live) 

Las declaraciones DELETE y BATCH admiten el siguiente parámetro.

1. TIMESTAMP 

3. ELIMINAR:
cuando el usuario desea eliminar algunos datos existentes en función de alguna condición, podemos ejecutar el comando de manipulación de datos ‘ELIMINAR’ en Cassandra.

Sintaxis:

DELETE table_name  
    USING  update _parameter
     ... 
    WHERE condition; 

Por ejemplo:

• Ejemplo 1:

  DELETE FROM Employee_info 
              USING TIMESTAMP 1450002143
   WHERE E_id = 107; 

  Producción:

  E_id	nombre_e	E_ciudad
  110	rana	Noida

• Ejemplo-2:

  DELETE E_city 
  FROM Employee_info
  WHERE E_id IN (107, 110); 

  Producción:

  E_id	nombre_e
  107	ashish rana
  110	rana

4. LOTE:
Se utiliza para ejecutar múltiples sentencias INSERTAR, ACTUALIZAR y ELIMINAR mediante la agrupación a través de una sentencia LOTE.

Sintaxis:

batch_statement ::=  BEGIN [ UNLOGGED | COUNTER ] BATCH
                         [ USING update_parameter ( AND update_parameter )* ]
                           modification_statement ( ';' modification_statement )*
                            APPLY BATCH
modification_statement ::=  insert_statement | update_statement | delete_statement 

fuente _

Por ejemplo:

BEGIN BATCH
   INSERT INTO users (E_id, E_name, E_city) 
          VALUES (908, 'Rahul Rana', 'Meerut');
   INSERT INTO users (E_id, E_name, E_city) 
          VALUES (909, 'Gaurav Rana', 'Meerut');   
   UPDATE Employee_info SET E_city = 'Noida' WHERE E_id = '908';
   DELETE E_name 
          FROM Employee_info 
          WHERE E_id = 909;
APPLY BATCH; 

Producción:

E_id	nombre_e	E_ciudad
908	Raúl Rana	Noida
909	Nulo	Meerut