package com.hero.Dao;



import java.sql.Connection;

import java.sql.SQLException;

import java.util.HashMap;

import java.util.Map;

import javax.sql.DataSource;

import org.apache.commons.dbcp.BasicDataSource;

/**

 * @author Hero

 *

 * dbcp 实用类，提供了dbcp连接，不允许继承；

 * 

 * 该类需要有个地方来初始化 DS ，通过调用initDS 方法来完成，可以在通过调用带参数的构造函数完成调用，

 * 可以在其它类中调用，也可以在本类中加一个static{}来完成；

 */

public final class MySqlDbPool {

	/** 数据源，static */

	private static DataSource DS;

	/** 从数据源获得一个连接 */

	public Connection getConn() {

		Connection con = null;

		if (DS!= null) {

			try {

				con = DS.getConnection();

			} catch (Exception e) {

				e.printStackTrace(System.err);

			}

			

			try {

				con.setAutoCommit(false);

			} catch (SQLException e) {

				e.printStackTrace();

			}

			return con;

		}

		return con;

	}

	/** 默认的构造函数 */

	public MySqlDbPool() {

	}

	/** 构造函数，初始化了 DS ，指定 数据库 */

	public MySqlDbPool(String connectURI) {

		initDS(connectURI);

	}

	/** 构造函数，初始化了 DS ，指定 所有参数 */

	public MySqlDbPool(String connectURI, String username, String pswd, String driverClass, int initialSize,

			int maxActive, int maxIdle, int maxWait) {

		initDS(connectURI, username, pswd, driverClass, initialSize, maxActive, maxIdle, maxWait);

	}

	/**

	 * 创建数据源，除了数据库外，都使用硬编码默认参数；

	 * 

	 * @param connectURI 数据库

	 * @return

	 */

	public static void initDS(String connectURI) {

		initDS(connectURI, "root", "sa", "com.mysql.jdbc.Driver", 10, 100, 30, 10000);

	}

	/** 

	 * 指定所有参数连接数据源

	 * 

	 * @param connectURI 数据库

	 * @param username 用户名

	 * @param pswd 密码

	 * @param driverClass 数据库连接驱动名

	 * @param initialSize 初始连接池连接个数

	 * @param maxActive 最大激活连接数

	 * @param maxIdle 最大闲置连接数

	 * @param maxWait 获得连接的最大等待毫秒数

	 * @return

	 */

	public static void initDS(String connectURI, String username, String pswd, String driverClass, int initialSize,

			int maxActive, int maxIdle, int maxWait) {

		BasicDataSource ds = new BasicDataSource();

		ds.setDriverClassName(driverClass);

		ds.setUsername(username);

		ds.setPassword(pswd);

		ds.setUrl(connectURI);

		ds.setInitialSize(initialSize); // 初始的连接数；

		ds.setMaxActive(maxActive);

		ds.setMaxIdle(maxIdle);

		ds.setMaxWait(maxWait);

		DS = ds;

	}

	/** 获得数据源连接状态 */

	public static Map<String, Integer> getDa