"Cassandra是一种分布式的NoSQL数据库。JAVA中可以使用DataStax执行Cassandra的CQL，CQL语言能简单地维护、读写数据，但不支持关联、分组聚合等操作，计算能力比关 .."

xjl 北京
乾学院 9 号会员
1 回帖 • 256 浏览 • 2 年前

...

SPL：访问 Cassandra

计算＆AI

Cassandra是一种分布式的NoSQL数据库。JAVA中可以使用DataStax执行Cassandra的CQL，CQL语言能简单地维护、读写数据，但不支持关联、分组聚合等操作，计算能力比关系数据库的SQL差很多。另一个掣肘CQL语言计算能力的原因是，它要支持更复杂的数据模型，字段值可能是Set，Map等一些嵌套集合。计算引擎语言SPL能很好的支持复杂数据模型计算，它提供了几个函数连接Cassandra，把数据读出来就能弥补Cassandra数据库较弱的计算能力。

创建/关闭Cassandra连接

使用方式类似关系数据库的JDBC连接，SPL也用成对的“创建/关闭”方式连接Cassandra。

stax_open(server[:port][,keyspace][,user:pwd][,compressor][,version:verX][,queryOptions:optionX])，server是服务器地址，之后分别是端口，键空间、用户名、密码、压缩算法、协议版本号、查询选项，这些参数不需要时可以省略。

stax_close(staxConn)，staxConn是要关闭的Cassandra连接。

示例：A1创建连接，中间做一些读写及计算操作后，A3关闭A1创建的连接

	A
1	=stax_open("127.0.0.1":9042)
2	……
3	=stax_close(A1)

执行CQL

stax_execute(staxConn, cql, [arg1], [arg2], ...) ，staxConn是Cassandra连接，cql是要执行的语句，可以带多个参数，传入参数的地方用“?”占位，arg1、arg2…是参数值，有几个“?”，后面就要提供几个参数值。

示例：

	A
1	=stax_open("127.0.0.1":9042)
2	=stax_execute(A1,"CREATE KEYSPACE splSpace WITH replication = {'class':'SimpleStrategy','replication_factor': 3}")
3	=stax_execute(A1,"USE splSpace")
4	CREATE TABLE emp( emp_id int PRIMARY KEY, emp_name text, emp_city text, emp_sal int, emp_phone text )
5	=stax_execute(A1,A4)
6	=stax_execute(A1, "select * from emp")
7	INSERT INTO emp(emp_id, emp_name, emp_city,emp_sal, emp_phone) VALUES(4,'robin', 'Hyderabad',?,?);
8	=stax_execute(A1, A7, 234, "984-8022-339")
9	=stax_execute(A1, "select * from emp")
10	=stax_cursor(A1, "select * from emp")
11	=A10.fetch(10)
12	CREATE TABLE users ( id text PRIMARY KEY, name text, favs map<text, text> )
13	=stax_execute(A1,A12)
14	INSERT INTO users (id, name, favs) VALUES ('jsmith', 'John Smith', { 'fruit' : 'Apple', 'band' : 'Beatles'})
15	=stax_execute(A1,A13)
16	=stax_execute(A1, "select * from users")
17	=stax_close(A1)