自定义JDBC链接池

上篇简单介绍了jdbc链接数据库；

本篇就说一下自定义连接池以及增删改查的测试：

自定义连接池

自定义链接池的原因

　　　　JDBC连接中用到Connection   在每次对数据进行增删查改 都要 开启  、关闭  ，在开发项目中 ，浪费了很大的资源 ，所以我们自己定义了一个连接池，用池来管理Connection，这样可以重复使用Connection，有了池，我们就不用自己来创建Connection，而是通过池来获取Connection对象，当使用完Connection后，调用Connection的close()方法也不会真的关闭Connection,而是把Connection“归还”给池，池也就可以再利用这个Connection对象。

 

创建自定义连接池的步骤

1 创建连接池实现（数据源），并实现接口javax.sql.DataSource.

2 提供一个集合，用于存放连接，因为移除/添加操作过多，所以选用LinkedList较好

3 为连接池初始化连接

4 程序如果需要连接，调用实现类的getConnection(),本方法将从连接池（容器List）获取连接，为了保证当前连接只是停工给一个线程使用，我们需要将连接先从连接池中移除。

5 当用户使用完连接，释放资源时，不执行close()方法，而是将连接添加到连接池中

自定义连接池的代码：

package com.baidu.database.tools;

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.SQLException;
import java.sql.SQLFeatureNotSupportedException;
import java.util.LinkedList;
import java.util.logging.Logger;

import javax.sql.DataSource;

/**
 * 自定义连接池
 * 
 * @author Admin
 *
 */
public class MyDatabasePool implements DataSource {

    /**
     * 创建集合存放连接
     */
    public LinkedList<Connection> list = new LinkedList<>();

    // 使用构造方法初始化连接池
    public MyDatabasePool() throws Exception {
        // 创建最小连接数个数据库连接对象以备使用
        for (int i = 1; i < 21; i++) {
            // 将创建好的数据库连接对象添加到Linkedlist集合中
            list.add(JdbcUtils.getConnection());
        }
    }

    @Override
    public void setLogWriter(PrintWriter out) throws SQLException {
        // TODO Auto-generated method stub

    }

    @Override
    public void setLoginTimeout(int seconds) throws SQLException {
        // TODO Auto-generated method stub

    }

    @Override
    public int getLoginTimeout() throws SQLException {
        // TODO Auto-generated method stub
        return 0;
    }

    @Override
    public Logger getParentLogger() throws SQLFeatureNotSupportedException {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public <T> T unwrap(Class<T> iface) throws SQLException {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public boolean isWrapperFor(Class<?> iface) throws SQLException {
        // TODO Auto-generated method stub
        return false;
    }

    /**
     * 获取链接 通过动态代理(Proxy)实现的数据库连接池的创建连接与归还链接的操作
     */
    @Override
    public Connection getConnection() throws SQLException {
        Connection connection = list.removeLast();
        //创建代理对象
        Connection proxyConnection = (Connection) Proxy.newProxyInstance(
                //类加载器
                connection.getClass().getClassLoader(),
                //目标接口对象
                new Class[] { Connection.class },
                //当调用connction对象的时候自动触发事务处理器
                new InvocationHandler() {
                    @Override
                    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
                        //判断执行close()就把连接放入连接池
                        if ("close".equals(method.getName())) {
                            //连接放入连接池
                            list.addLast(connection);
                            return null;
                        } else {
                             //调用目标方法对象
                            return method.invoke(connection, args);
                        }

                    }
                });
        return proxyConnection;

    }

    @Override
    public Connection getConnection(String username, String password) throws SQLException {
        // TODO Auto-generated method stub
        return null;
    }

    @Override
    public PrintWriter getLogWriter() throws SQLException {
        // TODO Auto-generated method stub
        return null;
    }

}
　　　　　　　　　　JdbcUtils地址

★测试增删改查：

package com.baidu.database.test;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

import org.junit.After;
import org.junit.Before;
import org.junit.Test;

import com.baidu.database.tools.JdbcUtils;
import com.baidu.database.tools.MyDatabasePool;

public class MySouceTest {

    // 初始化value
    static  MyDatabasePool database = null;
    static Connection connection = null;
    static PreparedStatement statement = null;
    static ResultSet result = null;
    @Before
    public void StartDocument() throws Exception {
        // 创建自定义数据库对象
        database = new MyDatabasePool();
    }

    @After
    public void end() throws Exception {
        // 关闭链接
        JdbcUtils.close(connection, statement, result);
        System.out.println("关闭链接");
    }
    
    @Test
    /**
     * 测试添加功能
     * 
     * @throws Exception
     */
    public void addTest() throws Exception {
        // 获取链接
        connection = database.getConnection();
        // 书写SQL语句
        String sql = "insert into test01 values(?,?)";
        // 使用prepareStatement对象进行预编译
        statement = connection.prepareStatement(sql);
        // 设置参数
        statement.setInt(1, 1);
        statement.setString(2, "张三");
        // 获取结果
        int result = statement.executeUpdate();

        if (result != 0) {
            System.out.println("success");
        }
    }

    @Test
    /**
     * 测试删除功能
     * 
     * @throws Exception
     */
    public void delTest() throws Exception {
        // 获取链接
        connection = database.getConnection();
        // 书写SQL语句
        String sql = "delete from test01 where id=?";
        // 使用prepareStatement对象进行预编译
        statement = connection.prepareStatement(sql);
        // 设置参数
        statement.setInt(1, 1);
        // 获取结果
        int result = statement.executeUpdate();

        if (result != 0) {
            System.out.println("success");
        }
    }

    @Test
    public void updateTest() throws Exception {
        // 获取链接
        connection = database.getConnection();
        // 书写SQL语句
        String sql = "update test01 set name=? where id=?";
        // 使用prepareStatement对象进行预编译
        statement = connection.prepareStatement(sql);
        // 设置参数
        statement.setString(1, "admin");
        statement.setInt(2, 1);
        // 获取结果
        int result = statement.executeUpdate();

        if (result != 0) {
            System.out.println("success");
        }
    }

    @Test
    /**
     * 测试查询全部
     * 
     * @throws Exception
     */
    public void selectTest() throws Exception {

        // 创建链接
        connection = database.getConnection();
        if (connection == null) {// 判断是否获取到了链接
            return;
        }
        // 书写SQL
        String sql = "select id,name from test01 where id=?";
        // 预编译SQL
        statement = connection.prepareStatement(sql);
        // 设置参数
        statement.setInt(1, 1);
        // 获取结果集
        result = statement.executeQuery();

        if (result.next()) {
            System.out.println("successful");
        }
        
    }
}

　　这就是自定义一个简单的JDBC连接池实现方法，希望能给大家一个参考，也希望大家多多支持我。