问题标签 [spring-data-cassandra]

我正在用 cassandra DB 做 Spring Dao。但我无法建立连接。

我收到此错误

SLF4J：无法加载类“org.slf4j.impl.StaticLoggerBinder”。SLF4J：默认为无操作 (NOP) 记录器实现 SLF4J：有关详细信息，请参阅http://www.slf4j.org/codes.html#StaticLoggerBinder。

线程“主”com.datastax.driver.core.exceptions.NoHostAvailableException 中的异常：所有主机尝试查询失败（尝试：PC264506/10.249.67.4:9042（com.datastax.driver.core.TransportException：[PC264506 /10.249.67.4:9042] 无法连接)) 在 com.datastax.driver.core.ControlConnection.reconnectInternal(ControlConnection.java:223) 在 com.datastax.driver.core.ControlConnection.connect(ControlConnection.java:78) 在com.datastax.driver.core.Cluster$Manager.init(Cluster.java:1230) 在 com.datastax.driver.core.Cluster.init(Cluster.java:157) 在 com.datastax.driver.core.Cluster。 connect(Cluster.java:245) at com.datastax.driver.core.Cluster.connect(Cluster.java:278) at org.spring.cassandra.example.CassandraApp.main(CassandraApp.java:32)

我的 POM：

我还验证了 cassandra.yaml 设置...

我正在尝试在使用 Spring Boot 应用程序插入和更新数据时将 TTL 添加到每一列。为此，我正在使用 spring-data-cassandra 1.1.3.RELEASE

为此，我编写了一个接口 CustomTTLRepository：

实现CustomTTLRepositoryImpl：

}

但是，当我尝试部署此应用程序时，出现以下错误：

Spring-data-Cassandra 1.3.2.RELEASE 是否支持@UDT ( http://docs.datastax.com/en/developer/java-driver/2.1/java-driver/reference/mappingUdts.html )？如果没有，我该如何为此添加解决方法

谢谢

我已经开始寻找很好的解决方案，如何使用 Spring CassandraOperations 很好地持久化实体。问题开始是因为我的实体中的某些字段不支持 cassandra，例如 joda DateTime。

解决方法是在 java.util.Date 类型的同一实体中添加其他字段，而不是 joda DateTime，用 @Transient 标记不需要的字段。但这并不干净，所以我开始寻找自动自定义转换。

目前 spring-data-cassandra 参考不提供如何注册自定义转换器的信息。http://docs.spring.io/spring-data/cassandra/docs/current/reference/html/#cassandra.custom-converters

是否可以在 CassandraSessionFactoryBean 中注册自定义转换器（如Spring Data Cassandra LocalDateTime Conversion）？

这是我的代码@Configuration public class CassandraConfig {

}

我正在同时运行超过 50 个线程的 ExecutorService。每个线程都打开与 Cassandra 的连接并使用springframework.data.cassandra. 问题是当我一次打开超过 50 个连接时，我收到以下错误。

如果我正好打开 50 个线程（或更少），它工作正常。有没有办法配置它，所以我可以允许更多？在我的 cassandra.yaml 文件中，rpc_max_threads根据默认注释“默认为无限制”

我在 Spring Boot 应用程序中使用 Cassandra 作为数据源，并希望在应用程序启动之前初始化数据库。

到目前为止，我已经定义了一个扩展“AbstractCassandraConfiguration”类的“CassandraConfiguration”类，如下面的示例所示，我有一个扩展“CassandraRepository”的存储库。当我自己创建键空间和表时，应用程序运行良好。

但是，我想在应用程序启动时自动创建键空间和表。为了做到这一点，我在资源文件夹下提供了一个 schema.cql 文件，但我无法使该脚本工作。

有谁知道我该怎么做才能自动创建键空间和表？

谢谢。

编辑：我正在使用 Cassandra 2.0.9、spring-boot 1.3.2.RELEASE 和 datastax cassandra 驱动程序 2.1.6 版本。

CassandraConfiguration.java

spring-cassandra 的最新版本依赖于 2.1.5 datastax 驱动程序。2.2 版本的更新是否有任何预计到达时间？

我正在尝试对 Cassandra 表进行查询，以获取具有特定 data_id 和 date_period 的所有匹配请求。但是我只得到单个匹配的数据

这是我的查询-

我做错了什么？我需要在此表中添加任何字段吗？像计数什么的？？

我的 spring-boot/spring-data-cassandra 应用程序过去在 Cassandra 2.1 上运行良好，但是当我将 Cassandra 升级到 3.3 时，它无法再连接 Cassandra 服务器。所以在 pom 文件中我决定使用特定的 spring-data-cassandra 模块（1.3.2.RELEASE）。我希望新版本的 spring-data-cassandra 模块将使用最新的 Cassandra Java 驱动程序。尽管新的 spring-data-cassandra 模块使用了更新版本（2.1.5）的 cassandra 驱动程序，但当我运行应用程序时它引发了一个奇怪的异常：

[...CassandraConfig.class]; 嵌套异常是 java.lang.annotation.AnnotationFormatError: Invalid default: public abstract java.lang.Class org.springframework.data.cassandra.repository.config.EnableCassandraRepositories.repositoryBaseClass()

有谁知道为什么会引发这个异常？该代码适用于 Cassandra 2.1/spring-data-cassandra 1.1.3。

spring-data-cassandra 是否支持 Cassandra 3.3.0？

CassandraConfig 类的源代码如下：

非常感谢！

如何限制查询结果。我的意思是如何从 cassandra 表中返回行的子集

@存储库-