自定义数据库连接池

1、定义自己的数据库连接池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.

2、* 编写者：hnylj 15. * 16. */ 17. public class DbConnectionPool 18.19. private List 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(poolSize); 30. this.createConnection(); 31. 32.33. /* 34. * 得到当前连接池的一个实例 35. */ 36. public static DbConnectionPool getInstance() 37. if (instance = null) 38. instance = new DbConn

3、ectionPool(); 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 dbConfig = DbConfig.readDbConfigInfo(); 61. this.poolSize = Integer.parseInt(dbConfig.get(poolSize); 62. for (int i = 0; i poolSize; i+) 63. try 64. Class.forNam

4、e(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

5、 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.Arra

6、yList;import java.util.List;import java.util.Map;/* * 定义自己的数据库连接池 * 编写者：hnylj * */public class DbConnectionPool private List pool; private int poolSize; private Connection conn = null; private static DbConnectionPool instance = null; /* * 单粒模式 * 私有构造方法，获得本类的对象，通过getIstance方法。 */ private DbConnectionPool() pool = new ArrayList(poolSize); this.createConnection(); /* * 得到当前连接池的一个实例 */ public static DbConnectionPool getInstance() if (instance = null) instance = new DbConnectionPool(); return instanc

7、e; /* * 得到连接池中的一个连接 */ 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 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

《自定义数据库连接池》由会员桔****分享，可在线阅读，更多相关《自定义数据库连接池》请在金锄头文库上搜索。