Вы можете удалить таблицу с помощью команды Удалить таблицу . Его синтаксис выглядит следующим образом —
Синтаксис
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
В нормальных условиях он должен выдавать следующий результат: