В этом примере показано, как импортировать данные из таблицы базы данных Apache Cassandra ® в MATLAB ® с использованием языка запросов Cassandra (CQL) и подключения к базе данных Cassandra.
Используйте executecql функция для выполнения запросов CQL, которые фильтруются, например, путем кластеризации столбцов или ограничения строк в результатах запроса. Кроме того, можно использовать executecql функция для записи не -SELECT Инструкции CQL. Для упрощения импорта данных с использованием ключевых значений разделов таблицы базы данных Cassandra используйте partitionRead вместо этого функция.
В этом примере база данных Cassandra содержит employees_by_job таблица базы данных с данными сотрудников и job_id ключ раздела. hire_date столбец базы данных является столбцом кластеризации.
Для выполнения этого примера необходимо сначала установить интерфейс Toolbox™ базы данных для базы данных Apache Cassandra ®. Дополнительные сведения см. в разделе Интерфейс панели инструментов базы данных для установки базы данных 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 переменные. hire_date переменная является datetime массив и job_id и email переменные являются строковыми массивами.
Закройте подключение к базе данных Cassandra.
close(conn)
cassandra | close | executecql