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