dbconnectfactory.java

数据库连接池源码

package llm.pool.relation;

import java.sql.SQLException;

import org.apache.log4j.Logger;

/**
 * 获取连接接口工厂
 * @author llm
 *
 */
public class DBConnectFactory {
	
	private static Logger log = Logger.getLogger( DBConnectFactory.class.getName() );

	public DBConnectFactory() {
	}
	
	/**
	 * 获取连接类
	 * @param dbConnectPara
	 * @return 连接类
	 * @throws LlmDBException 
	 * @throws LlmDBException
	 * @throws SQLException
	 */
	public static DBConnect getDBConnect( String jndiName ) throws LlmDBException {
		DBConnectParaManager dbConnectParaManager = new DBConnectParaManager();
		dbConnectParaManager.init();
		DBConnectPara dbConnectPara = dbConnectParaManager.getDBConnectPara( jndiName );
		DBConnect dBConnect;
		if ( dbConnectPara.getConnectType().equalsIgnoreCase( Contents.CONNECT_TYPE_LLM_SIMPLE_POOL ) ) {
			log.debug( Contents.CONNECT_TYPE_LLM_SIMPLE_POOL );
			dBConnect = new DBConnectDataSource();			
		} else if ( dbConnectPara.getConnectType().equalsIgnoreCase( Contents.CONNECT_TYPE_LLM_MUDULE_POOL ) ) {
			log.debug( Contents.CONNECT_TYPE_LLM_MUDULE_POOL );
			dBConnect = new DBConnectDataSource();
		} else  if ( dbConnectPara.getConnectType().equalsIgnoreCase( Contents.CONNECT_TYPE_LLM_COMMON_POOL ) ) {
			log.debug( Contents.CONNECT_TYPE_LLM_COMMON_POOL );
			dBConnect = new DBConnectCommon();
		} else {
			log.debug( "选择默认的数据库连接方式" );
			dBConnect = new DBConnectDataSource();
		}		        
		dBConnect.initialize( dbConnectPara );
		return dBConnect;
	}

	/**
	 * @param args
	 */
	public static void main(String[] args) {

	}

}