Вставка данных с помощью файла CSV в Cassandra

В этой статье мы обсудим, как можно вставить данные в таблицу с помощью CSV-файла. И мы также рассмотрим реализацию с помощью примеров. Давайте обсудим это один за другим.

Предварительное условие — Знакомство с Кассандрой

Введение :
Если вы хотите хранить данные в большом количестве, вставка данных из CSV-файла — один из хороших способов. Если у вас есть данные в файле, вы можете напрямую вставить свои данные в базу данных с помощью команды COPY в Cassandra. Это будет очень полезно, когда у вас очень большая база данных, и вы хотите быстро хранить данные, а ваши данные находятся в файле CSV, после чего вы можете напрямую вставлять свои данные.

Синтаксис –
Вы можете увидеть синтаксис команды COPY для справки следующим образом.

COPY table_name [( column_list )]
FROM "file_name path"[, "file2_name path", ...] | STDIN
[WITH option = "value" [AND ...]]

Теперь давайте создадим образцы данных для реализации подхода.

Шаг 1 :
Создание пространства ключей — данные
Здесь вы можете использовать следующую команду cqlsh для создания пространства ключей следующим образом.

CREATE KEYSPACE data
 WITH REPLICATION = {  
  "class" : "NetworkTopologyStrategy",  
  "datacenter1" : 1  
  } ;

Шаг 2 :
Создание таблицы Student_personal_data –
Здесь вы можете использовать следующую команду cqlsh для создания таблицы Student_personal_data следующим образом.

CREATE TABLE data.Student_personal_data (  
 S_id UUID PRIMARY KEY,  
S_firstname text,  
S_lastname text,    
);

Шаг 3 :
Создание CSV-файла –
Рассмотрим следующую данную таблицу как файл CSV, а именно как personal_data.csv. Но на самом деле вы можете вставить данные в CSV-файл и сохранить его на диске вашего компьютера.

Шаг-4:
Вставка данных из файла CSV –
Здесь вы увидите, как вы можете вставлять данные в базу данных из существующего файла CSV, который у вас есть, и вы можете использовать следующую команду cqlsh следующим образом.

COPY data.Student_personal_data (S_id, S_firstname, S_lastname) 
FROM "personal_data.csv" 
WITH HEADER = TRUE;

Шаг-5:
Проверка результата –
Как только вы выполните указанную выше команду, вы получите следующий результат следующим образом.

Using 7 child processes

Starting copy of data.Student_personal_data with columns [S_id, S_firstname, S_lastname].
Processed: 6 rows; Rate:      10 rows/s; Avg. rate:      14 rows/s
6 rows imported from 1 files in 0.422 seconds (0 skipped).

Вы можете использовать следующую команду, чтобы увидеть вывод следующим образом.

select * from data.Student_personal_data;

Выход :