Cassandra - Criar Dados

Criação de dados em uma tabela

Você pode inserir dados nas colunas de uma linha em uma tabela usando o comando INSERT. A seguir está a sintaxe para a criação de dados em uma tabela.

INSERT INTO <tablename>
(<column1 name>, <column2 name>....)
VALUES (<value1>, <value2>....)
USING <option>

Exemplo

Vamos supor que existe uma mesa chamada emp com colunas (emp_id, emp_name, emp_city, emp_phone, emp_sal) e você tem que inserir os seguintes dados no emp tabela.

emp_id	emp_name	emp_city	emp_phone	emp_sal
1	RAM	Hyderabad	9848022338	50000
2	Robin	Hyderabad	9848022339	40.000
3	rahman	Chennai	9848022330	45000

Use os comandos fornecidos abaixo para preencher a tabela com os dados necessários.

cqlsh:tutorialspoint> INSERT INTO emp (emp_id, emp_name, emp_city,
   emp_phone, emp_sal) VALUES(1,'ram', 'Hyderabad', 9848022338, 50000);

cqlsh:tutorialspoint> INSERT INTO emp (emp_id, emp_name, emp_city,
   emp_phone, emp_sal) VALUES(2,'robin', 'Hyderabad', 9848022339, 40000);

cqlsh:tutorialspoint> INSERT INTO emp (emp_id, emp_name, emp_city,
   emp_phone, emp_sal) VALUES(3,'rahman', 'Chennai', 9848022330, 45000);

Verificação

Após inserir os dados, use a instrução SELECT para verificar se os dados foram inseridos ou não. Se você verificar a tabela emp usando a instrução SELECT, ela fornecerá a seguinte saída.

cqlsh:tutorialspoint> SELECT * FROM emp;

 emp_id |  emp_city | emp_name |  emp_phone | emp_sal
--------+-----------+----------+------------+---------
      1 | Hyderabad |      ram | 9848022338 | 50000
      2 | Hyderabad |    robin | 9848022339 | 40000
      3 |   Chennai |   rahman | 9848022330 | 45000
 
(3 rows)

Aqui você pode observar que a tabela foi preenchida com os dados que inserimos.

Criação de dados usando Java API

Você pode criar dados em uma tabela usando o método execute () da classe Session. Siga as etapas fornecidas a seguir para criar dados em uma tabela usando a API Java.

Etapa 1: Criar um objeto de cluster

Crie uma instância de Cluster.builder classe de com.datastax.driver.core pacote conforme mostrado abaixo.

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

Adicione um ponto de contato (endereço IP do nó) usando o addContactPoint() método de Cluster.Builderobjeto. Este método retornaCluster.Builder.

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

Usando o novo objeto construtor, crie um objeto de cluster. Para fazer isso, você tem um método chamadobuild() no Cluster.Builderclasse. O código a seguir mostra como criar um objeto de cluster.

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

Você pode construir um objeto de cluster usando uma única linha de código, conforme mostrado abaixo.

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

Etapa 2: Criar um objeto de sessão

Crie uma instância do objeto Session usando o método connect () da classe Cluster conforme mostrado abaixo.

Session session = cluster.connect( );

Este método cria uma nova sessão e a inicializa. Se você já tiver um keyspace, poderá defini-lo como o existente passando o nome do KeySpace em formato de string para este método, conforme mostrado abaixo.

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

Aqui estamos usando o KeySpace chamado tp. Portanto, crie o objeto de sessão conforme mostrado abaixo.

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

Etapa 3: Executar consulta

Você pode executar consultas CQL usando o método execute () da classe Session. Passe a consulta em formato de string ou como umStatementobjeto de classe para o método execute (). Tudo o que você passar para este método em formato de string será executado nocqlsh.

No exemplo a seguir, estamos inserindo dados em uma tabela chamada emp. Você deve armazenar a consulta em uma variável de string e passá-la para o método execute () como mostrado abaixo.

String query1 = “INSERT INTO emp (emp_id, emp_name, emp_city, emp_phone, emp_sal)
   VALUES(1,'ram', 'Hyderabad', 9848022338, 50000);” ;
 
String query2 = “INSERT INTO emp (emp_id, emp_name, emp_city, emp_phone, emp_sal)
   VALUES(2,'robin', 'Hyderabad', 9848022339, 40000);” ;
 
String query3 = “INSERT INTO emp (emp_id, emp_name, emp_city, emp_phone, emp_sal)
   VALUES(3,'rahman', 'Chennai', 9848022330, 45000);” ;
 
session.execute(query1);
session.execute(query2);
session.execute(query3);

A seguir está o programa completo para inserir dados em uma tabela no Cassandra usando a API Java.

import com.datastax.driver.core.Cluster;
import com.datastax.driver.core.Session;

public class Create_Data {

   public static void main(String args[]){

      //queries
      String query1 = "INSERT INTO emp (emp_id, emp_name, emp_city, emp_phone,  emp_sal)"
		
         + " VALUES(1,'ram', 'Hyderabad', 9848022338, 50000);" ;
                             
      String query2 = "INSERT INTO emp (emp_id, emp_name, emp_city,
         emp_phone, emp_sal)"
      
         + " VALUES(2,'robin', 'Hyderabad', 9848022339, 40000);" ;
                             
      String query3 = "INSERT INTO emp (emp_id, emp_name, emp_city, emp_phone, emp_sal)"
       
         + " VALUES(3,'rahman', 'Chennai', 9848022330, 45000);" ;

      //Creating Cluster object
      Cluster cluster = Cluster.builder().addContactPoint("127.0.0.1").build();
 
      //Creating Session object
      Session session = cluster.connect("tp");
       
      //Executing the query
      session.execute(query1);
        
      session.execute(query2);
        
      session.execute(query3);
        
      System.out.println("Data created");
   }
}

Salve o programa acima com o nome da classe seguido por .java, navegue até o local onde ele foi salvo. Compile e execute o programa conforme mostrado abaixo.

$javac Create_Data.java
$java Create_Data

Em condições normais, ele deve produzir a seguinte saída -

Data created