Cassandra Linguagem de Consulta (CQL): Inserir, Atualizar e Excluir

Inserir dados

O Cassandra instrução insert grava dados em Cassandra colunas em forma de linha. Cassandra A consulta de inserção armazenará apenas as colunas fornecidas pelo usuário. Você deve necessariamente especificar apenas a coluna da chave primária.

Não ocupará nenhum espaço para valores não fornecidos. Nenhum resultado é retornado após a inserção.

Sintaxe

INSERT INTO KeyspaceName.TableName (ColumnName1, ColumnName2, ColumnName3)
VALUES (Column1Value, Column2Value, Column3Value);

Exemplo

Aqui está o instantâneo do executado Cassandra Inserir na consulta da tabela que irá inserir um registro em Cassandra tabela 'Aluno'.

INSERT INTO University.Student (RollNo, Name, dept, Semester)
VALUES (2, 'Michael', 'CS', 2);

Após a execução bem-sucedida do comando Inserir em Cassandra, uma linha será inserida no Cassandra tabela Aluno com RollNo 2, Nome Michael, dept CS e Semestre 2.

Aqui está o instantâneo do estado atual do banco de dados.

Upsert Dados

Cassandra perturba. Upsert significa que Cassandra irá inserir uma linha se uma chave primária ainda não existir; caso contrário, se a chave primária já existir, ele atualizará essa linha.

Isso tem uma consequência prática que vale a pena mencionar claramente: um comando INSERT nunca reporta um erro de chave duplicada, portanto, uma reinserção acidental sobrescreve a linha existente sem aviso prévio. Quando isso precisa ser evitado, adicione um IF NOT EXISTS para tornar a instrução uma transação leve.

INSERT INTO University.Student (RollNo, Name)
VALUES (2, 'Michael') IF NOT EXISTS;

Transações leves utilizam uma rodada de consenso entre réplicas, sendo consideravelmente mais lentas do que uma gravação normal e devem ser reservadas para casos que realmente necessitem da verificação.

Dados de atualização

O Cassandra A consulta de atualização é usada para atualizar os dados no Cassandra mesa. Se nenhum resultado for retornado após a atualização dos dados, significa que os dados foram atualizados com sucesso, caso contrário, um erro será retornado. Os valores das colunas são alterados na cláusula 'Set' enquanto os dados são filtrados com a cláusula 'Where'.

Sintaxe

UPDATE KeyspaceName.TableName
SET ColumnName1 = NewValue1,
    ColumnName2 = NewValue2
WHERE ColumnName = ColumnValue;

Exemplo

Aqui está a captura de tela que mostra o estado do banco de dados antes de atualizar os dados.

Aqui está o instantâneo do executado Cassandra Comando de atualização que atualiza o registro na tabela Aluno.

UPDATE University.Student
SET name = 'Hayden'
WHERE rollno = 1;

Após a execução bem-sucedida da consulta de atualização em Cassandra 'Atualizar Aluno', o nome do aluno será alterado de 'Clark' para 'Hayden' que possui rollno 1.

Aqui está a captura de tela que mostra o estado do banco de dados após a atualização dos dados.

Devido ao comportamento do upsert, uma operação UPDATE em uma chave primária inexistente cria a linha em vez de falhar.

Cassandra Excluir dados

O comando 'Excluir' remove uma linha inteira ou algumas colunas da tabela Aluno. Quando os dados são excluídos, eles não são excluídos da tabela imediatamente. Em vez disso, os dados excluídos são marcados com uma lápide e removidos após a compactação.

Sintaxe

DELETE FROM KeyspaceName.TableName
WHERE ColumnName1 = ColumnValue;

O referido Cassandra A sintaxe de exclusão de linha excluirá uma ou mais linhas, dependendo da filtragem de dados na cláusula where.

DELETE ColumnName1, ColumnName2 FROM KeyspaceName.TableName
WHERE ColumnName1 = ColumnValue;

A sintaxe acima excluirá algumas colunas da tabela.

Exemplo

