我正在使用 Spring Boot、Webflux 和 R2DBC(PostgreSQL) 构建一个新的 API。我的其中一个表将拥有一个 JSON 或 JSONB 字段,用于存储动态 JSON 文档。
目前为止,R2DBC 并不支持 PostgreSQL 数据库的 JSON 数据类型。我想知道是否有可能编写一些代码来在存储库中使用它。
我创建了一个简单的测试项目来尝试此操作,但是还没有成功。我可以使用 `org.springframework.data.r2dbc.core.DatabaseClient.execute()` 写入带有 `to_json()` 的查询并保存 JSON 字段,但是之后无法读取它。
测试实体:
读取时出现异常:
目前为止,R2DBC 并不支持 PostgreSQL 数据库的 JSON 数据类型。我想知道是否有可能编写一些代码来在存储库中使用它。
我创建了一个简单的测试项目来尝试此操作,但是还没有成功。我可以使用 `org.springframework.data.r2dbc.core.DatabaseClient.execute()` 写入带有 `to_json()` 的查询并保存 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)
JSON
和JSONB
。已添加新编解码器 -io.r2dbc.postgresql.codec.Json
。新的链接。 - Avinash Anand