Hibernate使用原生的动态sql实现带条件的查询分页功能

青旅半醒 2022-09-21 13:13 264阅读 0赞

# 背景 #

最近在做项目的时候需要使用到分页功能，项目用的框架是JPA，老实说SpringDataJpa的带条件的分页查询功能真的难用。。。所以想到用hibernate的动态SQL来实现算了。

# 实现步骤 #

1.在hibernate的配置文件中加实体类(移动要配置，如果没有配置，不会报错，但是就是查询不出来数据)  
2.编写dao和daoimpl类（关键）  
3.编写2个dto类  
4.调用

# 详细实现步骤 #

## 在hibernate的配置文件中加实体类 ##

### hibernate在使用中一般会和hibernate整合，整合之后要配置实体类有两种实现方案 ###

1.通过在hibernate.cfg.xml中配置的方式

applicationContext.xml

<bean id="sessionFactory" class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
    	<property name="dataSource" ref="dataSource" />
    	<property name="configLocations">
    	<list>
    		<value>classpath*:hibernate/**/hibernate.cfg.xml</value>
    	</list>
    </property>

hibernate.cfg.xml

<?xml version="1.0" encoding="UTF-8"?>
    <!DOCTYPE hibernate-configuration PUBLIC "-//Hibernate/Hibernate Configuration DTD 3.0//EN" "http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd">
    
    <hibernate-configuration>
    	<session-factory>
    		<mapping class="com.nantian.man.busi.domain.TCardInfo"/>
    		
    	</session-factory>
    </hibernate-configuration>

2.直接在applicationContext.xml配置

<bean id="sessionFactory" class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean">
    	<property name="annotatedClasses"> 
    		<list> 
    		<value>com.nantian.man.busi.domain.TCardInfo</value> 
    		</list> 
    	</property>
    </bean>

## 编写三个dto ##

PageModel（包装当前页数和每页显示条数的pojo）

public class PageModel{ 
    
    	private int pageNo = 1;//当前页
    	private int pageSize = 3;//每页显示条数
    	//get set方法
    }

HibernateQueryModel（包装查询条件，查询实体名字，排序等的POJO）

public class HibernateQueryModel { 
    	
    	private String tableName;//实体名字
    	
    	private Map<String,Object> map;//查询条件
    	
    	private String orderColumn;//排序字段
    	
    	private String orderType;//排序方式，比如：desc，asc
    	
    	private PageModel pageModel;//包装了当前页码和每页显示条数
    	//get set方法
    }

ReturnPageModel（包装了返回数据的POJO）

public class ReturnPageModel<T> implements Serializable  { 
    	private static final long serialVersionUID = 1L;
    	private int count;//总数
    	private int end;//结束的行数
    	private long pages;//页数
    	private int pageSize;//每页显示行数
    	private List<T> list; //返回数据
    	private int start;//开始行数
    	private long currentPage;//当前页
    	//get set方法
    }

## 编写dao和daoimpl类（关键） ##

dao

public interface HibernateQueryDao<T> { 
    
    	ReturnPageModel<T> getByConditionAndPage(HibernateQueryModel hqm);
    }

daoimpl

