JDBC-数据库连接池（druid）

news2024/11/15 21:49:05

一、背景

在介绍JDBC基本概念中，似乎Java程序每次与数据库交互都要通过驱动创建一个新的连接对象（Connection），再由连接对象创建一个可执行SQL的Statement对象（或PreparedStatement对象），操作完成后又将这些资源释放。频繁的对象创建显然会是一个耗时的动作，于是数据库连接池产生了。

二、概念

根据维基百科：In software engineering, a connection pool is a cache of database connections maintained so that the connections can be reused when future requests to the database are required.

数据库连接池是一个容器，负责分配、管理数据库连接，可以重复使用数据库连接对象而不是创建一个新的，当使用完成后，这个数据库连接将被归还到连接池，如下图所示：

三、实现

市场上有多种数据库连接池，我们采用阿里巴巴的druid作为示例。

（1）引入druid依赖

<!-- https://mvnrepository.com/artifact/com.alibaba/druid -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>1.1.23</version>
        </dependency>

（2）配置druid.properties：

#驱动加载
driverClassName=com.mysql.cj.jdbc.Driver
#地址
url=jdbc:mysql://
#连接数据库的用户名
username=
#连接数据库的密码
password=
#属性类型的字符串，通过别名的方式配置扩展插件， 监控统计用的stat 日志用log4j 防御sql注入:wall
filters=stat
#初始化时池中建立的物理连接个数。
initialSize=2
#最大的可活跃的连接池数量
maxActive=300
#获取连接时最大等待时间，单位毫秒，超过连接就会失效。配置了maxWait之后，缺省启用公平锁，并发效率会有所下降， 如果需要可以通过配置useUnfairLock属性为true使用非公平锁。
maxWait=60000
#连接回收器的运行周期时间，时间到了清理池中空闲的连接，testWhileIdle根据这个判断
timeBetweenEvictionRunsMillis=60000
minEvictableIdleTimeMillis=300000
#用来检测连接是否有效的sql，要求是一个查询语句。
validationQuery=SELECT 1
#建议配置为true，不影响性能，并且保证安全性。 申请连接的时候检测，如果空闲时间大于timeBetweenEvictionRunsMillis， 执行validationQuery检测连接是否有效。
testWhileIdle=true
#申请连接时执行validationQuery检测连接是否有效，做了这个配置会降低性能。设置为false
testOnBorrow=false
#归还连接时执行validationQuery检测连接是否有效，做了这个配置会降低性能,设置为flase
testOnReturn=false
#是否缓存preparedStatement，也就是PSCache。
poolPreparedStatements=false
#池中能够缓冲的preparedStatements语句数量
maxPoolPreparedStatementPerConnectionSize=200

（3）代码实现

    public static Connection getConnection() {

        Connection connection = null;

        try {

            Properties prop = new Properties();
            prop.load(new FileInputStream("src/druid.properties"));
            DataSource dataSource = DruidDataSourceFactory.createDataSource(prop);
            connection = dataSource.getConnection();
        } catch (Exception e) {
            e.printStackTrace();
        }

        return connection;
    }