glls

Appearance

JDBC开发时，每次创建和销毁数据库的连接对象，都会占用一定的时间和IO资源。假设网站有很大的访问量，如果数据库服务器为每次连接都创建连接连接，会极大的浪费数据库的资源，对程序的性能影响很大。

针对这个问题提出了数据库连接池的解决方案，通过数据库连接池，避免了频繁的创建和销毁连接对象**。数据库连接池负责分配,管理和释放数据库连接,它允许应用程序重复使用一个现有的数据库连接,而不是重新建立一个。**

img

数据库连接池在初始化时将创建一定数量的数据库连接放到连接池中, 这些数据库连接的数量是由最小数据库连接数来设定的。无论这些数据库连接是否被使用,连接池都将一直保证至少拥有这么多的连接数量。连接池的最大数据库连接数量限定了这个连接池能占有的最大连接数，当应用程序向连接池请求的连接数超过最大连接数量时，这些请求将被加入到等待队列中.

常见的连接池有DBCP、C3P0、Druid等，国内项目一般使用Druid连接池

1 Druid使用 ​

下载地址：https://repo1.maven.org/maven2/com/alibaba/druid/

1.1 导入jar ​

导入 druid-1.1.22.jar

1.2 druid配置文件 ​

properties
# 文件名 druid.properties 存储在src目录下
driverClassName=com.mysql.cj.jdbc.Driver
url=jdbc:mysql://localhost:3306/db2210?serverTimezone=Asia/Shanghai&useSSL=true
username=root
password=root
# 初始化数据库连接池中连接个数
initialSize=5
# 最大个数
maxActive=20
# TimeOut 等待超时时间
maxWait=2000

1.3 读取配置文件 ​

java
package com.glls.connpool;

import java.io.FileInputStream;
import java.sql.Connection;
import java.util.Properties;

import javax.sql.DataSource;

import com.alibaba.druid.pool.DruidDataSourceFactory;

public class App {

	public static void main(String[] args) throws Exception {
		// 读取配置文件
		Properties prop = new Properties();
		prop.load(new FileInputStream("src/druid.properties"));
		// 获取druid连接池对象
		DataSource dataSource = DruidDataSourceFactory.createDataSource(prop);
		// 通过连接池获取连接对象
		Connection connection = dataSource.getConnection();
		System.out.println(connection);
		// 关闭连接
		connection.close();
	}
}

1.4 与DbUtils结合 ​

java
package com.glls.connpool;

import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.util.Properties;

import javax.sql.DataSource;

import org.apache.commons.dbutils.QueryRunner;

import com.alibaba.druid.pool.DruidDataSourceFactory;

public class DruidUtils {
	
	private static DataSource dataSource = null;
	
	static {
		// 读取配置文件
		Properties prop = new Properties();
		try {
			prop.load(new FileInputStream("src/druid.properties"));
			// 获取druid连接池对象
			dataSource = DruidDataSourceFactory.createDataSource(prop);
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
	}
	
	public static QueryRunner getQueryRunner() {
        return new QueryRunner(dataSource);
    }

}

附录 ​

Druid配置参数 ​

配置缺省值说明
name配置这个属性的意义在于，如果存在多个数据源，监控的时候可以通过名字来区分开来。 如果没有配置，将会生成一个名字，格式是："DataSource-" + System.identityHashCode(this)
jdbcUrl连接数据库的url，不同数据库不一样。例如： mysql : jdbc:mysql://localhost:3306/db oracle : jdbc:oracle:thin:@localhost:1521:db
username连接数据库的用户名
password连接数据库的密码。如果你不希望密码直接写在配置文件中，可以使用ConfigFilter。详细看这里：https://github.com/alibaba/druid/wiki/使用ConfigFilter
driverClassName根据url自动识别这一项可配可不配，如果不配置druid会根据url自动识别dbType，然后选择相应的driverClassName(建议配置下)
initialSize0初始化时建立物理连接的个数。初始化发生在显示调用init方法，或者第一次getConnection时
maxActive8最大连接池数量
maxIdle8已经不再使用，配置了也没效果
minIdle最小连接池数量
maxWait获取连接时最大等待时间，单位毫秒。配置了maxWait之后，缺省启用公平锁，并发效率会有所下降，如果需要可以通过配置useUnfairLock属性为true使用非公平锁。
poolPreparedStatementsfalse是否缓存preparedStatement，也就是PSCache。PSCache对支持游标的数据库性能提升巨大，比如说oracle。在mysql下建议关闭。
maxOpenPreparedStatements-1要启用PSCache，必须配置大于0，当大于0时，poolPreparedStatements自动触发修改为true。在Druid中，不会存在Oracle下PSCache占用内存过多的问题，可以把这个数值配置大一些，比如说100
validationQuery用来检测连接是否有效的sql，要求是一个查询语句。如果validationQuery为null，testOnBorrow、testOnReturn、testWhileIdle都不会其作用。
testOnBorrowtrue申请连接时执行validationQuery检测连接是否有效，做了这个配置会降低性能。
testOnReturnfalse归还连接时执行validationQuery检测连接是否有效，做了这个配置会降低性能
testWhileIdlefalse建议配置为true，不影响性能，并且保证安全性。申请连接的时候检测，如果空闲时间大于timeBetweenEvictionRunsMillis，执行validationQuery检测连接是否有效。
timeBetweenEvictionRunsMillis有两个含义： 1) Destroy线程会检测连接的间隔时间2) testWhileIdle的判断依据，详细看testWhileIdle属性的说明
numTestsPerEvictionRun不再使用，一个DruidDataSource只支持一个EvictionRun
minEvictableIdleTimeMillis
connectionInitSqls物理连接初始化的时候执行的sql
exceptionSorter根据dbType自动识别当数据库抛出一些不可恢复的异常时，抛弃连接
filters属性类型是字符串，通过别名的方式配置扩展插件，常用的插件有： 监控统计用的filter:stat日志用的filter:log4j防御sql注入的filter:wall
proxyFilters类型是List<com.alibaba.druid.filter.Filter>，如果同时配置了filters和proxyFilters，是组合关系，并非替换关系

