Cassandra - Aggiorna dati

Aggiornamento dei dati in una tabella

UPDATEè il comando utilizzato per aggiornare i dati in una tabella. Le seguenti parole chiave vengono utilizzate durante l'aggiornamento dei dati in una tabella:

Where - Questa clausola viene utilizzata per selezionare la riga da aggiornare.
Set - Imposta il valore utilizzando questa parola chiave.
Must - Include tutte le colonne che compongono la chiave primaria.

Durante l'aggiornamento delle righe, se una determinata riga non è disponibile, UPDATE crea una nuova riga. Di seguito è riportata la sintassi del comando UPDATE -

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

Esempio

Supponiamo che ci sia una tabella denominata emp. Questa tabella memorizza i dettagli dei dipendenti di una determinata azienda e contiene i seguenti dettagli:

emp_id	emp_name	emp_city	emp_phone	emp_sal
1	ariete	Hyderabad	9848022338	50000
2	pettirosso	Hyderabad	9848022339	40000
3	rahman	Chennai	9848022330	45000

Aggiorniamo ora emp_city di robin a Delhi e il suo stipendio a 50000. Di seguito è riportata la query per eseguire gli aggiornamenti richiesti.

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

Verifica

Utilizzare l'istruzione SELECT per verificare se i dati sono stati aggiornati o meno. Se verifichi la tabella emp utilizzando l'istruzione SELECT, produrrà il seguente output.

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)

Qui puoi osservare che i dati della tabella sono stati aggiornati.

Aggiornamento dei dati utilizzando l'API Java

È possibile aggiornare i dati in una tabella utilizzando il metodo execute () della classe Session. Seguire i passaggi indicati di seguito per aggiornare i dati in una tabella utilizzando l'API Java.

Passaggio 1: creare un oggetto cluster

Crea un'istanza di Cluster.builder classe di com.datastax.driver.core pacchetto come mostrato di seguito.

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

Aggiungi un punto di contatto (indirizzo IP del nodo) utilizzando il file addContactPoint() metodo di Cluster.Builderoggetto. Questo metodo restituisceCluster.Builder.

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

Utilizzando il nuovo oggetto builder, creare un oggetto cluster. Per fare ciò, hai un metodo chiamatobuild() nel Cluster.Builderclasse. Utilizzare il codice seguente per creare l'oggetto cluster.

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

È possibile creare l'oggetto cluster utilizzando una singola riga di codice come mostrato di seguito.

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

Passaggio 2: creare un oggetto sessione

Crea un'istanza dell'oggetto Session utilizzando il metodo connect () della classe Cluster come mostrato di seguito.

Session session = cluster.connect( );

Questo metodo crea una nuova sessione e la inizializza. Se si dispone già di uno spazio chiavi, è possibile impostarlo su quello esistente passando il nome KeySpace in formato stringa a questo metodo come mostrato di seguito.

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

Qui stiamo usando il KeySpace denominato tp. Pertanto, creare l'oggetto sessione come mostrato di seguito.

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

Passaggio 3: eseguire la query

È possibile eseguire query CQL utilizzando il metodo execute () della classe Session. Passa la query in formato stringa o come oggetto della classe Statement al metodo execute (). Qualunque cosa passi a questo metodo in formato stringa verrà eseguita nel filecqlsh.

Nell'esempio seguente, stiamo aggiornando la tabella emp. È necessario memorizzare la query in una variabile stringa e passarla al metodo execute () come mostrato di seguito:

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

Di seguito è riportato il programma completo per aggiornare i dati in una tabella utilizzando l'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");
   }
 }

Salva il programma sopra con il nome della classe seguito da .java, vai alla posizione in cui è stato salvato. Compilare ed eseguire il programma come mostrato di seguito.

$javac Update_Data.java
$java Update_Data

In condizioni normali, dovrebbe produrre il seguente output:

Data updated