Cassandra 中的数据操作

dbmsdatabasecassandra更新于 2026/1/28 1:07:17

数据操作是指在数据库服务器中处理数据。数据的操作是通过查询中不同类型的命令来处理的。它帮助我们对数据库执行不同类型的操作。数据操作命令有四种。

插入

它用于将数据插入表中。它还可以用于向现有表中添加更多数据。其目的是使用 INSERT 语句将数据插入表中。

语法

INSERT INTO table_name(parameters) VALUES (values_for_parameter);

这里:

  • table_name 是要执行操作的表的名称。

  • 参数是要插入的列,例如 name、id、salary 等。

示例

此示例包含两个使用 INSERT 命令向表中插入数据的案例。

案例 1

正常插入数据

算法

  • 步骤 1:创建表格

  • 步骤 2:使用 INSERT 语句将值插入表格

  • 步骤 3:选择表格以显示输出并查看插入的值

CREATE TABLE student(id int,name char(50),roll_no. (50),branch char);#table created
INSERT INTO student(id,name,roll_no,branch) VALUES (1,aman,20,cs);#row 1 inserted
INSERT INTO student(id,name,roll_no,branch) VALUES (2,naman,21,civil);#row 2 inserted
INSERT INTO student

输出

id	name	roll_no. 	 branch
1	aman	 20	         cs
2	naman	 21	         civil
3	raman	 22	         bao

案例 2

使用 JSON 插入数据

算法

  • 步骤 1:创建表格

  • 步骤 2:使用 JSON 向表格中插入值

  • 步骤 3:选择表格以显示输出

示例

CREATE TABLE student(id int,name char(50),roll_no. (50),branch char);#table created
INSERT INTO student JSON ("id":"1","name":"aman","roll_no":"20","branch":"cs");#json is used 

输出

id	name	 roll_no. 	branch
1	aman	 20	        cs

更新

它用于更新现有表中的数据。数据已存在于表中,如果需要更改或更新任何数据,则使用 UPDATE 语句。

语法

UPDATE table_name USING update_parameter
SET values_to_update WHERE condition;

此处,

  • table_name 是将执行操作的表的名称

  • update_parameter 指的是时间戳

  • values_to_update 指的是要更新的值

  • 条件用于选择要更新值的行

示例

此示例涵盖了用于更新给定表中值的 update 命令

算法

  • 步骤 1: 使用 update 进行更新并提供表名

  • 步骤 2: 使用 ttl(时间到(实时)

  • 步骤 3:设置要更新的值

  • 步骤 4:提供执行更新的条件

  • 步骤 5:选择要显示输出的表格

输入

id	name	 roll_no. 	branch
1	aman	 20	        cs
2	naman	 21	        civil
3	raman	 22	        bao

示例

UPDATE student #update operation is to be performed
USING TTL 400# time to live is used
SET name='monu',roll_no=25#set updated values
WHERE id=1;#condition regarding where to update
SELECT * FROM student;#Select table to show output

输出

id	name	  roll_no. 	branch
1	monu	  25	        cs
2	naman	  21	        civil
3	raman	  22	        bao

删除

用于从表中删除任何数据。仅当数据已存在于数据表中时才有效。

语法

DELETE FROM table_name USING update_parameter
WHERE condition;

算法

  • 步骤 1:使用删除

  • 步骤 2:提供表名

  • 步骤 3:使用时间戳

  • 步骤 4:提供执行删除操作的条件

  • 步骤 5:选择要显示输出的表

输入

id	name	  roll_no. 	branch
1	monu	  25	        cs
2	naman	  21	        civil
3	raman	  22	        bao

示例

DELETE FROM student#table on which data deletion will occur
USING TIMESTAMP 234334 #timestamp is used
WHERE id=1;#condition condition regarding where to delete
SELECT * FROM student;#Select table to show output

输出

id	name	  roll_no. 	branch
2	naman	  21	    civil
3	raman	  22	     bao

批处理

它用于在单个语句中执行多个 INSERT、UPDATE 和 DELETE 操作。

语法

BEGIN [ UNLOGGED | COUNTER ] BATCH
modification_statement
APPLY BATCH;

此处:

  • unlogged 用于跳过批处理日志,即失败的批处理可能会留下补丁。

  • counter 用于批量计数器更新。

  • 修改语句涵盖插入、更新和删除语句

示例

此示例包含一个批处理,后跟插入、更新和删除语句。

算法

  • 步骤 1:创建表

  • 步骤 2:开始批处理

  • 步骤 3:执行操作

  • 步骤 4:将批处理应用于操作

  • 步骤 5:选择要显示输出的表

CREATE TABLE student(id int,name char(50),roll_no. (50),branch char);#table created
BEGIN BATCH#batch started
INSERT INTO student(id,name,roll_no,branch) VALUES (1,aman,20,cs);#value inserted
INSERT INTO student(id,name,roll_no,branch) VALUES (2,naman,21,civil);#value inserted
UPDATE student SET name='monu',roll_no=25 WHERE id=1;#value updated
DELETE name FROM student WHERE id=1;#value deleted
APPLY BATCH;#batch applied to above operations
SELECT * FROM student;#Select table to show output

输出

id	name	 roll_no. 	branch
1	null	 25	        cs
2	naman	 21	        civil

结论

数据操作包含四个命令。第一个命令是 INSERT,它支持两种情况,一种是常规插入,另一种是使用 JSON 插入数据。第二个命令是 update,用于更新数据库中的数据。第三个命令是 delete,用于删除数据。第四个命令是 batch,它将 insert、update 和 delete 合并成一个语句。