В этом примере показано, как экспортировать данные из таблицы MATLAB® в базу данных Apache Cassandra® с помощью соединения с базой данных Кассандры.
В этом примере база данных Кассандры включает employees_by_job таблица базы данных, которая содержит данные сотрудника и job_id ключ раздела.
Чтобы запустить этот пример, необходимо сначала установить Интерфейс Database Toolbox™ для Apache Cassandra® Database. Для получения дополнительной информации смотрите Интерфейс Database Toolbox для Apache Кассандра Дэйтабэз Инсталлэйшн.
Создайте соединение с базой данных Кассандры с помощью локального адреса хоста. conn cassandra объект.
contactPoints = "localhost";
conn = cassandra(contactPoints);Возвратите имена таблиц базы данных Кассандры в employeedata ключевое пространство. t массив строк, который содержит имена этих таблиц.
keyspace = "employeedata";
t = tablenames(conn,keyspace)t = 3×1 string array
"employees_by_job"
"employees_by_id"
"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 NaN 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"
Составьте таблицу данных, представляющих одного сотрудника, чтобы вставить в базу данных Кассандры. Задайте имена переменных. Составьте таблицу для получения информации об офисе. Затем составьте таблицу с информацией о сотруднике, которая содержит вложенную таблицу информации об офисе. Определите имена переменных.
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" 13-Mar-2019 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" 13-Mar-2019 301 0.25 30 "SMITH456" "Alex" "Smith" 114 "South" 160 {2×1 int32} "515.123.2345" 3000
close(conn)
cassandra | close | partitionRead | tablenames | upsert