定义自己的数据库连接池

这是一个很老的问题-数据库连接池，很多实际开发中都封装了自己的数据库连接访问机制，而数据库连接池是对数据库资源连接利用的一种更有效的管理方式，特别是资源的频繁分配﹑释放的问题。

数据库连接池的实现原理就是为数据库连接建立一个“缓冲池”，预先在这个"缓冲池"中放入一定数量的数据库连接，当我们需要连接时，就从“缓冲池”中取出一个连接，使用完毕之后再放回“缓冲池”中。同时我们通过设置"缓冲池"的最大个数来防止系统无穷无尽地与数据库连接。

在开源世界里，也有很多非常优秀的连接池，例如：C3P0，DBCP，proxool，DBPool等。

下面是本人写的一个非常简单的数据库连接池的实现，主要是体会一下数据库连接池的实现原理！

1.数据库连接池的实现类:

package org.hnylj.db.pool;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

/**
 * 定义自己的数据库连接池
 * @编写者：hnylj
 * 
 */
public class DbConnectionPool {

	private List<Connection> pool;
    private int poolSize;
    private Connection conn = null;
    private static DbConnectionPool instance = null;

    /** 
     * 单粒模式
     * 私有构造方法，获得本类的对象，通过getIstance方法。
     */
    private DbConnectionPool() {
    	pool = new ArrayList<Connection>(poolSize);
        this.createConnection();
    }
    
    /**
     * 得到当前连接池的一个实例
     */
    public static DbConnectionPool getInstance() {
        if (instance == null) {
            instance = new DbConnectionPool();
        }
        return instance;
    }
    
    /**
     * 得到连接池中的一个连接
     */
    public synchronized Connection getConnection() { 
        if (pool.size() > 0) {
            Connection conn = pool.get(0);
            pool.remove(conn);
            return conn;
        } else {
            return null;
        }
    }
    
    /**
     * 创建初始的数据库连接
     */
    private void createConnection() {
        Map<String,String> dbConfig = DbConfig.readDbConfigInfo();
        this.poolSize = Integer.parseInt(dbConfig.get("poolSize"));
        for (int i = 0; i < poolSize; i++) {
            try {
            	Class.forName((String)dbConfig.get("driver"));
                conn = DriverManager.getConnection((String)dbConfig.get("url"), (String)dbConfig.get("username"), (String)dbConfig.get("password"));
                pool.add(conn);
            } catch (ClassNotFoundException e) {
                e.printStackTrace();
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
    
    /**
     * 用完将连接放回到连接池中
     * @param conn
     */
    public synchronized void release(Connection conn) {
        pool.add(conn);
    }

    /** 
     * 关闭连接池中的所有连接
     */
    public synchronized void closePool() {
        for (int i = 0; i < pool.size(); i++) {
            try {
                conn = ((Connection) pool.get(i));
                conn.close();
                pool.remove(i);
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

    public static void main(String[] args) throws Exception  {
    	System.out.println(new DbConnectionPool().getConnection());
    }
}

 2.数据库连接配置类:

package org.ylj.db.pool;

import java.io.FileInputStream;
import java.util.HashMap;
import java.util.Map;
import java.util.Properties;

/**
 * 读取数据库配置信息
 * @编写者：hnylj
 *
 */
public class DbConfig {
	/**
	 * 读取数据库配置信息,以Key-Value对形式返回
	 * @return 
	 */
	public static Map<String,String> readDbConfigInfo() {
		Map<String,String> dbConfigMap = new HashMap<String,String>();
		try {
            String path = System.getProperty("user.dir") + "\\dbConfig.properties";
            FileInputStream is = new FileInputStream(path);
            Properties props = new Properties();
            props.load(is);
            dbConfigMap.put("driver", props.getProperty("driver"));
            dbConfigMap.put("username", props.getProperty("username"));
            dbConfigMap.put("password", props.getProperty("password"));
            dbConfigMap.put("url", props.getProperty("url"));
            dbConfigMap.put("poolSize", props.getProperty("poolSize"));
        } catch (Exception e) {
            e.printStackTrace();
            System.err.println("系统找不到指定的dbConfig.properties文件!");        
        }
        return dbConfigMap;
	}
}

 3.数据库配置属性文件dbConfig.properties:

driver = oracle.jdbc.driver.OracleDriver
url = jdbc:oracle:thin:@127.0.0.1:1521:orcl
username = scott
password = tiger
poolSize = 15

 

一个Java技术交流群，一起交流，共同进步，扣扣群号：513086638

 

 

 

评论

2 楼 hifun 2008-09-22  

C3P0 不错的。

1 楼 gml520 2008-09-21  

不错，学习了