Java操作数据库——使用连接池连接数据库
摘要：本文主要学习了如何使用JDBC连接池连接数据库。
传统方式和连接池方式
传统方式的步骤
使用传统方式在Java中使用JDBC连接数据库，完成一次数据库的操作，一般有以下几个步骤：
加载驱动。
建立连接。
执行SQL语句。
释放连接。
传统方式的弊端
每一次对数据库的操作都要建立一次连接，并且会将得到的Connection对象加载到内存中，导致消耗了大量的内存和时间。如果短时间有很多需要进行建立连接的操作，会导致占用很多系统资源，甚至会导致服务器崩溃。
同建立连接相对应，每次使用都需要手动释放连接，如果忘记释放连接或者程序出现异常未能成功释放，会导致内存泄露。
此外，传统方式并不能控制连接的数量，如果连接的人数过多，会导致无限制的创建连接对象，导致内存开销过大，服务器崩溃。
连接池的步骤
创建连接池并配置连接属性。
使用连接池获取连接。
连接池的优势
每次需要连接数据库时，不需要建立连接，而是通过连接池获取，由连接池提供连接。
在使用完连接后，不需要手动释放连接，而是交由连接池释放连接。
可以通过连接池控制连接的数量，在连接池里的连接可多次重复使用，避免了无限制创建连接的问题。
使用连接池
使用C3P0连接池
C3P0是一个开放源代码的JDBC连接池，它在lib目录中与Hibernate一起发布，包括实现了数据源和JNDI绑定，支持JDBC3规范和JDBC2的标准扩展。目前使用它的开源项目有Hibernate，Spring等。
导入jar包：
c3p0-0.9.5.2.jar
在当前项目的代码根目录 src 下新建名为 c3p0-config.xml 的配置文件，注意文件名称不可改变，内容如下：
<c3p0-config>
<!-- 连接名称 -->
<named-config name="mysql">
<!-- 接数据库的驱动类名 -->
<property name="driverClass">com.mysql.jdbc.Driver</property>
<!-- 连接属性 -->
<property name="jdbcUrl">jdbc:mysql://192.168.35.128:3306/demo</property>
<property name="user">root</property>
<property name="password">123456</property>
<!-- 当连接池用完时等待获取新连接的时间，超时后将抛出SQLException，单位毫秒，如设为0则无限期等待。默认为0。 -->
<property name="checkoutTimeout">5000</property>
<!-- 当连接用尽后，一次获取的连接个数 -->
<property name="acquireIncrement">2</property>
<!-- 初始连接数 -->
<property name="initialPoolSize">1</property>
<!-- 最小连接数 -->
<property name="minPoolSize">3</property>
<!-- 最大连接数 -->
<property name="maxPoolSize">5</property>
</named-config>
</c3p0-config>
程序代码：
public class TestDataPool {
// 根据配置文件里的名称创建连接池
public static ComboPooledDataSource cpds = new ComboPooledDataSource("mysql");
/**
* 主程序
*/
public static void main(String[] args) {
// 模拟多次对数据库的查询操作
for (int i = 0; i < 6; i++) {
new Thread(new Runnable() {
@Override
public void run() {
select();
}
}, "线程" + i).start();
}
}
/**
* 查询程序
*/
public static void select() {
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
// 获取连接并执行SQL
try {
conn = cpds.getConnection();
pstmt = conn.prepareStatement("select * from student where id = 906");
rs = pstmt.executeQuery();
while (rs.next()) {
System.out.println(Thread.currentThread().getName() + "\t" + rs.getString(1) + "\t" + rs.getString(2) + "\t" + rs.getString("address"));
}
} catch (Exception e) {
e.printStackTrace();
} finally {
// 释放资源
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
try {
pstmt.close();
} catch (SQLException e) {
e.printStackTrace();
}
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
使用DBCP连接池
DBCP是Apache上的一个Java连接池项目，是一个依赖Jakarta项目commons-pool对象池机制的数据库连接池。DBCP可以直接的在应用程序中使用，Tomcat的数据源使用的就是DBCP。
导入jar包：
commons-dbcp-1.4.jar commons-pool-1.5.5.jar
在当前项目的代码根目录 src 下新建名为 dbcp.properties 的配置文件，文件名需要同代码中引用的文件名一致，内容如下：
# 接数据库的驱动类名
driverClassName=com.mysql.jdbc.Driver
# 连接属性
url=jdbc:mysql://192.168.35.128:3306/demo
username=root
password=123456
# 初始化连接数
initialSize=10
# 最大连接数
maxActive=15
程序代码：
public class TestDBCP {
// 根据配置文件里的名称创建连接池
private static DataSource source = null;
static {
Properties pros = new Properties();
InputStream is = TestDBCP.class.getClassLoader().getResourceAsStream("dbcp.properties");
try {
pros.load(is);
source = BasicDataSourceFactory.createDataSource(pros);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 主程序
*/
public static void main(String[] args) {
// 模拟多次对数据库的查询操作
for (int i = 0; i < 6; i++) {
new Thread(new Runnable() {
@Override
public void run() {
select();
}
}, "线程" + i).start();
}
}
/**
* 查询程序
*/
public static void select() {
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
// 获取连接并执行SQL
try {
conn = source.getConnection();
pstmt = conn.prepareStatement("select * from student where id = 906");
rs = pstmt.executeQuery();
while (rs.next()) {
System.out.println(Thread.currentThread().getName() + "\t" + rs.getString(1) + "\t" + rs.getString(2) + "\t" + rs.getString("address"));
}
} catch (Exception e) {
e.printStackTrace();
} finally {
// 释放资源
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
try {
pstmt.close();
} catch (SQLException e) {
e.printStackTrace();
}
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
使用Druid连接池
Druid是阿里巴巴出品的数据源，而且是淘宝和支付宝专用数据库连接池，但它不仅仅是一个数据库连接池，它还包含一个ProxyDriver，一系列内置的JDBC组件库，一个SQL Parser。
导入jar包：
druid-1.0.9.jar
在当前项目的代码根目录 src 下新建名为 druid.properties 的配置文件，文件名需要同代码中引用的文件名一致，内容如下：
# 接数据库的驱动类名
driverClassName=com.mysql.jdbc.Driver
# 连接属性
url=jdbc:mysql://192.168.35.128:3306/demo
username=root
password=123456
# 最大连接数
maxActive=15
# 最长等待时间
maxWait=3000
# 配置初始化连接数
initialSize=1
# 配置最大活动连接数
maxActive=10
程序代码：
public class TestDruid {
// 根据配置文件里的名称创建连接池
private static DataSource source = null;
static {
Properties pros = new Properties();
InputStream is = TestDruid.class.getClassLoader().getResourceAsStream("druid.properties");
try {
pros.load(is);
source = DruidDataSourceFactory.createDataSource(pros);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 主程序
*/
public static void main(String[] args) {
// 模拟多次对数据库的查询操作
for (int i = 0; i < 6; i++) {
new Thread(new Runnable() {
@Override
public void run() {
select();
}
}, "线程" + i).start();
}
}
/**
* 查询程序
*/
public static void select() {
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
// 获取连接并执行SQL
try {
conn = source.getConnection();
pstmt = conn.prepareStatement("select * from student where id = 906");
rs = pstmt.executeQuery();
while (rs.next()) {
System.out.println(Thread.currentThread().getName() + "\t" + rs.getString(1) + "\t" + rs.getString(2) + "\t" + rs.getString("address"));
}
} catch (Exception e) {
e.printStackTrace();
} finally {
// 释放资源
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
try {
pstmt.close();
} catch (SQLException e) {
e.printStackTrace();
}
try {
conn.close();
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}