Hibernate简单的BaseDao

 

package com.xiva.hibernate.dao;

import java.io.Serializable;


public interface BaseDao<E extends Serializable, PK extends Serializable> {

	/**
	 * 插入一个对象
	 * @param person
	 */
	public void insert(E entity);
	
	/**
	 * 删除一个对象
	 * @param object
	 */
	public void delete(E entity);
	
	
	/**
	 * 根据主键，使用到Criteria接口查询
	 * @param id
	 * @return
	 */
	public E getByPK(PK id);
	
	/**
	 * 直接使用session的get方法
	 * @param id
	 * @return
	 */
	public E getById(PK id);
	
	/**
	 * 更新一个对象
	 * @param person
	 */
	public void update(E entity);
	
}

 

 接口实现类：

 

package com.xiva.hibernate.dao;

import java.io.Serializable;
import java.lang.reflect.ParameterizedType;
import java.lang.reflect.Type;

import org.hibernate.Criteria;
import org.hibernate.Session;
import org.hibernate.Transaction;
import org.hibernate.criterion.Restrictions;

import com.xiva.hibernate.HibernateUtil;

public  class BaseDaoImpl<E extends Serializable, PK extends Serializable> implements BaseDao<E, PK>  {
	
	
	private Class<?> entityClass;
	
	public BaseDaoImpl(){
		Class<?> c = this.getClass();  
        Type type = c.getGenericSuperclass();  
        if (type instanceof ParameterizedType) {  
            this.entityClass = (Class<?>) ((ParameterizedType) type)  
                    .getActualTypeArguments()[0];  
        }  
	}

	/**
	 * 插入数据库同样需要使用到事务
	 */
	public void insert(E entity) {
		Session session = null;
		Transaction tx = null;
		try{
			session = HibernateUtil.getSession();
			tx = session.beginTransaction();
			session.save(entity);
			tx.commit();
		}finally{
			if(session!=null){
				session.close();
			}
		}

	}

	/**
	 * 删除一个对象与查询不同必须使用事务提交
	 */
	public void delete(E entity) {
		Session session = null;
		Transaction tx = null;
		try{
			session = HibernateUtil.getSession();
			tx = session.beginTransaction();
			session.delete(entity);
			tx.commit();
		}finally{
			if(session!=null){
				session.close();
			}
		}
	}


	@SuppressWarnings("unchecked")
	public E getByPK(PK id) {
		Session session = null;
		E entity = null;
		try {
			session = HibernateUtil.getSession();
			Criteria criteria = session.createCriteria(this.entityClass);
			criteria.add(Restrictions.eq("id", id));
			// List<Person> list = criteria.list();
			// if(list.size()!=0)
			// person = list.get(0);
			entity = (E) criteria.uniqueResult();
//			if(person!=null)
//				System.out.println(person.getDepartment().getDepartmentName());
		} finally {
			if(session!=null){
				session.close();
			}
		}
		return entity;
	}


	public void update(E entity) {
		
		Session session = null;
		Transaction tx = null;
		try{
			session = HibernateUtil.getSession();
			tx = session.beginTransaction();
			session.update(entity);
			tx.commit();
		}finally{
			if(session!=null){
				session.close();
			}
		}

	}


	@SuppressWarnings("unchecked")
	public E getById(PK id) {
		Session session = null;
		E entity = null;
		try {
			session = HibernateUtil.getSession();
			entity = (E) session.get(this.entityClass, id);
//			Hibernate.initialize(person.getDepartment());
		} finally {
			if(session!=null){
				session.close();
			}
		}
		return entity;
	}
}

 

 

 

下面是调用方式：

 

 

package com.xiva.hibernate.dao;

import com.xiva.hibernate.domain.Person;

public interface PersonDao extends BaseDao<Person, Long>{

}

 

 

 

 

 

 

package com.xiva.hibernate.dao;

import com.xiva.hibernate.domain.Person;

public class PersonDaoImpl extends BaseDaoImpl<Person, Long> implements PersonDao {
	
}

 

 

 

实体类：

 

 

package com.xiva.hibernate.domain;

import java.io.Serializable;
import java.util.Date;

public class Person implements Serializable{
	
	
	/**
	 * 
	 */
	private static final long serialVersionUID = -6190737414531892695L;
	private Long id;
	private String name;
	private String password;
	private Date birthday;
	private Department department;
	private IdCard idCard;
	private Address address;
	

	public Person() {
	}

	public Person(Long id, String name, String password, Department department,
			IdCard idCard, Date birthday, Address address) {
		this.id = id;
		this.name = name;
		this.password = password;
		this.department = department;
		this.idCard = idCard;
		this.birthday = birthday;
		this.address = address;
	}

	public Long getId() {
		return id;
	}

	public void setId(Long id) {
		this.id = id;
	}

	public String getName() {
		return name;
	}

	public void setName(String name) {
		this.name = name;
	}

	public String getPassword() {
		return password;
	}

	public void setPassword(String password) {
		this.password = password;
	}

	public Department getDepartment() {
		return department;
	}

	public void setDepartment(Department department) {
		this.department = department;
	}

	public IdCard getIdCard() {
		return idCard;
	}

	public void setIdCard(IdCard idCard) {
		this.idCard = idCard;
	}

	public Date getBirthday() {
		return birthday;
	}

	public void setBirthday(Date birthday) {
		this.birthday = birthday;
	}

	public Address getAddress() {
		return address;
	}

	public void setAddress(Address address) {
		this.address = address;
	}
	
}

 

 

主要是需要实现Serializable接口。还有在实现类初始化的时候，需要知道是哪一个类，

 

 

public BaseDaoImpl(){
		Class<?> c = this.getClass();  
        Type type = c.getGenericSuperclass();  
        if (type instanceof ParameterizedType) {  
            this.entityClass = (Class<?>) ((ParameterizedType) type)  
                    .getActualTypeArguments()[0];  
        }  
	}

 

也许上面的方法是实现了基本的Dao，但是不可取，这个只是使用hibernate框架，我们的事务只能在Dao层进行控制，而一般的数据回滚，我们是在业务逻辑层来做的；因此可能结合Spring来实现这样的功能比较简单，以后贴出例子。