主要内容

使用CQL从Cassandra数据库表导入数据

打开实时脚本

这个例子展示了如何使用Cassandra查询语言(CQL)和与Apache Cassandra数据库c++接口的Cassandra数据库连接，将数据从Apache™Cassandra®数据库表导入到MATLAB®。

在本例中，使用executecql函数执行CQL查询，该查询通过群集列进行筛选并限制查询结果中的行。或者，您也可以使用executecql函数写入非选择CQL语句。要使用Cassandra数据库表的分区键值轻松导入数据，请使用partitionRead函数来代替。

对于本例，Cassandra数据库包含employees_by_job数据库表中包含员工数据和job_id分区键。的hire_date数据库列是一个集群列。

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

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

编写一个CQL查询，选择程序员或店员的所有员工，并检索他们的工作标识符、雇佣日期和电子邮件地址。，根据2006年4月30日以前雇用的雇员筛选查询hire_date集群列。将返回的数据限制为4行。

查询= strcat(“SELECT job_id,hire_date,email”，.．.“从employeedata。employees_by_job”，.．."WHERE job_id IN ('IT_PROG'，'SH_CLERK') "，.．."AND hire_date < '2006-04-30'"，.．.“限制4;”）;

使用Cassandra数据库连接执行CQL查询并显示结果。

结果= executecql(conn,query)
结果=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变量是adatetime数组和job_id而且电子邮件变量是字符串数组。

关闭Cassandra数据库连接。

关上(康涅狄格州)

另请参阅

||

相关的话题

外部网站

Baidu
map