Вставка или обновление данных в базу данных Apache Cassandra
Вставьте данные из MATLAB ® в базу данных Cassandra и отобразите данные при помощи соединения с базой данных Cassandra.
База данных Кассандры включает employees_by_job
таблица базы данных, содержащая данные о сотрудниках и job_id
ключ раздела.
Создайте соединение с базой данных Cassandra с помощью локального адреса хоста. conn
является cassandra
объект.
contactPoints = "localhost";
conn = cassandra(contactPoints);
Возвращает имена таблиц базы данных Cassandra в employeedata
keyspace. 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
таблица при помощи соединения с базой данных Cassandra.
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
- Расположение офиса (таблица, содержащая две переменные для создания и комнаты)
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"
Составьте таблицу данных, представляющую одного сотрудника, для вставки в базу данных Cassandra. Задайте имена переменных. Составьте таблицу для сведений о офисе. Затем составьте таблицу с информацией о сотруднике, которая содержит вложенную таблицу данных о офисе. Установите имена переменных.
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;
Вставьте информацию о сотруднике в базу данных Cassandra.
upsert(conn,keyspace,tablename,data)
Отобразите вставленные данные путем импорта их в MATLAB с помощью ключа раздела IT_ADMIN
. The 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
Закройте соединение с базой данных Cassandra.
close(conn)
Обновляйте данные в базе данных Cassandra с помощью данных MATLAB ® и отображайте обновленные данные при помощи соединения с базой данных Cassandra. Задайте уровень согласованности для операции записи.
База данных Кассандры включает employees_by_job
таблица базы данных, содержащая данные о сотрудниках и job_id
ключ раздела.
Создайте соединение с базой данных Cassandra с помощью локального адреса хоста. conn
является cassandra
объект.
contactPoints = "localhost";
conn = cassandra(contactPoints);
Возвращает имена таблиц базы данных Cassandra в employeedata
keyspace. 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
таблица при помощи соединения с базой данных Cassandra.
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
- Расположение офиса (таблица, содержащая две переменные для создания и комнаты)
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"
Импортируйте данные для обновления с помощью partitionRead
функция со значением ключа разбиения MK_REP
. Данные предназначены для сотрудника, являющегося представителем по маркетингу.
keyValue = "MK_REP";
data = partitionRead(conn,keyspace,tablename,keyValue)
data=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
________ ___________ ___________ ______________ _____________ ______ __________ _________ __________ ________________ ___________________ ______________ ______
"MK_REP" 17-Aug-2005 202 NaN 20 "PFAY" "Pat" "Fay" 201 "East" 349 {3×1 int32} "603.123.6666" 6000
Обновите процент комиссии до 0,25 для маркетингового представителя. Кроме того, задайте уровень согласованности "QUORUM"
чтобы убедиться, что большинство узлов реплики фиксируют операцию записи.
data.commission_pct = 0.25; level = "QUORUM"; upsert(conn,keyspace,tablename,data,'ConsistencyLevel',level)
Отобразите обновленные данные путем импорта их в MATLAB с помощью значения ключа раздела MK_REP
. Обновленный процент комиссионных для маркетингового представителя составляет 0,25.
keyValue = "MK_REP";
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
________ ___________ ___________ ______________ _____________ ______ __________ _________ __________ ________________ ___________________ ______________ ______
"MK_REP" 17-Aug-2005 202 0.25 20 "PFAY" "Pat" "Fay" 201 "East" 349 {3×1 int32} "603.123.6666" 6000
Закройте соединение с базой данных Cassandra.
close(conn)
conn
- Соединение с базой данных Кассандраcassandra
объектСоединение с базой данных Cassandra, заданное как cassandra
объект.
keyspace
- KeyspaceKeyspace, заданный как вектор символов или строковый скаляр. Если вы не знаете ключевого пространства, то получите доступ к Keyspaces
свойство cassandra
объект, использующий запись через точку для просмотра ключевых пространств в базе данных Cassandra.
Пример: "employeedata"
Типы данных: char
| string
tablename
- имя таблицы базы данных КассандраИмя таблицы базы данных Cassandra, заданное как вектор символов или строковый скаляр. Если вы не знаете имя таблицы, используйте tablenames
функция, чтобы найти его.
Пример: "employees_by_job"
Типы данных: char
| string
data
- Данные для вставки или обновленияДанные для вставки или обновления в базу данных Cassandra, заданные как таблица. Необходимо задать первичные ключи таблицы базы данных Cassandra, но можно игнорировать другие столбцы Cassandra. Имена переменных в таблице должны совпадать с именами столбцов Кассандра в таблице базы данных без чувствительности к регистру. Типы данных переменных в таблице должны быть совместимы с типами данных CQL столбцов Cassandra. Для получения дополнительной информации см. раздел Преобразование типов данных CQL в типы данных MATLAB.
Типы данных: table
level
- Уровень согласованности"ONE"
(по умолчанию) | символьный вектор | строковый скалярУровень согласованности операции записи, заданный как одно из значений в этой таблице.
Значение уровня согласованности | Операция записи |
---|---|
| Фиксация на всех узлах реплики. |
| Фиксация на большинстве узлов реплики в каждом центре обработки данных. |
| Фиксация на большинстве узлов реплики. |
| Фиксация на большинстве узлов реплики в локальном центре обработки данных. |
| Фиксация на одном узле реплики. |
| Фиксация на двух узлах реплики. |
| Фиксация на трех узлах реплики. |
| Фиксация на одном узле реплики в локальном центре обработки данных. |
| Фиксация по крайней мере на одном узле реплики. |
Можно задать значение уровня согласованности как вектор символов или строковый скаляр.
Дополнительные сведения об уровнях согласованности см. в разделе Настройка согласованности данных.
Типы данных: char
| string
cassandra
| close
| executecql
| partitionRead
| tablenames
У вас есть измененная версия этого примера. Вы хотите открыть этот пример с вашими правками?
1. Если смысл перевода понятен, то лучше оставьте как есть и не придирайтесь к словам, синонимам и тому подобному. О вкусах не спорим.
2. Не дополняйте перевод комментариями “от себя”. В исправлении не должно появляться дополнительных смыслов и комментариев, отсутствующих в оригинале. Такие правки не получится интегрировать в алгоритме автоматического перевода.
3. Сохраняйте структуру оригинального текста - например, не разбивайте одно предложение на два.
4. Не имеет смысла однотипное исправление перевода какого-то термина во всех предложениях. Исправляйте только в одном месте. Когда Вашу правку одобрят, это исправление будет алгоритмически распространено и на другие части документации.
5. По иным вопросам, например если надо исправить заблокированное для перевода слово, обратитесь к редакторам через форму технической поддержки.