数据库连接池

这里使用常用的两种创建数据库连接池的方法,dbcp与c3p0

DBCP

使用 DBCP 数据库连接池， 加入 jar 包(2 个jar 包). 依赖于 Commons Pool。

配置文件

username=root
password=123456
driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/text

代码:

/**
	 * 1. 加载 dbcp 的 properties 配置文件: 配置文件中的键需要来自 BasicDataSource
	 * 的属性.
	 * 2. 调用 BasicDataSourceFactory 的 createDataSource 方法创建 DataSource
	 * 实例
	 * 3. 从 DataSource 实例中获取数据库连接. 
	 */
	@Test
	public void testDBCPWithDataSourceFactory() throws Exception{
		
		Properties properties = new Properties();
		InputStream inStream = JDBCTest.class.getClassLoader()
				.getResourceAsStream("dbcp.properties");
		properties.load(inStream);
		
		DataSource dataSource = 
				BasicDataSourceFactory.createDataSource(properties);
		System.out.println(dataSource.getConnection()); 
		//需要在配置文件添加相关属性
//		BasicDataSource basicDataSource = 
//				(BasicDataSource) dataSource;
//		System.out.println(basicDataSource.getMaxWait()); 
	}

C3P0

C3P0推荐是用xml配置文件，格式为c3p0-config.xml。依赖于mchange-commons-java-0.2.19.jar

配置文件

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

	<named-config name="helloc3p0">
		
		<!-- 指定连接数据源的基本属性 -->
	      <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql://localhost:3306/text</property>
        <property name="user">root</property>
        <property name="password">123456</property>

		<!-- 若数据库中连接数不足时, 一次向数据库服务器申请多少个连接 -->
		<property name="acquireIncrement">5</property>
		<!-- 初始化数据库连接池时连接的数量 -->
		<property name="initialPoolSize">3</property>
		<!-- 数据库连接池中的最小的数据库连接数 -->
		<property name="minPoolSize">2</property>
		<!-- 数据库连接池中的最大的数据库连接数 -->
		<property name="maxPoolSize">5</property>

		<!-- C3P0 数据库连接池可以维护的 Statement 的个数 -->
		<property name="maxStatements">5</property>
		<!-- 每个连接同时可以使用的 Statement 对象的个数 -->
		<property name="maxStatementsPerConnection">2</property>
	
	</named-config>
		
</c3p0-config>

代码:

public void testC3poWithConfigFile() throws Exception{
		DataSource dataSource = 
				new ComboPooledDataSource("helloc3p0");  		
		System.out.println(dataSource.getConnection()); 
		ComboPooledDataSource comboPooledDataSource = 
				(ComboPooledDataSource) dataSource;
		//System.out.println(comboPooledDataSource.getMaxStatements()); 
	}