Cassandra - Tabelle abschneiden

Eine Tabelle abschneiden

Sie können eine Tabelle mit dem Befehl TRUNCATE abschneiden. Wenn Sie eine Tabelle abschneiden, werden alle Zeilen der Tabelle dauerhaft gelöscht. Unten ist die Syntax dieses Befehls angegeben.

Syntax

TRUNCATE <tablename>

Beispiel

Nehmen wir an, es gibt eine Tabelle namens student mit den folgenden Daten.

s_id	s_name	s_branch	s_aggregate
1	RAM	ES	70
2	rahman	EEE	75
3	Robbin	Mech	72

Wenn Sie die select-Anweisung ausführen, um die Tabelle abzurufen student, Sie erhalten die folgende Ausgabe.

cqlsh:tp> select * from student;

 s_id | s_aggregate | s_branch | s_name
------+-------------+----------+--------
    1 |          70 |       IT | ram
    2 |          75 |      EEE | rahman
    3 |          72 |     MECH | robbin

(3 rows)

Schneiden Sie nun die Tabelle mit dem Befehl TRUNCATE ab.

cqlsh:tp> TRUNCATE student;

Überprüfung

Überprüfen Sie, ob die Tabelle abgeschnitten ist, indem Sie die ausführen selectErklärung. Unten ist die Ausgabe der select-Anweisung in der Schülertabelle nach dem Abschneiden angegeben.

cqlsh:tp> select * from student;

 s_id | s_aggregate | s_branch | s_name
------+-------------+----------+--------

(0 rows)

Abschneiden einer Tabelle mithilfe der Java-API

Sie können eine Tabelle mit der Methode execute () der Session-Klasse abschneiden. Führen Sie die folgenden Schritte aus, um eine Tabelle abzuschneiden.

Schritt 1: Erstellen Sie ein Clusterobjekt

Erstellen Sie zunächst eine Instanz von Cluster.builder Klasse von com.datastax.driver.core Paket wie unten gezeigt.

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

Fügen Sie einen Kontaktpunkt (IP-Adresse des Knotens) hinzu addContactPoint() Methode von Cluster.BuilderObjekt. Diese Methode gibt zurückCluster.Builder.

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

Erstellen Sie mit dem neuen Builder-Objekt ein Cluster-Objekt. Dazu haben Sie eine Methode namensbuild() in dem Cluster.BuilderKlasse. Der folgende Code zeigt, wie Sie ein Clusterobjekt erstellen.

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

Sie können ein Clusterobjekt mit einer einzelnen Codezeile erstellen, wie unten gezeigt.

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

Schritt 2: Erstellen eines Sitzungsobjekts

Erstellen Sie eine Instanz des Sitzungsobjekts mit der Methode connect () der Cluster-Klasse (siehe unten).

Session session = cluster.connect( );

Diese Methode erstellt eine neue Sitzung und initialisiert sie. Wenn Sie bereits über einen Schlüsselbereich verfügen, können Sie ihn auf den vorhandenen festlegen, indem Sie den KeySpace-Namen im Zeichenfolgenformat wie unten gezeigt an diese Methode übergeben.

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

Hier verwenden wir den Schlüsselraum tp. Erstellen Sie daher das Sitzungsobjekt wie unten gezeigt.

Schritt 3: Abfrage ausführen

Sie können CQL-Abfragen mit der Methode execute () der Session-Klasse ausführen. Übergeben Sie die Abfrage entweder im Zeichenfolgenformat oder als Anweisungsklassenobjekt an die Methode execute (). Was auch immer Sie im String-Format an diese Methode übergeben, wird auf dem ausgeführtcqlsh.

Im folgenden Beispiel kürzen wir eine Tabelle mit dem Namen emp. Sie müssen die Abfrage in einer Zeichenfolgenvariablen speichern und an die übergebenexecute() Methode wie unten gezeigt.

//Query
String query = "TRUNCATE emp;;”;
session.execute(query);

Im Folgenden finden Sie das vollständige Programm zum Abschneiden einer Tabelle in Cassandra mithilfe der Java-API.

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

public class Truncate_Table {

   public static void main(String args[]){
   
      //Query
      String query = "Truncate student;";
   
      //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("Table truncated");
   }
}

Speichern Sie das obige Programm mit dem Klassennamen gefolgt von .java und navigieren Sie zu dem Speicherort, an dem es gespeichert ist. Kompilieren Sie das Programm und führen Sie es wie unten gezeigt aus.

$javac Truncate_Table.java
$java Truncate_Table

Unter normalen Bedingungen sollte die folgende Ausgabe erzeugt werden:

Table truncated