I have created a customer user type for resolving this issue. The user type selects the next sequence number from the database and sets it into the statement. The database row gets inserted as needed with the right sequence number. But when I look at the attrbutes of the customer object on the java side after the transaction commit, the sequence attribute does not have the right value in it. Do I need to so something special to get the generated sequence synched up with the actual java object after the insert ?
Hibernate Mapping File :
<hibernate-mapping>
<class name="com.wf.model.vo.MPCustomerVO" table="MP_CUSTOMER">
<id name="UUID" type="string">
<column name="CUSTOMER_ID" length="32" />
<generator class="uuid" />
</id>
<timestamp name="lastUpdated" column="LAST_UPDATED" generated="never"/>
<property name="identity" column="CUSTOMER_IID" update="false" insert="true" unique="true" not-null="true">
<type name="com.wf.dao.hibernate.OracleSequenceGeneratorType">
<param name="sequence-name">MP_CUSTOMER_SEQ</param>
</type>
</property>
</hibernate-mapping>
OracleSequenceGeneratorType class code :
package com.wf.dao.hibernate;
import java.io.Serializable;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Types;
import java.util.Properties;
import org.apache.log4j.Logger;
import org.hibernate.HibernateException;
import org.hibernate.usertype.ParameterizedType;
import org.hibernate.usertype.UserType;
public class OracleSequenceGeneratorType implements UserType, ParameterizedType, Serializable {
Long defaultValue = new Long(0);
private String sequenceName;
Logger _log = Logger.getLogger(OracleSequenceGeneratorType.class);
public Object assemble(Serializable cached, Object owner) throws HibernateException {
return cached;
}
public Object deepCopy(Object value) throws HibernateException {
return new Long(((Long)value).longValue());
}
public Serializable disassemble(Object value) throws HibernateException {
return (Serializable) value;
}
public boolean equals(Object x, Object y) throws HibernateException {
if (x==y) return true;
if (x==null || y==null) return false;
return x.equals(y);
}
public int hashCode(Object x) throws HibernateException {
return x.hashCode();
}
public boolean isMutable() {
return false;
}
public Object nullSafeGet(ResultSet rs, String[] names, Object owner) throws HibernateException, SQLException {
Long result = new Long(rs.getLong(names[0]));
return result == null ? null : new Long(result.longValue());
}
public void nullSafeSet(PreparedStatement st, Object value, int index) throws HibernateException, SQLException {
Connection conn = st.getConnection();
Statement sta;
ResultSet rs;
String sql = "select " + sequenceName + ".nextval from dual";
sta = conn.createStatement();
rs = sta.executeQuery(sql);
rs.next();
long nextSequence = rs.getLong(1);
rs.close();
sta.close();
_log.error("OracleSequenceGeneratorType.nullSafeSet: binding passed in variable : [" + value + "] at index [" + index + "]");
_log.error("OracleSequenceGeneratorType.nullSafeSet: Retrieved Sequence Value = [" + nextSequence + "]");
st.setLong(index, nextSequence);
}
public Object replace(Object original, Object target, Object owner) throws HibernateException {
return original;
}
public Class returnedClass() {
return long.class;
}
public int[] sqlTypes() {
return new int[] {Types.INTEGER};
}
public void setParameterValues(Properties parameters) {
sequenceName= (String) parameters.get("sequence-name");
_log.error("Recevied Parameter Name : 'sequence-name' = [" + sequenceName + "]");
}
}
Test Code which fails to get the sequence attribute on java side after the transaction commit :
Session session = HibernateUtil.getSessionFactory().getCurrentSession();
Assert.assertNotNull("Expected hibernate session to be not null", session);
Transaction tx = session.beginTransaction();
Assert.assertTrue("Expected hibernate transaction to be active", tx.isActive());
MPCustomerDAO dao = new MPCustomerDAO();
MPCustomerVO vo = new MPCustomerVO ("Test");
vo.setCustomerName("TestName");
vo.setCustomerAddress1("Address1");
vo.setCustomerAddress2("Address2");
dao.persist(vo);
tx.commit();
_log.error("CustomerVO.uuid = [" + vo.getUUID() + "]");
_log.error("CustomerVO.identity = [" + vo.getIdentity() + "]"); <<<<<<< Fails : Does not have the correct sequence number >>>>
_log.error("CustomerVO.address1 = [" + vo.getCustomerAddress1() + "]");
_log.error("CustomerVO.address1 = [" + vo.getCustomerAddress2() + "]");
_log.error("CustomerVO.name = [" + vo.getCustomerName() + "]");
Login
FAQ
Search
