Импортируйте данные от таблицы базы данных Кассандры Используя CQL

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

Смотрите также

| |

Похожие темы

Внешние веб-сайты

Для просмотра документации необходимо авторизоваться на сайте