@Repository
    public class HibernateQueryDaoImpl<T> extends HibernateDaoSupport implements HibernateQueryDao<T> { 
    
    	@Resource  
    	public void setMySessionFactory(SessionFactory sessionFactory){   
    		super.setSessionFactory(sessionFactory);  
    	}  
    	
    	/** * 条件查询 * */
    	@SuppressWarnings("unchecked")
    	@Override
    	@Transactional(propagation=Propagation.REQUIRED)
    	public ReturnPageModel<T> getByConditionAndPage(HibernateQueryModel hqm){ 
    		
    		ReturnPageModel<T> page=new ReturnPageModel<T>();
    		
    		String sql="from "+hqm.getTableName()+" t where 1=1 ";
    		StringBuilder sb=new StringBuilder();
    
    		List<Object> paramList=new ArrayList<Object>();
    		Map<String,Object> querymap = hqm.getMap();
    		if(!querymap.isEmpty()){ 
    			for(String key : querymap.keySet()){ 
    				if(StringUtil.isNotEmpty(querymap.get(key))){ 
    					paramList.add(querymap.get(key));
    					sb.append("and t."+key+"=? ");
    				}
    			}
    		}
    		final Object[] objectArr=paramList.toArray();
    		final String hql=sql+sb.toString()+"order by t."+hqm.getOrderColumn()+" "+hqm.getOrderType();
    		final String sqlcount="select count(*) "+hql;
    		
    		logger.info("查询语句为： ["+hql+"]");
    		logger.info("获取数量的查询语句为：["+sqlcount+"]");
    		final int pageNo=hqm.getPageModel().getPageNo();
    		final int pageSize=hqm.getPageModel().getPageSize();
    		
    		//得到总数据
    		List<T> list=this.getHibernateTemplate().executeFind(new HibernateCallback(){ 
    			public Object doInHibernate(Session session)
    					throws HibernateException, SQLException { 
    				Query query=session.createQuery(hql);
    				query.setFirstResult((pageNo-1)*pageSize);
    				query.setMaxResults(pageSize);
    				for(int i=0;i<objectArr.length;i++){ 
    					query.setParameter(i, objectArr[i]);
    				}
    				return query.list();
    		}});
    		
    		//得到总条数
    		List<Long> longlist=this.getHibernateTemplate().executeFind(new HibernateCallback(){ 
    			public Object doInHibernate(Session session)
    					throws HibernateException, SQLException { 
    				Query query=session.createQuery(sqlcount);
    				for(int i=0;i<objectArr.length;i++){ 
    					query.setParameter(i, objectArr[i]);
    				}
    				return query.list();
    		}});
    		
    		int count = longlist.get(0).intValue();
    		page.setList(list);
    		page.setPageSize(pageSize);
    		page.setStart(pageNo);
    		page.setCount(count);
    		int end = (pageNo - 1) * pageSize + pageSize;
    		if (count < end) { 
    			page.setEnd(count);
    		} else { 
    			page.setEnd((pageNo - 1) * pageSize + pageSize);
    		}
    		return page;
    	}
    }

## 如何调用 ##

public void test(){ 
    	//1、判断页码是否正确
    	int currentPage = Integer.parseInt(this.getDictionary().getDataMapValue(msgBean.getDataMap(),FieldConfigConstant.CURRENTPAGE));
    	int pageSize = Integer.parseInt(this.getDictionary().getDataMapValue(msgBean.getDataMap(),FieldConfigConstant.PAGESIZE));
    	if(currentPage<=0){ 
    		currentPage = 1;
    	}
    	if(pageSize<=0){ 
    		pageSize = 10;
    	}
    	HibernateQueryModel model = new HibernateQueryModel();
    	Map<String, Object> conditionMap = new HashMap<String,Object>();
    	PageModel pageModel=new PageModel(currentPage,pageSize);
    	
    	Field[] field = TCardInfoPKDto.class.getDeclaredFields();
    	for(Field fi:field){ 
    		String name = fi.getName();
    		String caseName = name.substring(0,1).toUpperCase()+name.substring(1); //将属性的首字符大写，方便构造
    		Method m = tc.getClass().getMethod("get"+caseName);
    		Object value = m.invoke(tc);
    	       if(StringUtil.isNotEmpty(value)){ 
    	       	conditionMap.put("id."+name, value);
    	       }
    	}
    	
    	model.setTableName(TCardInfo.class.getName());
    	model.setOrderColumn("id.value");
    	model.setOrderType("asc");
    	model.setMap(conditionMap);
    	model.setPageModel(pageModel);
    	
    	ReturnPageModel<TCardInfo> page = hibernateQueryDaoImpl.getByConditionAndPage(model);
    }