Java中JDBC连接池的基本原理及实现方式-eolink官网

Java中JDBC连接池的基本原理及实现方式

目录一、应用程序直接建立数据库连接模型二、使用数据库连接池优化模型1、关于连接池中的连接数量的一些规定：2、编写数据库连接池创建数据库连接池：进一步封装一些相关数据库的类的方法三、两个开源的数据库连接池1、dbcp连接（1）导入相关jar包（2）在项目根目录增加配置文件dbcp.properties（3）程序实现dbcp连接2、c3p0连接池（1）导入相关的jar包（2）在项目根目录下增加配置文件（3）编写类文件，创建连接池3、dbcp和c3p0不同之处

一、应用程序直接建立数据库连接模型

应用程序直接每次访问数据库时，都建立创建一个数据库的链接，这样每次建立这样的连接都需要耗费的资源，当同时有很多用户在使用应用程序时，可能会导致应用程序崩溃。

图为应用程序直接建立数据库连接模型

二、使用数据库连接池优化模型

数据库连接池的基本思路是，平时建立适量的数据库的连接，放在一个集合中，当有用户需要建立数据库连接的时候，直接到集合中取出一个数据库连接对象（Connection），这样不用再需要重新创建，这样会节省大量的资源，当用户不需要在对数据库进行访问了，那么就将数据库连接对象（Connection）重新放回到集合中，以便方便下次使用。

数据库连接池优化模型图

1、关于连接池中的连接数量的一些规定：

（1）最小连接数:是连接池一直保持的数据库连接,所以如果应用程序对数据库连接的使用量不大,将会有大量的数据库连接资源被浪费（适量）.

（2）最大连接数:是连接池能申请的最大连接数,如果数据库连接请求超过次数,后面的数据库连接请求将被加入到等待队列中,这会影响以后的数据库操作。通常在使用完起始集合中的连接后，会再重新创建一些数据库连接对象，用来满足用户需求，但是这种新建并不是无限制的。

（3）当使用完的连接对象需要重新放回到集合中以备使用，但是超过最小连接数的连接在使用完不会马上被释放,他将被放到连接池中等待重复使用或是超时后最终被释放。

2、编写数据库连接池

简单思路为：创建一个类继承DataSource接口，在类中实现静态的加载出配置文档db.properties文档，并创建最小连接量的数据库连接对象(Connection)，添加到Linkedlist（选择Linkedlist集合原因是便于增删）集合中。重写getConnection()函数，在getConnection()函数中实现数据库连接对象的获取。

db.properties文档

driver=com.mysql.jdbc.Driver

url=jdbc:mysql://127.0.0.1:3306/imooc?useUnicode=true&characterEncoding=utf-8

username=root

password=tiger

jdbcConnectionInitSize=10

创建数据库连接池：

package JDBC;

import java.io.IOException;

import java.io.InputStream;

import java.io.PrintWriter;

import java.lang.reflect.InvocationHandler;

import java.lang.reflect.Method;

import java.lang.reflect.Proxy;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.SQLException;

import java.sql.SQLFeatureNotSupportedException;

import java.util.LinkedList;

import java.util.Properties;

import java.util.logging.Logger;

import javax.sql.DataSource;

public class JdbcConnectionsPool implements DataSource {

* 使用静态块代码，初始化连接池，创建连接池的中最小链接数量连接，

* 创建linkedlist集合，将这些连接放入集合中

//创建linkedlist集合

private static LinkedList linkedlist1=new LinkedList();

private static String driver;//

private static String url;//

private static String username;//数据库登陆名

private static String password;//数据库的登陆密码

private static int jdbcConnectionInitSize;//最小连接数量

private static int max=1; //当前最大连接数量=max*jdbcConnectionInitSize

static{

//通过反射机制获取访问db.properties文件

InputStream is=JdbcConnectionsPool.class.getResourceAsStream("/db.properties");

Properties prop=new Properties();

try {

//加载db.properties文件

prop.load(is);

//获取db.properties文件中的数据库连接信息

driver=prop.getProperty("driver");

url=prop.getProperty("url");

username=prop.getProperty("username");

password=prop.getProperty("password");

jdbcConnectionInitSize=Integer.parseInt(prop.getProperty("jdbcConnectionInitSize"));

Class.forName("com.mysql.jdbc.Driver");

//创建最小连接数个数据库连接对象以备使用

for(int i=0;i

Connection conn=DriverManager.getConnection(url, username, password);

System.out.println("获取到了链接" + conn);

//将创建好的数据库连接对象添加到Linkedlist集合中

linkedlist1.add(conn);

}

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} catch (SQLException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} catch (ClassNotFoundException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

@Override

public PrintWriter getLogWriter() throws SQLException {