incasementproductdaohibernate.java

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

/**
 * 
 */
package cn.bway.foreigntrade.repertory.incasement.product.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 test.test1.model.Test;

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.units.model.Units;
import cn.bway.foreigntrade.order.exportproduct.model.Exportproduct;
import cn.bway.foreigntrade.repertory.cancel.document.model.Canceldocument;
import cn.bway.foreigntrade.repertory.cancel.product.model.Cancelproduct;
import cn.bway.foreigntrade.repertory.incasement.document.model.Incasementdocument;
import cn.bway.foreigntrade.repertory.incasement.product.model.Incasementproduct;
import cn.bway.foreigntrade.repertory.outstore.product.model.Outstoreproduct;

/**
 * @author Kson
 * 
 */
public class IncasementproductDAOHibernate extends BaseDAOHibernate implements IncasementproductDAO {

	/*
	 * (non-Javadoc)
	 * 
	 * @see cn.bway.myoffice.merchant.dao.MerchantDAO#findAllMerchant(cn.bway.common.vo.QueryVO)
	 */
	public Object findAllIncasementproduct(QueryVO qvo) throws BwayHibernateException {
//		
		Incasementproduct incasementproduct= new Incasementproduct();
		PageListVO rvo = new PageListVO();
		rvo.setRealPage(qvo.getCurPage());
		rvo.setPageSize(qvo.getPageSize());
		List list = null;
		session = currentSession();
		try {
			Criteria criteria = session.createCriteria(Incasementproduct.class);
			rvo.setTotalItems(criteria.add(Example.create(incasementproduct)).list().size());

			criteria.setFirstResult(qvo.getFirstItem());
			criteria.setMaxResults(qvo.getPageSize());

			list = criteria.add(Example.create(incasementproduct))
					.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;
	}
//		// 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 findAllIncasementproduct1(QueryVO qvo,String id) throws BwayHibernateException {
		// TODO Auto-generated method stub
		Incasementproduct Incasementproduct = new Incasementproduct();
		PageListVO rvo = new PageListVO();
		rvo.setRealPage(qvo.getCurPage());
		rvo.setPageSize(qvo.getPageSize());
		List list = null;
		session = currentSession();
		try {
			Criteria criteria = session.createCriteria(Incasementproduct.class);
//			查询条件
			 Map map= Util.scatterMap(qvo.getScatterMap());
			 if(map.isEmpty()){
			 }else{
				 //String name=map.get("Id").toString();
				 criteria.add(Expression.like("Id", id));
				 
			 }
			
			rvo.setTotalItems(criteria.add(Example.create(Incasementproduct)).list().size());

			criteria.setFirstResult(qvo.getFirstItem());
			criteria.setMaxResults(qvo.getPageSize());

			list = criteria.add(Example.create(Incasementproduct)).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 queryAllIncasementproduct(QueryVO qvo,String id) throws BwayHibernateException {
		
		Incasementproduct Incasementproduct= new Incasementproduct();
		PageListVO rvo = new PageListVO();
		rvo.setRealPage(qvo.getCurPage());
		rvo.setPageSize(qvo.getPageSize());
		List list = null;
		session = currentSession();
		try {
			Criteria criteria = session.createCriteria(Incasementproduct.class);
			
			//查询条件
//			 Map map= Util.scatterMap(qvo.getScatterMap());
//			 if(map.isEmpty()){
//			 }else{
				 //String name=map.get("Id").toString();
			criteria.add(Expression.eq("documentid", id));	
				 
//			 }
			rvo.setTotalItems(criteria.add(Example.create(Incasementproduct)).list().size());
			criteria.setFirstResult(qvo.getFirstItem());
			criteria.setMaxResults(qvo.getPageSize());
			list = criteria.add(Example.create(Incasementproduct)).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 getAllIncaseproduct(String id) throws BwayHibernateException {
		Incasementproduct product=new Incasementproduct();
		PageListVO rvo = new PageListVO();
		session=currentSession();
		Criteria criteria=session.createCriteria(Incasementproduct.class);
		criteria.add(Expression.eq("documentid", id));
		List list=criteria.list();
		rvo.setretVO(list);
		return rvo;
	}
}