日期:2014-05-16 浏览次数:20668 次
这是一个很老的问题-数据库连接池,很多实际开发中都封装了自己的数据库连接访问机制,而数据库连接池是对数据库资源连接利用的一种更有效的管理方式,特别是资源的频繁分配﹑释放的问题。
数据库连接池的实现原理就是为数据库连接建立一个“缓冲池”,预先在这个"缓冲池"中放入一定数量的数据库连接,当我们需要连接时,就从“缓冲池”中取出一个连接,使用完毕之后再放回“缓冲池”中。同时我们通过设置"缓冲池"的最大个数来防止系统无穷无尽地与数据库连接。
在开源世界里,也有很多非常优秀的连接池,例如: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 (Excepti