Импорт данных из таблицы базы данных Cassandra с помощью CQL

В этом примере показано, как импортировать данные из таблицы базы данных Apache Cassandra ® в MATLAB ® с помощью языка запросов Cassandra (CQL) и соединения базы данных Cassandra.

Используйте executecql функция для выполнения запросов CQL, которые фильтруются путем кластеризации столбцов или ограничения строк в результатах запроса, например. Кроме того, вы можете использовать executecql функция для записи в не- SELECT Операторы CQL. Для простого импорта данных с использованием значений ключа секционирования таблицы базы данных Cassandra используйте partitionRead вместо этого функция.

В этом примере база данных Cassandra содержит employees_by_job таблица базы данных с данными о сотрудниках и job_id ключ раздела. The hire_date столбец базы данных является кластерным столбцом.

Чтобы запустить этот пример, необходимо сначала установить интерфейс Toolbox™ базы данных для базы данных Apache Cassandra ®. Для получения дополнительной информации см. раздел «Интерфейс Database Toolbox для установки базы данных Apache Cassandra».

Создайте соединение с базой данных Cassandra с помощью локального адреса хоста. conn является cassandra объект.

contactPoints = "localhost";
conn = cassandra(contactPoints);

Написание запроса CQL, который выбирает всех сотрудников, являющихся программистами или продавцами магазинов, и извлекает их идентификаторы заданий, даты найма и адреса электронной почты. Фильтрация запроса сотрудниками, нанятыми до 30 апреля 2006 года, с помощью hire_date столбец кластеризации. Ограничьте возвращенные данные четырьмя строками.

query = strcat("SELECT job_id,hire_date,email ", ... 
    "FROM employeedata.employees_by_job ", ...
    "WHERE job_id IN ('IT_PROG','SH_CLERK') ", ...
    "AND hire_date < '2006-04-30'", ...
    "LIMIT 4;");

Выполните запрос CQL с помощью соединения с базой данных Cassandra и отобразите результаты.

results = executecql(conn,query)
results=4×3 table
      job_id       hire_date       email   
    __________    ___________    __________

    "IT_PROG"     05-Feb-2006    "VPATABAL"
    "IT_PROG"     03-Jan-2006    "AHUNOLD" 
    "IT_PROG"     25-Jun-2005    "DAUSTIN" 
    "SH_CLERK"    24-Apr-2006    "AWALSH"  

results - таблица с job_id, hire_date, и email переменные. The hire_date переменная является datetime массив и job_id и email переменные строковые массивы.

Закройте соединение с базой данных Cassandra.

close(conn)

См. также

| |

Похожие темы

Внешние веб-сайты

Для просмотра документации необходимо авторизоваться на сайте