Кассандра - выпадающий стол

Падение стола

Вы можете отбросить таблицу с помощью команды Drop Table. Его синтаксис следующий -

Синтаксис

DROP TABLE <tablename>

пример

Следующий код удаляет существующую таблицу из KeySpace.

cqlsh:tutorialspoint> DROP TABLE emp;

Проверка

Используйте команду Describe, чтобы проверить, удалена ли таблица. Поскольку таблица emp была удалена, вы не найдете ее в списке семейств столбцов.

cqlsh:tutorialspoint> DESCRIBE COLUMNFAMILIES;
employee

Удаление таблицы с помощью Java API

Вы можете удалить таблицу, используя метод execute () класса Session. Следуйте инструкциям ниже, чтобы удалить таблицу с помощью Java API.

Шаг 1. Создайте кластерный объект.

Прежде всего, создайте экземпляр Cluster.builder класс com.datastax.driver.core пакет, как показано ниже -

//Creating Cluster.Builder object
Cluster.Builder builder1 = Cluster.builder();

Добавьте точку контакта (IP-адрес узла), используя addContactPoint() метод Cluster.Builderобъект. Этот метод возвращаетCluster.Builder.

//Adding contact point to the Cluster.Builder object
Cluster.Builder builder2 = build.addContactPoint( "127.0.0.1" );

Используя новый объект построителя, создайте объект кластера. Для этого у вас есть метод под названиемbuild() в Cluster.Builderкласс. В следующем коде показано, как создать объект кластера.

//Building a cluster
Cluster cluster = builder.build();

Вы можете построить объект кластера, используя одну строку кода, как показано ниже.

Cluster cluster = Cluster.builder().addContactPoint("127.0.0.1").build();

Шаг 2. Создайте объект сеанса

Создайте экземпляр объекта Session, используя метод connect () класса Cluster, как показано ниже.

Session session = cluster.connect( );

Этот метод создает новый сеанс и инициализирует его. Если у вас уже есть пространство ключей, вы можете установить его в существующее, передав имя KeySpace в строковом формате этому методу, как показано ниже.

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

Здесь мы используем пространство ключей с именем tp. Поэтому создайте объект сеанса, как показано ниже.

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

Шаг 3: Выполнить запрос

Вы можете выполнять запросы CQL, используя метод execute () класса Session. Передайте запрос в строковом формате или в виде объекта класса Statement методу execute (). Все, что вы передадите этому методу в строковом формате, будет выполнено наcqlsh.

В следующем примере мы удаляем таблицу с именем emp. Вы должны сохранить запрос в строковой переменной и передать его методу execute (), как показано ниже.

// Query

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

Ниже приведена полная программа для удаления таблицы в Cassandra с использованием Java API.

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