问题标签 [r2dbc]

在 java 反应器中，r2dbc。我有两个表 A、B。我还为它们定义了存储库。我怎样才能得到由 A 和 B 组成的数据？

我只提出以下方法：从 A 调用 databaseClient.select，然后在循环中从 B 调用 select。

但我想要更有效和更被动的方式。怎么做？

我的任务是通过 r2dbc 数据库客户端插入实体，并将结果（映射）转换为实体。我想这样做：

但问题是转换器实体MappingR2dbcConverter不是由 spring 创建的。所以，我决定自己创建它：

我的问题，将结果映射转换为实体是否正确？

我已经使用 2.2.2.RELEASE 版本在类路径上设置了一个 Spring Boot 应用spring-boot-starter-data-r2dbc程序spring-boot-actuator-autoconfigure-r2dbc。但是，即使我正在通过应用程序进行数据库查询，我也无法在执行器端点上看到任何 r2dbc 指标。

我的理解是应该根据ConnectionPoolMetricsAutoConfiguration自动收集指标。不过，我已经调试了我的代码，并且这个类从未被 Spring Boot 初始化所触及。我究竟做错了什么？

我怎样才能转换io.ktor.utils.io.ByteReadChannel成kotlinx.coroutines.flow.Flow<java.nio.ByteBuffer>？

我将Ktor与此路由一起使用：

DAO 像这样使用R2DBC和Blob：

我尝试编写此扩展方法，但失败了：

我的主要问题是我没有找到任何类似的样本，而且两者ByteBuffer对ByteReadChannel我来说都是新的。

因为JpaRepository有@DataJpaTest。@DataJpaTest允许在 Spring 中对 JPA 存储库进行简单和隔离的测试。

我们正在使用spring-data-r2dbc. 是否有等效的@DataJpaTestforReactiveCrudRepository来单独测试它？

几天来，我一直在尝试使用 WebFlux 在 Spring Boot 中运行一个简单的 H2 / R2dbc 数据库。该应用程序启动得很好，但是当我调用 /todos 端点以获取数据库中的所有对象时，我收到以下错误：

我的理解是，如果我使用 create table 命令在类路径上添加一个 schema.sql 文件，它将使用它在启动时创建表，但它看起来不起作用。关于我可能做错了什么的任何想法？任何帮助将不胜感激，如果有人可以指出我想要的一个工作 mysql/r2dbc 示例。

所有代码位于：https ://gitlab.com/vanfleet/test-r2dbc-h2

如标题中所述，我无法在我的 Postgres 数据库中插入或更新记录。我刚开始使用 spring 和 kotlin，所以可能缺少一些非常基本的配置。提前致谢

这是我的代码库

用户存储库

用户模型 @Table("user_app")

用户 控制器@组件

用户配置

R2dbc配置

我与 R2DBC 合作，我需要执行查询，根据请求返回我的实体的 Flux，之后我需要将此实体转换为 DTO，但要创建 DTO，我需要为每个实体对数据库进行另一个查询，这从另一个表返回一些特殊信息，例如：

当 Id 总数超过 512 时，此代码不起作用

concatMap 没有帮助。

但是这段代码有效

我认为这个问题有更好的解决方案。我应该如何正确地进行这些查询？

在Spring Data R2DBC 中，我可以使用

在application.properties.

但是，这不会记录绑定为查询参数的实际值。

如何在 Spring Data R2DBC 中记录查询参数的实际值？

我正在尝试围绕响应式编程，特别是 Spring 和 Spring Data R2DBC。可以帮助我更好地理解它的一件事是对对象进行查找/修改/保存或“更新插入”。传统的交互可能如下所示：

Monos 看起来如何？我了解如何进行直接查找或直接保存，但更复杂的查找/更新/保存或 upsert 让我望而却步。

谢谢。