dbpool.java

中国移动定位引擎的客户端

package ffcs.db;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.io.Reader;
import org.logicalcobwebs.proxool.configuration.JAXPConfigurator;
import org.logicalcobwebs.proxool.ProxoolFacade;
import ffcs.util.Resources;
/**
 * <p>Title: </p>
 * <p>Description:采用 proxool连接池的工具类,该类装载时自动根据配置文件初始化数据库的连接池</p>
 * <p>Copyright: Copyright (c) 2005</p>
 * <p>Company: </p>
 * @author not attributable
 * @version 1.0
 */
public class DBPool {
  //默认的连接池全称
  public final static String DEFAULT_POOL_FULLNAME = "proxool.mypool";
  public final static String DEFAULT_POOL_NAME="mypool";
  /*  初始连接也,配置文件为 proxool.xml */
  static {
    try {
      Class.forName("org.logicalcobwebs.proxool.ProxoolDriver");

      Reader reader = Resources.getResourceAsReader("proxool.xml");
      JAXPConfigurator.configure(reader, false);
    }
    catch (ClassNotFoundException e) {
      System.out.println("找不驱动程序:org.logicalcobwebs.proxool.ProxoolDriver");
    }
    catch (java.io.IOException fnfe) {
      System.out.println("找不到配置文件:proxool.xml");
    }
    catch (Exception e) {
      e.printStackTrace();
    }
  }
  /**
   * 得到默认的连接池的连接
   * @return Connection
   */
  public final static Connection getConnection() throws SQLException{
    return getConnection(DEFAULT_POOL_FULLNAME);
  }
  /**
   * 得到指定连接池的连接
   * @param poolName String
   * @return Connection
   */
  public final static Connection getConnection(String poolName)throws SQLException {
     return DriverManager.getConnection(poolName);
  }
  /**
   * 销毁默认的连接池,释放资源
   */
  public static void destroyPool() {
    try {
      ProxoolFacade.removeConnectionPool(DEFAULT_POOL_NAME);
    
    }
    catch (Exception e) {
      e.printStackTrace();
    }
  }

  /**
   * 销毁指定名字的连接池,释放资源
   * @param poolName String
   */
  public static void destroyPool(String poolName) {
    try {
      ProxoolFacade.removeConnectionPool(poolName);
    }
    catch (Exception e) {
      e.printStackTrace();
    }
  }

  /**
   * 简单测试
   * @param args String[]
   * @throws Exception
   */

  public static void main(String[] args) throws Exception {
		int connSize = 1;
		Connection[] conns = new Connection[connSize];

		for (int i = 0; i < connSize; i++) {
			conns[i] = getConnection();
			System.out.println(conns[i]);
		}
		Thread.sleep(10000000);
		System.exit(0);
  }
}