问题标签 [r2dbc]

我正在尝试执行以下操作；
但是使用org.testcontainers.containers.MySQLR2DBCDatabaseContainer
谁能告诉我这是如何实现的，因为 MySQLR2DBCDatabaseContainer 似乎没有以下方法：

• ::getJdbcUrl
• ：：获取密码
• ::获取用户名

我尝试将 Spring R2DBC 与 postgres 驱动程序一起使用。我有以下存储库：

我尝试了几个这样的注释：

我的连接工厂是这样的：

和application.yml：

但我总是遇到以下异常：

在我的 OrderConverter 构造函数下面：

您知道为什么我的存储库 bean 未绑定吗？

感谢所有和最好的问候

阿德里安

我可以知道如何在 Spring 数据 JDBC 中与 R2DBC（Mysql）进行关联（一对多）吗？如果可能，请提供小代码示例或 git 链接。

例如，我有一个员工表，地址表是员工的孩子。一名员工可以有多个地址。如果我想检索员工，我也想要对应员工的地址作为 JSON。注意：软件栈是 Spring Functional Reactive，R2DBC 和 Mysql

我正在尝试在一个事务中生成一个同时执行 2 个 postgresql 命令的代码。我的 DB 2 规则中有不同的规则顺序，我想在它们之间切换规则顺序。我正在使用 r2dbc-postgresql (v0.8.4) 和 spring-data-r2dbc (v1.1.1)。

我已经定义了 DatabaseClient 和 TransactionalOperator 并尝试使用那段代码：

但结果是命令一个接一个地运行，所以我完成了两个规则的规则顺序 = 1。

我做错了什么，我该如何解决这个问题？

我尝试更新整个应用程序并使用 PostgreSQL 的反应式编程方法，因此我正在更新存储库并使它们从 R2dbcRepository 扩展，还更新了相关服务以处理 Mono 和 Flux。当我尝试运行应用程序时出现异常

我不确定这是否是由于使用了Pageable，如果是这种情况，我没有找到PageableR2DBC 方法的任何替代方法。

过去使用 JPA 方法可以正常工作的一切都是我的存储库

我尝试在示例应用程序中使用 Spring Data R2dbc/Postgres。

• Spring Boot 2.4.0-M2
• R2dbc Postgres（由 Spring Boot 管理）
• Spring Data R2dbc 1.2.0-M2（由 Spring Boot 管理）

表脚本。

数据.sql：

我使用 aResourceDatabasePopulator来填充数据，它可以工作。

但是当我试图通过存储库保存数据时，失败了。

它抛出了这样的异常：

完整的代码在这里。

更新：放弃扩展AbstractR2dbcConfiguration，按照官方指南解决。

嗨，我的 Spring Boot 应用程序使用属性文件自动配置了 r2dbc 连接池：

现在我需要获取一个 PostgresqlConnection 实例，我这样做：

但是因为这是一个池配置，所以我收到了 ClassCastException 和以下包含所需 PostgresqlConnection 的 PooledConnection 对象：

PooledConnection[PostgresqlConnection{client=io.r2dbc.postgresql.client.ReactorNettyClient@14c93774, codecs=io.r2dbc.postgresql.codec.DefaultCodecs@62a68bcb}]

我需要访问 PostgresqlConnection 并使用它的原生功能，比如通知：

问题是如何从 connectionFactory 正确获取 PostgresqlConnection 实例？任何帮助将不胜感激。

语境

我正在寻找支持反应式编程的 postgres jdbc 驱动程序。我遇到了https://r2dbc.io/这是 jdbc 的反应式 api 规范。站点中有两个部分，一个是“客户端”，另一个是“驱动程序”

客户部分以

R2DBC 鼓励库以客户端库的形式提供“人性化”的 API。R2DBC 避免在每个驱动程序中实现用户空间功能，并将这些功能留给特定的客户端来实现。

r2dbc 的 Postrgres 实现 - https://github.com/pgjdbc/r2dbc-postgresql以

此实现不打算直接使用，而是用作人性化客户端库的支持实现以委托给

我的问题

1. 一般来说，客户和司机之间有什么区别，或者至少在上述情况下有什么区别？

2. 这里提到的“人性化 api”是什么？

我正在使用 reactor java 使用 r2dbc 对 Postgres 运行定期任务，如下所示；

大约 5 分钟后，它停止处理作业，当我检查 postgres 连接都空闲时：

如何适当地使用 r2dbc 和 databaseClient 定期从表中获取数据而不会导致此异常？

我有以下代码：

和：

我收到以下错误：

更早的错误：

如果我修改我的代码说：

然后我不再收到有关现有项目关系的错误，但是，似乎交易被完全取消了？

我得到以下输出：

所以我的问题是

1. 这样做的正确方法是什么？

2. 为什么我的 CommandLineRunner 代码似乎执行了两次？该表在运行代码后不会持续存在，因此似乎必须执行两次才能获得有关该表存在的第一个错误。

谢谢你。