Hibernate，Postgres和Array Type

我在使用hibernate 4.1.0映射的postgresql 9.3中使用数组类型时遇到了一个特定的问题。 这种类型允许我拥有非常强大的数据模型，而无需构建大量的表和连接。

为了映射使用此特定类型存储的字段，我使用了UserType

无论如何，它适用于纯hibernate（hql），但我还需要将sql本机查询发送到我的数据库。 当我这样做时，尽管尝试了很多次，但我还没有找到任何办法。

我尝试了很多基于此的语法

String[] values = {"value1", "value2"}; String queryString = "SELECT * FROM instances WHERE values && :values"; Query query = this.getSession().createSQLQuery(queryString).addEntity(Instance.class); query.setParameterList("values", values); query.list(); 

我得到的运算符不存在：text [] &&字符变化

它应该在jdbc中给出以下语法：[‘value1’，’value2’]并且它似乎给’value1’…

我试过很多语法

• 采集
• 纯arrays
• [：values]语法：我在“[”附近出现语法错误

---

我需要发送本机查询，因为我使用Materialized View来提高性能。

我的SQL查询在postgresql控制台中有效。 所以这是一个特定于hibernate的问题。

Answer 1

我尝试了几个基于JDBC4引入的Array Type的版本： 如何将String []参数设置为本机查询？ 。 问题也是Hibernate（即使在最新版本4.3.1.final）也无法使用这个新function，并给了我以下错误消息

 Could not determine a type for class: org.postgresql.jdbc4.Jdbc4Array 

所以我不得不制作一个特定的UserType（基于stackoverflow中的几篇文章和其他来源）

我的模特

 @Type(type = "fr.mycompany.dao.hibernate.types.ArrayUserType") private String[] values; 

我的ArrayUserType

 public class ArrayUserType implements UserType { /** Constante contenant le type SQL "Array". */ protected static final int[] SQL_TYPES = { Types.ARRAY }; /** * Return the SQL type codes for the columns mapped by this type. The * codes are defined on java.sql.Types. * * @return int[] the typecodes * @see java.sql.Types */ public final int[] sqlTypes() { return SQL_TYPES; } /** * The class returned by nullSafeGet(). * * @return Class */ public final Class returnedClass() { return String[].class; } /** * Retrieve an instance of the mapped class from a JDBC resultset. Implementors * should handle possibility of null values. * * @param resultSet a JDBC result set. * @param names the column names. * @param session SQL en cours. * @param owner the containing entity * @return Object * @throws org.hibernate.HibernateException exception levée par Hibernate * lors de la récupération des données. * @throws java.sql.SQLException exception SQL * levées lors de la récupération des données. */ @Override public final Object nullSafeGet( final ResultSet resultSet, final String[] names, final SessionImplementor session, final Object owner) throws HibernateException, SQLException { if (resultSet.wasNull()) { return null; } String[] array = (String[]) resultSet.getArray(names[0]).getArray(); return array; } /** * Write an instance of the mapped class to a prepared statement. Implementors * should handle possibility of null values. A multi-column type should be written * to parameters starting from index. * * @param statement a JDBC prepared statement. * @param value the object to write * @param index statement parameter index * @param session sql en cours * @throws org.hibernate.HibernateException exception levée par Hibernate * lors de la récupération des données. * @throws java.sql.SQLException exception SQL * levées lors de la récupération des données. */ @Override public final void nullSafeSet(final PreparedStatement statement, final Object value, final int index, final SessionImplementor session) throws HibernateException, SQLException { if (value == null) { statement.setNull(index, SQL_TYPES[0]); } else { String[] castObject = (String[]) value; Array array = session.connection().createArrayOf("text", castObject); statement.setArray(index, array); } } @Override public final Object deepCopy(final Object value) throws HibernateException { return value; } @Override public final boolean isMutable() { return false; } @Override public final Object assemble(final Serializable arg0, final Object arg1) throws HibernateException { // TODO Auto-generated method stub return null; } @Override public final Serializable disassemble(final Object arg0) throws HibernateException { // TODO Auto-generated method stub return null; } @Override public final boolean equals(final Object x, final Object y) throws HibernateException { if (x == y) { return true; } else if (x == null || y == null) { return false; } else { return x.equals(y); } } @Override public final int hashCode(final Object x) throws HibernateException { return x.hashCode(); } @Override public final Object replace( final Object original, final Object target, final Object owner) throws HibernateException { return original; } 

}

最后，但最少（这是我错过的）：当我需要运行SQL Native Query时，我必须使用以下语法强制参数类型

 String[] values = ... Type arrayType = new CustomType(new ArrayUserType()); query.setParameter("value", values, arrayType);