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

Этот пример показывает, как исследовать структуру базы данных Apache Cassandra® и импортировать данные от таблицы базы данных Кассандры в MATLAB® с помощью соединения с базой данных Кассандры. База данных Кассандры хранит таблицы базы данных согласно ключу раздела. Ключ раздела влияет, как данные отфильтрованы в базе данных.

В этом примере база данных Кассандры содержит таблицу базы данных employees_by_job с данными сотрудника и ключом раздела job_id.

Чтобы запустить этот пример, необходимо сначала установить Интерфейс Database Toolbox™ для Apache Cassandra® Database. Для получения дополнительной информации смотрите Интерфейс Database Toolbox для Apache Кассандра Дэйтабэз Инсталлэйшн.

Создайте соединение с базой данных Кассандры

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

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

Исследуйте структуру базы данных Кассандры

Просмотрите ключевые пространства в базе данных Кассандры с помощью соединения с базой данных Кассандры. Массив возвращаемой строки содержит ключевые пространства. Ключевое пространство содержит одну или несколько таблиц базы данных и задает, как база данных реплицирует данные в таблицы.

conn.Keyspaces

ans = 1×6 string array
    "employeedata"    "system"    "system_auth"    "system_distributed"    "system_schema"    "system_traces"

Возвратите имена таблиц базы данных Кассандры в ключевом пространстве employeedata. t является массивом строк, который содержит имена таблиц базы данных в ключевом пространстве employeedata.

keyspace = "employeedata";
t = tablenames(conn,keyspace)

t = 3×1 string array
    "employees_by_job"
    "employees_by_id"
    "employees_by_name"

Возвратите имена столбцов базы данных Кассандры в таблице базы данных employees_by_job.

tablename = "employees_by_job";
cols = columninfo(conn,keyspace,tablename);

Отобразите первые несколько имен столбцов базы данных Кассандры в таблице базы данных employees_by_job.

head(cols)

ans=8×4 table
          Name          DataType    PartitionKey    ClusteringColumn
    ________________    ________    ____________    ________________

    "job_id"            "text"         true              ""         
    "hire_date"         "date"         false             "DESC"     
    "employee_id"       "int"          false             "ASC"      
    "commission_pct"    "double"       false             ""         
    "department_id"     "int"          false             ""         
    "email"             "text"         false             ""         
    "first_name"        "text"         false             ""         
    "last_name"         "text"         false             ""

cols является таблицей с этими переменными:

Имя Имя столбца базы данных Кассандры
Тип данных Тип данных Языка запросов Кассандры (CQL) столбца базы данных Кассандры
PartitionKey — Ключевой показатель раздела
ClusteringColumn — Кластеризация индикатора столбца

Значение в переменной PartitionKey указывает, является ли столбец базы данных ключом раздела. Столбец job_id (идентификатор задания) является ключом раздела в этой таблице базы данных.

Импортируйте данные от Кассандры Дэйтабэз

Импортируйте данные от таблицы базы данных employees_by_job в MATLAB с помощью значения ключа раздела для клерка магазина, SH_CLERK.

keyValue = "SH_CLERK";
results = partitionRead(conn,keyspace,tablename, ...
    keyValue);

Отобразите первые несколько строк возвращенных данных сотрудника.

head(results)

ans=8×13 table
      job_id       hire_date     employee_id    commission_pct    department_id      email       first_name    last_name     manager_id         office         performance_ratings     phone_number     salary
                                                                                                                                           building    room                                                   
    __________    ___________    ___________    ______________    _____________    __________    __________    __________    __________    ________________    ___________________    ______________    ______

    "SH_CLERK"    03-Feb-2008        183             NaN               50          "GGEONI"      "Girard"      "Geoni"          120         "West"     121         [        2]        "650.507.9879"     2800 
    "SH_CLERK"    13-Jan-2008        199             NaN               50          "DGRANT"      "Douglas"     "Grant"          124         "West"     139         [3×1 int32]        "650.507.9844"     2600 
    "SH_CLERK"    19-Dec-2007        191             NaN               50          "RPERKINS"    "Randall"     "Perkins"        122         "West"     255         [        2]        "650.505.4876"     2500 
    "SH_CLERK"    21-Jun-2007        182             NaN               50          "MSULLIVA"    "Martha"      "Sullivan"       120         "East"     112         [2×1 int32]        "650.507.9878"     2500 
    "SH_CLERK"    21-Jun-2007        198             NaN               50          "DOCONNEL"    "Donald"      "OConnell"       124         "East"     125         [3×1 int32]        "650.507.9833"     2600 
    "SH_CLERK"    17-Mar-2007        195             NaN               50          "VJONES"      "Vance"       "Jones"          123         "West"     236         [5×1 int32]        "650.501.4876"     2800 
    "SH_CLERK"    07-Feb-2007        187             NaN               50          "ACABRIO"     "Anthony"     "Cabrio"         121         "West"     345         [3×1 int32]        "650.509.4876"     3000 
    "SH_CLERK"    11-Jul-2006        190             NaN               50          "TGATES"      "Timothy"     "Gates"          122         "East"     297         [3×1 int32]        "650.505.3876"     2900

results является таблицей, которая содержит эти переменные:

job_id — Идентификатор задания
hire_date — Наймите дату
employee_id — Идентификатор сотрудника
commission_pct — Уполномочьте процент
department_id — Идентификатор отдела
email — Адрес электронной почты
first_name — Имя
last_name — Фамилия
manager_id — Идентификатор менеджера
office — Местоположение Office (таблица, которая содержит две переменные для создания и комнаты),
performance_ratings — Оценки производительности
phone_number — Номер телефона
salary — Зарплата

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

close(conn)

Документация