Spring R2DBC：如何替换不推荐使用的DatabaseClient。作为（…）并处理jsonb字段的自定义类型/转换器

Question

迁移到Spring Boot 2.4后，我遇到了对象映射问题。到目前为止，我使用的是Spring Boot 2.3（与Kotlin一起使用）。

对于示例数据库查询

    override fun findMyEntities(searchParams: SearchParams): Flux<MyEntity> =
        databaseClient
            .sql("SELECT *  FROM my_entities ........................... OFFSET :offset LIMIT :limit")
            .bind("searchPhrase", searchParams.searchPhrase)
            .bind("limit", searchParams.pageSize)
            .bind("offset", searchParams.offset)
            .map(::mapRow)
            .all()

    private fun mapRow(row: Row) = MyEntity(
        id = row.get("id", UUID::class.java)!!,
        name = row.get("name", String::class.java)!!,
        description = row.get("description", String::class.java)!!,
        creation = row.get("creation", UserActionMetadata::class.java)!!,
    )

我收到错误：

Suppressed: java.lang.IllegalArgumentException: Cannot decode value of type com.mypackage.model.UserActionMetadata
        at io.r2dbc.postgresql.codec.DefaultCodecs.decode(DefaultCodecs.java:153)
        at io.r2dbc.postgresql.PostgresqlRow.decode(PostgresqlRow.java:90)
        at io.r2dbc.postgresql.PostgresqlRow.get(PostgresqlRow.java:77)
        at com.mypackage.repository.MyRepotistory.mapRow(MyRepotistory.kt:59)

在版本升级之前，上述功能如下：

.execute("SELECT * FROM ...")
.`as`(MyEntity::class.java)
.fetch()
.all()

发生错误的地方，数据库中的创建字段是JSONB类型。为此，我有定制的读写转换器（在扩展AbstractR2dbcConfiguration的配置类中）。

import org.springframework.data.convert.ReadingConverter
import org.springframework.data.convert.WritingConverter

@Configuration
class DatabaseConfig(private val r2dbcProperties: R2dbcProperties, private val objectMapper: ObjectMapper) :
    AbstractR2dbcConfiguration() {

    @WritingConverter
    inner class UserActionMetadataToJsonConverter : Converter<UserActionMetadata, Json> {
        override fun convert(source: UserActionMetadata): Json {
            return Json.of(objectMapper.writeValueAsString(source))
        }
    }

    @ReadingConverter
    inner class JsonToUserActionMetadataConverter : Converter<Json, UserActionMetadata> {
        override fun convert(source: Json): UserActionMetadata {
            return objectMapper.readValue(source.asString())
        }
    }

知道如何成功迁移到Spring Boot 2.4吗？

我看到了Spring R2DBC DatabaseClient的建议。作为（…）使用R2dbcEntityTemplate，但我的查询太复杂，代码也会太臃肿。还有一个问题https://github.com/spring-projects/spring-framework/issues/26021 . 我希望有一些解决办法。

Answer 1

以下代码将数据转换为实体：

import org.springframework.r2dbc.core.DatabaseClient
import org.springframework.data.r2dbc.convert.MappingR2dbcConverter

class MyRepository(
    private val databaseClient: DatabaseClient,
    private val converter: MappingR2dbcConverter
) {
   fun fetchMyEntity() = databaseClient
       .sql("...")
       .map { row, metadata -> converter.read(MyEntity::class.java, row, metadata) }
       .all()
}