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

Создайте подключение к базе данных Cassandra, используя адрес локального узла. 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 переменные являются строковыми массивами.

Закройте подключение к базе данных Cassandra.

close(conn)

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

Создайте подключение к базе данных Cassandra, используя адрес локального узла. 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 переменная является строковым массивом.

Закройте подключение к базе данных Cassandra.

close(conn)