Cassandra - zaktualizuj dane

Aktualizacja danych w tabeli

UPDATEto polecenie używane do aktualizacji danych w tabeli. Następujące słowa kluczowe są używane podczas aktualizacji danych w tabeli -

Where - Ta klauzula służy do wybierania wiersza do zaktualizowania.
Set - Ustaw wartość za pomocą tego słowa kluczowego.
Must - Obejmuje wszystkie kolumny składające się na klucz podstawowy.

Podczas aktualizacji wierszy, jeśli dany wiersz jest niedostępny, UPDATE tworzy nowy wiersz. Poniżej podano składnię polecenia UPDATE -

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

Przykład

Załóżmy, że istnieje tabela o nazwie emp. Ta tabela przechowuje dane pracowników określonej firmy i zawiera następujące szczegóły -

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

Zaktualizujmy teraz emp_city Robina do Delhi, a jego pensję do 50000. Poniżej podano zapytanie o wykonanie wymaganych aktualizacji.

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

Weryfikacja

Użyj instrukcji SELECT, aby sprawdzić, czy dane zostały zaktualizowane, czy nie. Jeśli zweryfikujesz tabelę emp za pomocą instrukcji SELECT, wygeneruje ona następujący wynik.

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)

Tutaj możesz zaobserwować, że dane w tabeli zostały zaktualizowane.

Aktualizacja danych za pomocą Java API

Dane w tabeli można aktualizować za pomocą metody execute () klasy Session. Wykonaj czynności podane poniżej, aby zaktualizować dane w tabeli przy użyciu interfejsu API języka Java.

Krok 1: Utwórz obiekt klastra

Utwórz wystąpienie Cluster.builder klasa com.datastax.driver.core pakiet, jak pokazano poniżej.

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

Dodaj punkt kontaktowy (adres IP węzła) za pomocą rozszerzenia addContactPoint() metoda Cluster.Builderobiekt. Ta metoda zwracaCluster.Builder.

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

Korzystając z nowego obiektu konstruktora, utwórz obiekt klastra. Aby to zrobić, masz metodę o nazwiebuild() w Cluster.Builderklasa. Użyj poniższego kodu, aby utworzyć obiekt klastra.

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

Możesz zbudować obiekt klastra przy użyciu jednej linii kodu, jak pokazano poniżej.

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

Krok 2: Utwórz obiekt sesji

Utwórz wystąpienie obiektu Session za pomocą metody connect () klasy Cluster, jak pokazano poniżej.

Session session = cluster.connect( );

Ta metoda tworzy nową sesję i inicjuje ją. Jeśli masz już przestrzeń kluczy, możesz ustawić ją na istniejącą, przekazując nazwę KeySpace w formacie ciągu do tej metody, jak pokazano poniżej.

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

Tutaj używamy KeySpace o nazwie tp. Dlatego utwórz obiekt sesji, jak pokazano poniżej.

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

Krok 3: Wykonaj zapytanie

Zapytania CQL można wykonywać za pomocą metody execute () klasy Session. Przekaż zapytanie w formacie ciągu znaków lub jako obiekt klasy Statement do metody execute (). Cokolwiek przekażesz do tej metody w formacie ciągu, zostanie wykonane nacqlsh.

W poniższym przykładzie aktualizujemy tabelę emp. Musisz zapisać zapytanie w zmiennej łańcuchowej i przekazać je do metody execute (), jak pokazano poniżej:

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

Poniżej podano kompletny program do aktualizacji danych w tabeli przy użyciu Java API.

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

Zapisz powyższy program z nazwą klasy, a następnie .java, przejdź do lokalizacji, w której jest zapisany. Skompiluj i uruchom program, jak pokazano poniżej.

$javac Update_Data.java
$java Update_Data

W normalnych warunkach powinien dać następujący wynik -

Data updated