Cassandra - 批處理語句

使用批處理語句

使用BATCH，您可以同時執行多個修改語句（插入、更新、刪除）。其語法如下：

BEGIN BATCH
<insert-stmt>/ <update-stmt>/ <delete-stmt>
APPLY BATCH

示例

假設 Cassandra 中有一個名為 emp 的表，其中包含以下資料：

在本例中，我們將執行以下操作：

• 插入一個包含以下詳細資訊的新行 (4, rajeev, pune, 9848022331, 30000)。
• 將行 ID 為 3 的員工的工資更新為 50000。
• 刪除行 ID 為 2 的員工的城市。

要一次性執行上述操作，請使用以下 BATCH 命令：

cqlsh:tutorialspoint> BEGIN BATCH
... INSERT INTO emp (emp_id, emp_city, emp_name, emp_phone, emp_sal) values(  4,'Pune','rajeev',9848022331, 30000);
... UPDATE emp SET emp_sal = 50000 WHERE emp_id =3;
... DELETE emp_city FROM emp WHERE emp_id = 2;
... APPLY BATCH;

驗證

進行更改後，使用 SELECT 語句驗證表。它應該產生以下輸出：

cqlsh:tutorialspoint> select * from emp;

 emp_id |  emp_city | emp_name |  emp_phone | emp_sal
--------+-----------+----------+------------+---------
      1 | Hyderabad | ram      | 9848022338 | 50000
      2 | null      | robin    | 9848022339 | 50000
      3 | Chennai   | rahman   | 9848022330 | 50000
      4 | Pune      | rajeev   | 9848022331 | 30000
    
(4 rows)

在這裡您可以觀察到修改後的表資料。

使用 Java API 的批處理語句

可以使用 Session 類的 execute() 方法以程式設計方式在表中編寫批處理語句。按照以下步驟使用 Java API 透過批處理語句執行多個語句。

步驟 1：建立 Cluster 物件

建立com.datastax.driver.core包中Cluster.builder類的例項，如下所示。

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

使用Cluster.Builder物件的addContactPoint()方法新增一個聯絡點（節點的 IP 地址）。此方法返回Cluster.Builder。

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

使用新的 builder 物件，建立一個 cluster 物件。為此，您在Cluster.Builder類中有一個名為build()的方法。使用以下程式碼建立 cluster 物件：

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

您可以使用一行程式碼構建 cluster 物件，如下所示。

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

步驟 2：建立 Session 物件

使用 Cluster 類的 connect() 方法建立 Session 物件的例項，如下所示。

Session session = cluster.connect( );

此方法建立一個新的會話並對其進行初始化。如果您已經擁有一個 keyspace，則可以透過將 KeySpace 名稱以字串格式傳遞給此方法來將其設定為現有的 keyspace，如下所示。

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

這裡我們使用名為tp的 KeySpace。因此，建立會話物件如下所示。

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

步驟 3：執行查詢

您可以使用 Session 類的 execute() 方法執行 CQL 查詢。將查詢以字串格式或作為 Statement 類物件傳遞給 execute() 方法。您以字串格式傳遞給此方法的任何內容都將在cqlsh上執行。

在本例中，我們將執行以下操作：

• 插入一個包含以下詳細資訊的新行 (4, rajeev, pune, 9848022331, 30000)。
• 將行 ID 為 3 的員工的工資更新為 50000。
• 刪除行 ID 為 2 的員工的城市。

您必須將查詢儲存在一個字串變數中，並將其傳遞給 execute() 方法，如下所示。

String query1 = ” BEGIN BATCH INSERT INTO emp (emp_id, emp_city, emp_name,   emp_phone, emp_sal) values( 4,'Pune','rajeev',9848022331, 30000);
UPDATE emp SET emp_sal = 50000 WHERE emp_id =3;
DELETE emp_city FROM emp WHERE emp_id = 2;
APPLY BATCH;”;

以下是使用 Java API 在 Cassandra 中的表上同時執行多個語句的完整程式。

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

public class Batch {

   public static void main(String args[]){
    
      //query
      String query =" BEGIN BATCH INSERT INTO emp (emp_id, emp_city,
         emp_name, emp_phone, emp_sal) values( 4,'Pune','rajeev',9848022331, 30000);"
    
         + "UPDATE emp SET emp_sal = 50000 WHERE emp_id =3;"
         + "DELETE emp_city FROM emp WHERE emp_id = 2;"
         + "APPLY BATCH;";

      //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("Changes done");
   }
}

將上述程式儲存為類名後跟 .java，瀏覽到其儲存位置。編譯並執行程式，如下所示。

$javac Batch.java
$java Batch

在正常情況下，它應該產生以下輸出：

Changes done