spring-data-cassandra 相关问题

Cassandra的Spring Data是Spring Data项目的一部分,该项目为新数据存储提供了熟悉且一致的基于Spring的编程模型,同时保留了特定于商店的特性和功能。 Spring Data Cassandra项目提供与Cassandra Columnar NoSQL数据存储的集成

如何使用 Spring-Data 在 Cassandra 中启用乐观锁定(版本控制)?

答案是Cassandra乐观锁定,但问题描述了Cassandra中存在乐观锁定(版本控制)。 我的问题是如何在 Spring Boot 中做到这一点?

回答 2 投票 0

Spring Data Cassandra 异常

我正在尝试将我的 AstraDatabase (Cassandra) 与我的 Spring Boot 应用程序连接。我已经完成了运行它时所需的所有配置。它向我显示异常:用 na 创建 bean 时出错...

回答 2 投票 0

Spring 数据 cassandra - com.datastax.oss.driver.api.core.auth.AuthenticationException

我有一个 Spring Boot 应用程序尝试连接到 scyllaDB,所使用的依赖项是, 1)“org.springframework.boot:spring-boot-starter-data-cassandra:2.7.9”, 2)“组织。

回答 1 投票 0

Cassandra 缓慢读取(按分区键)获取大数据行

我在 AWS 上有一个 5 节点 cassandra (3.11) 集群。 机器规格 型号 vCPU 内存 (GiB) 实例存储 (GB) 网络带宽 (Gbps) i3.large 2 15.25 1 x 475 NVMe SSD 高达...

回答 1 投票 0

如何使用 Spring Data cassandra 和 Spring Boot 2.7.x 来管理两个 Cassandra 会话

