Cassandra教程

Cassandra -Alter Table

更改表

您可以使用 ALTER TABLE 命令更改表.下面给出了创建表的语法.

语法

ALTER (TABLE | COLUMNFAMILY) <tablename> <instruction>

使用ALTER命令，您可以执行以下操作 :

添加列
删除列

添加列

使用ALTER命令，可以向表中添加列.添加列时，必须注意列名称与现有列名称不冲突，并且表格未使用紧凑存储选项定义.下面给出了向表中添加列的语法.

ALTER TABLE table name
ADD  new column datatype;

示例

下面给出了一个向现有表添加列的示例.这里我们将一个名为 emp_email 的文本数据类型的列添加到名为 \\ temp \\/b>的表中.

cqlsh:it1352> ALTER TABLE emp
   ... ADD emp_email text;

验证

使用SELECT语句验证是否添加了列.在这里你
可以观察新添加的列emp_email.

cqlsh:it1352> select * from emp;

 emp_id | emp_city | emp_email | emp_name | emp_phone | emp_sal
--------+----------+-----------+----------+-----------+---------

删除列

使用ALTER命令，可以从表中删除列.在从表中删除列之前，请检查该表是否未使用紧凑存储选项定义.下面给出了使用ALTER命令从表中删除列的语法.

ALTER table name
DROP column name;

示例

以下是从表中删除列的示例.这里我们删除
名为 emp_email 的列.

cqlsh:it1352> ALTER TABLE emp DROP emp_email;

验证

使用选择

cqlsh:it1352> select * from emp; 
emp_id | emp_city | emp_name | emp_phone | emp_sal 
-------- + ---------- + ---------- + ----------- +  - ------- 
(0行)

由于 emp_email 列已删除，您无法找到它了.

使用Java API更改表

您可以使用Session类的execute()方法创建表.按照下面给出的步骤使用Java API更改表.

步骤1:创建集群对象

首先，创建一个

//创建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();

步骤2:创建会话对象

使用Cluster的connect()方法创建Session对象的实例class
，如下所示.

Session session = cluster.connect();

此方法创建一个新会话并对其进行初始化.如果您已经有一个键空间，可以通过将字符串格式的KeySpace名称传递给此方法将其设置为现有键空间，如下所示.

Session session = cluster.connect(" Your keyspace name " );
Session session = cluster.connect(" tp" );

这里我们使用名为tp的KeySpace.因此，创建会话对象
，如下所示.

步骤3:执行查询

您可以使用execute执行CQL查询( )Session类的方法.将查询以字符串格式或Statement类对象传递给execute()方法.无论以字符串格式传递给此方法的是什么，都将在 cqlsh 上执行.

在下面的示例中，我们将一个列添加到名为

//Query
String query1 = "ALTER TABLE emp ADD emp_email text";
session.execute(query);

以下是将列添加到现有表的完整程序.

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

public class Add_column {

   public static void main(String args[]){

      //Query
      String query = "ALTER TABLE emp ADD emp_email text";

      //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("Column added");
   }
}

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

 $ javac Add_Column.java 
 $ java Add_Column

在正常情况下，它应该产生以下输出 :

Column added

删除列

以下是从现有表中删除列的完整程序.

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

public class Delete_Column {

   public static void main(String args[]){

      //Query
      String query = "ALTER TABLE emp DROP emp_email;";

      //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("Column deleted");
   }
 }