导出MATLAB数据到Cassandra数据库

打开实时脚本

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

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

创建Cassandra数据库连接

使用配置的数据源创建Cassandra数据库连接CassandraDataSource还有一个空白的用户名和密码。的apacheCassandra函数返回康涅狄格州作为一个连接对象。

数据源=“CassandraDataSource”；用户名=＂＂；密码=＂＂；conn = apacheCassandra(数据源，用户名，密码);

从Cassandra数据库中探索数据

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

用于=“employeedata”；T = tablenames(conn,keyspace)

t =3×1的字符串"employees_by_id" "employees_by_job" "employees_by_name"

将员工数据导入MATLABemployees_by_job表中的employeedata使用Cassandra数据库连接keyspace。

用于=“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 - 20 202年8月- 2005年0.25”PFAY”“拍”“费”201"东" 349 {3×1 int32} "603.123.6666" 6000 "PU_CLERK" 2007年8月10日119南30 "KCOLMENA" "Karen" "Colmenares" 114 "西" 252 {5×1 int32} "515.127.4566" 2500 "PU_CLERK" 2006年11月15日118南30 "GHIMURO" "Guy" "Himuro" 114 "东" 227 {4×1 int32} "515.127.4565" 2600 "PU_CLERK" 2005年12月24日116南30 "SBAIDA" "Shelli" "Baida" 114 "北" 189 {2×1 int32} "515.127.4563" 2900 "PU_CLERK" 2005年7月24日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 "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

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

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数据库。指定变量的名称。为办公室信息创建一个表。然后，使用包含办公室信息嵌套表的员工信息创建一个表。设置变量的名称。

Varnames = [“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“07 - 10月30 - 2020 301 0.25”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“07 - 10月30 - 2020 301 0.25”SMITH456”“亚历克斯”“史密斯南部“114”“160”{2×1 int32} 515.123.2345 3000

关闭Cassandra数据库连接

关上(康涅狄格州)

另请参阅

apacheCassandra|表名|插入|partitionRead|关闭