【java】数据库连接池（C3P0/DBCP）的简单的应用

野性酷女 2024-02-19 14:51 37阅读 0赞

#### 文章目录 ####

*  一、C3P0
 *   *  1、简介：
     *  2、准备：
     *  3、步骤：
     *   *  3-1)导入上面的两个jar，并将jar 包build path。
         *  3-2)设置配置文件
     *  4、c3p0的工具类
 *  二、DBCP
 *   *  1、简介：
     *  2、准备：
     *  3、步骤：
     *   *  3-1)导入上面的jar，并将jar 包build path。
         *  3-2)设置配置文件

## 一、C3P0 ##

前言：连接池的作用详见：[https://blog.csdn.net/aiming66/article/details/82938398][https_blog.csdn.net_aiming66_article_details_82938398]

### 1、简介： ###

C3P0开源免费的连接池！目前使用它的开源项目有：Spring、Hibernate等。使用第三方工具需要导入jar包，C3P0使用时还需要添加配置文件c3p0-config.xml。

### 2、准备： ###

myeclipse  
jdbc相关jar  
C3P0相关jar包  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FpbWluZzY2_size_16_color_FFFFFF_t_70]

### 3、步骤： ###

#### 3-1)导入上面的两个jar，并将jar 包build path。 ####

#### 3-2)设置配置文件 ####

> 注意事项：  
> 配置文件名：c3p0-config.xml(固定)  
> 配置文件位置：src （类路径）  
> 配置文件的内容如下：

<?xml version="1.0" encoding="UTF-8"?>
    <c3p0-config>
    
      <default-config> <--默认配置方式--!>
        <property name="driverClass">com.mysql.jdbc.Driver</property>
    	<property name="jdbcUrl">jdbc:mysql:///web_07</property>
    	<property name="user">root</property>
    	<property name="password">123</property>
    	<property name="initialPoolSize">5</property>
    	<property name="maxPoolSize">20</property>
      </default-config>
      
      <named-config name="oracle"> <--以oracle命名配置方式--!>
        <property name="driverClass">com.mysql.jdbc.Driver</property>
    	<property name="jdbcUrl">jdbc:mysql:///web_07</property>
    	<property name="user">root</property>
    	<property name="password">123</property>
      </named-config>
      
    
    </c3p0-config>

添加一个测试类  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FpbWluZzY2_size_16_color_FFFFFF_t_70 1]

c3p0test.java 中的代码

