Кассандра - Создание данных

Создание данных в таблице

Вы можете вставить данные в столбцы строки таблицы с помощью команды INSERT. Ниже приведен синтаксис для создания данных в таблице.

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

пример

Предположим, есть таблица с именем emp со столбцами (emp_id, emp_name, emp_city, emp_phone, emp_sal), и вы должны вставить следующие данные в emp Таблица.

emp_id	emp_name	emp_city	emp_phone	emp_sal
1	ОЗУ	Хайдарабад	9848022338	50000
2	Робин	Хайдарабад	9848022339	40000
3	рахман	Ченнаи	9848022330	45000

Используйте приведенные ниже команды, чтобы заполнить таблицу необходимыми данными.

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);

Проверка

После вставки данных используйте оператор SELECT, чтобы проверить, были ли данные вставлены или нет. Если вы проверите таблицу emp с помощью оператора SELECT, она выдаст вам следующий результат.

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)

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

Создание данных с использованием 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 ” );

Здесь мы используем KeySpace под названием tp. Поэтому создайте объект сеанса, как показано ниже.

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

Шаг 3: Выполнить запрос

Вы можете выполнять запросы CQL, используя метод execute () класса Session. Передайте запрос либо в строковом формате, либо какStatementобъект класса в метод execute (). Все, что вы передадите этому методу в строковом формате, будет выполнено наcqlsh.

В следующем примере мы вставляем данные в таблицу с именем emp. Вы должны сохранить запрос в строковой переменной и передать его методу execute (), как показано ниже.

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);

Ниже приведена полная программа для вставки данных в таблицу в Cassandra с использованием Java API.

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");
   }
}

Сохраните указанную выше программу с именем класса, за которым следует .java, перейдите в место, где она сохранена. Скомпилируйте и выполните программу, как показано ниже.

$javac Create_Data.java
$java Create_Data

В нормальных условиях он должен выдавать следующий результат -

Data created