文档

导出MATLAB数据到Cassandra数据库

这个例子展示了如何使用Cassandra数据库连接从MATLAB®表导出数据到Apache Cassandra®数据库。

在本例中,Cassandra数据库包括employees_by_job数据库表,其中包含员工数据和job_id分区键。

要运行此示例,必须首先安装Apache Cassandra®数据库的数据库工具箱™接口。详情请参见数据库工具箱接口Apache Cassandra数据库安装

创建Cassandra数据库连接

使用本地主机地址创建Cassandra数据库连接。康涅狄格州是一个卡珊德拉对象。

联络点=“localhost”;conn = cassandra(contactPoints);

从卡桑德拉数据库探索数据

中返回Cassandra数据库表的名称employeedata用于。t包含这些表的名称的字符串数组。

用于=“employeedata”;T = tablenames(conn,keyspace)
t =3×1字符串数组"employees_by_job" "employees_by_id" "employees_by_name"

导入员工数据到MATLAB中employees_by_job表格employeedatakeyspace通过使用Cassandra数据库连接。

用于=“employeedata”;表名=“employees_by_job”;results = partitionRead(conn,keyspace,tablename);

显示导入的员工数据的最后几行。

尾(结果)
ans =表8×13job_id hire_date employee_id commission_pct department_id邮件first_name last_name manager_id办公室performance_ratings phone_number工资建筑房间  ____________ ___________ ___________ ______________ _____________ __________ ___________ ____________ __________ ________________ ___________________ ______________ ______ " SH_CLERK“27 - 184年1月- 2004年南50”NSARCHAN”“Nandita”“Sarchand北部“121”“256”{2×1 int32} 650.509.1876“4200”MK_REP“17 - 202年8月- 2005年南20”PFAY”“拍”“费”201"东" 349 {3×1 int32} "603.123.6666" 6000 "PU_CLERK" 10-Aug-2007 119南30 "KCOLMENA" "Karen" "Colmenares" 114 "西" 252 {5×1 int32} "515.127.4566" 2500 "PU_CLERK" 15- 11 -2006 118南30 "GHIMURO" "Guy" "Himuro" 114 "东" 227 {4×1 int32} "515.127.4565" 2600 "PU_CLERK" 24- 12 -2005 116南30 "SBAIDA" "Shelli" "Baida" 114 "北" 189 {2×1 int32} "515.127.4563" 2900 "PU_CLERK" 24- 7 -2005 117南30 "STOBIAS" "Sigal" "Tobias" 114 "南" 195 {2×1 int32} "515.127.4564" 2800 "PU_CLERK"2003年5月18日115 NaN 30 "AKHOO" "Alexander" "Khoo" 114 "西" 135 {2×1 int32} "515.127.4562" 3100 "AC_ACCOUNT" 07- 6月-2002年206 NaN 110 "WGIETZ" "William" "Gietz" 205 "东" 258 {2×1 int32} "515.123.8181" 8300

结果是一个包含以下变量的表:

  • job_id-工作标识符

  • hire_date-租用日期

  • employee_id-员工标识

  • commission_pct-佣金百分比

  • department_id-部门标识

  • 电子邮件-电子邮件地址

  • first_name-名字

  • last_name-姓氏

  • manager_id—管理员标识符

  • 办公室-办公室位置(包含建筑和房间两个变量的表格)

  • performance_ratings-性能评级

  • phone_number-电话号码

  • 工资- - - - - -工资

控件中列的CQL数据类型employees_by_job数据库表中。

Cols = columninfo(conn,keyspace,tablename);关口(:1:2)
ans =13×2表数据类型名称  _____________________ ___________ " job_id”“文本”“hire_date”“日期”“employee_id”“int”“commission_pct”“双”“department_id”“int”“电子邮件”、“文本”“first_name”“文本”“last_name”“文本”“manager_id”“int”“办公室”“办公室”“performance_ratings”“列表< int >”“phone_number”“文本”“工资”“int”

从MATLAB中插入数据到Cassandra数据库

创建一个数据表,表示要插入到Cassandra数据库的一名员工。指定变量的名称。为办公室信息创建一个表。然后,创建一个雇员信息表,其中包含办公室信息的嵌套表。设置变量的名称。

变量名= [“job_id”“hire_date”“employee_id”...“commission_pct”“department_id”“电子邮件”“first_name”...“last_name”“manager_id”“办公室”“performance_ratings”...“phone_number”“工资”];办公室=桌子“南”, 160,...“VariableNames”,[“建筑”“房间”]);数据=表(“IT_ADMIN”datetime (“今天”0.25), 301年,30岁的“SMITH123”...“亚历克斯”“史密斯”, 114,办公室,{[4 - 5]},“515.123.2345”, 3000);data.Properties.VariableNames = varnames;

将员工信息插入Cassandra数据库。

插入(康涅狄格州,用于、表、数据)

通过使用分区键将插入的数据导入到MATLAB中显示IT_ADMIN.的employees_by_job表包含新行。

keyValue =“IT_ADMIN”;results = partitionRead(conn,keyspace,tablename,keyValue)
结果=表1×13job_id hire_date employee_id commission_pct department_id邮件first_name last_name manager_id办公室performance_ratings phone_number工资建筑房间  __________ ___________ ___________ ______________ _____________ __________ __________ _________ __________ ________________ ___________________ ______________ ______ " IT_ADMIN“13 - 3月- 2019 301 0.25 30”SMITH123”“亚历克斯”“史密斯南部“114”“160”{2×1 int32} 515.123.2345 3000

更新Cassandra数据库中的数据

更新电子邮件变量在雇员信息的新行中。

结果。电子邮件=“SMITH456”;用于插入(康涅狄格州,表名,结果)

将更新后的数据导入MATLAB中显示。控件中更新的数据电子邮件的变量employees_by_job表格

results = partitionRead(conn,keyspace,tablename,keyValue)
结果=表1×13job_id hire_date employee_id commission_pct department_id邮件first_name last_name manager_id办公室performance_ratings phone_number工资建筑房间  __________ ___________ ___________ ______________ _____________ __________ __________ _________ __________ ________________ ___________________ ______________ ______ " IT_ADMIN“13 - 3月- 2019 301 0.25 30”SMITH456”“亚历克斯”“史密斯南部“114”“160”{2×1 int32} 515.123.2345 3000

关闭Cassandra数据库连接

关上(康涅狄格州)

另请参阅

||||

相关的话题

外部网站