标签: r2dbc

所以我有这个想法，这真的超出了我的想象，因为我只编程了很短一段时间，但我想构建一个反应式 Spring webflux 应用程序，将 json 端点暴露给反应前端。

当我决定在 Postgres 中使用 jsonb 格式时，问题就开始了，因为我认为我可能会从数据库一直到前端层一直使用 json。

当我尝试使用反应式 R2dbc 驱动程序使用 jsonb SELECT 表时，出现以下错误：

Caused by: java.lang.IllegalArgumentException: 3802 is not a valid object id

我在 postgres 中有一个表，如下所示：

Column  |  Type   | Collation | Nullable |           Default
---------+---------+-----------+----------+------------------------------
 id      | integer |           | not null | generated always as identity
 details | jsonb   |           |          |
Indexes:
    "snacks_new_pkey" PRIMARY KEY, btree (id)

因此，如果我将其作为文本提取到 Spring webflux，它就可以正常工作，因为它不再是 json。

"SELECT id, details->>'name' as NAME, details->>'price' AS PRICE, details->>'quantity' AS QUANTITY …

我正在开发一个多租户反应式应用程序，使用 Spring-Webflux + Spring-data-r2dbc 和 r2dbc 驱动程序连接到 Postgresql 数据库。多租户部分是基于模式的：每个租户一个模式。因此，根据上下文（例如用户登录），请求将命中数据库的特定架构。

我正在努力研究如何在 r2dbc 中实现这一点。理想情况下，这将是 Hibernate 使用MultiTenantConnectionProvider 的方式（参见示例 16.3）。

到目前为止我发现了什么以及我做了什么：

• 可以使用此处提到的AbstractRoutingConnectionFactory。但我被迫按租户/架构创建 ConnectionFactory。在我看来，这远非高效/可扩展，我宁愿使用像r2dbc-pool这样的连接池

• 我查看了PostgresqlConnectionFactory。有趣的是，有prepareConnection一个电话setSchema(connection)：

  private Mono<Void> setSchema(PostgresqlConnection connection) {
      if (this.configuration.getSchema() == null) {
          return Mono.empty();
      }
  
      return connection.createStatement(String.format("SET SCHEMA '%s'", this.configuration.getSchema()))
          .execute()
          .then();
  }
  

  Run Code Online (Sandbox Code Playgroud)

我可能需要找到一种方法来覆盖它，以便从上下文而不是配置中动态获取模式？

• 否则，我可以尝试将请求中的架构指定为表前缀：

      String s = "tenant-1";
      databaseClient.execute("SELECT * FROM \"" + s + "\".\"city\"")
              .as(City.class)
              .fetch()
              .all()
  

  Run Code Online (Sandbox Code Playgroud)

但我不能再使用 SpringData，或者我需要重写每个请求以将租户作为参数传递。

任何提示/帮助表示赞赏:)

如何将自定义转换器添加到 mu spring boot 应用程序？我的实体字段

    @CreatedDate
    @Column(value = "create_time")
    private Instant createTime;

我的转换器是

    @Bean
    public Converter<Long, Instant> longInstantConverter() {
        return new Converter<Long, Instant>() {
            @Override
            public Instant convert(Long source) {
                return Instant.ofEpochMilli(source);
            }
        };
    }

    @Bean
    public Converter<Instant, Long> instantLongConverter() {
        return new Converter<Instant, Long>() {
            @Override
            public Long convert(@NotNull Instant source) {
                return source.toEpochMilli();
            }
        };
    }

我有一个例外

org.springframework.data.mapping.MappingException: Could not read property @org.springframework.data.relational.core.mapping.Column(value=create_time) @org.springframework.data.annotation.CreatedDate()private java.time.Instant com.example.database.model.MyTable.createTime from result set!
.........
Caused by: org.springframework.core.convert.ConverterNotFoundException: No converter found capable of …

我无法使用 spring-webflux 和 r2dbc （使用 r2dbc-pool driver 0.8.0.M8）打开超过 10 个连接。我的配置如下：

@Configuration
public class PostgresConfig extends AbstractR2dbcConfiguration {

  @Override
  @Bean
  public ConnectionFactory connectionFactory() {
    ConnectionFactory connectionFactory = ConnectionFactories.get(ConnectionFactoryOptions.builder()
        .option(DRIVER, "pool")
        .option(PROTOCOL, "postgresql")
        .option(HOST, host)
        .option(USER, user)
        .option(PASSWORD, password)
        .option(DATABASE, database)
        .build());
    ConnectionPoolConfiguration configuration = ConnectionPoolConfiguration.builder(connectionFactory)
        .maxIdleTime(Duration.ofMinutes(30))
        .initialSize(initialSize)
        .maxSize(maxSize)
        .maxCreateConnectionTime(Duration.ofSeconds(1))
        .build();
    return new ConnectionPool(configuration);
  }
}

