productdaohibernate.java

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

/**
 * 
 */
package cn.bway.foreigntrade.reperstory.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 cn.bway.common.BwayHibernateException;
import cn.bway.common.DataBaseUtils;
import cn.bway.common.Util;
import cn.bway.common.code.codeDao;
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.order.exportclient.model.Exportclient;
import cn.bway.foreigntrade.order.exportproduct.model.Exportproduct;
import cn.bway.foreigntrade.reperstory.product.model.Product;
import cn.bway.foreigntrade.repertory.buydocument.model.Buydocument;
import cn.bway.foreigntrade.repertory.buyproduct.model.Buyproduct;

/**
 * @author Kson
 * 
 */
public class ProductDAOHibernate extends BaseDAOHibernate implements ProductDAO {

	/*
	 * (non-Javadoc)
	 * 
	 * @see cn.bway.myoffice.merchant.dao.MerchantDAO#findAllMerchant(cn.bway.common.vo.QueryVO)
	 */
	public Object findAllProduct() throws BwayHibernateException {
		Product product=new Product();
		PageListVO rvo = new PageListVO();
		session=currentSession();
		Criteria criteria=session.createCriteria(Product.class);
		criteria.add(Expression.eq("types","成品仓库"));
		criteria.add(Expression.lt("names",""+new Integer(5)));
		List list=criteria.list();
		rvo.setretVO(list);
		return rvo;
	}

	/*
	 * (non-Javadoc)
	 * 
	 * @see cn.bway.myoffice.merchant.dao.MerchantDAO#findAllMerchant1(cn.bway.common.vo.QueryVO)
	 */
	public Object findAllProduct1(QueryVO qvo,String types) throws BwayHibernateException {
		// TODO Auto-generated method stub
		Product Product= new Product();
		PageListVO rvo = new PageListVO();
		rvo.setRealPage(qvo.getCurPage());
		rvo.setPageSize(qvo.getPageSize());
		List list = null;
		session = currentSession();
		try {
			Criteria criteria = session.createCriteria(Product.class);
			criteria.add(Expression.like("types",types));
			rvo.setTotalItems(criteria.add(Example.create(Product)).list().size());
			criteria.setFirstResult(qvo.getFirstItem());
			criteria.setMaxResults(qvo.getPageSize());
			list = criteria.add(Example.create(Product))
					.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 queryAllProduct(QueryVO qvo) throws BwayHibernateException {
		Product Product= new Product();
		PageListVO rvo = new PageListVO();
		rvo.setRealPage(qvo.getCurPage());
		rvo.setPageSize(qvo.getPageSize());
		List list = null;
		session = currentSession();
		try {
			Criteria criteria = session.createCriteria(Product.class);			
			//查询条件
			Map map= Util.scatterMap(qvo.getScatterMap());
			String types=new String((map.get("codes").toString()).getBytes("iso-8859-1"));
			String typess=new codeDao().getColumes("Storymanagement","names","types",types);
			String names=map.get("names").toString();
			criteria.add(Expression.eq("types",typess));
			criteria.add(Expression.like("names", "%"+names+"%"));
			rvo.setTotalItems(criteria.add(Example.create(Product)).list().size());
			criteria.setFirstResult(qvo.getFirstItem());
			criteria.setMaxResults(qvo.getPageSize());
			list = criteria.add(Example.create(Product))
					.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 queryProduct(QueryVO qvo, String types, String codes) throws BwayHibernateException {
		Product Product= new Product();
		PageListVO rvo = new PageListVO();
		rvo.setRealPage(qvo.getCurPage());
		rvo.setPageSize(qvo.getPageSize());
		List list = null;
		session = currentSession();
		try {
			Criteria criteria = session.createCriteria(Product.class);
			criteria.add(Expression.eq("types",types)).add(Expression.eq("codes",codes));
			rvo.setTotalItems(criteria.add(Example.create(Product)).list().size());
			criteria.setFirstResult(qvo.getFirstItem());
			criteria.setMaxResults(qvo.getPageSize());
			list = criteria.add(Example.create(Product))
					.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 queryProduct(String types, String codes) throws BwayHibernateException {
		Product product=new Product();
		PageListVO rvo = new PageListVO();
		session=currentSession();
		Criteria criteria=session.createCriteria(Product.class);
		criteria.add(Expression.eq("types",types));
		criteria.add(Expression.eq("codes",codes));
		List list=criteria.list();
		rvo.setretVO(list);
		return rvo;
	}
}