问题标签 [datastax-java-driver]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
0 回答
1587 浏览

java - 与 *.*.*.* 的连接失效(java.io.IOException:现有连接被远程主机强制关闭)

我有一个简单的 mvc 应用程序,它存储 com.datastax.driver.core.Session 类的单个实例。此应用程序连接到 10 个节点的集群。其中 6 个是 Cassandra 节点、2 个 Hadoop 节点和 2 个 Solar 节点。将节点添加到查询主机列表时,我可以看到节点的所有 IP 地址。

一切正常,但是当我让应用程序运行一段时间而不被使用时,我得到以下信息:

以上对所有节点重复。毕竟我得到:

然后它似乎在那之后自我修复。

要创建会话对象,我使用了以下代码:

会话对象存储为类的成员。在 cassandra 节点上,我在大约同一时间段的日志中看不到任何异常。在设置我的集群和会话对象时我缺少什么吗?我应该添加更多配置吗?

我应该补充一点,我正在从 Windows 机器运行客户端应用程序。当我将客户端应用程序移动到 linux 机器上时,我没有遇到同样的问题。这向我表明问题可能出在网络级别,而不是在应用程序中。

0 投票
0 回答
179 浏览

java - cassandra java驱动程序返回带有复合键的空列表

我有一个简单的列族:

当我使用 cqlsh 查询所有行时,我得到了预期的结果集:

但是,当我使用 java API 尝试此操作时,我得到 0 结果,代码非常简单:

我玩过,如果我更改架构以便只有 sub_id 是主键,那么查询通过 java api 工作......

我正在使用最新的 api 版本:

有人见过这个吗?我做错了什么还是api的错误?

0 投票
1 回答
136 浏览

transactions - 如何控制 Datastax java 驱动程序中的事务

我们计划使用 datastax 2.0。我们的应用程序中的驱动程序。我们的应用程序中有以下场景。有两种不同的交易,一种用于增加消耗,另一种用于减少消耗,可以同时完成。
例如:
假设机器 1 的 Repair_Qty = 10 - 我正在进行新的维修,因此新的 Repair_Qty 应该是 10 + 1 .. 即 11 同时来自机器 2,其他人正在取消维修。Repair_Qty 应该是 11-1 = 10。但是,由于事务同时发生并且没有事务锁,新的 Repair Qty 将是 10-1 = 9,这是错误的。
我想知道datastax java驱动程序中是否有某种机制支持WRITE-READ_WRITE锁。

请帮忙。

问候,
阿伦

0 投票
2 回答
134 浏览

solr4 - 是否可以从 CQL 对 DSE Search 3.2.0 实例执行 SOLR 4.0 空间查询?

是否可以从 CQL 对 DSE Search 3.2.0 实例执行 SOLR 4.0 空间查询?如果是,正确的语法是什么?特别是我的问题是关于引用使用 solr.SpatialRecursivePrefixTreeFieldType 类实现的类型的字段的 CQL 查询。使用 SOLR Web 控制台针对 DSE Search 3.2.0 实例运行引用此类型的 SOLR 查询效果很好。

谢谢,莱昂

0 投票
1 回答
778 浏览

cassandra - 用于处理 Cassandra CQL 中的集合的 Java API

我正在寻找可以处理 Cassandra 中的集合的 java API。它具有读取/更新/插入/删除列值中的列表/设置/映射等集合的方法。我现在正在使用 Hector 客户端,我没有找到任何可以执行上述要求的方法。API 应该能够处理混合列类型(比如一个列值可以是 utf8,而另一个可以是集合)。任何示例或教程也将不胜感激。

0 投票
1 回答
2651 浏览

cassandra - Cassandra com.datastax.driver 打开会话到可能不存在的键空间

我正在研究使用 cassandra 作为 NoSql 数据库的项目。我正在尝试将我的测试框架设置为能够使用任意键空间,以避免同时运行的不同测试之间发生冲突。

我希望能够针对可能不存在的键空间创建会话。基本上我想要的是首先检查它是否存在,如果不创建它,然后连接。

似乎 Api 已捕获 22,因为为了执行命令(可以创建密钥空间),我已经必须连接到现有的密钥空间。

我错过了什么?

0 投票
1 回答
2508 浏览

cassandra - 具有 kerberos 安全性的 Datastax Java 驱动程序

我正在尝试从 Eclipse 访问启用了 kerberos 的 DSE 集群。

示例连接代码是

我的 dseclient 文件看起来像这样

运行代码时出现以下异常

我正在使用 DSE 3.2.3 和 java 驱动程序 1.0.4

0 投票
2 回答
2269 浏览

cassandra - Cassandra:两次截断表会引发一致性异常

我有一个失败的 scalatest 套件,我已将原因缩小到在测试之前运行并截断数据表的代码。如果我运行以下代码,我可以重新创建问题

抛出:

我正在使用 datastax 驱动程序 2.0.0-RC2,并且有一个由三个节点组成的集群。

关于这里出了什么问题的任何想法?

0 投票
2 回答
1434 浏览

cassandra - 如何在 CQL DataStax java 驱动程序中完成数据更新

我正在使用 DataStax java 驱动程序进行 CQL 表数据插入、更新。我的问题是我如何知道更新查询已通过ResultSet.Following 成功更新。以下代码正在更新表中的记录。

0 投票
3 回答
14256 浏览

java - Datastax QueryBuilder 插入语句

使用 Datastax Java Driver for Cassandra 中的 QueryBuilder 构建插入语句的正确方法是什么

我正在使用带有 Java 驱动程序 2.0.0-rc1 的 Cassandra 2.x

我知道我可以使用准备好的语句来实现相同的目的,但我期待使用 QueryBuilder

我可以确认查询字符串是有效的,因为它在 cqlsh 上手动尝试时成功

驱动报错是

我在这里的官方文档页面上找不到任何示例