Spring MVC4+Hibernate4整合

package com.frame.support; import java.io.Serializable; import java.lang.reflect.ParameterizedType; import java.math.BigDecimal; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Timestamp; import java.sql.Types; import java.util.ArrayList; import java.util.Collection; import java.util.Date; import java.util.List; import org.hibernate.Query; import org.hibernate.ScrollableResults; import org.hibernate.Session; import org.hibernate.SessionFactory; import org.hibernate.jdbc.Work; import org.springframework.beans.factory.annotation.Autowired; @SuppressWarnings({ "rawtypes", "unchecked" }) public class BaseDao<T> { @Autowired private SessionFactory sessionFactory; protected Class<T> entityClass; public BaseDao() { } protected Class getEntityClass() { if (entityClass == null) { entityClass = (Class<T>) ((ParameterizedType) getClass().getGenericSuperclass()).getActualTypeArguments()[0]; } return entityClass; } /** * @return session */ public Session getSession() { //需要开启事物，才能得到CurrentSession return sessionFactory.getCurrentSession(); } /** * <保存实体> * <完整保存实体> * @param t 实体参数 * @see com.itv.launcher.util.IBaseDao#save(java.lang.Object) */ public void save(T t) { this.getSession().save(t); } /** * <保存或者更新实体> * @param t 实体 * @see com.itv.launcher.util.IBaseDao#saveOrUpdate(java.lang.Object) */ public void saveOrUpdate(T t) { this.getSession().saveOrUpdate(t); } /** * <load> * <加载实体的load方法> * @param id 实体的id * @return 查询出来的实体 * @see com.itv.launcher.util.IBaseDao#load(java.io.Serializable) */ public T load(Serializable id) { T load = (T) this.getSession().load(getEntityClass(), id); return load; } /** * <get> * <查找的get方法> * @param id 实体的id * @return 查询出来的实体 * @see com.itv.launcher.util.IBaseDao#get(java.io.Serializable) */ public T get(Serializable id) { T load = (T) this.getSession().get(getEntityClass(), id); return load; } /** * <contains> * @param t 实体 * @return 是否包含 * @see com.itv.launcher.util.IBaseDao#contains(java.lang.Object) */ public boolean contains(T t) { return this.getSession().contains(t); } /** * <delete> * <删除表中的t数据> * @param t 实体 * @see com.itv.launcher.util.IBaseDao#delete(java.lang.Object) */ public void delete(T t) { this.getSession().delete(t); } /** * <根据ID删除数据> * @param Id 实体id * @return 是否删除成功 * @see com.itv.launcher.util.IBaseDao#deleteById(java.io.Serializable) */ public boolean deleteById(Serializable Id) { System.out.println("-----------"+Id); T t = get(Id); System.out.println("======="+t); if(t == null){ return false; } delete(t); return true; } /** * <删除所有> * @param entities 实体的Collection集合 * @see com.itv.launcher.util.IBaseDao#deleteAll(java.util.Collection) */ public void deleteAll(Collection<T> entities) { for(Object entity : entities) { this.getSession().delete(entity); } } /** * <执行Hql语句> * @param hqlString hql * @param values 不定参数数组 * @see com.itv.launcher.util.IBaseDao#queryHql(java.lang.String, java.lang.Object[]) */ public void queryHql(String hqlString, Object... values) { Query query = this.getSession().createQuery(hqlString); if (values != null) { for (int i = 0; i < values.length; i++) { query.setParameter(i, values[i]); } } query.executeUpdate(); } /** * <执行Sql语句> * @param sqlString sql * @param values 不定参数数组 * @see com.itv.launcher.util.IBaseDao#querySql(java.lang.String, java.lang.Object[]) */ public void querySql(String sqlString, Object... values) { Query query = this.getSession().createSQLQuery(sqlString); if (values != null) { for (int i = 0; i < values.length; i++) { query.setParameter(i, values[i]); } } query.executeUpdate(); } /** * <根据HQL语句查找唯一实体> * @param hqlString HQL语句 * @param values 不定参数的Object数组 * @return 查询实体 * @see com.itv.launcher.util.IBaseDao#getByHQL(java.lang.String, java.lang.Object[]) */ public T getByHQL(String hqlString, Object... values) { Query query = this.getSession().createQuery(hqlString); if (values != null) { for (int i = 0; i < values.length; i++) { query.setParameter(i, values[i]); } } return (T) query.uniqueResult(); } /** * <根据SQL语句查找唯一实体> * @param sqlString SQL语句 * @param values 不定参数的Object数组 * @return 查询实体 * @see com.itv.launcher.util.IBaseDao#getBySQL(java.lang.String, java.lang.Object[]) */ public T getBySQL(String sqlString, Object... values) { Query query = this.getSession().createSQLQuery(sqlString); if (values != null) { for (int i = 0; i < values.length; i++) { query.setParameter(i, values[i]); } } return (T) query.uniqueResult(); } /** * <根据HQL语句，得到对应的list> * @param hqlString HQL语句 * @param values 不定参数的Object数组 * @return 查询多个实体的List集合 * @see com.itv.launcher.util.IBaseDao#getListByHQL(java.lang.String, java.lang.Object[]) */ public List<T> getListByHQL(String hqlString, Object... values) { Query query = this.getSession().createQuery(hqlString); if (values != null) { for (int i = 0; i < values.length; i++) { query.setParameter(i, values[i]); } } return query.list(); } /** * <根据SQL语句，得到对应的list> * @param sqlString HQL语句 * @param values 不定参数的Object数组 * @return 查询多个实体的List集合 * @see com.itv.launcher.util.IBaseDao#getListBySQL(java.lang.String, java.lang.Object[]) */ public List<T> getListBySQL(String sqlString, Object... values ) { Query query = this.getSession().createSQLQuery(sqlString); if (values != null) { for (int i = 0; i < values.length; i++) { query.setParameter(i, values[i]); } } return query.list(); } /** * 由sql语句得到List * @param sql * @param map * @param values * @return List * @see com.itv.launcher.util.IBaseDao#findListBySql(java.lang.String, com.itv.launcher.util.RowMapper, java.lang.Object[]) */ public List findListBySql(final String sql, final RowMapper map, final Object... values) { final List list = new ArrayList(); // 执行JDBC的数据批量保存 Work jdbcWork = new Work()