R2DBC笔记

• 官网 https://docs.spring.io/spring-data/r2dbc/docs/1.1.9.RELEASE/reference/html/#r2dbc.repositories
• 依赖:

  <dependency>
    <groupId>org.springframework.data</groupId>
    <artifactId>spring-data-r2dbc</artifactId>
    <version>1.1.9.RELEASE</version>
  </dependency>

• 实体类id 注解 : 不是 javax.persistence.Id ,而是 org.springframework.data.annotation.Id

• JPA 中的关系映射，如 @ManyToOne @OneToMany等,在R2DBC中不支持，所以遇到有关联的时候，需要我们自己处理

• 不支持 类似的JPA 中的Specifications分页查询 ，使用 Specifications 来查询分页内容,但是 R2DBC支持 Pageable分页查询,比JPA稍微麻烦一些

• 启用 Auditing: @EnableR2dbcAuditing

• 数据库连接:

spring.r2dbc.url=r2dbc:postgresql://10.103.21.143:5450/数据库名?schema=schema名
spring.r2dbc.username=
spring.r2dbc.passweord=
spring.r2dbc.pool.enabled=true
spring.r2dbc.pool.initial-size=1
spring.r2dbc.pool.max-size=5
spring.r2dbc.pool.min-idle=1
spring.r2dbc.pool.max-idle-time=30m
spring.r2dbc.pool.max-life-time=60000
spring.r2dbc.pool.validation-query=SELECT 1

• 多线程同时修改数据库同一条数据, 乐观锁version 失败,需要重试( 是整个逻辑从头再来,不是重新保存数据 ):

     // 定义重试策略
        RetryBackoffSpec retrySpec = Retry
                .backoff(3, Duration.ofMillis(100))
                .maxBackoff(java.time.Duration.ofSeconds(5))
                .jitter(0.5);

      // 在Mono上应用重试策略
        Mono<String> retryMono = mono.retryWhen(retrySpec).doOnError(e->
         {

           log.error("retry 3 times fail {}",e.getMasseage());
              //重试失败后的逻辑
         }
);