我在使用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’…
我尝试了许多语法
我需要发送本机查询,因为我使用实例化视图来提高性能。
我的SQL查询可在postgresql控制台中使用。因此,这是一个特定于hibernate的问题。
我尝试了几种基于JDBC4引入的数组类型的版本:如何为本地查询设置String []参数?。问题也是hibernate(即使在最新版本4.3.1.final中)也无法使用此新功能,并给了我以下错误消息
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
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 <tt>java.sql.Types</tt>. * * @return int[] the typecodes * @see java.sql.Types */ public final int[] sqlTypes() { return SQL_TYPES; } /** * The class returned by <tt>nullSafeGet()</tt>. * * @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 <tt>index</tt>. * * @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);