自定义数据库连接池

定义自己的数据库连接池JavaSQLOracle配置管理JDBC 这是一个很老的问题-数据库连接池，很多实际开发中都封装了自己的数据库连接访问机制，而数据库连接池是对数据库资源连接利用的一种更有效的管理方式，特别是资源的频繁分配释放的问题。数据库连接池的实现原理就是为数据库连接建立一个“缓冲池”，预先在这个"缓冲池"中放入一定数量的数据库连接，当我们需要连接时，就从“缓冲池”中取出一个连接，使用完毕之后再放回“缓冲池”中。同时我们通过设置"缓冲池"的最大个数来防止系统无穷无尽地与数据库连接。在开源世界里，也有很多非常优秀的连接池，例如：C3P0，DBCP，proxool，DBPool等。下面是本人写的一个非常简单的数据库连接池的实现，主要是体会一下数据库连接池的实现原理！1.数据库连接池的实现类:Java代码 1. package ; 2.3. import ; 4. import ; 5. import ; 6. import ; 7. import ; 8. import ; 9. import ; 10. import ; 11.12. /* 13. * 定义自己的数据库连接池 14. * 编写者：hnylj 15. * 16. */ 17. public class DbConnectionPool 18.19. private List<Connection> pool; 20. private int poolSize; 21. private Connection conn = null; 22. private static DbConnectionPool instance = null; 23.24. /* 25. * 单粒模式 26. * 私有构造方法，获得本类的对象，通过getIstance方法。 27. */ 28. private DbConnectionPool() 29. pool = new ArrayList<Connection>(poolSize); 30. this.createConnection(); 31. 32.33. /* 34. * 得到当前连接池的一个实例 35. */ 36. public static DbConnectionPool getInstance() 37. if (instance = null) 38. instance = new DbConnectionPool(); 39. 40. return instance; 41. 42.43. /* 44. * 得到连接池中的一个连接 45. */ 46. public synchronized Connection getConnection() 47. if (pool.size() > 0) 48. Connection conn = pool.get(0); 49. pool.remove(conn); 50. return conn; 51. else 52. return null; 53. 54. 55.56. /* 57. * 创建初始的数据库连接 58. */ 59. private void createConnection() 60. Map<String,String> dbConfig = DbConfig.readDbConfigInfo(); 61. this.poolSize = Integer.parseInt(dbConfig.get("poolSize"); 62. for (int i = 0; i < poolSize; i+) 63. try 64. Class.forName(String)dbConfig.get("driver"); 65. conn = DriverManager.getConnection(String)dbConfig.get("url"), (String)dbConfig.get("username"), (String)dbConfig.get("password"); 66. pool.add(conn); 67. catch (ClassNotFoundException e) 68. e.printStackTrace(); 69. catch (SQLException e) 70. e.printStackTrace(); 71. 72. 73. 74.75. /* 76. * 用完将连接放回到连接池中 77. * param conn 78. */ 79. public synchronized void release(Connection conn) 80. pool.add(conn); 81. 82.83. /* 84. * 关闭连接池中的所有连接 85. */ 86. public synchronized void closePool() 87. for (int i = 0; i < pool.size(); i+) 88. try 89. conn = (Connection) pool.get(i); 90. conn.close(); 91. pool.remove(i); 92. catch (SQLException e) 93. e.printStackTrace(); 94. 95. 96. 97.98. public static void main(String args) throws Exception 99. (new DbConnectionPool().getConnection(); 100. 101. 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); co