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