sessioncommit.java

这是本人以前在学校时

/*
 * Created on 2006-6-22
 * 与数据库交互提供的公共方法及会话对象
 */
package com.funddeal.base;

import net.sf.hibernate.HibernateException;
import net.sf.hibernate.Session;
import net.sf.hibernate.SessionFactory;
import net.sf.hibernate.Transaction;
import net.sf.hibernate.cfg.Configuration;

/**
 * @author zhangxianxin
 * @version
 * 提供对数据库的同步操作的方法及会话
 * 方法一：[String getSessionAdd(Object)]将实体中的数据保存到数据库Object为已赋值的实体对象
 * 方法二：[Session getSession()]返回一个会话对象
 * 方法三：[boolean getSessionUpdate(Object)]将实体中的已修改过的数据与数据库表进行同步（更新）
 */
public class SessionCommit {
	private Session session;
	public static String errorMsg="";
	public SessionCommit() throws HibernateException
	{
		Configuration cfg = new Configuration().configure();
		SessionFactory sessionFactory = cfg.buildSessionFactory();
		this.session = sessionFactory.openSession();
	}
	
	/**
	 * 提供会话（Session）工厂对象
	 * @return 一个会话对象
	 */
	public Session getSession()
	{
		return this.session;
	}
	
	
	/**
	 * 对数据库表的数据的添加的方法
	 * @param Object对象obj（一般为实体对象）
	 * @return 返回表的主键
	 * @throws HibernateException
	 */
	public String getSessionAdd(Object obj) throws HibernateException
	{
		Transaction tx = session.beginTransaction();
		String id = (String)session.save(obj);
		tx.commit();
		session.close();
		return id;
	}
	
	
	/**
	 * 删除数据库表中的某条记录
	 * @param obj 持久层实体对象
	 * @return True|False （删除成功与否）
	 */
	public boolean getSessionDelete(Object obj)
	{
		errorMsg="";
		boolean flag=true;
		Transaction tx;
		try {
			tx=session.beginTransaction();
			session.delete(obj);
			tx.commit();
			session.close();
		} catch (HibernateException e) {
			errorMsg=e.getMessage();
			flag=false;
		}catch(Exception ex){
			errorMsg=ex.getMessage();
			flag=false;			
		}
		return flag;
	}

	
	/**
	 * 对数据库表中的记录进行修改
	 * @param obj 持久层实体对象
	 * @return True|False （更新成功与否）
	 */
	public boolean getSessionUpdate(Object obj)
	{
		errorMsg="";
		boolean flag=true;
		Transaction tx;
		try {
			tx = session.beginTransaction();
			session.update(obj);
			tx.commit();
			session.close();
		} catch (HibernateException e){
			e.printStackTrace();
			errorMsg=e.getMessage();
			flag=false;
		}
		return flag;
	}
}