basedao.java

struts+hibernate+spring框架实现

package com.cvicse.myssh.struts.dao.base.impl;

import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.hibernate.Query;
import org.hibernate.Session;
import org.springframework.beans.factory.InitializingBean;
import org.springframework.orm.ObjectRetrievalFailureException;
import org.springframework.orm.hibernate3.support.HibernateDaoSupport;

import com.cvicse.myssh.struts.PO.LoginPO;
import com.cvicse.myssh.struts.dao.base.IBaseDAO;

public class BaseDAO extends HibernateDaoSupport implements IBaseDAO,
		InitializingBean {

	private static final Log log = LogFactory.getLog(BaseDAO.class);

	public List queryById(String sql) {
		List list = new ArrayList();
		Session session = getSessionFactory().openSession();
		Query query = session.createSQLQuery(sql);
		list = query.list();
		return list;
	}

	public LoginPO queryObjectById(String id) {
		Session session = getSessionFactory().openSession();
		LoginPO loginPO = (LoginPO) session.get(
				"com.cvicse.myssh.struts.PO.LoginPO", new Integer(id));
		return loginPO;
	}

	public void save(LoginPO loginPO) {
		log.debug("saving Login instance");
		try {
			getHibernateTemplate().save(loginPO);
			log.debug("save successful");
		} catch (RuntimeException re) {
			log.error("save failed", re);
			throw re;
		}
	}

	public void delete(Class clazz, Serializable id) {
		getHibernateTemplate().delete(getObject(clazz, id));
	}

	public Object getObject(Class clazz, Serializable id) {
		Object o = getHibernateTemplate().get(clazz, id);

		if (o == null) {
			throw new ObjectRetrievalFailureException(clazz, id);
		}

		return o;
	}

	public void update(LoginPO loginPO) {
		getHibernateTemplate().saveOrUpdate(loginPO);

	}

	public void delete(String id) {
		LoginPO loginPO = this.queryObjectById(id);
		if (loginPO != null) {
			getHibernateTemplate().delete(loginPO);
		}
	}

}