使用Postgres JSONB类型时，带有R2DBC的Kotlin Micronaut数据失败

Question

我正在尝试使用Postgres设置Micronaut Data R2DBC，但它会以

    io.r2dbc.postgresql.ExceptionFactory$PostgresqlBadGrammarException: [42804] column blob is of type jsonb but expression is of type character varying

micronautversion = 3.5.1 失败。 kotlinversion = 1.6.10 javaversion = 17

build.gradle.kts

    val coroutinesVersion = "1.6.0"
    dependencies {
        kapt("io.micronaut.data:micronaut-data-processor")
        // kapt("io.micronaut:micronaut-http-validation")
        // implementation("io.micronaut:micronaut-http-client")
        implementation("io.micronaut:micronaut-jackson-databind")
        implementation("io.micronaut.data:micronaut-data-r2dbc")
        implementation("io.micronaut.kotlin:micronaut-kotlin-runtime")
        implementation("jakarta.annotation:jakarta.annotation-api")
        implementation("org.jetbrains.kotlin:kotlin-reflect:${kotlinVersion}")
        implementation("org.jetbrains.kotlin:kotlin-stdlib-jdk8:${kotlinVersion}")
        implementation("org.jetbrains.kotlinx:kotlinx-coroutines-reactive:${coroutinesVersion}")
        implementation("org.jetbrains.kotlinx:kotlinx-coroutines-jdk8:${coroutinesVersion}")
        runtimeOnly("ch.qos.logback:logback-classic")
        runtimeOnly("org.postgresql:r2dbc-postgresql")
        implementation("io.micronaut:micronaut-validation")
        implementation("io.micronaut:micronaut-runtime")
        implementation("io.micronaut:micronaut-jackson-databind")
        runtimeOnly("com.fasterxml.jackson.module:jackson-module-kotlin")
    }

postgres schema

    CREATE TABLE entity (
        entity_id          TEXT PRIMARY KEY,
        entity_type        TEXT NOT NULL,
        blob               JSONB NOT NULL,
        CREATED_DATE       TIMESTAMP(3) DEFAULT now() NOT NULL
    );

对应的kotlin数据类未能使

    @MappedEntity
    data class Entity(
      @field:Id val entityId: String,
      val entityType: String,
      @TypeDef(type = DataType.JSON) val blob: Any,
      val createdDate: Instant
    )

失败的测试

    @Test
    fun testInsert() = runBlocking {
        val now = Instant.now()
        val entity = Entity("entity-uuid-1", "test-entity-type", "{}", now)
        Assertions.assertEquals(entity, entityRepository.save(entity))
    }

完整项目 为在这里

看起来要么缺少将字符串转换为JSON所需的依赖项，要么需要自定义转换器。有人可以帮忙吗？

Answer 1

我通过使用

    implementation("io.r2dbc:r2dbc-postgresql:0.8.12.RELEASE")

而不是

    implementation("org.postgresql:r2dbc-postgresql")

数据类来更新以使用io.r2dbc.postgresql.codec.json而不是任何

    @MappedEntity
    data class Entity(
      @field:Id val entityId: String,
      val entityType: String,
      @TypeDef(type = DataType.JSON) val blob: Json,
      val createdDate: Instant
    )

Answer 2

编辑：看来我误会了，实际问题是映射：

而不是：

@TypeDef(type = DataType.JSON)

应该是：

@field:TypeDef(type = DataType.JSON)

看起来R2DBC Postgres驱动程序不允许String用于JSONB，这很奇怪，因为JDBC很好。您可能需要尝试创建attributeconverter将其转换为byte []。

。