JDBC数据库连接池:dbcp和c3p0

逃离我推掉我的手 2021-08-11 23:17 364阅读 0赞

### 【一】为什么要有连接池 ###

传统的模式基本为：

1.  在主程序中建立数据库连接 
2.  进行sql操作
3.  断开数据库连接

这种模式开发存在的问题为：

传统的方式会消耗大量的资源和时间。数据库的连接资源并没有得到很好的重复利用。

对于每一次数据库的连接，使用完后都得断开。

开发不能控制被创建的连接对象数，系统资源会被毫无顾忌的分配出去，如果连接过多，也可能导致内存泄漏，服务器崩溃。

为了解决传统开发中的数据库连接为题，可以采用数据库连接池技术。

### 【二】数据库连接池 ###

数据库连接池的基本思想：为数据库连接建立一个“缓冲池”。预先在数据库连接池中放入一定数量的连接，当需要建立连接时，只需要从连接池中取出，使用完后再放回去。

数据库连接池负责分配、管理、释放数据库连接，它允许应用程序重复使用一个现有的数据库连接，而不是重新建立一个。

数据库连接池的优点：

1.  资源重用
2.  更快的系统反应速度
3.  新的资源分配手段
4.  统一的连接管理，避免数据库连接泄漏

JDBC的数据库连接池使用javax.sql.DataSource来表示，DataSource只是一个接口，该接口通常由服务器来提供实现，也有一些开元组织提供实现：DBCP数据库连接池、C3P0数据库连接池。

DataSource通常称为数据源，它包含连接池和连接池管理两部分。

### 【三】DBCP数据库连接池 ###

> 使用方式一（常用）：
> 
> 首先导包：commons-dbcp-1.4.jar
> 
>                   commons-pool-1.5.5.jar
> 
> 配置文件：dbcp.properties
> 
> username=root  
> password=root  
> url=jdbc:mysql://localhost:3306/plant  
> driverClassName=com.mysql.jdbc.Driver
> 
> initialSize=10  
> maxActive=50  
> minIdle=5  
> maxWait=5000
> 
> 1.加载dbcp的properties配置文件：配置文件的键来自BasicDataSource的属性
> 
> 2.调用BasicDataSourceFactory的createDataSource方法创建DataSource实例
> 
> 3.从DataSource实例中获取数据库连接
> 
> 使用方式二：
> 
>  1.导包：commons-dbcp-1.4.jar
> 
>                commons-pool-1.5.5.jar
> 
> 2.创建数据库连接池
> 
> 3.为数据源实例指定必要的属性
> 
>  *  setUserName(String username):数据库的连接用户
>  *  setPassword(String password):数据库的连接密码
>  *  setUrl(String url):数据库的连接路径
>  *  setDriverClassName(String driver):驱动
> 
> 4.指定数据源的一些可选的属性
> 
>  *  setInitialSize(int num):指定数据库连接池中初始化连接的个数
>  *  setMaxActive(int num):指定最大的连接数，同一时刻可以同时向数据库申请的连接数
>  *  setMinIdle(int num):指定最小空闲连接数，在数据库连接池中保存的最少的空闲连接的数量，保证有连接时可以最快的分配连接。
>  *  setMaxWait(time):等待数据库连接池分配连接的最长时间，单位为毫秒，超出改时间将抛出异常。
> 
> 5.从数据源中获取数据库连接

### 【四】C3P0数据库连接池 ###

使用：

1.导包：c3p0-0.9.1.2.jar

可以创建properties文件或xml文件，xml文件推荐使用（命名：c3p0-config.xml）

<c3p0-config>
        <named-config name="helloc3p0">
            
            <property name="user">root</property>
            <property name="password">root</property>
            <property name="driverClass">com.mysql.jdbc.Driver</property>
            <property name="jdbcUrl">jdbc:mysql://localhost:3306/plant</property>
            
            <property name="acquireIncrement">50</property>
            
            <property name="initialPoolSize">100</property>
            
            <property name="minPoolSize">50</property>
            
            <property name="maxPoolSize">1000</property>
            
            <property name="maxStatements">0</property>
            
            <property name="maxStatementsPerConnection">5</property>
        </named-config>
    </c3p0-config>

2.创建ComboPooledDataSource实例：DataSource dataSource=new ComboPooledDataSource("helloc3p0");

3.从DataSource实例中获取数据库连接

使用c3p0后重构的JDBCUrl

package com.jdbc.c3p0;
    
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    
    import javax.sql.DataSource;
    
    import com.mchange.v2.c3p0.ComboPooledDataSource;
    
    public class JDBCUtils {
    	private static DataSource dataSource=null;
    	static {
    		dataSource=new ComboPooledDataSource("helloc3p0");
    	}
    	//获取连接
    	public static Connection getConnection() throws SQLException, ClassNotFoundException {
    		return dataSource.getConnection();
    	}
    	
    	//关闭资源
    	public static void close(PreparedStatement stat,Connection conn) {
    		closeAll(null,stat,conn);
    	}
    	
    	//关闭所有资源
    	public static void closeAll(ResultSet rs,PreparedStatement stat,Connection conn) {
    		if(rs!=null) {
    			try {
    				rs.close();
    			} catch (SQLException e) {
    				e.printStackTrace();
    			}
    		}
    		if(stat!=null) {
    			try {
    				stat.close();
    			} catch (SQLException e) {
    				
    				e.printStackTrace();
    			}
    		}
    		
    		if(conn!=null) {
    			try {
    				//这里的关闭连接并不是真正的关闭连接，而是把连接归还给连接池
    				conn.close();
    			} catch (SQLException e) {
    				
    				e.printStackTrace();
    			}
    		}
    	}
    }