Экспортируйте данные MATLAB в базу данных Кассандры

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

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

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

Создайте соединение с базой данных Кассандры с помощью сконфигурированного источника данных CassandraDataSource и пустое имя пользователя и пароль. apacheCassandra функция возвращает conn как connection объект.

datasource = "CassandraDataSource";
username = "";
password = "";
conn = apacheCassandra(datasource,username,password);

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

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

keyspace = "employeedata";
t = tablenames(conn,keyspace)
t = 3×1 string
    "employees_by_id"
    "employees_by_job"
    "employees_by_name"

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

keyspace = "employeedata";
tablename = "employees_by_job";
results = partitionRead(conn,keyspace,tablename);

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

tail(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"      27-Jan-2004        184              NaN               50         "NSARCHAN"    "Nandita"      "Sarchand"         121        "North"     256         {2×1 int32}        "650.509.1876"     4200 
    "MK_REP"        17-Aug-2005        202             0.25               20         "PFAY"        "Pat"          "Fay"              201        "East"      349         {3×1 int32}        "603.123.6666"     6000 
    "PU_CLERK"      10-Aug-2007        119              NaN               30         "KCOLMENA"    "Karen"        "Colmenares"       114        "West"      252         {5×1 int32}        "515.127.4566"     2500 
    "PU_CLERK"      15-Nov-2006        118              NaN               30         "GHIMURO"     "Guy"          "Himuro"           114        "East"      227         {4×1 int32}        "515.127.4565"     2600 
    "PU_CLERK"      24-Dec-2005        116              NaN               30         "SBAIDA"      "Shelli"       "Baida"            114        "North"     189         {2×1 int32}        "515.127.4563"     2900 
    "PU_CLERK"      24-Jul-2005        117              NaN               30         "STOBIAS"     "Sigal"        "Tobias"           114        "South"     195         {2×1 int32}        "515.127.4564"     2800 
    "PU_CLERK"      18-May-2003        115              NaN               30         "AKHOO"       "Alexander"    "Khoo"             114        "West"      135         {2×1 int32}        "515.127.4562"     3100 
    "AC_ACCOUNT"    07-Jun-2002        206              NaN              110         "WGIETZ"      "William"      "Gietz"            205        "East"      258         {2×1 int32}        "515.123.8181"     8300 

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 — Зарплата

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

cols = columninfo(conn,keyspace,tablename);
cols(:,1:2)
ans=13×2 table
            Name              DataType  
    _____________________    ___________

    "job_id"                 "text"     
    "hire_date"              "date"     
    "employee_id"            "int"      
    "commission_pct"         "double"   
    "department_id"          "int"      
    "email"                  "text"     
    "first_name"             "text"     
    "last_name"              "text"     
    "manager_id"             "int"      
    "office"                 "office"   
    "performance_ratings"    "list<int>"
    "phone_number"           "text"     
    "salary"                 "int"      

Вставьте данные MATLAB в базу данных Кассандры

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

varnames = ["job_id" "hire_date" "employee_id" ...
    "commission_pct" "department_id" "email" "first_name" ...
    "last_name" "manager_id" "office" "performance_ratings" ... 
    "phone_number" "salary"];
office = table("South",160, ...
    'VariableNames',["building" "room"]);
data = table("IT_ADMIN",datetime('today'),301,0.25,30,"SMITH123", ...
    "Alex","Smith",114,office,{[4 5]},"515.123.2345",3000);
data.Properties.VariableNames = varnames;

Вставьте информацию о сотруднике в базу данных Кассандры.

upsert(conn,keyspace,tablename,data)

Отобразите вставленные данные путем импорта его в MATLAB с помощью ключа IT_ADMIN раздела. employees_by_job таблица содержит новую строку.

keyValue = "IT_ADMIN";
results = partitionRead(conn,keyspace,tablename,keyValue)
results=1×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                                                   
    __________    ___________    ___________    ______________    _____________    __________    __________    _________    __________    ________________    ___________________    ______________    ______

    "IT_ADMIN"    07-Oct-2020        301             0.25              30          "SMITH123"      "Alex"       "Smith"        114        "South"     160         {2×1 int32}        "515.123.2345"     3000 

Обновите данные в базе данных Кассандры

Обновите email переменная в новой строке информации о сотруднике.

results.email = "SMITH456";
upsert(conn,keyspace,tablename,results)

Отобразите обновленные данные путем импорта его в MATLAB. Строка содержит обновленные данные в email переменная employees_by_job таблица.

results = partitionRead(conn,keyspace,tablename,keyValue)
results=1×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                                                   
    __________    ___________    ___________    ______________    _____________    __________    __________    _________    __________    ________________    ___________________    ______________    ______

    "IT_ADMIN"    07-Oct-2020        301             0.25              30          "SMITH456"      "Alex"       "Smith"        114        "South"     160         {2×1 int32}        "515.123.2345"     3000 

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

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