描述:
创建Cassandra外部库连接。
语法:
stax_open(nodes[:port][,keyspace][,user:pwd][,compressor][,version:verX][,clusterName:nameX][,queryOptions:optionX])
备注:
外部库函数,在PasswordAuthentication模式下启动Cassandra数据库不需要用户名和密码,在authorizer: AllowAllAuthorizer模式下启动Cassandra数据库需要用户名和密码。Keyspace省略则在cql查询时需要用keyspace.table格式。
参数:
nodes |
数据库IP地址 |
port |
端口号,可省略 |
user:pwd |
用户名:密码,可省略 |
keyspace |
keyspace名称,可省略 |
compressor |
压缩算法,有lz4、snappy、none,缺省为none |
version |
协议版本号信息,可省略 |
queryOptions |
查询选项,有ANY、ONE、TOW、THREE、ALL、QUORUM,具体参考cassandra开发文档 |
返回值:
数据库连接
示例:
|
A |
|
1 |
=stax_open("127.0.0.1":9042, "mycasdb","cassandra":"cassandra") |
在authorizer: AllowAllAuthorizer模式 下的Cassandra数据库连接 |
2 |
=stax_open("127.0.0.1":9042, "mycasdb") |
在authenticator: PasswordAuthenticator 模式下的Cassandra数据库连接 |
3 |
=stax_open("127.0.0.1":9042, "mycasdb","cassandra":"cassandra":"lz4") |
设置解压算法为lz4 |
4 |
=stax_open("127.0.0.1":9042) |
Keyspace省略 |
5 |
=stax_query(A1,"select * from mycasdb.user") |
cql查询时使用keyspace.table格式 |