В этом примере показано, как импортировать данные из таблицы базы данных 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)
cassandra
| close
| executecql