datasourcecreater.java

用JAVA开发

package cn.netjava.feeserver.servletcontainer;

import javax.sql.DataSource;
import java.sql.*;

import cn.netjava.feeserver.cfgbean.CfgDataSource;
import org.apache.commons.dbcp.BasicDataSource;
import cn.netjava.feeserver.cfgbean.*;


/**
 * 创建数据源，提供提取数据源接口
 * 计费查询服务器
 * @author www.NetJava.cn
 *
 */
public class DataSourceCreater {
	
	/**
	 * 提取对应名字的数据源
	 * @param dataSourceName
	 * @return
	 * @throws Exception
	 */
	public static  java.sql.Connection getDataSource(String dataSourceName) throws Exception{
		
		DataSource ds=dataSourceMap.get(dataSourceName);
		if(null==ds){
			CfgDataSource cds=WebAppCfgManager.ins().getWebApp().getCfgDataSource(dataSourceName);
			BasicDataSource bds=new BasicDataSource();			
		//	bds.setLoginTimeout(1000);
			bds.setDriverClassName(cds.getDriverClassName());
			bds.setUrl(cds.getUrl());
			bds.setMaxActive(cds.getMaxActive());
			bds.setMaxIdle(cds.getMaxIdle());
            bds.setUsername(cds.getUserName());
            bds.setPassword(cds.getPassWord());
			dataSourceMap.put(dataSourceName, bds);
			return bds.getConnection();
		}
		return ds.getConnection();
	}
	
//	dataSource配置集合
	private static java.util.Map<String,DataSource> dataSourceMap=new java.util.HashMap();
		 

	/**
	 * 连结数据库
	 * @param driveName
	 * @param dbURL
	 * @param useerName
	 * @param pwd
	 * @return
	 */
//	public Connection getDataSource(String driveName,String dbURL,String useerName,String pwd) throws Exception{
//		try{
//	
//		//到classpath中查找驱动类：
//		Class.forName(driveName);
//		conn=java.sql.DriverManager.getConnection(dbURL, useerName, pwd);
//		return conn;
//		}catch(Exception ef){
//			LogManager.error("conn to db error: "+ef);
//		}
//		return null;
//	}
//	
//	 private static Connection conn=null;
}