Cassandra - Truncate Table

Cassandra截断表 - 从简介，架构和数据模型，安装，参考Api，Cassandra Cqlsh，Shell命令，创建Keyspace，Alter Keyspace，Drop Keyspace，创建表，Alter Table，Drop Table，Truncate等简单易懂的步骤学习cassandra表，创建索引，删除索引，创建数据，更新数据，删除数据，批处理，选择子句，Cql数据类型，Cql集合，Cql用户定义的数据类型。

截断表

您可以使用TRUNCATE命令截断表.截断表时，表的所有行都将永久删除.下面给出了这个命令的语法.

语法

TRUNCATE< tablename>

示例

我们假设有一个名为 student 的表，其中包含以下数据.

s_id	s_name	clearanch	s_aggregate
1	ram	IT	70
2	rahman	EEE	75
3	robbin	Mech	72

执行select语句以获取表学生，它会给你以下输出.

cqlsh:tp> select * from student; s_id | s_aggregate | s_branch | s_name------+-------------+----------+--------    1 |          70 |       IT | ram    2 |          75 |      EEE | rahman    3 |          72 |     MECH | robbin(3 rows)

现在使用TRUNCATE命令截断表.

cqlsh:tp> TRUNCATE student;

验证

验证是否通过执行 select 语句截断表.下面给出了截断后学生表上select语句的输出.

cqlsh:tp> select * from student; s_id | s_aggregate | s_branch | s_name------+-------------+----------+--------(0 rows)

使用Java API截断表

您可以使用execute截断表()Session类的方法.按照下面给出的步骤截断表.

步骤1:创建群集对象

首先，创建群集的实例.builder 类 com.datastax.driver.core 包，如下所示.

//创建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()的方法.以下代码显示了如何创建集群对象.

//Building a clusterCluster 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的键空间.因此，创建会话对象，如下所示.

步骤3:执行查询

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

在以下示例中，我们将截断名为 \\ temp

//QueryString query = "TRUNCATE emp;;";session.execute(query);

以下是使用Java API在Cassandra中截断表的完整程序.

import com.datastax.driver.core.Cluster;import com.datastax.driver.core.Session;public class Truncate_Table {   public static void main(String args[]){         //Query      String query = "Truncate student;";         //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("Table truncated");   }}

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

 $ javac Truncate_Table.java  $ java Truncate_Table

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

Table truncated