C3P0使用 ​

1.1 导入jar文件 ​

c3p0-0.9.5.5.jar

mchange-commons-java-0.2.19.jar

1.2 c3p0的配置文件 ​

xml
<?xml version="1.0" encoding="UTF-8"?>

<c3p0-config>
	<default-config>
		 <property name="driverClass">com.mysql.jdbc.Driver</property>
		 <property name="jdbcUrl">jdbc:mysql:///db1702</property>
		 <property name="user">root</property>
		 <property name="password">root</property>
		 
		 <property name="initialPoolSize">3</property>
		 <property name="maxPoolSize">6</property>
		 <property name="maxIdleTime">2000</property>
	</default-config>
	
	<named-config name="myconfig">
		 <property name="driverClass">com.mysql.jdbc.Driver</property>
		 <property name="jdbcUrl">jdbc:mysql:///supermarket</property>
		 <property name="user">root</property>
		 <property name="password">root</property>
		 
		 <property name="initialPoolSize">3</property>
		 <property name="maxPoolSize">6</property>
		 <property name="maxIdleTime">2000</property>
	
	</named-config>
	
</c3p0-config>

1.3 获取连接对象 ​

java
public void testC3P02(){
		
    //会自动加载src下的c3p0-config.xml,读取default-config
    //ComboPooledDataSource dataSource = new ComboPooledDataSource();

    //读取配置文件中指定名称的配置
    ComboPooledDataSource dataSource = new ComboPooledDataSource("myconfig");

    try {
        Connection connection = dataSource.getConnection();
        System.out.println(connection);
        connection.close();


    } catch (SQLException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
}

1.4 与DBUtils结合使用 ​

java
public class JdbcUtils {
    private static ComboPooledDataSource dataSource = null;

    static {
        dataSource = new ComboPooledDataSource();
    }

    public static QueryRunner getQueryRunner() {
        // 参数使用连接池对象，QueryRunner内部管理连接对象
        return new QueryRunner(dataSource);
    }
}

1.5 C3P0参数 ​

java
<c3p0-config>
  <default-config>
    <!--当连接池中的连接耗尽的时候c3p0一次同时获取的连接数。Default: 3 -->
    <property name="acquireIncrement">3</property>
    
    <!--定义在从数据库获取新连接失败后重复尝试的次数。Default: 30 -->
    <property name="acquireRetryAttempts">30</property>
    
    <!--两次连接中间隔时间，单位毫秒。Default: 1000 -->
    <property name="acquireRetryDelay">1000</property>
    
    <!--连接关闭时默认将所有未提交的操作回滚。Default: false -->
    <property name="autoCommitOnClose">false</property>
    
    <!--c3p0将建一张名为Test的空表，并使用其自带的查询语句进行测试。如果定义了这个参数那么
  属性preferredTestQuery将被忽略。你不能在这张Test表上进行任何操作，它将只供c3p0测试
  使用。Default: null-->
    <property name="automaticTestTable">Test</property>
    
    <!--获取连接失败将会引起所有等待连接池来获取连接的线程抛出异常。但是数据源仍有效
  保留，并在下次调用getConnection()的时候继续尝试获取连接。如果设为true，那么在尝试
  获取连接失败后该数据源将申明已断开并永久关闭。Default: false-->
    <property name="breakAfterAcquireFailure">false</property>
    
    <!--当连接池用完时客户端调用getConnection()后等待获取新连接的时间，超时后将抛出
  SQLException,如设为0则无限期等待。单位毫秒。Default: 0 --> 
    <property name="checkoutTimeout">100</property>
    
    <!--通过实现ConnectionTester或QueryConnectionTester的类来测试连接。类名需制定全路径。
  Default: com.mchange.v2.c3p0.impl.DefaultConnectionTester-->
    <property name="connectionTesterClassName"></property>
    
    <!--指定c3p0 libraries的路径，如果（通常都是这样）在本地即可获得那么无需设置，默认null即可
  Default: null-->
    <property name="factoryClassLocation">null</property>
    
    <!--Strongly disrecommended. Setting this to true may lead to subtle and bizarre bugs. 
  （文档原文）作者强烈建议不使用的一个属性--> 
    <property name="forceIgnoreUnresolvedTransactions">false</property>
    
    <!--每60秒检查所有连接池中的空闲连接。Default: 0 --> 
    <property name="idleConnectionTestPeriod">60</property>
    
    <!--初始化时获取三个连接，取值应在minPoolSize与maxPoolSize之间。Default: 3 --> 
    <property name="initialPoolSize">3</property>
    
    <!--最大空闲时间,60秒内未使用则连接被丢弃。若为0则永不丢弃。Default: 0 -->
    <property name="maxIdleTime">60</property>
    
    <!--连接池中保留的最大连接数。Default: 15 -->
    <property name="maxPoolSize">15</property>
    
    <!--JDBC的标准参数，用以控制数据源内加载的PreparedStatements数量。但由于预缓存的statements
  属于单个connection而不是整个连接池。所以设置这个参数需要考虑到多方面的因素。
  如果maxStatements与maxStatementsPerConnection均为0，则缓存被关闭。Default: 0-->
    <property name="maxStatements">100</property>
    
    <!--maxStatementsPerConnection定义了连接池内单个连接所拥有的最大缓存statements数。Default: 0  -->
    <property name="maxStatementsPerConnection"></property>
    
    <!--c3p0是异步操作的，缓慢的JDBC操作通过帮助进程完成。扩展这些操作可以有效的提升性能
  通过多线程实现多个操作同时被执行。Default: 3--> 
    <property name="numHelperThreads">3</property>
    
    <!--当用户调用getConnection()时使root用户成为去获取连接的用户。主要用于连接池连接非c3p0
  的数据源时。Default: null--> 
    <property name="overrideDefaultUser">root</property>
    
    <!--与overrideDefaultUser参数对应使用的一个参数。Default: null-->
    <property name="overrideDefaultPassword">password</property>
    
    <!--密码。Default: null--> 
    <property name="password"></property>
    
    <!--定义所有连接测试都执行的测试语句。在使用连接测试的情况下这个一显著提高测试速度。注意：
  测试的表必须在初始数据源的时候就存在。Default: null-->
    <property name="preferredTestQuery">select id from test where id=1</property>
    
    <!--用户修改系统配置参数执行前最多等待300秒。Default: 300 --> 
    <property name="propertyCycle">300</property>
    
    <!--因性能消耗大请只在需要的时候使用它。如果设为true那么在每个connection提交的
  时候都将校验其有效性。建议使用idleConnectionTestPeriod或automaticTestTable
  等方法来提升连接测试的性能。Default: false -->
    <property name="testConnectionOnCheckout">false</property>
    
    <!--如果设为true那么在取得连接的同时将校验连接的有效性。Default: false -->
    <property name="testConnectionOnCheckin">true</property>
    
    <!--用户名。Default: null-->
    <property name="user">root</property>
    
    <!--早期的c3p0版本对JDBC接口采用动态反射代理。在早期版本用途广泛的情况下这个参数
  允许用户恢复到动态反射代理以解决不稳定的故障。最新的非反射代理更快并且已经开始
  广泛的被使用，所以这个参数未必有用。现在原先的动态反射与新的非反射代理同时受到
  支持，但今后可能的版本可能不支持动态反射代理。Default: false-->
    <property name="usesTraditionalReflectiveProxies">false</property>
    
    <property name="automaticTestTable">con_test</property>
    <property name="checkoutTimeout">30000</property>
    <property name="idleConnectionTestPeriod">30</property>
    <property name="initialPoolSize">10</property>
    <property name="maxIdleTime">30</property>
    <property name="maxPoolSize">25</property>
    <property name="minPoolSize">10</property>
    <property name="maxStatements">0</property>
    <user-overrides user="swaldman">
    </user-overrides>
  </default-config>
  <named-config name="dumbTestConfig">
    <property name="maxStatements">200</property>
    <user-overrides user="poop">
      <property name="maxStatements">300</property>
    </user-overrides>
  </named-config>
</c3p0-config>