使用 BATCH，可以同时执行多个修改语句(插入，更新，删除).其语法如下 :
BEGIN BATCH <insert-stmt>/ <update-stmt>/ <delete-stmt> APPLY BATCH
假设Cassandra中有一个名为emp的表，其中包含以下数据&minus ;
| emp_id | emp_name | emp_city | emp_phone | emp_sal |
|---|---|---|---|---|
| 1 | ram | Hyderabad | 9848022338 | 50000 |
| 2 | robin | Delhi | 9848022339 | 50000 |
| 3 | rahman | Chennai | 9848022330 | 45000 |
在这个例子中，我们将执行以下操作 :
插入一个包含以下详细信息的新行(4，rajeev，pune，9848022331,30000).
更新行号为3到50000的员工的工资.
删除城市行ID为2的员工.
要一次执行上述操作，请使用以下BATCH命令 :
cqlsh:it1352> 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:it1352> 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)
您可以在此处观察包含修改数据的表格.
可以使用Session类的execute()方法以编程方式在表中编写批处理语句.按照下面给出的步骤，在Java API的帮助下使用批处理语句执行多个语句.
创建实例 com.datastax.driver.core 包的 Cluster.builder 类如下所示.
//创建Cluster.Builder对象 Cluster.Builder builder1 = Cluster.builder();
使用 Cluster.Builder <的 addContactPoint()方法添加联系点(节点的IP地址)/b>对象.此方法返回 Cluster.Builder .
//将联系人点添加到Cluster.Builder对象
Cluster.Builder builder2 = build.addContactPoint("127.0.0.1");使用新的构建器对象，创建一个集群对象.为此，您在 Cluster.Builder 类中有一个名为 build()的方法.使用以下代码创建集群对象 :
//构建集群 Cluster cluster = builder.build();
您可以使用一行代码构建集群对象，如下所示.
Cluster cluster = Cluster.builder().addContactPoint("127.0.0.1").build();使用Cluster的connect()方法创建Session对象的实例class如下所示.
Session session = cluster.connect();
此方法创建一个新会话并对其进行初始化.如果您已经有一个键空间，则可以通过将字符串格式的KeySpace名称传递给此方法将其设置为现有键空间，如下所示.
Session session = cluster.connect(" Your keyspace name ");这里我们使用名为 tp 的KeySpace.因此，创建会话对象，如下所示.
Session session = cluster.connect("tp");您可以使用Session类的execute()方法执行CQL查询.将查询以字符串格式或Statement类对象传递给execute()方法.无论您以字符串格式传递给此方法的是什么，都将在 cqlsh 上执行.
在此示例中，我们将执行以下操作 :
插入一个包含以下详细信息的新行(4，rajeev，pune，9848022331,30000).
更新行号为3到50000的员工的工资.
删除行号为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
