jdbc----连接池和数据源

什么是数据源？
就是用来创建连接的，和DriverManager一样，只不过数据源（DataSource）
他的优势是：创建连接的速度快，通过DataSource创建的Connection是被包裹后的，他的close方法已经被修改，他close是放到池里面去，而数据源内部会有一个连接池，而我们的程序之和数据源打交道，不会直接访问到连接池，因为的池是包内有好，而我们的程序一般和开源组织提供的类肯定不是在同一个包下，所以我们访问不到。


public class MyDataSource{
  private static String url = "jdbc:mysql://localhost:3306/jdbc";
  private static String user = "root";
  private static pwd = "";
  private List<Connection> connsPool = new LinkedList<Connection>();
  
  public MyDataSource(){
    try{
	    for(int i=0;i<10;i++){
	       this.connsPool.addLast(this.createConnection()); //加到最后，这是先进先出的算法
	    }
    }catch(SQLException e){
       throw new ExceptionInInitializerError(e); //因为在初始化的时候就出现异常，这是很严重的，所以要让调用它的那层知道，所以需要向上抛
    }
  }
  
  public Connection getConnection(){
    return this.connsPool.removeFirst();//从前面拿到
  }
  
  
  private Connection createConnection() throws Exception{
     return DriverManager.getConnection(url,user,pwd);
  }
  
  public  void free(Connection conn){
     this.connsPool.addLast(conn);
  }
  
}


然后在jdbcUtils中加上一个属性，也就是让jdbcUtils问MyDataSource要连接

public Connection getConnection(){
  return myDataSource.getConnection();
}

public void free(Connection conn){
  return myDataSource.free(conn);
}



//---下面改造这个Conn,我们使用代理来完成这个工作，在连接池里面就创建出代理，然后我们的代理调用close方法是来把资源放回去

class MyConnection implements Connection{ //伪装成Conn
    Connection conn ;
    MyDataSource dataSource;
    MyConnection(Connection conn,MyDataSource dataSource){ //注意，如果不写public那么是包友好，这样的话，别人是拿不到MyConnection的
       this.conn = conn;
       this.dataSource = dataSource;
    }
    
    public void close(){
       this.dataSource.connsPool.addLast(this);
    }
    
    。。。。。
    
}

public class MyDataSource{
  private static String url = "jdbc:mysql://localhost:3306/jdbc";
  private static String user = "root";
  private static pwd = "";
  private static int initCount = 5;
  private static int maxCount = 10;
  private int currentCount = 0;
  private List<Connection> connsPool = new LinkedList<Connection>();
  
  public MyDataSource(){
    try{
	    for(int i=0;i<initCount;i++){
	       this.connsPool.addLast(this.createConnection()); 
	        currentCount ++;
	    }
    }catch(SQLException e){
       throw new ExceptionInInitializerError(e); 
    }
  }
  
  public Connection getConnection(){
     synchronized(connsPool){
        if(this.connsPool.size()>0){
    			return this.connsPool.removeFirst();
    		}else if(this.currentCount < maxCount){
    		  this.currentCount ++;
    		   return this.createConnection();
    		}
    		throw new SQLException("已经没有可用的连接");
    }
  }
  
  
  private Connection createConnection() throws Exception{
  	Connection conn = DriverManager.getConnection(url,user,pwd);
  	Connection conn = new MyConnection(conn,this); //把包装类给别人。。。。这个地方不同了
     return conn;
  }
  
  public  void free(Connection conn){   
     this.connsPool.addLast(conn);
  }
  
}

//---------------下面是开源的阿帕奇写的DBCP--------------------------------------

1.使用DBCP必须用的三个包
commons-dbcp-1.2.1.jar
commons-pool-1.2.jar
commons.collections-3.1.jar

2.配置--XX.properties

3.java API
BasicDataSourceFactory.createDataSource(prop);