Jooq数组作为集合

Question

我想在java中使用集合而不是数组来序列化postgreSQL数组。例如INT[]、varchar(256)[]到java集合和Collection。

public class PostgresArrayBinding implements Binding<Object, Collection> {

    @Override
    public Converter<Object, Collection> converter() {
        return new Converter<Object, Collection>() {
            @Override
            public Collection from(final Object dbObj) {
                return dbObj == null ? null : new ArrayList<>(Arrays.asList((Object[])dbObj));
            }

            @Override
            public Object to(final Collection userObject) {
                return userObject == null ? null : "ARRAY[" + Joiner.on(',').join(userObject) + "]";
            }

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

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

    @Override
    public void sql(final BindingSQLContext<Collection> ctx) throws SQLException {
        ctx.render().visit(DSL.val(ctx.convert(converter()).value())).sql("::ARRAY");
    }

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

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

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

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

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

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

<configuration>
...
<generator>
    <database>
        <name>org.jooq.util.postgres.PostgresDatabase</name>
        <includes>.*</includes>
        <excludes>schema_version</excludes>
        <inputSchema>public</inputSchema>            
        <customTypes>
            ...
            <customType>
                <name>ARRAY</name>
                <type>java.util.Collection</type>
                <binding>ru.fabit.contingent.configuration.persistence.PostgresArrayBinding</binding>
            </customType>                
        </customTypes>

        <forcedTypes>
            ...
            <forcedType>
                <name>ARRAY</name>
                <expression>.*_ARRAY</expression>
                <types>.*</types>
            </forcedType>                
        </forcedTypes>
    </database>
    <generate>
        <records>true</records>
        <interfaces>true</interfaces>
        <relations>true</relations>
        <validationAnnotations>true</validationAnnotations>
    </generate>
    <target>
        <packageName>ru.fabit.contingent.models.generated</packageName>
        <directory>src/main/java/</directory>
    </target>
</generator>
</configuration>

SQL：

创建表array_tests(string_array varchar(256)[])；

我在生成的类中出错：

public final TableField<ArrayTestsRecord, Collection[]> STRING_ARRAY = createField("string_array", org.jooq.impl.DefaultDataType.getDefaultDataType("java.util.Collection").getArrayDataType(), this, "", new PostgresArrayBinding());

Answer 1

这是由于代码生成器中的一个bug，该bug在jOOQ 3.8中得到了修复:https://github.com/jOOQ/jOOQ/issues/4388

对于Jooq3.7或更低版本，除了手动修补错误生成的代码之外，恐怕没有任何解决办法。