В этом примере показано, как импортировать данные из таблицы базы данных Apache Cassandra ® в MATLAB ® с использованием языка запросов Cassandra (CQL) и соединения базы данных Cassandra с интерфейсом базы данных Apache Cassandra C++.
Используйте executecql функция для выполнения запросов CQL, которые фильтруются, например, путем кластеризации столбцов или ограничения строк в результатах запроса. Кроме того, можно использовать executecql функция для записи не -SELECT Инструкции CQL. Для упрощения импорта данных с использованием ключевых значений разделов таблицы базы данных Cassandra используйте partitionRead вместо этого функция.
В этом примере база данных Cassandra содержит employees_by_job таблица базы данных с данными сотрудников и job_id ключ раздела. hire_date столбец базы данных является столбцом кластеризации.
Создание подключения к базе данных Cassandra с использованием настроенного источника данных CassandraDataSource и пустое имя пользователя и пароль. apacheCassandra функция возвращает conn в качестве connection объект
datasource = "CassandraDataSource"; username = ""; password = ""; conn = apacheCassandra(datasource,username,password);
Напишите запрос 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)
apacheCassandra | close | executecql