package e_office.systemframework.pool; /***编者:李国庆*类的描述信息:此类为一个数据库连接池类，是一个单态的类，其中对数据库连接的信息*都放在一个属性文件中，可以进行方便的设置****最后修改时间:2006-1-12 10:30**********/import java.sql.*;import java.io.*;import java.util.*;import javax.servlet.ServletException;import javax.servlet.http.HttpServlet;import javax.servlet.http.HttpServletRequest;import javax.servlet.http.HttpServletResponse; import javax.servlet.*;import javax.servlet.http.*;import java.util.ResourceBundle; /** * 这是一个数据库连接池 *访问属性文件：mypool.properties *返回一个Connection * */ public class ConnectionPool{ private int minConn;        //最少连接数 private int maxConn;        //最大连接数 private String user;        //用户名 private String password;    //数据库密码 private int connAmount;       //现有连接个数 private Stack connStack;     //使用Stack保存数据库连接 private String dry;            //驱动 private String connString;    //连接字符串    private static ConnectionPool  connectionPool; private int waitTime;               //忙时的等告待时间 static ResourceBundle  bundle=null;    //属性文件读取    /**  *返回一个实例。如果是第一次调用此方法则个建一个实例  */  public static  synchronized ConnectionPool getInstance(){   if(connectionPool==null){    connectionPool = new ConnectionPool();   }   return connectionPool;  }   /**  *读属性文件得到数据库连接信息及连接池信息  */  public void readProperties(){       try   {    bundle=ResourceBundle.getBundle("properties.mypool");    this.user=bundle.getString("user");    this.password = bundle.getString("password");    this.connString=bundle.getString("connString");    this.dry = bundle.getString("dry");       this.minConn=Integer.parseInt(bundle.getString("minConn"));    System.out.println("this  mincon:"+this.minConn);    this.maxConn=Integer.parseInt(bundle.getString("maxConn"));    this.waitTime=Integer.parseInt(bundle.getString("waitTime"));           }   catch(Exception w) { w.toString();  }   System.out.println("初始化成功..........");     }    private ConnectionPool(){   readProperties();   this.connStack = new Stack();   System.out.println(this.dry);   try{    Class.forName(this.dry);   }catch(Exception e){    e.printStackTrace();   }   for(int i = 0;i<this.minConn;i++){    System.out.println("myPool:"+i);    connStack.push(newConnection());   }  }    /**   *从连接池得到连接   */   public synchronized Connection getConnection(){    Connection conn = null;    System.out.println("user connection:"+this.connStack.size());    if(!this.connStack.empty()){     conn = (Connection)connStack.pop();     System.out.println("得到一个连接");    }else if(this.connAmount<this.maxConn){     conn = newConnection();    }else{     try{      wait(this.waitTime);      System.out.println("等待");      return getConnection();     }catch(Exception e){      e.printStackTrace();     }    }    return conn;   }      /**    /*释放连接    */    public synchronized void freeConnection(Connection con){     this.connStack.push(con);     System.out.println("归还连接");     notifyAll();    }     /**   *创建新连接   */   public Connection newConnection(){    Connection conn=null;    try{         conn = DriverManager.getConnection(this.connString,this.user,this.password);     this.connAmount++;     System.out.println("连接池创建一个连接"+conn.toString());     return conn;    }catch(Exception e){     e.printStackTrace();     return null;    }   } }  

评论