Cassandra的Spring Data是Spring Data项目的一部分,该项目为新数据存储提供了熟悉且一致的基于Spring的编程模型,同时保留了特定于商店的特性和功能。 Spring Data Cassandra项目提供与Cassandra Columnar NoSQL数据存储的集成
无法使用 UDT 写入表,出现“无法解析 [设备] 的 UserDefinedType”
这些是我在 spring 项目中安装的依赖项 //卡桑德拉 实现 'org.springframework.data:spring-data-cassandra:3.1.2' 实施 'io.projectreactor:reactor-core'
设置 bean 属性“cassandraTemplate”时无法解析对 bean“cassandraTemplate”的引用
我正在使用 spring boot 连接到 Cassandra 数据库。我在启动时收到错误消息 创建 com.myspace.mycompany.repository def 中定义的名为“abcItemsRepository”的 bean 时出错...
无法从 Spring Boot 应用程序连接到 Cassandra
目前我正在为 Cassandra 的这个错误而苦恼: 创建类路径资源 [com/project/config/CassandraConfiguration.class] 中定义的名为“cassandraSession”的 bean 时出错:Invocat...
有没有办法在 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 子句将确定您如何对表进行分区。
我在进行查询以从特定表检索数据(大约 2000 行)时遇到问题(它适用于其他实体,我有 50 多个表);我收到 500 错误。什么是
在 Spring boot 中配置两个不同的数据库 - Postgres SQL 和 cassandra Db
在我们的应用程序中,数据库是使用 Spring boot starter JPA 和 application.properties 完成的配置 - spring.datasource.url= postgres spring.datasource.username=用户名 spring.datasource.pas...
Spring 应用程序由于 NoNodeAvailableException 而返回 CassandraConnectionFailureException:没有可用的节点来执行查询
我们在现有集群中又添加了 1 个 dc。应用程序分别部署在每个区域。添加 DC 和区域明智的应用程序部署后,我们开始看到以下异常......
Spring Data Cassandra 在执行实体查询时未配置表
@Table("person_details") 类人{ } 公共接口 PresonRepo 扩展了 CassandraRepository{ findByAgeGreaterThan(整数年龄) 错误: 无效查询异常:
在 Spring Data Cassandra 4.0.5 中连接到多个键空间时出错
创建类路径资源中定义的名为“cassandraTemplate”的 bean 时出错 \ [学习/多/数据库/配置/SerenoKeyspaceConfig.class]:\ 在类 [
无法使用 Reactive Cassandra 访问具有复合键的 Cassandra 表
我正在使用 Spring-Reactive 和 Reactive-Cassandra [spring-boot-starter-data-cassandra-reactive] 来访问 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(); } 但这也给出了同样的错误。
从spring boot应用中获取cassandra cql指标。
我想从springboot cassandra应用中获取db查询指标,并将其暴露给prometheus端点。已经有了springboot+postgres的实现,并且它与r2dbc-proxy一起工作。...
Spring Boot + cassandra轻量级事务更新
有什么方法可以在不写查询的情况下用轻量级事务实现更新?我怎么能实现casandra的例子 UPDATE cycling.cyclist_name SET firstname = 'Roxane' WHERE id = ....
Spring-data-cassandra:创建名称为'sessionFactory'的bean时出错,并且无法解析对bean'cassandraTemplate'的引用
我有一个springboot应用程序,在其中我要连接到cassandra DB。我的pom.xml:父代> org.springframework.boot spring-boot-starter-parent&...
Springboot:在同一项目中同时导入spring-data-jdbc和spring-data-cassandra时出现的问题
在我的springboot应用程序中,我想连接到两个数据源,一个cassandra DB和一个oracle DB。因此,我在pom.xml中添加了以下内容: org ..
我的应用程序基于Spring Reactive,我需要开始使用Cassandra DB(v 3.11.6)。最初,我通过添加spring-data-cassandra来满足数据库的要求,并且能够写DB ...
无法使用带有弹簧数据的NetworkReplication创建第二个cassandra键空间
我有两个键空间。其中一个完美创建,而另一个仅通过SimpleReplication创建。当我通过网络复制创建它时,会创建它,但是当我确实描述...
无法使用带有弹簧数据的NetworkReplication创建cassandra键空间
我有两个键空间。其中一个完美创建,而另一个仅通过SimpleReplication创建。当我通过网络复制创建它时,会创建它,但是当我确实描述...
如何仅使用ReactiveCassandraRepository插入实体的几个文件
[使用Spring Data,我如何向ReactiveCassandraRepository指定,只需将传递的实体的几个文件插入到Cassandra DB中,例如,如果我的实体如下,@Table(“ ...
com.datastax.driver.core.exceptions.InvalidQueryException:未配置的表peers_v2
[我正在使用Spring Boot开发连接到cassandra的应用程序,这是我的连接设置spring.data.cassandra.contact-points = localhost spring.data.cassandra.keyspace-name = ...