testpool.java

此为连接池实现程序

/**
 * @author 肖建军
 * 数据库连接池测试
 */

package com.sunrise.chnl.sql;

import java.sql.*;

public class TestPool {
  public TestPool(){

  }
  public void test1() {
    String user = "stchnl";
    String password = "manager";
    String driver = "com.microsoft.jdbc.sqlserver.SQLServerDriver";
    String url = "jdbc:microsoft:sqlserver://10.200.2.54:1433;DatabaseName=stchnl";
    ConnectionParam param = new ConnectionParam(driver,url,user,password);
    ConnectionFactory cf = null;//new ConnectionFactory(param, new FactoryParam());
    try{
      cf = new ConnectionFactory(param,new FactoryParam());
      Connection conn1 = cf.getFreeConnection();
      Statement stmt = conn1.createStatement();
      ResultSet rs = stmt.executeQuery("select * from TC_ID_TYP");
      System.out.println("conn1 begin：");
      while(rs.next()){
        System.out.println(rs.getString(2).trim());
      }
      rs.close();
      stmt.close();
      System.out.println("conn2 begin：");
      Connection conn2 = cf.getFreeConnection();
      stmt = conn2.createStatement();
      rs = stmt.executeQuery("select * from TC_ID_TYP");
      while(rs.next()){
        System.out.println(rs.getString(2).trim());
      }
      rs.close();
      stmt.close();
      System.out.println("conn3 begin：");
      Connection conn3 = cf.getFreeConnection();
      stmt = conn3.createStatement();
      rs = stmt.executeQuery("select * from TC_ID_TYP");
      while(rs.next()){
        System.out.println(rs.getString(2).trim());
      }
      rs.close();
      stmt.close();
      System.out.println("conn4 begin：");
      Connection conn4 = cf.getFreeConnection();
      stmt = conn4.createStatement();
      rs = stmt.executeQuery("select * from TC_ID_TYP");
      while(rs.next()){
        System.out.println(rs.getString(2).trim());
      }
      rs.close();
      stmt.close();
      System.out.println("conn5 begin：");
      Connection conn5 = cf.getFreeConnection();
      stmt = conn5.createStatement();
      rs = stmt.executeQuery("select * from TC_ID_TYP");
      while(rs.next()){
        System.out.println(rs.getString(2).trim());
      }
      rs.close();
      stmt.close();
      //conn1.close();
      //conn2.close();
      //conn3.close();
      //conn4.close();
      //conn5.close();
    }catch(Exception e){e.printStackTrace(); }
    finally{
      try{
        cf.close();
      }catch(Exception e){e.printStackTrace();}
    }
  }

  public static void main(String[] args) {
    /*String user = "stchnl";
    String password = "manager";
    String driver = "com.microsoft.jdbc.sqlserver.SQLServerDriver";
    String url = "jdbc:microsoft:sqlserver://10.200.2.54:1433;DatabaseName=stchnl";
    ConnectionParam param = new ConnectionParam(driver,url,user,password);
    ConnectionFactory cf = null;
    try{
      cf = new ConnectionFactory(param,new FactoryParam());
      ConnectionFactory cf1= new ConnectionFactory(param,new FactoryParam());
      Connection conn1 = null;
      long time = System.currentTimeMillis();
      for (int i=0; i <10;i++){
        conn1 = cf.getFreeConnection();
        Statement stmt = conn1.createStatement();
        ResultSet rs = stmt.executeQuery("select * from TC_EMP_INF");
        if (rs.next()){
          System.out.println("conn1 y");
        }
        else{
          System.out.println("conn1 n");
        }
        conn1.close();
      }
      System.out.println("pool:" + (System.currentTimeMillis()-time));
      time = System.currentTimeMillis();
      Class.forName(param.getDriver()).newInstance();
      for (int i=0; i <10;i++){
        conn1 = DriverManager.getConnection(param.getUrl(),param.getUser(), param.getPassword());
        Statement stmt = conn1.createStatement();
        ResultSet rs = stmt.executeQuery("select * from TC_EMP_INF");
        if (rs.next())    {
          System.out.println("conn1 y");
        }
        else{
          System.out.println("conn1 n");
        }
        conn1.close();
      }
      System.out.println("no pool:" + (System.currentTimeMillis()-time));
    }catch(Exception e){e.printStackTrace();}
    finally{
      try{
        cf.close();
      }catch(Exception e){e.printStackTrace(); }
    }*/
    TestPool test=new TestPool();
    test.test1();
  }
}