问题标签 [spring-data-cassandra]

我正在使用 Spring Data Cassandra 项目 v1.3.0 无法为我的 Cassandra 集群 (v2.0.17) 配置 SSL。Sprint Data Cassandra 文档说它使用 DataStax Java 驱动程序 (2.0.X) 支持 Cassandra 2.X，所以那里不应该有问题。这是我初始化 cassandra 集群 bean 的 Java cassandra 配置：

我已验证设置 SSL 上下文的环境属性已正确填充，并且与 cassandra 配置文件中使用的密钥库和信任库相同。以下是我关于启用客户端到节点加密的 cassandra 配置：

启动我的客户端应用程序时，初始化 cassandra 集群时出现以下错误：

如果有人对此有任何见解，将不胜感激。我按照Datastax 上的这些说明准备服务器证书并启用客户端到节点加密。

我有一个这样定义的 Cassandra 表：

我在其中放置了一些数据：

然后我试图spring-data-cassandra用它来与之交互。我有一个 POJO：

还有一个Repository：

然后下面的代码尝试检索所有记录作为一个简单的测试：

不幸的是，这会引发异常。不那么时髦的列类型可以正常工作，例如，aList<String>和非嵌套的 `Map 类型的列可以正常工作。但是这张地图对我不起作用。

想知道是否不支持此功能spring-data-cassandra（尽管异常似乎出现在 DataStax 代码中），或者我是否只需要对 POJO 做一些不同的事情。

抛出的异常如下：

有没有办法在通过 Java 使用 Cassandra 时检查选定的键空间？

上下文：子系统使用身份验证凭据来选择密钥空间。我正在开发一个执行命令的 DTO。我有一种预感，我在错误的键空间中操作（命令在 DevCenter 中成功执行，但不在 Java 代码中）。

我是 Cassandra 和这个 Java 应用程序的新手，所以如果这是一个愚蠢的问题，我深表歉意。

使用时

在com.foo包中有一个扩展接口的地方CrudRepository。

有没有办法让它在启动时在数据库关闭时不会引发异常？

理想情况下，我们启动时，无论何时您调用存储库上的方法，它都会首先尝试连接到数据库，然后如果数据库仍然关闭，则返回一个错误，说无法连接。

我目前观察到的行为是NoHostAvailableException被抛出并且 web 容器没有启动。

我正在使用 spring-data-cassandra (1.3.1.RELEASE) 连接到 cassandra 数据库。有没有办法改变 spring-data-cassandra 中的一致性级别。默认情况下它是 1级（spring-data-cassandra 中的默认一致性级别是什么？）。但是如何改变呢？

谢谢！

我正在使用以下代码使用 spring 数据与 cassandra 连接。但是每次都建立联系是很痛苦的。

有什么方法可以让我们拥有一个通用的静态连接或实用程序类型的东西。我在 Web 应用程序中使用它，其中会有很多 CRUD 操作。所以到处重复代码会很痛苦。

我有多个 Cassandra 集群。每个集群都有一组特定的接触点。每个集群都有一组单独的表/CF。

在我的 C* 客户端中，我应该查询两个集群。我正在使用 Cassandra 的 spring-boot 版本。我正在尝试使用 CassandraOperations 进行查询。我该怎么做呢？

以上是我使用 sessionA 设置 cassandra 操作的示例，如何为 sessionB 做同样的事情？

在任何给定的时间基础上，查询都可以转到 sessionA 或 sessionB。

任何指针表示赞赏

谢谢

我是Spring的新手，所以请原谅我的基本问题。我正在使用基于 spring 的 cassandra 来执行一些 CRUD 操作。一个简单的插入似乎不起作用，并且想知道是否有人可以指出我做错了什么。以下是我简单地插入时得到的错误

这是代码：

假设会话有效。这是实际执行写入的代码

这是地址的对象：

有什么我缺少初始化的吗？

使用 CassandraReporitory 的 findOne() 或 findAll() 方法时出现以下异常：

我的类定义如下：

本质上，这里发生的是，在调用 findOne() 或 findAll() 期间从 Cassandra 读取一行后，spring data cassandra 尝试使用 ClassGeneratingEntityInstantiator 实例化不知道如何填充复合主键对象的 ItemAndLocation 对象，项目和位置键。我不知道如何提供自定义对象实例化器。当前版本没有示例或文档。

任何帮助都感激不尽。

我尝试使用 Spring Integration 实现以下工作流程：

• 1) 轮询 REST API
• 2) 将 POJO 存储在 Cassandra 集群中

这是我第一次尝试使用 Spring Integration，所以我仍然对来自参考的大量信息感到不知所措。经过一番研究，我可以进行以下工作。

• 1) 轮询 REST API
• 2) 将映射的 POJO JSON 结果转换为字符串
• 3）将字符串保存到文件中

这是代码：

这很好用！

但是现在，我不想将对象写入文件，而是想将其存储在带有 spring-data-cassandra 的 Cassandra 集群中。为此，我在配置文件中注释掉了文件处理程序，在转换器中返回 POJO 并创建以下内容：

但这似乎是一种错误的做法，服务方法永远不会被触发。

所以我的问题是，对于我的用例来说，正确的方法是什么？我是否必须在我的服务组件中实现 MessageHandler 接口，并在我的配置中使用 @ServiceActivator。还是我当前的“网关方法”中缺少某些东西？或者也许还有另一种解决方案，我看不到..

如前所述，我是 SI 新手，所以这可能是一个愚蠢的问题......

不过，提前非常感谢！