Cassandra Fromjson

Cassandra é um banco de dados versátil com toneladas de recurso e suporte para recursos modernos. Um desses recursos é JSON. Cassandra permite que você exporte ou importe dados de objetos JSON.

Nesta postagem, discutiremos como podemos inserir dados do JSON em um banco de dados Cassandra.

Amostra de Keyspace e tabela

Vamos começar criando um espaço de amostra e tabela. Isso nos permitirá inserir dados de amostra do formato JSON.

Você pode usar o código como mostrado abaixo:

Crie a loja de chaves
com replicação =
'Classe': 'SimpleStrategy',
'Replicação_factor': 1;

Depois de termos o espaço de chave de destino, podemos mudar para ele e criar uma tabela como mostrado:

cqlsh> use store;
CQLSH: Armazene> Criar produtos de tabela (Product_id UUID, Product_name Text, Price Int, Primary Key (Product_id));

O comando acima criará uma tabela chamada Produtos Holding Columns Product_id, Product_name e Price.

Podemos então criar os dados JSON que desejamos inserir na tabela. A amostra JSON é como mostrado:

"Product_id": "A872710C-39EE-4F34-964A-843A73EB0032",
"Product_name": "Product One",
"Preço": 100

Podemos inserir os dados JSON acima usando a inserção no comando como mostrado:

CQLSH: armazenar> Inserir na loja.Produtos JSON
'
"Product_id": "A872710C-39EE-4F34-964A-843A73EB0032",
"Product_name": "Product One",
"Preço": 100
';

No código de exemplo acima, começamos chamando a inserção no comando seguida pelo nome da tabela. Em seguida, usamos a palavra -chave JSON e anexamos os dados JSON em citações únicas.

Isso deve inserir os dados na tabela, conforme especificado pelas colunas e valores. Podemos confirmar buscando os dados.

cqlsh: armazenar> selecionar * da loja.produtos;

A consulta acima deve retornar os dados como mostrado:

product_id | Preço | Nome do Produto
--------------------------------------+-------+--------------
A872710C-39EE-4F34-964A-843A73EB0032 | 100 | Produto um
(1 linhas)

Observe que, embora insira o valor do produto como uma string, Cassandra analisará e o armazenará como um valor UUID.

Se o valor de uma determinada coluna não for fornecida, Cassandra inserirá um valor nulo em seu lugar.

Um exemplo é como mostrado:

CQLSH: armazenar> Inserir na loja.Produtos JSON '"Product_id": "350EB980-1EE3-4892-84D2-888EAB97CC71F", "Product_Name": "Product Three"';

Observe que, neste caso, omitimos a coluna de preços. Cassandra substituirá o valor por nulo como mostrado:

cqlsh: armazenar> selecionar * da loja.produtos;

Saída resultante:

product_id | Preço | Nome do Produto
--------------------------------------+-------+---------------
A872710C-39EE-4F34-964A-843A73EB0032 | 100 | Produto um
350EB980-1EE3-4892-84D2-888EAB97CC71F | nulo | Produto três
(2 linhas)

Conclusão

Neste artigo, você aprendeu a inserir dados JSON em uma tabela Cassandra usando comandos CQLSH.