使用CQL从Cassandra数据库表导入数据
这个例子展示了如何使用Cassandra查询语言(CQL)和Cassandra数据库连接将数据从Apache Cassandra®数据库表导入到MATLAB®。
使用executecql
函数执行CQL查询,例如,通过集群列过滤或限制查询结果中的行。你也可以使用executecql
函数写入非选择
CQL语句。为方便使用Cassandra数据库表的分区键值导入数据,请使用partitionRead
函数来代替。
在本例中,Cassandra数据库包含employees_by_job
数据库表,包含员工数据和job_id
分区键。的hire_date
数据库列是集群列。
要运行这个例子,您必须首先为Apache Cassandra®数据库安装数据库工具箱™接口。有关详细信息,请参见用于安装Apache Cassandra数据库的数据库工具箱接口.
使用本地主机地址创建一个Cassandra数据库连接。康涅狄格州
是一个卡珊德拉
对象。
联络点=“localhost”;康涅狄格州=卡桑德拉(联络点);
编写一个CQL查询,选择所有程序员或商店职员,并检索他们的工作标识符、雇佣日期和电子邮件地址。筛选那些在2006年4月30日之前雇佣的员工的查询hire_date
集群列。将返回的数据限制为4行。
查询= strcat (“选择job_id、hire_date邮件”,...“从employeedata。employees_by_job”,...WHERE job_id IN ('IT_PROG','SH_CLERK') ",..."AND hire_date < '2006-04-30'",...“限制4;”);
使用Cassandra数据库连接执行CQL查询并显示结果。
结果= executecql(康涅狄格州、查询)
结果=4×3表job_id hire_date邮件 __________ ___________ __________ " IT_PROG“05 - 2月- 2006”VPATABAL”“IT_PROG“03 - 1月- 2006”AHUNOLD”“IT_PROG 25 - 2005年6月——“DAUSTIN”“SH_CLERK AWALSH“24 - 4月- 2006
结果
是一张桌子吗job_id
,hire_date
,电子邮件
变量。的hire_date
变量是一个datetime
数组和job_id
和电子邮件
变量是字符串数组。
关闭Cassandra数据库连接。
关上(康涅狄格州)