假设我有一个这样的 postgres 表:

CREATE TABLE sal_emp (
    name            text,
    pay_by_quarter  integer[],
    schedule        text[][]
);

我什至可以使用 Spring Data 插入列 pay_by_quarter 或 schedule 吗？如果可能的话，这看起来如何作为 Repository 和 Entity ？我一直无法找到解决此问题的任何文档或示例，可能是因为它如何与更常见的用例重叠，以一对多关系插入多个表。说到这里，我完全打算使用 Postgresql array 数据类型，而不使用关系表。

最佳答案

您需要创建自己的类型并实现 UserType interface .立足于下response我写了一个通用的 UserType在所有数组中使用并且它有效，但您必须使用非原始数据类型(整数、长整型、字符串...)。否则请参阅上面的更新 Boolean类型。

public class GenericArrayUserType<T extends Serializable> implements UserType {

    protected static final int[] SQL_TYPES = { Types.ARRAY };
    private  Class<T> typeParameterClass;

    @Override
    public Object assemble(Serializable cached, Object owner) throws HibernateException {
        return this.deepCopy(cached);
    }

    @Override
    public Object deepCopy(Object value) throws HibernateException {
        return value;
    }

    @SuppressWarnings("unchecked")
    @Override
    public Serializable disassemble(Object value) throws HibernateException {
        return (T) this.deepCopy(value);
    }

    @Override
    public boolean equals(Object x, Object y) throws HibernateException {

        if (x == null) {
            return y == null;
        }
        return x.equals(y);
    }

    @Override
    public int hashCode(Object x) throws HibernateException {
        return x.hashCode();
    }

    @Override
    public boolean isMutable() {
        return true;
    }

    @Override
    public Object nullSafeGet(ResultSet resultSet, String[] names, SessionImplementor session, Object owner)
            throws HibernateException, SQLException {
        if (resultSet.wasNull()) {
            return null;
        }
        if (resultSet.getArray(names[0]) == null) {
            return new Integer[0];
        }

        Array array = resultSet.getArray(names[0]);
        @SuppressWarnings("unchecked")
        T javaArray = (T) array.getArray();
        return javaArray;
    }

    @Override
    public void nullSafeSet(PreparedStatement statement, Object value, int index, SessionImplementor session)
            throws HibernateException, SQLException {
        Connection connection = statement.getConnection();
        if (value == null) {
            statement.setNull(index, SQL_TYPES[0]);
        } else {
            @SuppressWarnings("unchecked")
            T castObject = (T) value;
            Array array = connection.createArrayOf("integer", (Object[]) castObject);
            statement.setArray(index, array);
        }
    }

    @Override
    public Object replace(Object original, Object target, Object owner) throws HibernateException {
        return original;
    }

    @Override
    public Class<T> returnedClass() {
        return typeParameterClass;
    }

    @Override
    public int[] sqlTypes() {
        return new int[] { Types.ARRAY };
    }


}

那么数组属性将是具有相同维度的相同类型的数据库:

• integer[] -> Integer[]
• text[][] -> String[][]

在这种特殊情况下，输入 GenericType属性之上的类

@Type(type = "packageofclass.GenericArrayUserType")

那么您的实体将是:

@Entity
@Table(name="sal_emp")
public class SalEmp {

    @Id
    private String name;

    @Column(name="pay_by_quarter")
    @Type(type = "packageofclass.GenericArrayUserType")
    private Integer[] payByQuarter;

    @Column(name="schedule")
    @Type(type = "packageofclass.GenericArrayUserType")
    private String[][] schedule;

    //Getters, Setters, ToString, equals, and so on

}

如果您不想使用此通用 UserType Integer[]键入并写入 String[][]类型。您需要编写自己的类型，在您的情况下将如下所示:

• 整数[]

  public class IntArrayUserType implements UserType {
  
  protected static final int[] SQL_TYPES = { Types.ARRAY };
  
  @Override
  public Object assemble(Serializable cached, Object owner) throws HibernateException {
      return this.deepCopy(cached);
  }
  
  @Override
  public Object deepCopy(Object value) throws HibernateException {
      return value;
  }
  
  @Override
  public Serializable disassemble(Object value) throws HibernateException {
      return (Integer[]) this.deepCopy(value);
  }
  
  @Override
  public boolean equals(Object x, Object y) throws HibernateException {
  
      if (x == null) {
          return y == null;
      }
      return x.equals(y);
  }
  
  @Override
  public int hashCode(Object x) throws HibernateException {
      return x.hashCode();
  }
  
  @Override
  public boolean isMutable() {
      return true;
  }
  
  @Override
  public Object nullSafeGet(ResultSet resultSet, String[] names, SessionImplementor session, Object owner)
          throws HibernateException, SQLException {
      if (resultSet.wasNull()) {
          return null;
      }
      if (resultSet.getArray(names[0]) == null) {
          return new Integer[0];
      }
  
      Array array = resultSet.getArray(names[0]);
      Integer[] javaArray = (Integer[]) array.getArray();
      return javaArray;
  }
  
  @Override
  public void nullSafeSet(PreparedStatement statement, Object value, int index, SessionImplementor session)
          throws HibernateException, SQLException {
      Connection connection = statement.getConnection();
      if (value == null) {
          statement.setNull(index, SQL_TYPES[0]);
      } else {
          Integer[] castObject = (Integer[]) value;
          Array array = connection.createArrayOf("integer", castObject);
          statement.setArray(index, array);
      }
  }
  
  @Override
  public Object replace(Object original, Object target, Object owner) throws HibernateException {
      return original;
  }
  
  @Override
  public Class<Integer[]> returnedClass() {
      return Integer[].class;
  }
  
  @Override
  public int[] sqlTypes() {
      return new int[] { Types.ARRAY };
  }
  }
  

