springMVC4.0.6+spring4.0.6+hibernate4.3.6

package com.itv.weixin.dao.impl; 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; import com.itv.weixin.dao.IBaseDao; import com.itv.weixin.util.PageResults; import com.itv.weixin.util.RowMapper; /** * @ClassName: BaseDao * @Description: baseDao实现 * @author yz * */ @SuppressWarnings({ "rawtypes", "unchecked" }) public class BaseDao<T, ID extends Serializable> implements IBaseDao<T, ID> { @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; } /** * <保存实体> * <完整保存实体> * @param t 实体参数 * @see com.itv.launcher.util.IBaseDao#save(java.lang.Object) */ @Override public void save(T t) { this.getSession().save(t); } /** * <保存或�?更新实体> * @param t 实体 * @see com.itv.launcher.util.IBaseDao#saveOrUpdate(java.lang.Object) */ @Override 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) */ @Override public T load(ID 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) */ @Override public T get(ID 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) */ @Override public boolean contains(T t) { return this.getSession().contains(t); } /** * <delete> * <删除表中的t数据> * @param t 实体 * @see com.itv.launcher.util.IBaseDao#delete(java.lang.Object) */ @Override public void delete(T t) { this.getSession().delete(t); } /** * <根据ID删除数据> * @param Id 实体id * @return 是否删除成功 * @see com.itv.launcher.util.IBaseDao#deleteById(java.io.Serializable) */ @Override public boolean deleteById(ID Id) { T t = get(Id); if(t == null){ return false; } delete(t); return true; } /** * <删除�?��> * @param entities 实体的Collection集合 * @see com.itv.launcher.util.IBaseDao#deleteAll(java.util.Collection) */ @Override 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[]) */ @Override 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[]) */ @Override 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[]) */ @Override 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[]) */ @Override 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[]) */ @Override 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[]) */ @Override 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[]) */ @Override public List findListBySql(final String sql, final RowMapper map, final Object... values) { final List list = new ArrayList(); // 执行JDBC的数据批量保�? Work jdbcWork = new Work() { public void execute(Connection connection) throws SQLException { PreparedStatement ps = null; ResultSet rs = null; try { ps = connection.prepareStatement(sql); for (int i = 0; i < values.length; i++) { setParameter(ps, i, values[i]); } rs = ps.execute