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");
}
}
Run Code Online (Sandbox Code Playgroud)
以及实体类和存储库。
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;
}
Run Code Online (Sandbox Code Playgroud)
架构脚本。(不用担心 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)
);
Run Code Online (Sandbox Code Playgroud)
当我在 中添加以下代码片段来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)
);
Run Code Online (Sandbox Code Playgroud)
控制台打印:
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)
Run Code Online (Sandbox Code Playgroud)
更新:为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 次 |
| 最近记录: |