在我的应用程序中,使用以下技术 春季启动 2.7.x spring-boot-starter-data-cassandra 2.7.x 春季批次 5.x 爪哇11 配置 @EnableCassandraRepositories( 基本包 = ...

回答 1 投票 0

从 Spark scala 中的 cassandra 检索集给出了类型不匹配的 java.utils

我在 cassandra 中有一个表,它是一个集合类型,并在 scala 中创建了案例类,如下所示: 案例类测试( var status: 选项[设置[字符串]] ) 现在我正在尝试从 cassandr 检索数据...

回答 2 投票 0

Spring Data cassandra 线程安全吗?

这就是问题,Spring Data cassandra 线程安全吗?我的意思是,例如, org.springframework.data.cassandra.repository.CassandraRepository 接口公开的操作线程安全吗?

回答 1 投票 0

设置 ttl 时 Spring data cassandra 反应式批处理操作失败

我使用reactiveCassandraTemplate.batchOps()来插入多个实体,但是 找不到请求的操作的编解码器:[null <-> org.springframework.data.cassandra.core.cql.ExecutionProfileRe...

回答 1 投票 0

Docker compose:Cassandra 未连接到同一网络中的我的 Spring 应用程序

我的应用程序依赖于 Cassandra,所以我已将它们全部放入 docker-compose 文件中,现在只需使用此处给出的普通 docker,我就可以在本地正常运行它,但是当我尝试使用相同的

回答 1 投票 0

无法使用 UDT 写入表,出现“无法解析 [设备] 的 UserDefinedType”

这些是我在 spring 项目中安装的依赖项 //卡桑德拉 实现 'org.springframework.data:spring-data-cassandra:3.1.2' 实施 'io.projectreactor:reactor-core'

回答 1 投票 0

设置 bean 属性“cassandraTemplate”时无法解析对 bean“cassandraTemplate”的引用

我正在使用 spring boot 连接到 Cassandra 数据库。我在启动时收到错误消息 创建 com.myspace.mycompany.repository def 中定义的名为“abcItemsRepository”的 bean 时出错...

回答 1 投票 0

无法从 Spring Boot 应用程序连接到 Cassandra

目前我正在为 Cassandra 的这个错误而苦恼: 创建类路径资源 [com/project/config/CassandraConfiguration.class] 中定义的名为“cassandraSession”的 bean 时出错:Invocat...

回答 1 投票 0

有没有办法在 Spring Boot 中将反应式 cassandra 存储库与 Pageable 一起使用?

我正在尝试为我的存储库使用 ReactiveCassandraRepository 接口。当我尝试添加这样的 findAll 方法时: 公共接口 MatchRepository 扩展了 ReactiveCassandraRepository 我正在尝试为我的存储库使用 ReactiveCassandraRepository 界面。当我尝试添加这样的 findAll 方法时: public interface MatchRepository extends ReactiveCassandraRepository<Match, UUID> { Flux<Match> findAll(Pageable pageable); } 我收到此错误消息: Error creating bean with name 'matchRepository' defined in MatchRepository defined in @EnableReactiveCassandraRepositories declared on CassandraReactiveRepositoriesRegistrar.EnableReactiveCassandraRepositoriesConfiguration: Could not create query for public abstract reactor.core.publisher.Flux MatchRepository.findAll(org.springframework.data.domain.Pageable); Reason: No property 'findAll' found for type 'Match' 如何在 Spring Boot 中使用 Pageable 实现反应式 cassandra 存储库?有这方面的文档吗? 分页和响应式 Spring Boot Data Cassandra 不提供任何响应式分页功能,因为它确实有意义。 https://docs.spring.io/spring-data/commons/docs/current/api/org/springframework/data/repository/reactive/package-summary.html 在同步中,您正在等待页面作为结果集返回。 在异步中,每页都有一个回调 在这两种情况下,当您耗尽结果集时,都会触发下一页的加载。 在反应式中,页面的概念没有意义,你会得到每条记录的回调/事件作为记录流/流量,没有开始也没有结束,因此页面没有意义。 可能的解决方案 现在要获取表中项目的子集,假设 100 个元素中有 15 到 25 个项目,有一个技巧称为 limit(),但您必须使用 Flux<>。您可能需要访问 CassandraOperations int offset=15; int pageSize=10; ReactiveResultSet rs = cqlSession.executeReactive(bound); Flux<ReactiveRow> myPage = Flux.from(rs).skip(offset).take(pageSize); 更多建议 永远、永远不要在 Cassandra 表中执行 findAll()。 Cassandra 旨在存储数十亿条记录。您正在对表进行完整扫描(非常慢),并且您可能永远无法在内存中处理它。 在 Cassandra 中,表的设计基于查询/请求模式,并且始终有一个 where 子句。 where 子句将确定您如何对表进行分区。

回答 1 投票 0

面对 java.nio.charset.MalformedInputException :输入长度 = 1 - 使用 Spring Data Cassandra 和 Amazon Keyspace,如何解决?

我在进行查询以从特定表检索数据(大约 2000 行)时遇到问题(它适用于其他实体,我有 50 多个表);我收到 500 错误。什么是

回答 1 投票 0

在 Spring boot 中配置两个不同的数据库 - Postgres SQL 和 cassandra Db

在我们的应用程序中,数据库是使用 Spring boot starter JPA 和 application.properties 完成的配置 - spring.datasource.url= postgres spring.datasource.username=用户名 spring.datasource.pas...

回答 1 投票 0

Spring 应用程序由于 NoNodeAvailableException 而返回 CassandraConnectionFailureException:没有可用的节点来执行查询

我们在现有集群中又添加了 1 个 dc。应用程序分别部署在每个区域。添加 DC 和区域明智的应用程序部署后,我们开始看到以下异常......

回答 1 投票 0

Spring Data Cassandra 在执行实体查询时未配置表

@Table("person_details") 类人{ } 公共接口 PresonRepo 扩展了 CassandraRepository{ findByAgeGreaterThan(整数年龄) 错误: 无效查询异常:

回答 0 投票 0

在 Spring Data Cassandra 4.0.5 中连接到多个键空间时出错

创建类路径资源中定义的名为“cassandraTemplate”的 bean 时出错 \ [学习/多/数据库/配置/SerenoKeyspaceConfig.class]:\ 在类 [

回答 1 投票 0

无法使用 Reactive Cassandra 访问具有复合键的 Cassandra 表

我正在使用 Spring-Reactive 和 Reactive-Cassandra [spring-boot-starter-data-cassandra-reactive] 来访问 Cassandra 上的表。我能够访问带有代表

回答 1 投票 0

Cassandra 页面请求除第一页以外的索引页面

Java:19 弹簧靴:3.0 依赖: org.springframework.data 弹簧数据卡桑德拉 爪哇:19 Springboot:3.0 依赖性: <dependency> <groupId>org.springframework.data</groupId> <artifactId>spring-data-cassandra</artifactId> </dependency> 资料库: PersonRepository extends ReactiveCassandraRepository<Person, Integer> { Mono<Slice<Person>> findAll(Pageable page); Mono<Slice<Person>> findAllByType(String type, Pageable page); } 服务: public Mono<Slice<Person>> findPaginatedPerson(int limit, int offset) { int page = offset / limit; //only working with page = 0 Pageable pageRequest = CassandraPageRequest.of(page,limit); Mono<Slice<Person>> persons = personRepository.findAll(pageRequest); //working for first page only //Mono<Slice<Person>> persons = personRepository.findAll(CassandraPageRequest.first(1)); return persons; } 控制器: @GetMapping("/persons") public List<Person> findPaginated(@RequestParam int limit, @RequestParam int offset) { Mono<Slice<Person>> personPage = personService.findPaginatedPerson(limit, offset); return personPage.block().getContent(); } paagination 仅适用于第一页,下一页出现错误“无法为第一页以外的索引页面创建 Cassandra 页面请求 (0)” 有一个相关的answer,但没有提供足够的信息对我有帮助。 我试过像这样直接使用 Slice public List<Person> findFoo(int limit, int offset) { int page = offset / limit; int currpage = 0, size = 2; Pageable pageRequest = CassandraPageRequest.of(size, limit); Slice< Person > persons = personRepository.findAllByAssetType(pageRequest); while(persons.hasNext() && currpage < page) { persons = personRepository.findAllByAssetType(persons.nextPageable()); currpage++; } return persons.getContent(); } 但这也给出了同样的错误。

回答 0 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.