Han*_*tsy 5 postgresql spring-data spring-boot spring-webflux spring-data-r2dbc
我的示例代码基于 Spring Boot 2.4.0-M2(spring-data-r2dbc 1.2.0-M2)、Java 11、Postgres。
在 Spring 博客和更改日志中,它删除了 Spring Data R2dbc 获得了审计支持。
我像这样启用了审核。
@Configuration
@EnableR2dbcAuditing
class DataConfig {
    @Bean
    ReactiveAuditorAware<String> auditorAware() {
        return () -> Mono.just("hantsy");
    }
}
以及实体类和存储库。
interface PersonRepository extends R2dbcRepository<Person, UUID> {
}
@Data
@ToString
@Builder
@NoArgsConstructor
@AllArgsConstructor
@Table(value = "persons")
class Person {
    @Id
    @Column("id")
    private UUID id;
    @Column("first_name")
    private String firstName;
    @Column("last_name")
    private String lastName;
    @Column("created_at")
    @CreatedDate
    private LocalDateTime createdAt;
    @Column("updated_at")
    @LastModifiedDate
    private LocalDateTime updatedAt;
    @Column("version")
    @Version
    private Long version;
}
架构脚本。(不用担心 UUID,在 docker init 脚本中初始化的扩展)
 CREATE TABLE IF NOT EXISTS persons (
 -- id SERIAL PRIMARY KEY,
  id UUID DEFAULT uuid_generate_v4(),
  first_name VARCHAR(255),
  last_name VARCHAR(255),
  created_at TIMESTAMP ,
  updated_at TIMESTAMP,
  version INTEGER,
  PRIMARY KEY (id)
  );
当我在 中添加以下代码片段来ApplicationRunner体验审核时,@createdDate和都没有@lastModifiedDate被填充。
            persons
                    .save(
                            Person.builder()
                                    .firstName("hantsy")
                                    .lastName("bai")
                                    .build()
                    )
                    .log()
                    .map(person -> {
                        person.setFirstName("new Hantsy");
                        return person;
                    })
                    .flatMap(persons::save)
                    .log()
                    .then()
                    .thenMany(persons.findAll())
                    .subscribe(
                            data -> log.info("saved data: {}", data),
                            err -> log.error("err: {}", err)
                    );
控制台打印:
2020-09-07 22:12:30.734  INFO 8800 --- [actor-tcp-nio-2] reactor.Mono.UsingWhen.1                 : onNext(Person(id=8814e87c-c6d3-4dca-a095-fb5f41696b49, firstName=hantsy, lastName=bai, createdAt=null, updatedAt=null, version=0))
2020-09-07 22:12:30.779  INFO 8800 --- [actor-tcp-nio-2] reactor.Mono.UsingWhen.1                 : onComplete()
2020-09-07 22:12:30.801  INFO 8800 --- [actor-tcp-nio-2] reactor.Mono.FlatMap.2                   : | onNext(Person(id=8814e87c-c6d3-4dca-a095-fb5f41696b49, firstName=new Hantsy, lastName=bai, createdAt=null, updatedAt=null, version=1))
2020-09-07 22:12:30.801  INFO 8800 --- [actor-tcp-nio-2] reactor.Mono.FlatMap.2                   : | onComplete()
2020-09-07 22:12:30.823  INFO 8800 --- [actor-tcp-nio-2] com.example.demo.DemoApplication         : saved data: Person(id=981741c3-4468-474d-9e92-b4d396f004d9, firstName=hantsy, lastName=bai, createdAt=null, updatedAt=null, version=0)
2020-09-07 22:12:30.824  INFO 8800 --- [actor-tcp-nio-2] com.example.demo.DemoApplication         : saved data: Person(id=8814e87c-c6d3-4dca-a095-fb5f41696b49, firstName=new Hantsy, lastName=bai, createdAt=null, updatedAt=null, version=1)
更新:为r2dbc审计创建了另一个简单的示例(基于H2)来重现它,测试代码有效,但应用程序仍然存在问题。不确定我的原始示例(基于 Postgres,并使用 Pg 特定的 JSON、Enum 等)是否需要其他配置,应用程序和测试代码都无法按预期工作。
更新:Github issues 中报告了相关问题,请参阅issues#451。更新了我的示例以确保修复程序适用于 1.2.0 snapshot20200910 版本。我认为下一个版本(1.2.0-RC1)将包含修复程序。
更新:我的示例已更新到 Spring Boot 2.4.0-M3,错误已修复。
| 归档时间: | 
 | 
| 查看次数: | 3953 次 | 
| 最近记录: |