可以手动将JSON或JSONB postgresql数据类型与spring r2dbc一起使用吗？

Question

我正在用spring boot、webflux和r2dbc（postgresql）构建一个新的api。我的一个表将有一个json或jsonb字段，用于存储动态json文档。

就目前而言，r2dbc不支持postgresql数据库的json数据类型。我想知道是否可以使用它，为存储库编写一些代码。

我已经创建了一个简单的测试项目来尝试这个，但还没有成功。我可以使用org保存JSON字段。springframework。数据r2dbc。果心DatabaseClient。execute（）并在查询中用将json字段包装为\u json（），但我以后无法读取它。

测试实体：

@Data
@NoArgsConstructor
@AllArgsConstructor
@Table("Test")
public class Test {

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Column(name = "id", columnDefinition = "serial")
    private Long id;
    @Column(name = "data", columnDefinition = "json")
    private String data;

}

保存方法工作：

public Mono<Integer> save(Test test) {
        return databaseClient.execute("INSERT INTO test (data) VALUES(to_json($1))")
                .bind("$1", test.getData())
                .fetch()
                .rowsUpdated();
    }

回读时出现异常：

java.lang.IllegalArgumentException: Cannot decode value of type java.lang.Object
    at io.r2dbc.postgresql.codec.DefaultCodecs.decode(DefaultCodecs.java:97)
    at io.r2dbc.postgresql.PostgresqlRow.get(PostgresqlRow.java:88)
    at io.r2dbc.spi.Row.get(Row.java:63)
    at org.springframework.data.r2dbc.convert.ColumnMapRowMapper.getColumnValue(ColumnMapRowMapper.java:100)
    at org.springframework.data.r2dbc.convert.ColumnMapRowMapper.apply(ColumnMapRowMapper.java:59)
    at org.springframework.data.r2dbc.convert.ColumnMapRowMapper.apply(ColumnMapRowMapper.java:44)
    at io.r2dbc.postgresql.PostgresqlResult.lambda$map$0(PostgresqlResult.java:71)

Answer 1

我能够通过查询将json/jsonb转换为TEXT来做到这一点。我不确定这是否是正确的选择，但它有效。

public Mono<Test> findById(Long id) {
    return databaseClient.execute("SELECT id, data::TEXT FROM test WHERE id = $1")
            .bind("$1", id)
            .map(row -> new Test(
                          row.get("id", Long.class),
                          row.get("data", String.class)
                        )
            )
            .one();
}

Answer 2

使用io。r2dbc。postgresql。编解码器。Json作为您的实体属性类型，请查看我的帖子。