R2DBC Postgres SQL枚举问题

Question

作为学习r2DBC的一部分，我遇到了Enum转换面临的问题。我在这里使用PostgreSQL。当读取评级为PG-13和NC-17（任何带破折号的东西）的电影数据时，我面临问题。

下面是我的表模式

create table film
(
film_id          integer       default nextval('film_film_id_seq'::regclass) not null
    constraint film_pkey
        primary key,
title            varchar(255)                                                not null,
description      text,
release_year     year,
language_id      smallint                                                    not null
    constraint film_language_id_fkey
        references language
        on update cascade on delete restrict,
rental_duration  smallint      default 3                                     not null,
rental_rate      numeric(4, 2) default 4.99                                  not null,
length           smallint,
replacement_cost numeric(5, 2) default 19.99                                 not null,
rating           mpaa_rating   default 'G'::mpaa_rating,
last_update      timestamp     default now()                                 not null,
special_features text[]
);

mpaa_rating定义为

create type mpaa_rating as enum ('G', 'PG', 'PG-13', 'R', 'NC-17');

这是我的代码，它在我的配置中注册转换器

@Configuration
@EnableTransactionManagement
@EnableR2dbcRepositories
@EnableR2dbcAuditing
public class DVDRentalDBConfiguration extends AbstractR2dbcConfiguration {

@Bean
public ConnectionFactory connectionFactory() {
    System.out.println("Initializing postgreSQL connection factory");
    return new PostgresqlConnectionFactory(
            PostgresqlConnectionConfiguration.builder()
                    .host("localhost")
                    .database("dvdrental")
                    .username("postgres")
                    .password("postgres")
                    .codecRegistrar(EnumCodec.builder().withEnum("mpaa_rating", Rating.class).build())
                    .build()
    );
}

@Override
protected List<Object> getCustomConverters() {
    return Collections.singletonList(new RatingWritingConverter());
}

@Bean
ReactiveTransactionManager transactionManager(ConnectionFactory connectionFactory) {
    System.out.println("Initializing postgreSQL connection factory");
    return new R2dbcTransactionManager(connectionFactory);
}
}

我的检索代码很简单

 private Mono<FilmModel> getFilmById(Long id) {
    return filmRepository.findById(id).switchIfEmpty(Mono.error(DataFormatException::new));
}
  

添加引发的异常https://gist.github.com/harryalto/bd51bbcdd081868c5064c808d08205e4

我试图研究堆栈溢出，但无法找出问题所在。非常感谢您的帮助。

Answer 1

如果您使用Spring Boot/Spring数据R2dbc将表映射到POJO，则可以跳过Postgres中的枚举定义，默认情况下，Spring数据R2dbc将在db端将枚举处理为varchar/char，并在java POJO中使用enum，请查看我的示例，以及架构sql脚本和映射的实体类。Spring Boot注册映射转换器以自动转换它们。

如果您想自己处理Enum类型，请检查此示例。