businessdaohibernate.java

这个是完整的wap项目的源码 开发语言 Java 系统架构 Struts + hibernate + spring 数据库 Mysql5.0 应用服务器Tomcat5.0 开发工具 MyEc

package com.longtime.wap.module.business.dao.hibernate;

import java.sql.SQLException;
import java.util.List;

import org.hibernate.HibernateException;
import org.hibernate.Query;
import org.hibernate.Session;
import org.springframework.orm.hibernate3.HibernateCallback;

import com.longtime.wap.common.BaseDao;
import com.longtime.wap.model.Business;
import com.longtime.wap.module.business.dao.BusinessDao;

/**
 * BusinessDao层代码实现类
 * 
 * @author gengb
 * @date Nov 15, 2007
 */
public class BusinessDaoHibernate extends BaseDao implements BusinessDao {

	/**
	 * 批量删除业务对象
	 * 
	 * @param businessList
	 *            业务对象列表
	 */
	public void deleteBusinessesByIds(List businessList) {
		this.getHibernateTemplate().deleteAll(businessList);

	}

	/**
	 * 获取某单位的业务集合
	 * 
	 * @param cpId
	 *            单位Id
	 * @return 业务对象集合
	 */
	public List retrieveBusinessByCpId(Long cpId) {
		return this.getHibernateTemplate().find(
			"from Business where cp_id=" + cpId + "order by businessId asc");
	}

	/**
	 * 根据业务Id获取业务对象
	 * 
	 * @param id
	 *            业务Id
	 * @return 业务对象
	 */
	public Business retrieveBusinessById(Long id) {
		return (Business) this.getHibernateTemplate().get(Business.class, id);
	}

	/**
	 * 获取某类的业务对象集合
	 * 
	 * @param category
	 *            业务类别
	 * @return 业务对象集合
	 */
	public List retrieveBusinessByCategory(Integer category) {
		return this.getHibernateTemplate().find(
				"from Business where category=" + category
						+ "order by businessId asc");

	}

	/**
	 * 根据业务Id集合获取业务对象集合
	 * 
	 * @param ids
	 *            业务Id集合
	 * @return 业务对象列表
	 */
	public List retrieveBusinessesByIds(final String[] ids) {
		return this.getHibernateTemplate().executeFind(
				new HibernateCallback() {
			public Object doInHibernate(Session session) {
				StringBuilder hql = new StringBuilder("from Business where ");
				for (int i = 0; i < ids.length; i++) {
					hql.append("businessId =" + Long.parseLong(ids[i]));
					if (i < ids.length - 1) {
						hql.append(" or ");
					}
				}
				Query query = session.createQuery(hql.toString());
				return query.list();
			}
		});
	}

	/**
	 * 更新业务对象
	 * 
	 * @param business
	 *            业务对象
	 */
	public void updateBusiness(Business business) {
		this.getHibernateTemplate().update(business);

	}

	/**
	 * 批量更新业务对象的有效时间
	 * 
	 * @param businessList
	 *            业务对象集合列表
	 */
	public void updateBusinessesDuration(List businessList) {
		this.getHibernateTemplate().saveOrUpdateAll(businessList);

	}

	/**
	 * 根据业务名称获取业务对象集合
	 * 
	 * @param businessName
	 *            业务名称
	 * @return 业务对象列表
	 */
	public List retrieveBusinessByName(final String businessName) {
		return this.getHibernateTemplate().executeFind(
				new HibernateCallback() {
			public Object doInHibernate(Session session)
					throws HibernateException, SQLException {
				Query query = session
						.createQuery("from Business where businessName= ?");
				query.setString(0, businessName);
				return query.list();
			}
		});

	}
	/**
	 * 新增业务
	 * 
	 * @param business
	 *            业务对象
	 */
	public void createBusiness(Business business) {
		this.getHibernateTemplate().save(business);
		
	}

}