如何使用JOOQ在PostgreSQL中插入帶有JSON列的可更新記錄？

Question

我跟着Is it possible to write a data type Converter to handle postgres JSON columns? 的答案來實現nodeObject轉換器。

然後我試圖使用一個可更新的記錄插入一條記錄，我。「org.jooq.exception.SQLDialectNotSupportedException：Type類org.postgresql.util.PGobject不方言POSTGRES支持」異常」

？

我怎樣才能解決這個

以下是我的代碼：

TableRecord r = create.newRecord(TABLE); 
ObjectNode node = JsonNodeFactory.instance.objectNode(); 
r.setValue(TABLE.JSON_FIELD, node, new JsonObjectConverter()); 
r.store(); 

Answer 1

由於jOOQ 3.5，你可以在這裏是自己的自定義數據類型綁定註冊代碼生成器：

http://www.jooq.org/doc/latest/manual/code-generation/custom-data-type-bindings

不像Converter，一個Binding決定如何你的數據類型正在以內部jOOQ JDBC級別處理，不知道jOOQ你實現。也就是說，你不僅會定義如何類型（T =數據庫類型，U =用戶類型）<T>和<U>之間進行轉換，但你也可以定義這樣的類型如何：

• 呈現爲SQL
• 綁定到用預處理
• 綁定到的SQLOutput
• 註冊於CallableStatements中作爲OUT參數
• 從結果擷取的
• 從的SQLInput擷取的
• 從CallableStatements中作爲OUT擷取的參數

一個例子Binding用於與傑克遜使用以產生JsonNode類型在這裏給出：

public class PostgresJSONJacksonJsonNodeBinding 
implements Binding<Object, JsonNode> { 

    @Override 
    public Converter<Object, JsonNode> converter() { 
     return new PostgresJSONJacksonJsonNodeConverter(); 
    } 

    @Override 
    public void sql(BindingSQLContext<JsonNode> ctx) throws SQLException { 

     // This ::json cast is explicitly needed by PostgreSQL: 
     ctx.render().visit(DSL.val(ctx.convert(converter()).value())).sql("::json"); 
    } 

    @Override 
    public void register(BindingRegisterContext<JsonNode> ctx) throws SQLException { 
     ctx.statement().registerOutParameter(ctx.index(), Types.VARCHAR); 
    } 

    @Override 
    public void set(BindingSetStatementContext<JsonNode> ctx) throws SQLException { 
     ctx.statement().setString(
      ctx.index(), 
      Objects.toString(ctx.convert(converter()).value())); 
    } 

    @Override 
    public void get(BindingGetResultSetContext<JsonNode> ctx) throws SQLException { 
     ctx.convert(converter()).value(ctx.resultSet().getString(ctx.index())); 
    } 

    @Override 
    public void get(BindingGetStatementContext<JsonNode> ctx) throws SQLException { 
     ctx.convert(converter()).value(ctx.statement().getString(ctx.index())); 
    } 

    // The below methods aren't needed in PostgreSQL: 

    @Override 
    public void set(BindingSetSQLOutputContext<JsonNode> ctx) throws SQLException { 
     throw new SQLFeatureNotSupportedException(); 
    } 

    @Override 
    public void get(BindingGetSQLInputContext<JsonNode> ctx) throws SQLException { 
     throw new SQLFeatureNotSupportedException(); 
    } 
} 

，這是上面使用可以是Converter看到這裏：

public class PostgresJSONJacksonJsonNodeConverter 
implements Converter<Object, JsonNode> { 
    @Override 
    public JsonNode from(Object t) { 
     try { 
      return t == null 
       ? NullNode.instance 
       : new ObjectMapper().readTree(t + ""); 
     } 
     catch (IOException e) { 
      throw new RuntimeException(e); 
     } 
    } 

    @Override 
    public Object to(JsonNode u) { 
     try { 
      return u == null || u.equals(NullNode.instance) 
       ? null 
       : new ObjectMapper().writeValueAsString(u); 
     } 
     catch (IOException e) { 
      throw new RuntimeException(e); 
     } 
    } 

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

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

你現在可以註冊上述bindin g通過代碼生成器配置：

<customType> 
    <name>com.example.PostgresJSONJacksonJsonNodeBinding</name> 
    <type>com.fasterxml.jackson.databind.JsonNode</type> 
    <binding>com.example.PostgresJSONJacksonJsonNodeBinding</binding> 
</customType> 

<forcedType> 
    <name>com.example.PostgresJSONJacksonJsonNodeBinding</name> 
    <expression>my_schema\.table\.json_field</expression> 
</forcedType>