当我指定超过 10 个连接时，我会收到如下错误：

org.springframework.dao.DataAccessResourceFailureException: 
Failed to obtain R2DBC Connection; nested exception is 
java.util.concurrent.TimeoutException: 
Did not observe any item or terminal signal within 1000ms in 'lift' …

我正在使用 R2DBC-H2 驱动程序，我的 UR.L 是spring.r2dbc.url=r2dbc:h2:mem:///customer

使用此配置，SpringBoot 启动正常，但是，我无法访问 h2-console。

有谁知道为什么，以及我该如何解决它？

我试图使用最新版本的 r2dbc-postgresql (0.8.4) 中的 EnumCodec，但没有成功，我想知道你是否可以帮助我。

我还使用 spring-data-r2dbc 版本 1.1.1。

我从 GitHub 中获取了确切的示例，并在 Postgres 中创建了一个枚举类型 \xe2\x80\x9cmy_enum\xe2\x80\x9d，\n 和一个包含 \xe2\ 的表 \xe2\x80\x9csample_table\xe2\x80\x9d x80\x98name\xe2\x80\x99 （文本）和 \xe2\x80\x98value\xe2\x80\x99 （my_enum）。

然后我按照例子做了：

SQL：

CREATE TYPE my_enum AS ENUM ('FIRST', 'SECOND');\n

Java模型：

enum MyEnumType {\n  FIRST, SECOND;\n}\n

编解码器注册：

PostgresqlConnectionConfiguration.builder()\n.codecRegistrar(EnumCodec.builder().withEnum("my_enum", MyEnumType.class).build());\n

我使用 DatabaseClient 来与数据库通信。\n我尝试使用两种方法插入：

databaseClient.insert().into(SampleTable.class)\n.using(sampleTable).fetch().rowsUpdated();\n

或者：

databaseClient.insert().into("sample_table")\n.value("name", sampleTable.getName())\n.value("value", sampleTable.getValue())\n.then();\n

其中 SampleTable 是：

@Data\n@AllArgsConstructor\n@NoArgsConstructor\n@Builder\n@Table("sample_table")\n@JsonIgnoreProperties(ignoreUnknown = true)\n@JsonInclude(JsonInclude.Include.NON_NULL)\npublic class SampleTable implements Serializable {\n   private String name;\n   @Column("value")\n   @JsonProperty("value")\n …

我使用 spring-boot 2.4.2 和 webflux 连接到 postgres 数据库。@Transactional我在使用时观察到一种我不明白的行为。

为了展示该行为，我创建了一个示例应用程序，尝试将行添加到两个表中；表“a”和表“b”。对表“a”的插入预计会因重复键冲突而失败。鉴于使用了事务性，我预计不会将任何行添加到表“b”中。

但是，根据我使用的注释方法，@Transactional我会得到不同的结果。

如果我注释控制器方法，一切都会按预期工作，并且不会向表 B 添加任何行。

    @PostMapping("/")
    @Transactional
    public Mono<Void> postEntities() {
        return demoService.doSomething();
    }

演示服务如下所示：

    public Mono<Void> doSomething() {
        return internal();
    }


    public Mono<Void> internal() {
        Mono<EntityA> clash = Mono.just(EntityA.builder().name("clash").build()).flatMap(repositoryA::save);
        Mono<EntityB> ok = Mono.just(EntityB.builder().name("ok").build()).flatMap(repositoryB::save);
        return ok.and(clash);
    }

如果我将@Transactional注释从控制器移至doSomething()，那么事务仍然按预期工作。但是，如果我将@Transactional注释移至internal()，则事务将无法按预期工作。一行被添加到表“b”中。

此示例的完整代码在这里：https ://github.com/alampada/pg-spring-r2dbc-transactional

我不明白为什么将注释移至internal()方法会导致事务处理出现问题。您能解释一下吗？

在我的 Vaadin 和 Spring Boot 应用程序中，我已从 jOOQ 3.14.12 更新到 3.15.0。此更新后，我的应用程序不再启动。这是我得到的错误：

***************************
APPLICATION FAILED TO START
***************************

Description:

Parameter 0 of constructor in org.komunumo.data.service.MemberService required a bean of type 'org.jooq.DSLContext' that could not be found.


Action:

Consider defining a bean of type 'org.jooq.DSLContext' in your configuration.

我不明白为什么我必须定义这个 bean，因为使用 jOOQ 3.14.12 我没有必要。据我所知，这是JooqAutoConfiguration自动完成的。

关于使用 Spring JDBC，它工作得非常好，并且在使用批处理时比 JPA 有一些改进。

我很想了解当您已经拥有Spring Data JDBC 时为什么要使用 Spring Data JDBC。