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