Hibernate反射DAO模式（二）

通过这些复杂的过程，我们可以获取反射序列化的具体Class实例类型，这样就可以通过该Class实例来获取具体查询的结果集合。

因此实现类的代码大致如下：

public class GenericHibernateDaoextends Serializable,ID extends Serializable>

extends HibernateDaoSupport implements IGenericDao {

Class persistentClass;

public GenericHibernateDao() {

this.persistentClass=(Class) ((ParameterizedType)getClass().getGenericSuperclass()).getActualTypeArguments()[0];

}

public Class getPersistentClass() {

return persistentClass;

}

public void setPersistentClass(Class persistentClass) {

this.persistentClass = persistentClass;

}

@Override

public T create(T entity) {

return (T) this.getHibernateTemplate().save(entity);

}

@Override

public void delete(ID id) {

System.out.println("IDD "+id);

this.getHibernateTemplate().delete(this.findById(id));

}

@Override

public void update(T entity) {

this.getHibernateTemplate().update(entity);

}

@Override

public T findById(ID id) {

return this.getHibernateTemplate().get(persistentClass, id);

}

@Override

public List findAll() {

return this.getHibernateTemplate().loadAll(persistentClass);

}

@Override

public List findByObject(String hql, Object[] param) {

return this.getHibernateTemplate().find(hql, param);

}

@Override

public PageBean findByPageBean(final String hql,final Object[] param,final int currentpage,final int pageSize) {

return this.getHibernateTemplate().execute(new HibernateCallback() {

@Override

public PageBean doInHibernate(Session session)throws HibernateException, SQLException {

PageBean pb=new PageBean();

Query qu=session.createQuery(hql);

if(param.length>0){

for (int i = 0; i < param.length; i++) {

qu.setParameter(i, param);

}

}

qu.setFirstResult((currentpage-1)*pageSize);

qu.setMaxResults(pageSize);

pb.setData(qu.list());

qu=session.createQuery("select count(*) "+hql.substring(hql.toLowerCase().indexOf("from")));

if(param.length>0){

for (int j = 0; j < param.length; j++) {

qu.setParameter(j, param[j]);

}

}

pb.setTotalRows(Integer.parseInt(qu.uniqueResult().toString()));

pb.setCurrentPage(currentpage);

pb.setPageSize(pageSize);

return pb;

}

});

}

@Override

public void bulkUpdate(String bulk, Object[] param) {

this.getHibernateTemplate().bulkUpdate(bulk,param);

}

@Override

public Integer countByObject(final String hql,final Object[] param) {

return this.getHibernateTemplate().execute(new HibernateCallback() {

@Override

public Integer doInHibernate(Session session)throws HibernateException, SQLException {

Query qu=session.createQuery(hql);

for (int i = 0; i < param.length; i++) {

qu.setParameter(i, param);