Cassandra - Atualizar dados

Atualizando dados em uma tabela

UPDATEé o comando usado para atualizar dados em uma tabela. As seguintes palavras-chave são usadas durante a atualização de dados em uma tabela -

Where - Esta cláusula é usada para selecionar a linha a ser atualizada.
Set - Defina o valor usando esta palavra-chave.
Must - Inclui todas as colunas que compõem a chave primária.

Durante a atualização de linhas, se uma determinada linha não estiver disponível, UPDATE cria uma nova linha. A seguir está a sintaxe do comando UPDATE -

UPDATE <tablename>
SET <column name> = <new value>
<column name> = <value>....
WHERE <condition>

Exemplo

Suponha que haja uma mesa chamada emp. Esta tabela armazena os detalhes dos funcionários de uma determinada empresa, e possui os seguintes detalhes -

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

Vamos agora atualizar emp_city de robin para Delhi, e seu salário para 50000. Abaixo está a consulta para realizar as atualizações necessárias.

cqlsh:tutorialspoint> UPDATE emp SET emp_city='Delhi',emp_sal=50000
   WHERE emp_id=2;

Verificação

Use a instrução SELECT para verificar se os dados foram atualizados ou não. Se você verificar a tabela emp usando a instrução SELECT, ela 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 |     Delhi |    robin | 9848022339 | 50000
      3 |   Chennai |   rahman | 9848022330 | 45000
      
(3 rows)

Aqui você pode observar que os dados da tabela foram atualizados.

Atualização de dados usando a API Java

Você pode atualizar os dados em uma tabela usando o método execute () da classe Session. Siga as etapas fornecidas abaixo para atualizar os dados em uma tabela usando a 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 código a seguir 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.

No exemplo a seguir, estamos atualizando a tabela emp. Você deve armazenar a consulta em uma variável de string e passá-la para o método execute () conforme mostrado abaixo:

String query = “ UPDATE emp SET emp_city='Delhi',emp_sal=50000
WHERE emp_id = 2;” ;

A seguir está o programa completo para atualizar dados em uma tabela usando a API Java.

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

public class Update_Data {
  
   public static void main(String args[]){
      
      //query
      String query = " UPDATE emp SET emp_city='Delhi',emp_sal=50000"
          
      //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 updated");
   }
 }

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 Update_Data.java
$java Update_Data

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

Data updated