SpringMVC+Hibernate3+CXF整合详细实例

package com.tj.hibernate; import java.io.Serializable; import java.sql.Connection; import java.sql.DatabaseMetaData; import java.sql.ResultSet; import java.sql.ResultSetMetaData; import java.sql.SQLException; import java.sql.Statement; import java.util.ArrayList; import java.util.List; import java.util.Map; import javax.annotation.Resource; import org.apache.log4j.Logger; import org.hibernate.HibernateException; import org.hibernate.Query; import org.hibernate.SQLQuery; import org.hibernate.ScrollableResults; import org.hibernate.Session; import org.hibernate.SessionFactory; import org.hibernate.transform.Transformers; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.orm.hibernate3.HibernateCallback; import org.springframework.orm.hibernate3.HibernateTemplate; import org.springframework.orm.hibernate3.support.HibernateDaoSupport; import org.springframework.stereotype.Component; import com.tj.page.Page; /** * DAO操作基类 本DAO层实现了通用的数据操作 * * @param <T> POJO实体对象 * @param <ID> ID */ public class BaseHibernateDAOImpl<T> extends HibernateDaoSupport implements BaseHibernateDAO<T> { private static final Logger logger = Logger.getLogger(BaseHibernateDAOImpl.class); @Resource(name="sessionFactory") public void setSessionFactoryOverride(SessionFactory sessionFactory){ super.setSessionFactory(sessionFactory); } /** @SuppressWarnings("unused") private Class<T> clazz; @SuppressWarnings("unchecked") public BaseHibernateDAOImpl() { //通过反射获取T的类型信息实例 this.clazz = (Class<T>)((ParameterizedType)this.getClass().getGenericSuperclass()) .getActualTypeArguments()[0]; } **/ /** * 保存指定实体类 * * @param entityobj * 实体类 */ public void save(T entity) { try { getHibernateTemplate().save(entity); } catch (RuntimeException e) { logger.error("保存实体异常", e); throw e; } } /** * 更新指定实体类 * * @param entityobj 实体类 */ public void update(T entity) { try { getHibernateTemplate().update(entity); } catch (RuntimeException e) { logger.error("更新实体异常", e); throw e; } } /** * 根据HQL更新数据 * * @param hqlUpdate HQL更新语句 * @param values HQL查询值数组 */ public void update(final String hqlUpdate, final Object[] values) { try { getHibernateTemplate().execute(new HibernateCallback() { public Object doInHibernate(Session session) throws HibernateException, SQLException { Query query = session.createQuery(hqlUpdate); if (values != null) { for (int i = 0; i < values.length; i++) { query.setParameter(i, values[i]); } } return query.executeUpdate(); } }); } catch (RuntimeException e) { logger.error("更新实体异常", e); throw e; } } /** * 更新或保存指定实体 * * @param entity 实体类 */ public void saveOrUpdate(T entity) { try { getHibernateTemplate().saveOrUpdate(entity); } catch (RuntimeException e) { logger.error("更新或保存实体异常", e); throw e; } } /** * 更新或保存指定实体 * * @param entity 实体类 */ public void saveOrUpdate(List<T> list) throws Exception { if (list == null || list.size() == 0) { return; } Session session = this.getSession(); for (int i = 0; i < list.size(); i++) { session.saveOrUpdate(list.get(i)); if (i % 20 == 0) {//flush数 session.flush(); session.clear(); } } } /** * 删除指定实体 * * @param entityobj 实体类 */ public void delete(T entity) { try { getHibernateTemplate().delete(entity); } catch (RuntimeException e) { logger.error("删除实体异常", e); throw e; } } /** * 加载指定ID实体类对象 * * @param entityClass 实体Class * @param id 实体ID * @return 实体对象 */ @SuppressWarnings("unchecked") public T load(Class<T> entityClass, Long id) { try { return (T) getHibernateTemplate().get(entityClass, id); } catch (RuntimeException e) { logger.error("加载指定ID实体类异常，ID：" + id, e); throw e; } } /** * 根据hsql查找指定条件的List * * @param hsql hsql语句 * @param id 实体ID * @return 实体对象 */ @SuppressWarnings("unchecked") public List<T> find(final String hsql, final Object[] parms) { try { return getHibernateTemplate().executeFind(new HibernateCallback() { public Object doInHibernate(Session s) throws HibernateException, SQLException { Query query = s.createQuery(hsql); if (parms != null) { for (int i = 0; i < parms.length; i++) { query.setParameter(i, parms[i]); } } return query.list(); } }); } catch (RuntimeException e) { logger.error("查找指定条件实体异常：" + hsql, e); throw e; } } @SuppressWarnings("unchecked") public List<T> find(final String hsql, final List<Object> parms) { try { return getHibernateTemplate().executeFind(new HibernateCallback() { public Object doInHibernate(Session s) throws HibernateException, SQLException { Query query = s.createQuery(hsql); if (parms != null) { for (int i = 0; i < parms.size(); i++) { query.setParameter(i, parms.get(i)); } } return query.list(); } }); } catch (RuntimeException e) { logger.error("查找指定条件实体异常：" + hsql, e); throw e; } } /** * 查找实体所有对象 * * @param entityClass 实体Class * @return 实体对象List */ @SuppressWarnings("unchecked") public List<T> findAll(Class<T> entityClass) { try { return getHibernateTemplate().loadAll(entityClass); } catch (RuntimeException e) { logger.error("查找实体所有对象异常：" + entityClass, e); throw e; } } /** * 查找指定ID实体类对象 * @param entityClass 实体Class * @param id 实体ID * @return 实体对象 */ @SuppressWarnings("unchecked") public T findById(Class<T> entityClass, Long id) { try { return (T) getHibernateTemplate().get(entityClass, id); } catch (RuntimeException e) { try { return (T) getHibernateTemplate().get(entityClass, id.toString()); } catch (RuntimeException e1) { logger.error("查找指定ID实体异常，ID：" + id, e1); throw e; } } } @SuppressWarnings("unchecked") public T findById(Class<T> entityClass, String id) { try { return (T) getHibernateTemplate().get(entityClass, id); } catch (RuntimeException e) { try { return (T) getHibernateTemplate().get(entityClass, id.toString()); } catch (RuntimeException e1) { logger.error("查找指定ID实体异常，ID：" + id, e1); throw e; } } } /** * 查找指定属性的实体集合 * @param entityClass 实体 * @param propertyName 属性名 * @param value 条件 * @return 实体集合 */ @SuppressWarnings("unchecked") public List<T> findByProperty(Class<T> entityClass, String propertyName, Object value) { try { String queryStr = "from " + entityClass.getName() + " as model where model." + propertyName + "=?"; return getHibernateTemplate().find(queryStr, value); } catch (RuntimeException e) { logger.error("查找指定条件实体集合异常，条件：" + propertyName, e); throw e; } } /** * 分页查询入口 * @param countSql 总记录sql * @param listSql 当前页记录sql * @param Page 分页对象 * @return 返回 当前页需要显示List */ @SuppressWarnings("unchecked") public List<T