dbcon.java

短信

package com.asiainfo.batchsend.sms.boss;

import java.sql.Connection;
import java.sql.ResultSet;

import javax.sql.DataSource;



import org.apache.commons.dbcp.BasicDataSource;

import com.asiainfo.database.ConnectionEx;

/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Company: Asiainfo Technologies(China),Inc </p>
 * <p>Date: Nov 6, 2007 3:55:51 PM </p>
 * <p>Email to: [e-mail] </p>
 * @author jiangyl
 * @version 1.0
 */
public class DBCon {
	//深运数据库的数据源
	private static DataSource dataSource;
	//BOSS数据库的数据源
	private static BasicDataSource ds = null;

	static {
		init();
	}
	
	public static void init(){
		dataSource = ConnectionEx.getDataSource();
		
    	ds = new BasicDataSource();
    	ds.setDriverClassName(Config12350.driveclass);
    	ds.setUrl( Config12350.driveUrl);
    	ds.setUsername(Config12350.userName);
    	ds.setPassword(Config12350.userPwd);
    	ds.setInitialSize(3);
    	ds.setMaxIdle(2);
	}
	
	public static synchronized Connection  getConnection() {
        try{
        	//System.out.println("初始连接数" + ds.getInitialSize() + ",当前活动的数据库链接数" + ds.getNumActive() + ",当前非活动状态的" + ds.getNumIdle());
        	return ds.getConnection();
        }catch (Exception e) {
            e.printStackTrace();
        }
        return null;
	}
	
	private static void test(){
		Connection con = null;
        try{
        	con =  ds.getConnection();
        	ResultSet rs = con.createStatement().executeQuery(" select done_code0.nextval val from dual ");
        	System.out.println(rs.getInt("val"));
        	rs.close();
        }catch (Exception e) {
            e.printStackTrace();
        }finally{
        	try{
        		con.close();
        	}catch(Exception xe){
        	}
        }
	}
	
    //获得深运数据链接
	public static DataSource getShenYunDataSource() {
		return dataSource;
	}
	
}