数据库连接池技术 之 Druid[通俗易懂]

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.13</version>
</dependency>
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid</artifactId>
    <version>1.1.17</version>
</dependency>

driverClassName=com.mysql.cj.jdbc.Driver
url=jdbc:mysql://localhost:3306/test?useSSL=false&serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=UTF8&autoReconnect=true&failOverReadOnly=false
username=root
password=root
	

#检测数据库链接是否有效，必须配置
validationQuery=SELECT 'x'
#初始连接数
initialSize=3
#最大连接池数量
maxActive=10
#去掉，配置文件对应去掉
#maxIdle=20
#配置0,当线程池数量不足，自动补充。
minIdle=0
#获取链接超时时间为1分钟，单位为毫秒。
maxWait=60000
#获取链接的时候，不校验是否可用，开启会有损性能。
testOnBorrow=false
#归还链接到连接池的时候校验链接是否可用。
testOnReturn=false
#此项配置为true即可，不影响性能，并且保证安全性。意义为：申请连接的时候检测，如果空闲时间大于timeBetweenEvictionRunsMillis，执行validationQuery检测连接是否有效。
testWhileIdle=true
#1.Destroy线程会检测连接的间隔时间
#2.testWhileIdle的判断依据
timeBetweenEvictionRunsMillis=60000
#一个链接生存的时间（之前的值：25200000，这个时间有点BT，这个结果不知道是怎么来的，换算后的结果是：25200000/1000/60/60 = 7个小时）
minEvictableIdleTimeMillis=300000
#链接使用超过时间限制是否回收
removeAbandoned=false
#超过时间限制时间（单位秒），目前为5分钟，如果有业务处理时间超过5分钟，可以适当调整。
removeAbandonedTimeout=300
#链接回收的时候控制台打印信息，测试环境可以加上true，线上环境false。会影响性能。
logAbandoned=false

import com.alibaba.druid.pool.DruidDataSourceFactory;

import javax.sql.DataSource;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

public class DBUtil { 
     
    private static final ThreadLocal<Connection> threadLocal = new ThreadLocal<>();
    private static DataSource dataSource = null;

    static { 
         //配置文件加载，只执行一次
        try (InputStream is = DBUtil.class.getResourceAsStream("/mysql.properties");) { 
     
            Properties properties = new Properties();
            properties.load(is);
            dataSource = DruidDataSourceFactory.createDataSource(properties);
        } catch (Exception e1) { 
     
            throw new RuntimeException("读取配置文件异常", e1);
        }
    }
    public static Connection getConnection() { 
         //获取连接
        Connection conn = null;
        try { 
     
            conn = threadLocal.get();//从当前线程获得conn
            if (conn == null || conn.isClosed()) { 
      //重点，需要注意conn.isClosed()条件的判断
                conn = dataSource.getConnection();
                threadLocal.set(conn);
            }
        } catch (Exception e) { 
     
            throw new RuntimeException("连接数据库异常", e);
        }
        return conn;
    }
    public  static QueryRunner getQueryRunner(){ 
     
        return  new QueryRunner(dataSource);
    }
	public static void release(ResultSet rs, Statement stmt, Connection conn) { 
     
		try { 
      // 建议采用这种形式来释放资源，因为finally里面的一定会被释放
			if (rs != null) { 
     
				rs.close();
			}
		} catch (SQLException e) { 
     
			e.printStackTrace();
		} finally { 
     
			try { 
     
				if (stmt != null) { 
     
					stmt.close();
				}
			} catch (SQLException e) { 
     
				e.printStackTrace();
			} finally { 
     
				if (conn != null) { 
     
					try { 
     
						conn.close();
					} catch (SQLException e) { 
     
						e.printStackTrace();
					}
				}
			}
		}
	}

}

public static void main(String[] args) throws SQLException { 
     
    for(int i=0;i<5;i++){ 
      //开启5个线程
        new Thread(()->{ 
     //在每个线程中获取Connection对象，并输出
            Connection conn = getConnection();
            System.out.println(conn);
        }).start();
    }
}

initialSize=3
maxActive=4

public class DemoTest { 
     
    @Test
    public void insert() throws SQLException { 
     
        String sql ="insert into tb_dept values (?,?,?)";
        Connection conn = DBUtil.getConnection();
        PreparedStatement ps = conn.prepareStatement(sql);
        ps.setInt(1,11);
        ps.setString(2,"aa");
        ps.setString(3,"aaaaa");
        ps.executeUpdate();
        DBUtil.release(null,ps,conn);
    }
    @Test
    public void update() throws SQLException { 
     
        String sql ="update tb_dept set dname=?,loc =? where deptno =?";
        Connection conn = DBUtil.getConnection();
        PreparedStatement ps = conn.prepareStatement(sql);
        ps.setString(1,"b");
        ps.setString(2,"bbbbb");
        ps.setInt(3,11);
        ps.executeUpdate();
        DBUtil.release(null,ps,conn);
    }
    @Test
    public void delete() throws SQLException { 
     
        String sql ="delete from tb_dept where deptno =?";
        Connection conn = DBUtil.getConnection();
        PreparedStatement ps = conn.prepareStatement(sql);
        ps.setInt(1,11);
        ps.executeUpdate();
        DBUtil.release(null,ps,conn);
    }
    @Test
    public void select() throws SQLException { 
     
        String sql ="select * from tb_dept where deptno =?";
        Connection conn = DBUtil.getConnection();
        PreparedStatement ps = conn.prepareStatement(sql);
        ps.setInt(1,10);
        ResultSet res = ps.executeQuery();
        while (res.next()){ 
     
            Dept  dept = new Dept(res.getInt("deptno"),res.getString("dname"),res.getString("loc"));
            System.out.println(dept);
        }
        DBUtil.release(res,ps,conn);
    }
}