Cassandra - Obetnij tabelę
Obcinanie tabeli
Możesz skrócić tabelę za pomocą polecenia TRUNCATE. Po obcięciu tabeli wszystkie wiersze tabeli są trwale usuwane. Poniżej podano składnię tego polecenia.
Składnia
TRUNCATE <tablename>
Przykład
Załóżmy, że istnieje tabela o nazwie student z następującymi danymi.
s_id | s_name | s_branch | s_aggregate |
---|---|---|---|
1 | Baran | TO | 70 |
2 | rahman | EEE | 75 |
3 | rabować | Mech | 72 |
Po wykonaniu instrukcji select w celu pobrania tabeli student, da ci następujący wynik.
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)
Teraz obetnij tabelę za pomocą polecenia TRUNCATE.
cqlsh:tp> TRUNCATE student;
Weryfikacja
Sprawdź, czy tabela jest obcinana, wykonując selectkomunikat. Poniżej podano wynik instrukcji select w tabeli ucznia po obcięciu.
cqlsh:tp> select * from student;
s_id | s_aggregate | s_branch | s_name
------+-------------+----------+--------
(0 rows)
Obcinanie tabeli przy użyciu interfejsu API języka Java
Tabelę można obcinać za pomocą metody execute () klasy Session. Wykonaj kroki podane poniżej, aby skrócić tabelę.
Krok 1: Utwórz obiekt klastra
Przede wszystkim utwórz instancję 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. Poniższy kod przedstawia sposób tworzenia obiektu 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: Tworzenie obiektu 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 ” );
Session session = cluster.connect(“ tp” );
Tutaj używamy przestrzeni kluczy o nazwie tp. Dlatego utwórz obiekt sesji, jak pokazano poniżej.
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 obcinamy tabelę o nazwie emp. Musisz zapisać zapytanie w zmiennej łańcuchowej i przekazać je doexecute() metoda, jak pokazano poniżej.
//Query
String query = "TRUNCATE emp;;”;
session.execute(query);
Poniżej podano kompletny program do obcinania tabeli w Cassandrze przy użyciu 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");
}
}
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 Truncate_Table.java
$java Truncate_Table
W normalnych warunkach powinien dać następujący wynik -
Table truncated