Cassandra 简明教程
Cassandra - Delete Data
Deleting Datafrom a Table
你可以使用命令 DELETE 从表中删除数据。其语法如下:
DELETE FROM <identifier> WHERE <condition>;
Example
假设 Cassandra 中有一个名为 emp 的表,其中有以下数据:
emp_id |
emp_name |
emp_city |
emp_phone |
emp_sal |
1 |
ram |
Hyderabad |
9848022338 |
50000 |
2 |
robin |
Hyderabad |
9848022339 |
40000 |
3 |
rahman |
Chennai |
9848022330 |
45000 |
以下语句将删除最后一行中的 emp_sal 列:
cqlsh:tutorialspoint> DELETE emp_sal FROM emp WHERE emp_id=3;
Verification
使用 SELECT 语句验证数据是否已被删除。如果你使用 SELECT 验证 emp 表,它将产生以下输出:
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 的工资,因此你会看到工资位置有一个空值。
Deleting an Entire Row
以下命令从表中删除整行。
cqlsh:tutorialspoint> DELETE FROM emp WHERE emp_id=3;
Verification
使用 SELECT 语句验证数据是否已被删除。如果你使用 SELECT 验证 emp 表,它将产生以下输出:
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)
由于我们删除了最后一行,因此表中只剩两行。
Deleting Data using Java API
你可以使用 Session 类的 execute() 方法从表中删除数据。按照下面给出的步骤使用 java API 从表中删除数据。
Step1: Create a Cluster Object
如以下所示,创建 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" );
使用新的构建器对象创建一个集群对象。 为此,你可以在 Cluster.Builder 类中使用名为 build() 的方法。使用以下代码创建一个集群对象。
//Building a cluster
Cluster cluster = builder.build();
你可以使用如以下所示的单行代码构建集群对象。
Cluster cluster = Cluster.builder().addContactPoint("127.0.0.1").build();
Step 2: Create a Session Object
如以下所示,使用 Cluster 类的 connect() 方法创建一个 Session 对象的实例。
Session session = cluster.connect();
此方法创建一个新会话并对其进行初始化。如果你已经有一个密钥空间,那么你可以通过将 KeySpace 名称以字符串格式传递给此方法,将其设置为现有的密钥空间,如下所示。
Session session = cluster.connect(“ Your keyspace name ”);
这里我们使用名为 tp 的 KeySpace。因此,创建会话对象如下所示。
Session session = cluster.connect(“tp”);
Step 3: Execute Query
你可以使用 Session 类的 execute() 方法执行 CQL 查询。将查询以字符串格式或 Statement 类对象的形式传递给 execute() 方法。你以字符串格式传递给此方法的任何内容都将在 cqlsh 上执行。
在下面的示例中,我们正在从一个名为 emp. 的表中删除数据。你必须将查询存储在字符串变量中,并将它传递给 execute() 方法,如下所示。
String query1 = ”DELETE FROM emp WHERE emp_id=3; ”;
session.execute(query);
下面给出的是一个完整程序,用来使用 Java API 从 Cassandra 中的一个表中删除数据。
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,浏览到它被保存的位置。编译并执行程序,如下所示。
$javac Delete_Data.java
$java Delete_Data
在正常条件下,它应该产生以下输出 −
Data deleted