springmvc整合spring、hibernate

package com.tgb.service.base.impl; import java.io.Serializable; import java.util.LinkedHashMap; import java.util.Map; import javax.annotation.Resource; import org.hibernate.Query; import org.hibernate.SessionFactory; import org.hibernate.persister.entity.AbstractEntityPersister; import org.springframework.transaction.annotation.Propagation; import org.springframework.transaction.annotation.Transactional; import com.tgb.service.base.HibernateService; import com.tgb.utils.QueryResult; import com.tgb.utils.ReflectManager; @SuppressWarnings({"unchecked","hiding"}) public abstract class HibernateServiceImpl<T,PK extends Serializable> implements HibernateService<T,PK> { private LinkedHashMap<String,Object> temp=new LinkedHashMap<String,Object>(); @Transactional(propagation=Propagation.REQUIRED) public <T extends Serializable> PK save(T entity) { PK pk=null; pk=(PK)sessionFactory.getCurrentSession().save(entity); return pk; } @Transactional(propagation=Propagation.REQUIRED) public <T extends Serializable> void update(T entity) { // sessionFactory.getCurrentSession().update(entity); sessionFactory.getCurrentSession().saveOrUpdate(entity); } private <T extends Serializable> String getUpdateStr(LinkedHashMap<String,T> update) { StringBuilder updateStr=new StringBuilder(); int i=1; for(Map.Entry<String,T> entry:update.entrySet()) { updateStr.append(entry.getKey()).append("=").append(":u").append(i).append(","); this.temp.put("u"+i, entry.getValue()); i++; } updateStr.deleteCharAt(updateStr.length()-1); return updateStr.toString(); } /* * 设置update的set参数 * */ private void setUpdateParameter(Query query) { for(Map.Entry<String,Object> entry:this.temp.entrySet()) { query.setParameter(entry.getKey(),entry.getValue()); } } @Transactional(propagation=Propagation.REQUIRED) public <T extends Serializable> void update(LinkedHashMap<String,T> update) { this.update(update,null,null); } @Transactional(propagation=Propagation.REQUIRED) public <T extends Serializable> void update(LinkedHashMap<String,T> update,String where,Object[] parameter) { String entityName=t.getName(); //this.sessionFactory.getCurrentSession().createQuery("update "+entityName+" o o.name=:name").setParameter("name","xiaoxiao").executeUpdate(); StringBuilder hql=new StringBuilder(); hql.append("update "+entityName+" as o set "+this.getUpdateStr(update)); if(where!=null&&parameter!=null) { hql.append(" ").append(where); } System.out.println(hql.toString()); Query query=sessionFactory.getCurrentSession().createQuery(hql.toString()); if(parameter!=null) { this.setQueryParameter(query, parameter); } if(update!=null) { this.setUpdateParameter(query); } query.executeUpdate(); } //删除 @Transactional(propagation=Propagation.REQUIRED) public <T extends Serializable> void delete(T entity) { // TODO Auto-generated method stub sessionFactory.getCurrentSession().delete(entity); } @Transactional(propagation=Propagation.REQUIRED) public void delete(PK... primaryKeyId) { for(PK pkId:primaryKeyId) { Object entity=sessionFactory.getCurrentSession().get(t,pkId); sessionFactory.getCurrentSession().delete(entity); } } @Transactional(propagation=Propagation.REQUIRED) public void delete(String where,Object[] parameter) { String entityName=t.getName(); StringBuilder hql=new StringBuilder(); hql.append("delete "+entityName+" as o"); if(where!=null&&parameter!=null) { hql.append(" ").append(where); } Query query=sessionFactory.getCurrentSession().createQuery(hql.toString()); if(parameter!=null) { this.setQueryParameter(query,parameter); } query.executeUpdate(); } //根据ID查找记录 @Transactional(propagation=Propagation.REQUIRED) public T find(PK primarKeyId) { // TODO Auto-generated method stub T findObj=null; findObj=(T) sessionFactory.getCurrentSession().get(t, primarKeyId); return findObj; } private void setQueryParameter(Query query,Object[] parameter) { if(parameter!=null) { for(int i=0;i<parameter.length;i++) { query.setParameter("p"+(i+1), parameter[i]); } } } private String getOrderStr(LinkedHashMap<String,String> orderBy) { StringBuilder orderStr=new StringBuilder(); /* Iterator<Map.Entry<String, String>> iterator=orderBy.entrySet().iterator(); while(iterator.hasNext()) { Map.Entry<String,String> entry=iterator.next(); orderStr.append(entry.getKey()).append(" ").append(entry.getValue()).append(","); }*/ /* * 鏁版嵁閲忓ぇ鏃朵娇鐢? for(Map.Entry<String,String> entry:orderBy.entrySet()) { orderStr.append(entry.getKey()).append(" ").append(entry.getValue()).append(","); }*/ for(String key:orderBy.keySet()) { orderStr.append(key).append(" ").append(orderBy.get(key)).append(","); } /* * 鍘绘帀鏈?悗涓?釜閫楀彿 */ orderStr.deleteCharAt(orderStr.length()-1); return orderStr.toString(); } /** * 查询指定范围、条件的结果集 * firstResult:起始索引 * maxResults:最大记录数 * where:where参数，用法如下： * String where="where name=:p1 and pwd=:p2" * 说明：上面的p是固定写法 * parameter:参数，用法如下： * Object[] obt={"kute","123"} * orderBy:排序设置，用法如下： * map.put("age","DESC"); * 说明：以年龄降序排序 */ @Transactional(propagation=Propagation.REQUIRED) public <T extends Serializable> QueryResult<T> getScrollData(int firstResult,int maxResults,String where,Object[] parameter,LinkedHashMap<String,String> orderBy) { /* * 获取实体类全名 */ String entityName=t.getName(); StringBuilder hql=new StringBuilder(); hql.append("select o from "+entityName+" as o"); if(where!=null&&parameter!=null) { hql.append(" ").append(where); } if(orderBy!=null) { hql.append(" order by ").append(this.getOrderStr(orderBy)); } Query query=null; if(firstResult!=-1&&maxResults!=-1) { query=sessionFactory.getCurrentSession().createQuery(hql.toString()).setFirstResult(firstResult).setMaxResults(maxResults); } else { query=sessionFactory.getCurrentSession().createQuery(hql.toString()); } /* * 设置where参数 * */ if(parameter!=null) { this.setQueryParameter(query, parameter); } QueryResult<T> queryResult = new QueryResult<T>(); queryResult.setResultlist(query.list()); queryResult.setTotalrecord((long)query.list().size()); return queryResult; } @Transactional(propagation=Propagation.REQUIRED) public <T extends Serializable> QueryResult<T> getScrollData(int firstResult,int maxResults,LinkedHashMap<String,String> orderBy) { if(orderBy==null) { orderBy=new LinkedHashMap<String,String>(); orderBy.put("o."+((AbstractEntityPersister)sessionFactory.getClassMetadata(t)).getIdentifierPropertyName(), "ASC"); } return this.getScrollData(firstResult, maxResults, null,null,orderBy); } @Transactional(propagation=Propagation.REQUIRED) public <T extends Serializable> QueryResult<T> getScrollData(int firstResult,int maxResults) { return this.getScrollData(firstResult, maxResults, null); } @Transactional(propagation=Propagation.REQUIRED) public <T extends Serializable> QueryResult<T> getScrollData(String where,Object[] parameter) { return this.getScrollData(-1, -1,where,parameter,null); } public <T extends Serializable> QueryResult<T> getScrollData() { return this.getScrollData(-1,-1,null,null,null); } /* * 注入SessionFactory */ protected SessionFactory sessionFactory; public Sessi