自定义连接池

普通的数据库连接

连接资源宝贵，需要对连接进行管理，

操作数据：创建连接

操作结束：关闭连接

分析：然而在程序中频繁的打开和关闭连接会影响程序的运行的效率

自定义的数据库的连接池：

预先创建一个连接，用的时候取出一个，用完后放回。能够提高程序的运行效率。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.util.LinkedList;

/**
 * 自定义连接池类
    1.    创建连接池类
    2.    指定一些全局参数，
    初始化连接数量，
    最大连接数，
    当前连接数，
    连接池集合(用来存放连接的)
    3.    构造函数，循环创建初始化连接数目，
    4.    写一个创建连接的方法，
    5.    写一个获取连接的方法：先判断连接池中是否有连接，如果有直接使用，如果没有连接，则先判断当前的连接是否达到最大连接数，达到的话 抛出异常，没有达到最大连接 则创建连接。
    6.    写一个释放连接的方法：把连接放回连接池（集合）中。如果池中连接数小初始化连接数目就放回池中，其他则关闭连接。
 * @author xinqi
 *
 */
public class MyPool {
    
    //初始化连接数目
    private int initCount = 3;
    //最大连接数目
    private int initMaxCount = 6;
    //记录当前使用 的连接数目
    private int currentCount = 0;
    
    //连接池   使用linkedList集合存储   存放初始化的连接
    private LinkedList<Connection> connectionPool = new LinkedList<>();
    
    
    //构造函数  初始化连接
    public MyPool(){
        //初始化3个连接
        for(int i=0;i<3;i++){
            connectionPool.add(createConnection());
        }
    }
        
    /**
     * 创建连接的方法
     * @return  Connection
     */
    public    Connection createConnection(){
            
        try {
            Class.forName("com.mysql.jdbc.Driver");
            return DriverManager.getConnection("jdbc:mysql://localhost:3306/test","root","root");
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return null;
    }
    
    /**
     * 获取连接的方法
     * @return
     */
    public Connection getConnection(){
        
        //1.判断，池中若有连接直接使用
        if(connectionPool.size()>0){
            //把这个链接移出集合并返回当前连接对象。
            currentCount++;
            return connectionPool.removeFirst();
            
        }
        //如果池中没有连接而且没有达到最大连接数目；则创建连接
        if(currentCount>=initCount && currentCount<initMaxCount){
            currentCount++;
            //创建一个新的连接
            return createConnection();
        }
        //判断是否达到最大连接数，达到则抛出异常
        throw new RuntimeException("当前连接已经达到最大连接数！");
    }
    
    
    /**
     * 释放连接的方法
     * @param conn
     */
    public void releaseConnection(Connection conn){
        //判断池中的数目如果小于初始化连接就放回连接池中。
        
        //判断连接池中的剩余数目是否<连接池初始化数目   如果为真 则放回连接池
        //
        
        if(currentCount<=initCount){
            //放回连接池
            connectionPool.addLast(conn);
            //当前连接-1
            currentCount--;
            
        }else{
            //关闭连接
            try {
                conn.close();
                currentCount--;
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
    
    
    public static void main(String[] args) {
        
        MyPool pool = new MyPool();
        
        Connection conn1 = pool.getConnection();
        Connection conn2 = pool.getConnection();
        Connection conn3 = pool.getConnection();
        Connection conn4 = pool.getConnection();
        
        
        System.out.println("池中初始化的连接:"+pool.initCount);
        System.out.println("最大连接数目:"+pool.initMaxCount);
        
        System.out.println("池中剩余连接:"+pool.connectionPool.size());
        System.out.println("当前连接数目:"+pool.currentCount);
        
    }
}