Aqui está o instantâneo que mostra o estado atual do banco de dados antes de excluir os dados.

Aqui está o instantâneo do comando que removerá uma linha da tabela Student.

DELETE FROM University.Student WHERE rollno = 1;

Após a execução bem-sucedida do comando CQL Delete, uma linha será excluída da tabela Student onde o valor de rollno é 1.

Aqui está o instantâneo que mostra o estado do banco de dados após a exclusão dos dados.

Os marcadores de exclusão (tombstones) permanecem ativos por um período definido em `gc_grace_seconds`, dez dias por padrão, de forma que um nó offline durante a exclusão não possa recuperar a linha quando retornar. Portanto, a exclusão de grandes volumes deixa marcadores que cada leitura subsequente deve ignorar.

O quê Cassandra não suporta

A CQL utiliza a sintaxe SQL, mas não o modelo de execução relacional, portanto, várias construções familiares se comportam de maneira diferente ou estão ausentes.

1. CQL não suporta junções entre tabelas. Os dados relacionados devem ser desnormalizados em uma única tabela no momento da gravação.
2. A linguagem CQL não suporta condições OR em uma cláusula WHERE. Use IN em uma única coluna ou execute consultas separadas.
3. CQL não suporta UNION ou INTERSECT.
4. Colunas que não são chaves primárias não podem ser filtradas até que exista um índice nelas.
5. As comparações "maior que" e "menor que" aplicam-se apenas a colunas de agrupamento, pois somente essas são classificadas no disco.
6. A correspondência de padrões com LIKE requer um índice SASI e não está disponível em colunas comuns.

Uma afirmação antiga precisa ser corrigida. Funções agregadas são suportadas: CONTAR, MÍNIMO, MÁXIMO, SOMA e AVG chegou a Cassandra 2.2, e GROUP BY Chegou em 3.10. A ressalva é o escopo, e não a disponibilidade.

SELECT dept, COUNT(*) FROM University.Student
WHERE RollNo = 1 GROUP BY dept;

Quando restrito a uma única partição, como acima, um agregado é eficiente. Executado em toda a tabela, ele se torna uma varredura em todo o cluster, e é por isso que... Cassandra continua inadequado para análises ad hoc e é por isso que a geração de relatórios complexos é normalmente direcionada para Spark ou um armazém externo.

Cassandra Onde cláusula

In Cassandra, a recuperação de dados é uma questão delicada. A coluna é filtrada em Cassandra criando um índice em colunas de chave não primária.

Sintaxe

SELECT ColumnNames FROM KeyspaceName.TableName
WHERE ColumnName1 = Column1Value
  AND ColumnName2 = Column2Value;

Exemplo

• Aqui está o instantâneo que mostra a recuperação de dados da tabela Student sem filtragem de dados.

SELECT * FROM University.Student;

Dois registros são recuperados da tabela Student.

• Aqui está o instantâneo que mostra a recuperação de dados do Student com filtragem de dados. Um registro é recuperado.

Os dados são filtrados pela coluna "nome". Todos os registros que possuem nome igual a são recuperados. Guru99.

SELECT * FROM University.Student WHERE name = 'Guru99';

As regras que regem quais colunas uma cláusula WHERE pode referenciar decorrem diretamente da chave primária.

• O chave de partição Deve ser fornecido na íntegra para qualquer consulta eficiente, pois identifica o nó que contém os dados.
• Clustercolunas ing podem então ser restringidas, mas apenas na ordem em que foram declaradas.ping Uma delas foi rejeitada.
• É permitida a comparação de intervalos na última coluna de agrupamento referenciada, e não em colunas anteriores.
• Qualquer outra coluna precisa de um índice secundário, abordado no criar e excluir índice tutorial.

Quando uma consulta é rejeitada, Cassandra Muitas vezes, sugere-se adicionar ALLOW FILTERING. Considere isso como um aviso, não como uma correção: o comando verifica todas as partições em todos os nós, e uma alteração no esquema é quase sempre a resposta correta.

Perguntas Frequentes