主要内容

使用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_idhire_date,电子邮件变量。的hire_date变量是一个datetime数组和job_id电子邮件变量是字符串数组。

关闭Cassandra数据库连接。

关上(康涅狄格州)

另请参阅

||

相关的话题

外部网站