Cassandra 简明教程

Cassandra - Update Data

Updating Data in a Table

UPDATE 是用于更新表中数据的命令。更新表中的数据时，会使用以下关键字 −

  1. Where − 此子句用于选择要更新的行。

  2. Set − 使用此关键字设置值。

  3. Must − 包含组成主键的所有列。

更新行时，如果给定行不可用，则 UPDATE 会创建一个新行。以下是 UPDATE 命令的语法 −

UPDATE <tablename>
SET <column name> = <new value>
<column name> = <value>....
WHERE <condition>

Example

假设有一张名为 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

现在，让我们将 robin 的 emp_city 更新为德里，并将他的薪水更新为 50000。以下是执行所需更新的查询。

cqlsh:tutorialspoint> UPDATE emp SET emp_city='Delhi',emp_sal=50000
   WHERE emp_id=2;

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 | 45000

(3 rows)

此处您可以看到表数据已更新。

Updating 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 session = cluster.connect(“tp”);

Step 3: Execute Query

你可以使用 Session 类的 execute() 方法执行 CQL 查询。将查询以字符串格式或 Statement 类对象的形式传递给 execute() 方法。你以字符串格式传递给此方法的任何内容都将在 cqlsh 上执行。

在以下示例中，我们正在更新 emp 表。您需要将查询存储在字符串变量中，并将其传递给 execute() 方法，如下所示：

String query = “ UPDATE emp SET emp_city='Delhi',emp_sal=50000
WHERE emp_id = 2;” ;

以下是使用 Java API 更新表中数据的完整程序。

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

public class Update_Data {

   public static void main(String args[]){

      //query
      String query = " UPDATE emp SET emp_city='Delhi',emp_sal=50000"

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

使用类名保存以上的程序，后跟 .java，浏览到它被保存的位置。编译并执行程序，如下所示。

$javac Update_Data.java
$java Update_Data

在正常条件下，它应该产生以下输出 −

Data updated