Cassandra - Demonstrações em lote

Usando extratos de lote

Usando BATCH,você pode executar várias instruções de modificação (inserir, atualizar, excluir) simultaneamente. Sua sintaxe é a seguinte -

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

Exemplo

Suponha que haja uma tabela no Cassandra chamada emp com os seguintes dados -

emp_id	emp_name	emp_city	emp_phone	emp_sal
1	RAM	Hyderabad	9848022338	50000
2	Robin	Délhi	9848022339	50000
3	rahman	Chennai	9848022330	45000

Neste exemplo, vamos realizar as seguintes operações -

Insira uma nova linha com os seguintes detalhes (4, rajeev, pune, 9848022331, 30000).
Atualize o salário do funcionário com a linha id 3 para 50000.
Exclua a cidade do funcionário com a id de linha 2.

Para realizar as operações acima de uma vez, use o seguinte comando 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;

Verificação

Depois de fazer as alterações, verifique a tabela usando a instrução SELECT. Ele deve produzir a seguinte saída -

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)

Aqui você pode observar a tabela com os dados modificados.

Instruções de lote usando Java API

As instruções em lote podem ser escritas programaticamente em uma tabela usando o método execute () da classe Session. Siga as etapas fornecidas a seguir para executar várias instruções usando a instrução batch com a ajuda da API Java.

Etapa 1: Criar um objeto de cluster

Crie uma instância de Cluster.builder classe de com.datastax.driver.core pacote conforme mostrado abaixo.

//Creating Cluster.Builder object
Cluster.Builder builder1 = Cluster.builder();

Adicione um ponto de contato (endereço IP do nó) usando o addContactPoint() método de Cluster.Builderobjeto. Este método retornaCluster.Builder.

//Adding contact point to the Cluster.Builder object
Cluster.Builder builder2 = build.addContactPoint( "127.0.0.1" );

Usando o novo objeto construtor, crie um objeto de cluster. Para fazer isso, você tem um método chamadobuild() no Cluster.Builderclasse. Use o seguinte código para criar o objeto de cluster -

//Building a cluster
Cluster cluster = builder.build();

Você pode construir o objeto de cluster usando uma única linha de código, conforme mostrado abaixo.

Cluster cluster = Cluster.builder().addContactPoint("127.0.0.1").build();

Etapa 2: Criar um objeto de sessão

Crie uma instância do objeto Session usando o método connect () da classe Cluster conforme mostrado abaixo.

Session session = cluster.connect( );

Este método cria uma nova sessão e a inicializa. Se você já tiver um keyspace, poderá defini-lo como o existente passando o nome do KeySpace em formato de string para este método, conforme mostrado abaixo.

Session session = cluster.connect(“ Your keyspace name ”);

Aqui estamos usando o KeySpace chamado tp. Portanto, crie o objeto de sessão conforme mostrado abaixo.

Session session = cluster.connect(“tp”);

Etapa 3: Executar consulta

Você pode executar consultas CQL usando o método execute () da classe Session. Passe a consulta no formato de string ou como um objeto da classe Statement para o método execute (). Tudo o que você passar para este método em formato de string será executado nocqlsh.

Neste exemplo, vamos realizar as seguintes operações -

Insira uma nova linha com os seguintes detalhes (4, rajeev, pune, 9848022331, 30000).
Atualize o salário do funcionário com a linha id 3 para 50000.
Exclua a cidade do funcionário com o id de linha 2.

Você deve armazenar a consulta em uma variável de string e passá-la para o método execute () como mostrado abaixo.

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;”;

A seguir está o programa completo para executar várias instruções simultaneamente em uma tabela no Cassandra usando a API Java.

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");
   }
}

Salve o programa acima com o nome da classe seguido por .java, navegue até o local onde ele foi salvo. Compile e execute o programa conforme mostrado abaixo.

$javac Batch.java $java Batch

Em condições normais, ele deve produzir a seguinte saída -

Changes done