steelsinformationdaohibernate.java

这是本人曾经在公司里用的,内部开发框架,基于struts+hibernate今天分享给大家

/**
 * 
 */
package cn.bway.foreigntrade.operation.steelsinformation.dao;

import java.sql.ResultSet;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

import org.hibernate.Criteria;
import org.hibernate.HibernateException;
import org.hibernate.criterion.Example;
import org.hibernate.criterion.Expression;
import org.hibernate.criterion.Order;

import cn.bway.common.BwayHibernateException;
import cn.bway.common.DataBaseUtils;
import cn.bway.common.Util;
import cn.bway.common.dao.BaseDAOHibernate;
import cn.bway.common.vo.PageListVO;
import cn.bway.common.vo.QueryVO;
import cn.bway.myoffice.merchant.model.Merchant;
import cn.bway.foreigntrade.operation.steelsinformation.model.Steelsinformation;
import cn.bway.foreigntrade.operation.units.model.Units;

/**
 * @author Kson
 *
 */
public class SteelsinformationDAOHibernate extends BaseDAOHibernate implements
		SteelsinformationDAO {

	/* (non-Javadoc)
	 * @see cn.bway.myoffice.merchant.dao.MerchantDAO#findAllMerchant(cn.bway.common.vo.QueryVO)
	 */
	public Object findAllSteelsinformation(QueryVO qvo) throws BwayHibernateException {
		// TODO Auto-generated method stub
		PageListVO rvo=new PageListVO();
		rvo.setRealPage(qvo.getCurPage());
		rvo.setPageSize(qvo.getPageSize());
		ArrayList list=new ArrayList();
		Statement stmt  =null;
	 	ResultSet rs  =null;
	 	String sql=DataBaseUtils.getMySQLLimitString("select * from merchant ",qvo.getCurPage()-1,qvo.getPageSize());
	 	try{
			stmt = currentSession().connection().createStatement();
			rs = stmt.executeQuery(sql);
			Merchant p=null;
        	while(rs.next()) {
        		p=new Merchant();  
            	p.setId(String.valueOf(rs.getInt("id")));
//            	p.setStorename(rs.getString("storename"));
            	list.add(p);
			}
        	rs =stmt.executeQuery("select count(*) from merchant");
        	rs.next();
        	rvo.setTotalItems(rs.getInt(1));
            rvo.setretVO(list);
    	}catch(HibernateException he){
    		log.error(this.getClass().getName()+".findAllMerchant(QueryVO qvo)"+he);
    		throw new BwayHibernateException(he.getMessage());
    	}catch (Exception e) {
    		log.error(this.getClass().getName()+".findAllMerchant(QueryVO qvo)"+e);
    		throw new BwayHibernateException(e.getMessage());
		}finally{
    		close(stmt,rs);
    		closeSession();
    	}
       return rvo;
	}

	/* (non-Javadoc)
	 * @see cn.bway.myoffice.merchant.dao.MerchantDAO#findAllMerchant1(cn.bway.common.vo.QueryVO)
	 */
	public Object findAllSteelsinformation1(QueryVO qvo) throws BwayHibernateException {
		// TODO Auto-generated method stub
		Steelsinformation steelsinformation= new Steelsinformation();
		PageListVO rvo=new PageListVO();
		rvo.setRealPage(qvo.getCurPage());
		rvo.setPageSize(qvo.getPageSize());
		List list=null;
		session=currentSession();
		try {
	    	Criteria criteria=session.createCriteria(Steelsinformation.class);
	    	rvo.setTotalItems(criteria.add(Example.create(steelsinformation)).list().size());
	    	
	    	criteria.setFirstResult(qvo.getFirstItem());
	    	criteria.setMaxResults(qvo.getPageSize());
	    	
			list=criteria.add(Example.create(steelsinformation))
			.addOrder(Order.desc("id"))
			.list();
	    	
	    	rvo.setretVO(list);
		} catch (Exception ex)	{
			ex.printStackTrace();
			log.error(this.getClass().getName()+".updateObject(Object obj)"+ex);
		}finally{
			closeSession();
		}
    	return rvo;
	}

	public Object querySteelsinformation(QueryVO qvo) throws BwayHibernateException {
		Steelsinformation steelsinformation= new Steelsinformation();
		PageListVO rvo=new PageListVO();
		rvo.setRealPage(qvo.getCurPage());
		rvo.setPageSize(qvo.getPageSize());
		List list=null;
		session=currentSession();
		try {
	    	Criteria criteria=session.createCriteria(Steelsinformation.class);
	    	rvo.setTotalItems(criteria.add(Example.create(steelsinformation)).list().size());
	    	
//	    	查询条件
			 Map map= Util.scatterMap(qvo.getScatterMap());
			 if(map.isEmpty()){
			 }else{
				 String name=map.get("lilynumber").toString();
				 criteria.add(Expression.like("lilynumber", "%"+name+"%"));
				 
			 }
	    	criteria.setFirstResult(qvo.getFirstItem());
	    	criteria.setMaxResults(qvo.getPageSize());	    	
			list=criteria.add(Example.create(steelsinformation))
			.addOrder(Order.desc("id"))
			.list();
	    	
	    	rvo.setretVO(list);
		} catch (Exception ex)	{
			ex.printStackTrace();
			log.error(this.getClass().getName()+".updateObject(Object obj)"+ex);
		}finally{
			closeSession();
		}
    	return rvo;
	}
}