JavaWeb12_数据库连接池

淡淡的烟草味﹌ 2022-10-29 07:50 1阅读 0赞

**数据库连接池**

JDBC的数据库连接对象是通过 DriverManager 来获取的，每次获取都需要向数据库申请获取连接，验证用户名和密码，执行完 SQL 语句后断开连接，这样的方式会造成资源的浪费，数据连接资源没有得到很好的重复利用。

我们可以使用数据库连接池解决这一问题。

**数据库连接池的基本思想**

数据库连接池的基本思想就是为数据库建立一个缓冲池，预先向缓冲池中放入一定数量的连接对象，当需要获取数据库连接的时候，只需要从缓冲池中取出一个对象，用完之后再放回到缓冲池中，供下一次请求使用，做到了资源的重复利用，允许程序重复使用一个现有的数据库连接对象，而不需要重新创建。

当数据库连接池中没有空闲的连接时，新的请求就会进入等待队列，等待其他线程释放连接。

**数据库连接池的实现：C3P0**

JDBC 的数据库连接池使用 javax.sql.DataSource 接口来完成的，DataSource 是 Java 官方提供的接口，使用的时候开发者并不需要自己来实现该接口，可以使用第三方的工具。

C3P0 是一个常用的第三方实现，实际开发中直接使用 C3P0 即可完成数据库连接池的操作。

**测试：**

public class DataSourceTest { 
    	
    	public static void main(String[] args) { 
    		
    		try { 
    			//创建C3P0连接池
    			ComboPooledDataSource dataSource = new ComboPooledDataSource();
    			dataSource.setDriverClass("com.mysql.cj.jdbc.Driver");
    			dataSource.setJdbcUrl("jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8");
    			dataSource.setUser("root");
    			dataSource.setPassword("123456");
    			//设置初始化的连接个数
    			dataSource.setInitialPoolSize(20);
    			//设置最大连接数（连接对象不够时可以向数据库再次申请的上限）
    			//如果连接数到了40个，新的请求将会进入等待队列
    			dataSource.setMaxPoolSize(40);
    			//设置连接对象不够时向数据库申请的连接对象个数
    			dataSource.setAcquireIncrement(5);
    			//设置最小空闲连接数
    			//当空闲连接数为2时即判定连接数不够，开始申请增加连接数量
    			dataSource.setMinPoolSize(2);
    			//从连接池中获取连接
    			Connection connection = dataSource.getConnection();
    			System.out.println(connection);
    			//执行sql语句
    			String sql = "insert into user(name,age) values('司马懿',33)";
    			connection.createStatement().executeUpdate(sql);
    			//JDBC原生的close方法是释放资源
    			//而C3P0的close方法是将对象还给连接池
    			connection.close();
    		} catch (PropertyVetoException e) { 
    			e.printStackTrace();
    		} catch (SQLException e) { 
    			e.printStackTrace();
    		}
    		
    	}
    
    }

com.mchange.v2.c3p0.impl.NewProxyConnection@5ccd43c2

--------------------

实际开发中一般将 C3P0 的配置信息定义在 xml 文件中，Java 程序只需要加载配置文件即可完成数据库连接池的初始化操作。

1、配置文件的名字必须是 **c3p0-config.xml**

2、初始化 ComboPooledDataSource 时，传入的参数必须是 **named-config** 标签的 name 属性值。

3、注意该配置文件需放在 src 下

<?xml version="1.0" encoding="UTF-8"?>
    <c3p0-config>
    	<named-config name="testc3p0">
    		
    		<property name="user">root</property>
    		<property name="password">123456</property>
    		<property name="driverClass">com.mysql.jdbc.Driver</property>
    		<property name="jdbcUrl">jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8</property>
    		
    		<property name="acquireIncrement">5</property>
    		
    		<property name="initialPoolSize">20</property>
    		
    		<property name="minPoolSize">2</property>
    		
    		<property name="maxPoolSize">40</property>
    	</named-config>
    </c3p0-config>

public class DataSourceTest { 
    	
    	public static void main(String[] args) { 
    		try { 
    			ComboPooledDataSource dataSource = new ComboPooledDataSource("testc3p0");
    			Connection connection = dataSource.getConnection();
    			System.out.println(connection);
    			String sql = "insert into user(name,age) values('周瑜',28)";
    			connection.createStatement().executeUpdate(sql);
    			connection.close();
    		} catch (SQLException e) { 
    			e.printStackTrace();
    		}
    	}
    
    }

com.mchange.v2.c3p0.impl.NewProxyConnection@16f65612