Используя соединение с базой данных Cassandra®, выполните запрос CQL, чтобы импортировать данные от таблицы базы данных Кассандры в MATLAB®. В этом случае база данных Кассандры содержит таблицу базы данных employees_by_job с данными сотрудника в ключевом пространстве employeedata.

Создайте соединение с базой данных Кассандры с помощью локального адреса хоста. conn является объектом cassandra .

contactPoints = "localhost";
conn = cassandra(contactPoints);

Запишите запрос CQL, который выбирает всех сотрудников, которые являются программистами или клерками магазина, нанятыми до 30 апреля 2006, и получает их идентификаторы задания, арендные даты и адреса электронной почты. job_id является ключом раздела таблицы базы данных employees_by_job, и 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';");

Выполните запрос CQL и отобразите первые несколько строк результатов.

results = executecql(conn,query);
head(results)

ans=8×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"  
    "SH_CLERK"    23-Feb-2006    "JFLEAUR" 
    "SH_CLERK"    24-Jan-2006    "WTAYLOR" 
    "SH_CLERK"    13-Aug-2005    "JDILLY"  
    "SH_CLERK"    14-Jun-2005    "KCHUNG"  

results является таблицей с job_id, hire_date и переменными email. Переменная hire_date является массивом datetime, и переменные job_id и email являются строковыми массивами.

Закройте соединение с базой данных Кассандры.

close(conn)

Используя соединение с базой данных Cassandra®, выполните запрос CQL, чтобы импортировать данные от таблицы базы данных Кассандры в MATLAB®. Задайте уровень непротиворечивости для возврата результатов запроса. В этом случае база данных Кассандры содержит таблицу базы данных employees_by_job с данными сотрудника в ключевом пространстве employeedata.

Создайте соединение с базой данных Кассандры с помощью локального адреса хоста. conn является объектом cassandra .

contactPoints = "localhost";
conn = cassandra(contactPoints);

Запишите запрос CQL, который выбирает всех сотрудников, которые являются программистами, и получает их арендные даты и адреса электронной почты. job_id является ключом раздела таблицы базы данных employees_by_job. Ограничьте возвращенные данные тремя строками.

query = strcat("SELECT hire_date,email ", ... 
    "FROM employeedata.employees_by_job ", ...
    "WHERE job_id = 'IT_PROG'", ...
    "LIMIT 3;");

Выполните запрос CQL с набором уровня непротиворечивости к кворуму и отобразите результаты.

level = "QUORUM";
results = executecql(conn,query,'ConsistencyLevel',level)

results=3×2 table
     hire_date       email   
    ___________    __________

    21-May-2007    "BERNST"  
    07-Feb-2007    "DLORENTZ"
    05-Feb-2006    "VPATABAL"

Большинство узлов копии отвечает возвращенными данными. results является таблицей с переменными hire_date и email. Переменная hire_date является массивом datetime, и переменная email является массивом строк.

Закройте соединение с базой данных Кассандры.

close(conn)