stax_open()

阅读(632) 标签: 创建, cassandra外部库, 连接,

描述:

创建Cassandra外部库连接。

语法:

stax_connect(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

压缩算法,有lz4snappynone,缺省为none

version

协议版本号信息,可省略

queryOptions

查询选项,有ANYONETOWTHREEALLQUORUM,具体参考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格式