Exponenta Banner
exponenta event banner

upsert

Вставка или обновление данных в базе данных Apache Cassandra

свернуть все на странице

Синтаксис

upsert (conn, keyspace, tablename, data)
upsert (conn, ключевое пространство, имя таблицы, данные, 'ConsistencyLevel', уровень)

Описание

пример

upsert(conn,keyspace,tablename,data) экспортирует данные из MATLAB ®, вставляя или обновляя их в таблицу базы данных Apache Cassandra ®.

пример

upsert(conn,keyspace,tablename,data,'ConsistencyLevel',level) задает уровень непротиворечивости для операции записи, указывающий, сколько узлов должно ответить при экспорте данных MATLAB в таблицу базы данных 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. 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)

Входные аргументы

свернуть все

Подключение к базе данных Кассандры, указанное как cassandra объект.

Keyspace, заданный как вектор символа или скаляр строки. Если вы не знаете ключевое пространство, то получите доступ к Keyspaces имущества cassandra объект, использующий точечную нотацию для просмотра ключевых пространств в базе данных Кассандры.

Пример: "employeedata"

Типы данных: char | string

Имя таблицы базы данных Cassandra, указанное как вектор символов или скаляр строки. Если имя таблицы неизвестно, используйте tablenames функция, чтобы найти его.

Пример: "employees_by_job"

Типы данных: char | string

Данные для вставки или обновления в базе данных Cassandra, указанные как таблица. Необходимо указать первичные ключи таблицы базы данных Cassandra, но можно игнорировать другие столбцы Cassandra. Имена переменных в таблице должны совпадать с именами столбцов Кассандры в таблице базы данных без учета регистра. Типы данных переменных в таблице должны быть совместимы с типами данных CQL столбцов Кассандры. Дополнительные сведения см. в разделе Преобразование типов данных CQL в типы данных MATLAB.

Типы данных: table

Уровень согласованности операции записи, указанный как одно из значений в этой таблице.

Значение уровня согласованностиОперация записи

"ALL"

Фиксация на всех узлах реплики.

"EACH_QUORUM"

Фиксация на большинстве узлов реплики в каждом центре обработки данных.

"QUORUM"

Фиксация на большинстве узлов реплики.

"LOCAL_QUORUM"

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

"ONE" (по умолчанию)

Фиксация на одном узле реплики.

"TWO"

Фиксация на двух узлах реплики.

"THREE"

Фиксация на трех узлах реплики.

"LOCAL_ONE"

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

"ANY"

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

Значение уровня согласованности можно указать как вектор символа или скаляр строки.

Дополнительные сведения об уровнях непротиворечивости см. в разделе Настройка непротиворечивости данных.

Типы данных: char | string

См. также

| | | |

Темы

Внешние веб-сайты

Представлен в R2019b

Документация панели инструментов базы данных

Поддержка