• 文字[][]

  public class StringMultidimensionalArrayType implements UserType {
  
  protected static final int[] SQL_TYPES = { Types.ARRAY };
  
  @Override
  public Object assemble(Serializable cached, Object owner) throws HibernateException {
      return this.deepCopy(cached);
  }
  
  @Override
  public Object deepCopy(Object value) throws HibernateException {
      return value;
  }
  
  @Override
  public Serializable disassemble(Object value) throws HibernateException {
      return (String[][]) this.deepCopy(value);
  }
  
  @Override
  public boolean equals(Object x, Object y) throws HibernateException {
  
      if (x == null) {
          return y == null;
      }
      return x.equals(y);
  }
  
  @Override
  public int hashCode(Object x) throws HibernateException {
      return x.hashCode();
  }
  
  @Override
  public boolean isMutable() {
      return true;
  }
  
  @Override
  public Object nullSafeGet(ResultSet resultSet, String[] names, SessionImplementor session, Object owner)
          throws HibernateException, SQLException {
      if (resultSet.wasNull()) {
          return null;
      }
      if (resultSet.getArray(names[0]) == null) {
          return new String[0][];
      }
  
      Array array = resultSet.getArray(names[0]);
      String[][] javaArray = (String[][]) array.getArray();
      return javaArray;
  }
  
  @Override
  public void nullSafeSet(PreparedStatement statement, Object value, int index, SessionImplementor session)
          throws HibernateException, SQLException {
      Connection connection = statement.getConnection();
      if (value == null) {
          statement.setNull(index, SQL_TYPES[0]);
      } else {
          String[][] castObject = (String[][]) value;
          Array array = connection.createArrayOf("integer", castObject);
          statement.setArray(index, array);
      }
  }
  
  @Override
  public Object replace(Object original, Object target, Object owner) throws HibernateException {
      return original;
  }
  
  @Override
  public Class<String[][]> returnedClass() {
      return String[][].class;
  }
  
  @Override
  public int[] sqlTypes() {
      return new int[] { Types.ARRAY };
  }
  
  }
  

在这种情况下，您的属性具有不同的类型:

@Column(name="pay_by_quarter")
@Type(type = "packageofclass.IntArrayUserType")
private Integer[] payByQuarter;

@Column(name="schedule")
@Type(type = "packageofclass.StringMultidimensionalArrayType")
private String[][] schedule;

更新 hibernate 用户类型

使用 boolean 值或 boolean 值似乎不适用于 GenericArrayUserType ，因此可以在您的 CREATE DDL 中创建解决方案申报boolean类型 bytea :

CREATE TABLE sal_emp (
    name text,
    pay_by_quarter  integer[],
    schedule        text[][],
    wow_boolean     bytea
    );

你的属性(property)没有任何类型:

private boolean[][][] wowBoolean;

它在没有任何 Type 的情况下解析得很好或 Converter .输出:wowBoolean=[[[true, false], [true, false]], [[true, true], [true, true]]])

更新为 @Converter的 JPA 2.1

我尝试了一个选项 @Converter JPA 2.1 与 EclipseLink和 Hibernate .我刚试过 integer[] (不是 text[][] )Converter像这样(*我已将属性更改为 List<Integer> 但没关系):

@Converter
public class ConverterListInteger implements AttributeConverter<List<Integer>, Array>{

    @Override
    public Array convertToDatabaseColumn(List<Integer> attribute) {
        DataSource source = ApplicationContextHolder.getContext().getBean(DataSource.class);

        try {
            Connection conn = source.getConnection();
            Array array = conn.createArrayOf("integer", attribute.toArray());
            return  array;

        } catch (SQLException e) {
            e.printStackTrace();
        }

        return null;

    }

    @Override
    public List<Integer> convertToEntityAttribute(Array dbData) {
        List<Integer> list = new ArrayList<>();

        try {
            for(Object object : (Object[]) dbData.getArray()){
                list.add((Integer) object);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }

        return list;

    }

}

然后，将转换器添加到实体中的属性:

@Convert(converter=ConverterListInteger.class)
private List<Integer> pay_by_quarter;

所以解决方案基于JPA specification不起作用。为什么？ Hibernate 不支持数据库数组(java.sql.Array)....

然后我尝试使用 EclipseLink(查看如何配置 here)并且它有效，但并非总是如此......似乎有一个错误，它第一次运行良好但下次无法更新或查询此行。然后我就成功添加了新行，但是之后无法更新或查询....

结论

目前，JPA 似乎不支持供应商正确...只有Hibernate的解决方案UserType效果很好，但它只适用于 Hibernate .

关于java - 如何使用 Spring Data/JPA 插入到 Postgres 数组类型的列中？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/39119164/