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