Hibernate UserType for Oracle TABLE OF NUMBERS. OracleNativeExtractor can be found here: https://community.jboss.org/wiki/MappingOracleXmlTypeToDocument . Replace the string YOUR_CUSTOM_ARRAY_TYPE with your name.
import oracle.sql.ARRAY; import oracle.sql.ArrayDescriptor; import org.apache.commons.lang.ArrayUtils; import org.hibernate.HibernateException; import org.hibernate.usertype.UserType; import java.io.Serializable; import java.sql.*; import java.util.ArrayList; import java.util.Arrays; import java.util.List; public class ArrayUserType implements UserType, Serializable { private static final OracleNativeExtractor EXTRACTOR = new OracleNativeExtractor(); @Override public int[] sqlTypes() { return new int[]{Types.ARRAY}; } @Override public Class returnedClass() { return List.class; } @Override public boolean equals(Object x, Object y) throws HibernateException { if (x == null && y == null) return true; else if (x == null && y != null) return false; else return x.equals(y); } @Override public int hashCode(Object x) throws HibernateException { return x.hashCode(); } @Override public Object nullSafeGet(ResultSet rs, String[] names, Object owner) throws HibernateException, SQLException { return Arrays.asList(ArrayUtils.toObject(((ARRAY) rs.getObject(names[0])).getLongArray())); } @Override public void nullSafeSet(PreparedStatement st, Object value, int index) throws HibernateException, SQLException { ARRAY array = null; if (value != null) { Connection nativeConn = EXTRACTOR.getNativeConnection(st.getConnection()); ArrayDescriptor descriptor = ArrayDescriptor.createDescriptor("YOUR_CUSTOM_ARRAY_TYPE", nativeConn); array = new ARRAY(descriptor, nativeConn, ((List<Long>) value).toArray(new Long[]{})); } st.setObject(1, array); } @Override public Object deepCopy(Object value) throws HibernateException { if (value == null) return null; return new ArrayList<Long>((List<Long>) value); } @Override public boolean isMutable() { return false; } public Object assemble(Serializable _cached, Object _owner) throws HibernateException { return _cached; } public Serializable disassemble(Object _obj) throws HibernateException { return (Serializable) _obj; } @Override public Object replace(Object original, Object target, Object owner) throws HibernateException { return deepCopy(original); } }
source share