Cassandra 刪除數(shù)據(jù)

使用Cqlsh刪除數(shù)據(jù)

您可以使用命令DELETE從表中刪除數(shù)據(jù)。其語法如下：

DELETE FROM <identifier> WHERE <condition>;

示例

讓我們假設(shè)Cassandra中有一個(gè)名為emp的具有以下數(shù)據(jù)的表：

以下語句刪除最后一行的emp_sal列：

cqlsh:tutorialspoint> DELETE emp_sal FROM emp WHERE emp_id=3;

驗(yàn)證

使用SELECT語句驗(yàn)證數(shù)據(jù)是否已刪除。如果使用SELECT驗(yàn)證emp表，它將產(chǎn)生以下輸出：

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 | null
(3 rows)

由于我們刪除了Rahman的薪資，你將看到一個(gè)空值代替薪資。

刪除整行

以下命令從表中刪除整個(gè)行。

cqlsh:tutorialspoint> DELETE FROM emp WHERE emp_id=3;

驗(yàn)證

使用SELECT語句驗(yàn)證數(shù)據(jù)是否已刪除。如果使用SELECT驗(yàn)證emp表，它將產(chǎn)生以下輸出：

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
 
(2 rows)

由于我們刪除了最后一行，因此表中只剩下兩行。

使用Java API刪除數(shù)據(jù)

您可以使用Session類的execute（）方法刪除表中的數(shù)據(jù)。按照以下步驟使用java API從表中刪除數(shù)據(jù)。

第1步：創(chuàng)建集群對(duì)象

創(chuàng)建一個(gè)名為com.datastax.driver.core的Cluster.builder類的實(shí)例，如下所示。

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

使用Cluster.Builder對(duì)象的addContactPoint（）方法添加聯(lián)系點(diǎn)（節(jié)點(diǎn)的IP地址）。此方法返回Cluster.Builder。

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

使用新的構(gòu)建器對(duì)象，創(chuàng)建一個(gè)集群對(duì)象。為此，在Cluster.Builder類中有一個(gè)名為build（）的方法。使用以下代碼創(chuàng)建集群對(duì)象。

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

您可以使用單行代碼構(gòu)建集群對(duì)象，如下所示。

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

第2步：創(chuàng)建會(huì)話對(duì)象

使用Cluster類的connect（）方法創(chuàng)建一個(gè)Session對(duì)象的實(shí)例，如下所示。

Session session = cluster.connect();

使用新的構(gòu)建器對(duì)象，創(chuàng)建一個(gè)集群對(duì)象。為此，在Cluster.Builder類中有一個(gè)名為build（）的方法。使用以下代碼創(chuàng)建集群對(duì)象。

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

這里我們使用KeySpace稱為tp。因此，創(chuàng)建會(huì)話對(duì)象如下所示。

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

第3步：執(zhí)行查詢

您可以使用Session類的execute（）方法執(zhí)行CQL查詢。將查詢以字符串格式或Statement類對(duì)象傳遞給execute（）方法。無論您以字符串格式傳遞給此方法將在cqlsh上執(zhí)行。

在下面的示例中，我們從名為emp的表中刪除數(shù)據(jù)。您必須將查詢存儲(chǔ)在字符串變量中，并將其傳遞給execute（）方法，如下所示。

String query1 = ”DELETE FROM emp WHERE emp_id=3; ”;
session.execute(query);

下面給出了使用Java API從Cassandra中的表中刪除數(shù)據(jù)的完整程序。

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

public class Delete_Data {

   public static void main(String args[]){
   
      //query
      String query = "DELETE FROM emp WHERE emp_id=3;";

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

使用類名稱和.java保存上述程序，瀏覽到保存位置。編譯并執(zhí)行程序如下圖所示。

$javac Delete_Data.java
$java Delete_Data

在正常條件下，它應(yīng)該產(chǎn)生以下輸出：

Data deleted