简单讲述Hibernate实例
在向大家详细介绍Hibernate实例之前,首先让大家了解下Hibernate提供了多种生成主键的方式,然后全面介绍Hibernate实例。
Hibernate(目前使用的版本是3.2)中提供了多种生成主键的方式。然而当前的这么多种生成方式未必能满足我们的要求。比如increment,可以在一个Hibernate实例的应用上很方便的时候,但是在集群的时候就不行了。再如 identity ,sequence ,native 是数据局提供的主键生成方式,往往也不是我们需要,而且在程序跨数据库方面也体现出不足。还有基于算法的生成方式生成出来的主键基本都是字符串的。
我们现在需要一种生成方式:使用Long作为主键类型,自动增,支持集群。那么我们需要自定义一个我们的主键生成器才能实现了。
Hibernate实例代码:
package hibernate; import java.io.Serializable; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.Properties; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.hibernate.HibernateException; import org.hibernate.MappingException; import org.hibernate.dialect.Dialect; import org.hibernate.engine.SessionImplementor; import org.hibernate.id.Configurable; import org.hibernate.id.IdentifierGenerator; import org.hibernate.id.PersistentIdentifierGenerator; import org.hibernate.type.Type; public class IncrementGenerator implements IdentifierGenerator, Configurable { private static final Log log = LogFactory.getLog(IncrementGenerator.class); private Long next; private String sql; public Serializable generate(SessionImplementor session, Object object) throws HibernateException { if (sql!=null) { getNext( session.connection() ); } return next; } public void configure(Type type, Properties params, Dialect d) throws MappingException { String table = params.getProperty("table"); if (table==null) table = params. getProperty(PersistentIdentifierGenerator.TABLE); String column = params.getProperty("column"); if (column==null) column = params. getProperty(PersistentIdentifierGenerator.PK); String schema = params.getProperty (PersistentIdentifierGenerator.SCHEMA); sql = "select max("+column +") from " + ( schema==null ? table : schema + '.' + table ); log.info(sql); } private void getNext(Connection conn) throws HibernateException { try { PreparedStatement st = conn.prepareStatement(sql); ResultSet rs = st.executeQuery(); if ( rs.next() ) { next = rs.getLong(1) + 1; } else { next = 1l; } }catch(SQLException e) { throw new HibernateException(e); } finally { try{ conn.close(); }catch(SQLException e) { throw new HibernateException(e); } } } }