Tag: cql

使用IN子句过滤Spark Cassandra连接器

我正面临着针对java的spark cassandra连接器过滤的一些问题。 Cassandra允许使用IN子句过滤分区键的最后一列。 例如 create table cf_text (a varchar,b varchar,c varchar, primary key((a,b),c)) Query : select * from cf_text where a =’asdf’ and b in (‘af’,’sd’); sc.cassandraTable(“test”, “cf_text”).where(“a = ?”, “af”).toArray.foreach(println) 我如何指定在spark中的CQL查询中使用的IN子句？ 如何指定范围查询？

Cassandra NoHostAvailableException Java-CQLDriver

我正在使用Cassandra的CQL驱动程序在java中构建应用程序。 当我使用本地cassandra服务器时，我能够正常运行它。 但是，当我尝试运行时，相同的代码不适用于远程cassandra服务器。 初始化期间出现以下错误： – 以下是我用于CQL驱动程序的maven依赖： – com.datastax.cassandra cassandra-driver-core 2.1.3 com.datastax.cassandra cassandra-driver-mapping 2.1.2 以下是错误： – com.datastax.driver.core.exceptions.NoHostAvailableException: All host(s) tried for query failed (tried: yyyy.yyy.yyy.yyy.yyy-yyy.net/yy.yy.yy.yy:9160 (com.datastax.driver.core.ConnectionException: [yyyy.yyy.yyy.yyy.yyy-yyy.net/yy.yy.yy.yy:9160] Unexpected error during transport initialization (com.datastax.driver.core.ConnectionException: [yyyy.yyy.yyy.yyy.yyy-yyy.net/yy.yy.yy.yy:9160] Operation timed out)), Unexpected error during transport initialization (com.datastax.driver.core.ConnectionException: [xxxx.xxx.xxx.xxx.xxx-xxx.net/xx.xx.xx.xx:9160] Operation timed out))) at com.datastax.driver.core.ControlConnection.reconnectInternal(ControlConnection.java:220) at com.datastax.driver.core.ControlConnection.connect(ControlConnection.java:78) at com.datastax.driver.core.Cluster$Manager.init(Cluster.java:1231) at com.datastax.driver.core.Cluster.init(Cluster.java:158) at […]

使用CQL jdbc驱动程序时应该是什么连接字符串

使用CQL jdbc驱动程序时连接字符串应该是什么？ 我能在Java在线使用CQL JDBC驱动程序找到适当/完整的CQL示例吗？

使用Datastax API（使用新的二进制协议）升级/读入/读取Cassandra数据库

我已经开始使用Cassandra database 。 我打算使用Datastax API来upsert/read Cassandra database 。 我对这个Datastax API （使用新的二进制协议）完全不Datastax API ，我也找不到很多具有一些适当示例的文档。 create column family profile with key_validation_class = ‘UTF8Type’ and comparator = ‘UTF8Type’ and default_validation_class = ‘UTF8Type’ and column_metadata = [ {column_name : crd, validation_class : ‘DateType’} {column_name : lmd, validation_class : ‘DateType’} {column_name : account, validation_class : ‘UTF8Type’} {column_name : advertising, validation_class […]

如何在CQL 3预处理语句中绑定IN子句值？

我有一张大致相似的桌子 create table mytable ( id uuid, something text, primary key (id) ); 我正在尝试创建一个具有绑定in子句的预准备语句： PreparedStatement ps = session.prepare(“select * from mytable where id IN (?)”); … UUID[] ids = { uuid1, uuid2, uuid3} ; 无论我如何表达要绑定的id，java驱动程序都会拒绝它们。 ps.bind( /*as array*/) ：driver complains语句只有一个值，2提供 ps.bind( /*as comma separated string list of uuids*/) ：驱动程序抱怨它想要UUID.class对象，而不是字符串 ps.bind( /*as list object*/) ：驱动程序抱怨它想要UUID.class objs，而不是List.class对象 […]

使用DataStax客户端将参数传递给Cassandra CQL查询

我使用datastax作为连接cassandra的客户端。 我已经通过Java成功连接到cassandra集群/密钥空间/列系列。 我正在尝试，对cassandra专栏家族thriugh java发出一些疑问。 对我来说，它适用于简单的查询 ResultSet results = session.execute(“select * from demodb.customer where id = 1”); 现在我想从用户获取id参数并将其传递给session.execute（）; 声明。 我该怎么办呢？

Cassandra的IN关系对查询有害吗？

给出CQL中以下select的示例： SELECT * FROM tickets WHERE ID IN (1,2,3,4) 给定ID是一个分区键，使用IN关系比做多个查询更好还是没有区别？