package it.c3p0;
    
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.SQLException;
    
    import org.junit.Test;
    
    import com.mchange.v2.c3p0.ComboPooledDataSource;
    
    public class c3p0test {
        
    
    	@Test
    	public void testAdduser(){
        
    		Connection conn=null;
    		PreparedStatement pstmt=null;
    		
    		//1、创建连接池对象
    		ComboPooledDataSource datasource=new ComboPooledDataSource();//实例化后，自动加载c3p0-config.xml文件。
    																	 // 实例化后，自动加载c3p0-config.xml文件中的默认配置
    		//ComboPooledDataSource datasource=new ComboPooledDataSource("oracle");实例化后，自动加载c3p0-config.xml文件中的以“oracle”命名的配置
    		
    		//2、连接池中获取链接
    		try {
        
    			conn=datasource.getConnection();
    			String sql="insert into user values(?,?)";
    			pstmt=conn.prepareStatement(sql);
    			pstmt.setString(1,"test1");
    			pstmt.setString(2, "test1pwd");
    			
    			int rows=pstmt.executeUpdate();
    			
    			if(rows>0){
        System.out.print("添加成功");}
    			else{
        System.out.print("添加失败");}
    		} catch (SQLException e) {
        
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    		finally
    		{
        // 关闭连接
    			try {
        
    					if(pstmt!=null)pstmt.close();
    				} catch (SQLException e) {
        
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			
    				try {
        
    					if(conn!=null)conn.close();
    				} catch (SQLException e) {
        
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    		}
    	}
    		
    		
    }

配置文件中的代码：

<?xml version="1.0" encoding="UTF-8"?>
    <c3p0-config>
    
      <default-config>
        <property name="driverClass">com.mysql.cj.jdbc.Driver</property>
    	<property name="jdbcUrl">jdbc:mysql://localhost:3306/mydb</property>
    	<property name="user">root</property>
    	<property name="password">root</property>
    	<property name="initialPoolSize">5</property>
    	<property name="maxPoolSize">20</property>
      </default-config>
      
      <named-config name="oracle"> 
        <property name="driverClass">com.mysql.jdbc.Driver</property>
    	<property name="jdbcUrl">jdbc:mysql:///web_07</property>
    	<property name="user">root</property>
    	<property name="password">123</property>
      </named-config>
      
    
    </c3p0-config>

运行结果：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FpbWluZzY2_size_16_color_FFFFFF_t_70 2]

### 4、c3p0的工具类 ###

仔细分析下面代码，我们大部分操作数据库时，仅仅有下面红框的部分不懂，那么我们可以使用一个工具类将其他的封装起来。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FpbWluZzY2_size_16_color_FFFFFF_t_70 3]  
步骤：  
新建C3P0utils工具类  
![在这里插入图片描述][2018121915083788.png]

C3P0utils.java

package it.utils;
    
    import java.sql.Connection;
    import java.sql.SQLException;
    import javax.sql.DataSource;
    import com.mchange.v2.c3p0.ComboPooledDataSource;
    
    public class C3P0utils {
        
    	private static ComboPooledDataSource datasource=new ComboPooledDataSource();
    	
    	public static DataSource getDataSource(){
        
    		return datasource;
    	}
    	
    	public static Connection getConnection(){
        
    		try {
        
    			return datasource.getConnection();
    		} catch (SQLException e) {
        
    			throw new RuntimeException(e);
    		}
    	}
    }

C3P0testV\_2.java

package it.c3p0;
    
    import it.utils.C3P0utils;
    
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.SQLException;
    
    import org.junit.Test;
    
    	
    public class C3P0testV_2 {
        
    	@Test
    	public void testAdduser(){
        
    		Connection conn=null;
    		PreparedStatement pstmt=null;
    
    		//2、连接池中获取链接
    		try {
        
    			conn=C3P0utils.getConnection();
    			String sql="insert into user values(?,?)";
    			pstmt=conn.prepareStatement(sql);
    			pstmt.setString(1,"test1");
    			pstmt.setString(2, "test1pwd");
    			
    			int rows=pstmt.executeUpdate();
    			
    			if(rows>0){
        System.out.print("添加成功");}
    			else{
        System.out.print("添加失败");}
    		} catch (SQLException e) {
        
    			// TODO Auto-generated catch block
    			e.printStackTrace();
    		}
    		finally
    		{
        // 关闭连接
    			try {
        
    					if(pstmt!=null)pstmt.close();
    				} catch (SQLException e) {
        
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    			
    				try {
        
    					if(conn!=null)conn.close();
    				} catch (SQLException e) {
        
    					// TODO Auto-generated catch block
    					e.printStackTrace();
    				}
    		}
    	}
    
    }

运行结果：  
![在这里插入图片描述][20181219151048780.png]

## 二、DBCP ##

### 1、简介： ###

DBCP也是一个开源的连接池！是ApacheCommon成员之一，在企业开发中也比较常见，  
tomcat内置连接池。

### 2、准备： ###

myeclipse  
jdbc相关jar  
DBCP相关jar包  
![在这里插入图片描述][20181219152805135.png]

### 3、步骤： ###

#### 3-1)导入上面的jar，并将jar 包build path。 ####

#### 3-2)设置配置文件 ####

> 配置文件名称：\*.properties  
> 配置文件位置：任意，建议src(classpath/类路径）  
> 配置文件内容：properties不能编写中文，不支持在STS中修改，必须使用记事本修改内容，否则中文注释就乱码了

#连接设置
    driverClassName=com.mysql.jdbc.Driver
    url=jdbc:mysql://localhost:3306/jdbc
    username=root
    password=
    
    #
    initialSize=10
    
    #最大连接数量
    maxActive=50
    
    #
    maxIdle=20
    
    #
    minIdle=5
    
    #
    maxWait=60000
    
    
    #JDBC驱动建立连接时附带的连接属性属性的格式必须为这样：[属性名=property;] 
    #注意："user" 与 "password" 两个属性会被明确地传递，因此这里不需要包含他们。
    connectionProperties=useUnicode=true;characterEncoding=gbk
    
    #指定由连接池所创建的连接的自动提交（auto-commit）状态。
    defaultAutoCommit=true
    
    #driver default 指定由连接池所创建的连接的事务级别（TransactionIsolation）。
    #可用值为下列之一：（详情可见javadoc。）NONE,READ_UNCOMMITTED, READ_COMMITTED, REPEATABLE_READ, SERIALIZABLE
    defaultTransactionIsolation=READ_UNCOMMITTED

4、工具类

package cn.itheima.jdbc.utils;
    
    import java.io.InputStream;
    import java.sql.Connection;
    import java.sql.SQLException;
    import java.util.Properties;
    
    import javax.sql.DataSource;
    
    import org.apache.commons.dbcp.BasicDataSourceFactory;
    
    public class DBCPUtils {
        
    	private static DataSource dataSource;
    	static{
        
    		try {
        
    			//1.加载找properties文件输入流
    			InputStream is = DBCPUtils.class.getClassLoader().getResourceAsStream("db.properties");
    			//2.加载输入流
    			Properties props = new Properties();
    			props.load(is);
    			//3.创建数据源
    			dataSource = BasicDataSourceFactory.createDataSource(props);
    		} catch (Exception e) {
        
    			throw new RuntimeException(e);
    		}
    	}
    	
    	public static DataSource getDataSource(){
        
    		return dataSource;
    	}
    	
    	public static Connection getConnection(){
        
    		try {
        
    			return dataSource.getConnection();
    		} catch (SQLException e) {
        
    			throw new RuntimeException(e);
    		}
    	}
    }

测试类文件：

package cn.itheima.jdbc.test;
    
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    
    import org.junit.Test;
    
    import cn.itheima.jdbc.utils.DBCPUtils;
    
    public class TestDBCP {
        
    
    	@Test
    	public void testUpdateUserById(){
        
    		Connection conn = null;
    		PreparedStatement pstmt = null;
    		try {
        
    			conn = DBCPUtils.getConnection();
    			String sql ="update tbl_user set upassword=? where uid=?";
    			pstmt= conn.prepareStatement(sql);
    			pstmt.setString(1, "柳岩");
    			pstmt.setInt(2, 20);
    			int rows = pstmt.executeUpdate();
    			if(rows>0){
        
    				System.out.println("更新成功!");
    			}else{
        
    				System.out.println("更新失败!");
    			}
    		} catch (Exception e) {
        
    			throw new RuntimeException(e);
    		}
    	}
    }

[https_blog.csdn.net_aiming66_article_details_82938398]: https://blog.csdn.net/aiming66/article/details/82938398
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FpbWluZzY2_size_16_color_FFFFFF_t_70]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/de1e293ed04e44b294919f86570249c6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FpbWluZzY2_size_16_color_FFFFFF_t_70 1]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/bb876d5b07f546f79e3674c7a1b14853.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FpbWluZzY2_size_16_color_FFFFFF_t_70 2]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/e73d50d440ea4e0683a504cdef08ec6b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2FpbWluZzY2_size_16_color_FFFFFF_t_70 3]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/dc8fe7e2ca7f46278590ac6988bc12d1.png
[2018121915083788.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/45d72dfa61b5486aa0ad8e414d8ea1c6.png
[20181219151048780.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/dce9a62fc3824dbca11c8d75cdcff5d0.png
[20181219152805135.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/d41bed5c163840a0b4d70b5f392372f4.png