是否可以编写数据类型Converter来处理Postgres JSON列？

Question

理想情况是在Java方面使用Jackson。我尝试了明显的解决方案：

public class JsonObjectConverter implements Converter<Object, ObjectNode> {

    private final ObjectMapper mapper = new ObjectMapper();

    @Override public ObjectNode from(Object dbo) {
        try {
            return dbo != null ? mapper.readValue((String) dbo, ObjectNode.class) : null;
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
    }

    @Override public Object to(ObjectNode uo) {
        try {
            return uo != null ? mapper.writeValueAsString(uo) : null;
        } catch (JsonProcessingException e) {
            throw new RuntimeException(e);
        }
    }

    @Override public Class<Object> fromType() {
        return Object.class;
    }

    @Override public Class<ObjectNode> toType() {
        return ObjectNode.class;
    }
}

但是，如果我尝试使用它，则会出现类似以下的错误：

org.jooq.exception.DataAccessException: SQL [insert into "public"."my_table" ("id", "stuff") values (?, ?)]; ERROR: column "stuff" is of type json but expression is of type character varying
  Hint: You will need to rewrite or cast the expression.

但是，由于jOOQ强制执行类型安全（这很不错，顺便说一句），我不能只添加a.cast(String.class)并完成操作。那么，我是否需要在转换器中做其他事情，还是应该以其他方式调用代码？我目前正在这样做：

Long id = ...
ObjectNode stuff = ...
create.insertInto(MY_TABLE)
    .set(MY_TABLE.ID, id)
    .set(MY_TABLE.STUFF, stuff)
    .execute();

并在代码的其他地方使用可更新的记录。

Answer 1

是的，是的，但是您需要使用Postgres特定的API。在上面的代码中，您需要将from / to方法替换为以下内容：

@Override
public ObjectNode from(Object databaseObject) {
    if (databaseObject == null) { return null; }
    try {
        PGobject dbo = (PGobject) databaseObject;
        return mapper.readValue(dbo.getValue(), ObjectNode.class);
    } catch (IOException e) {
        throw new RuntimeException(e);
    }
}

@Override
public Object to(ObjectNode userObject) {
    if (userObject == null) { return null; }
    try {
        PGobject dbo = new PGobject();
        dbo.setType("json");
        dbo.setValue(mapper.writeValueAsString(userObject));
        return dbo;
    } catch (JsonProcessingException|SQLException e) {
        throw new RuntimeException(e);
    }
}