×

Cassandra 教程

Cassandra 简介Cassandra 架构Cassandra 数据模型Cassandra 安装Cassandra 参考APICassandra CqlshCassandra Shell命令

Cassandra 键空间操作

Cassandra 创建键空间Cassandra 修改键空间Cassandra 删除键空间

Cassandra 表操作

Cassandra 创建表Cassandra 修改表Cassandra 删除表Cassandra 截断表Cassandra 创建索引Cassandra 删除索引Cassandra 批处理

Cassandra CURD操作

Cassandra 创建数据Cassandra 更新数据Cassandra 读取数据Cassandra 删除数据

Cassandra CQL数据类型

Cassandra CQL数据类型Cassandra CQL集合Cassandra CQL用户定义的数据类型

Cassandra 相关资源

Cassandra 相关资源Cassandra 相关讨论

Cassandra 删除表


使用Cqlsh删除表

您可以使用命令Drop Table删除表。其语法如下:

语法

DROP TABLE 

示例

以下代码从KeySpace删除现有表。

cqlsh:bootwiki> DROP TABLE emp;

验证

用Describe命令验证表是否已删除。由于emp表已删除,您不会在列族列表中找到它。

cqlsh:bootwiki> DESCRIBE COLUMNFAMILIES;

employee

使用Java API删除表

您可以使用Session类的execute()方法删除表。按照以下步骤使用Java API删除表。

第1步:创建集群对象

首先,创建一个Cluster.builder类的实例com.datastax.driver.core包,如下所示:

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

第2步:创建会话对象

使用Cluster类的connect()方法创建一个Session对象的实例,如下所示。

Session session = cluster.connect( );

此方法创建一个新会话并初始化它。如果您已经有一个键空间,您可以通过将KeySpace名称以字符串格式传递到此方法来将其设置为现有键空间,如下所示。

Session session = cluster.connect(“Your keyspace name”);

这里我们使用名为tp的键空间。因此,创建会话对象如下所示。

Session session = cluster.connect(“tp”);

第3步:执行查询

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

在下面的示例中,我们将删除名为emp的表。您必须将查询存储在字符串变量中,并将其传递给execute()方法,如下所示。

// Query

String query = "DROP TABLE emp1;”;
session.execute(query);

下面给出了使用Java API在Cassandra中删除表的完整程序。

import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.Session;
 
public class Drop_Table {

   public static void main(String args[]){

      //Query
      String query = "DROP TABLE emp1;";
      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("Table dropped");
   }
}

使用类名称和.java保存上述程序,浏览到保存位置。编译并执行程序如下图所示。

$javac Drop_Table.java
$java Drop_Table

在正常条件下,它应该产生以下输出:

Table dropped

分类导航

关注微信下载离线手册

bootwiki移动版 bootwiki
(群号:472910771)