connectionprovider.java

野蔷薇论坛源码 java 自己看看吧。 学习用

/* 
 * Created on 2007-9-8
 * Last modified on 2007-9-8
 * Powered by YeQiangWei.com
 */
package com.yeqiangwei.club.dao.hibernate;

import java.io.File;

import org.apache.log4j.Logger;
import org.hibernate.HibernateException;

import com.yeqiangwei.club.service.search.Constants;

public class ConnectionProvider {
	
	private static final Logger logger = Logger.getLogger(ConnectionProvider.class);
	
	public static Integer whichConnection = null;

	static {
		if(whichConnection==null){
			logger.info("loading yeqiangwei.user.hb.xml");
			StringBuffer sb = new StringBuffer(Constants.REAL_PATH);
			sb.append("WEB-INF");
			sb.append(File.separator);
			sb.append("classes");
			sb.append(File.separator);
			sb.append("yeqiangwei.user.hb.xml");
			logger.info(sb.toString());
			File file = new File(sb.toString());
			if(file.exists()){
				whichConnection =  new Integer(1);
			}else{
				whichConnection =  new Integer(0);
			}
		}
	}
	
	public static void init(){
		ConnectionManager.init();
		if(whichConnection==1){
			ConnectionUserManager.init();
		}
	}
	
	public static void beginTransaction() throws HibernateException{
		ConnectionManager.beginTransaction();
		if(whichConnection==1){
			ConnectionUserManager.beginTransaction();
		}
	}
	
	public static void commitTransaction() throws HibernateException{
		ConnectionManager.commitTransaction();
		if(whichConnection==1){
			ConnectionUserManager.commitTransaction();
		}
	}
	
	public static void closeSession() throws HibernateException{
		ConnectionManager.closeSession();
		if(whichConnection==1){
			ConnectionUserManager.closeSession();
		}
	}
	
	public static void rollbackTransaction() throws HibernateException{
		ConnectionManager.rollbackTransaction();
		if(whichConnection==1){
			ConnectionUserManager.rollbackTransaction();
		}
	}
}