Cassandra - Meja Potong

Memotong Tabel

Anda dapat memotong tabel menggunakan perintah TRUNCATE. Saat Anda memotong tabel, semua baris tabel dihapus secara permanen. Diberikan di bawah ini adalah sintaks dari perintah ini.

Sintaksis

TRUNCATE <tablename>

Contoh

Mari kita asumsikan ada tabel bernama student dengan data berikut.

s_id	nama S	s_branch	s_aggregate
1	ram	ITU	70
2	rahman	EEE	75
3	robbin	Mech	72

Saat Anda menjalankan pernyataan pilih untuk mendapatkan tabel student, itu akan memberi Anda output berikut.

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)

Sekarang potong tabel menggunakan perintah TRUNCATE.

cqlsh:tp> TRUNCATE student;

Verifikasi

Verifikasi apakah tabel terpotong dengan menjalankan selectpernyataan. Diberikan di bawah ini adalah output dari pernyataan pilih pada tabel siswa setelah pemotongan.

cqlsh:tp> select * from student;

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

(0 rows)

Memotong Tabel menggunakan Java API

Anda dapat memotong tabel menggunakan metode execute () kelas Sesi. Ikuti langkah-langkah yang diberikan di bawah ini untuk memotong tabel.

Langkah 1: Buat Objek Cluster

Pertama-tama, buat instance Cluster.builder kelas dari com.datastax.driver.core paket seperti yang ditunjukkan di bawah ini.

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

Tambahkan titik kontak (alamat IP node) menggunakan addContactPoint() metode dari Cluster.Builderobyek. Metode ini kembaliCluster.Builder.

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

Menggunakan objek builder baru, buat objek cluster. Untuk melakukannya, Anda memiliki metode yang disebutbuild() dalam Cluster.Builderkelas. Kode berikut menunjukkan cara membuat objek cluster.

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

Anda dapat membangun objek cluster menggunakan satu baris kode seperti yang ditunjukkan di bawah ini.

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

Langkah 2: Membuat Objek Sesi

Buat instance objek Sesi menggunakan metode connect () dari kelas Cluster seperti yang ditunjukkan di bawah ini.

Session session = cluster.connect( );

Metode ini membuat sesi baru dan menginisialisasinya. Jika Anda sudah memiliki ruang kunci, Anda dapat menyetelnya ke yang sudah ada dengan meneruskan nama KeySpace dalam format string ke metode ini seperti yang ditunjukkan di bawah ini.

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

Di sini kami menggunakan ruang kunci bernama tp. Oleh karena itu, buat objek sesi seperti yang ditunjukkan di bawah ini.

Langkah 3: Jalankan Kueri

Anda dapat menjalankan kueri CQL menggunakan metode execute () dari kelas Sesi. Teruskan kueri baik dalam format string atau sebagai objek kelas Pernyataan ke metode execute (). Apa pun yang Anda berikan ke metode ini dalam format string akan dieksekusi dicqlsh.

Dalam contoh berikut, kami memotong tabel bernama emp. Anda harus menyimpan kueri dalam variabel string dan meneruskannya keexecute() metode seperti yang ditunjukkan di bawah ini.

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

Diberikan di bawah ini adalah program lengkap untuk memotong tabel di Cassandra menggunakan 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");
   }
}

Simpan program di atas dengan nama kelas diikuti dengan .java, telusuri ke lokasi penyimpanannya. Kompilasi dan jalankan program seperti yang ditunjukkan di bawah ini.

$javac Truncate_Table.java
$java Truncate_Table

Dalam kondisi normal, itu harus menghasilkan keluaran berikut -

Table truncated