為什么要使用連接池？
連接池一般比直接連接更有優越性因為它提高了性能的同時還保存了寶貴的資源。打開數據庫連接時CPU和網絡的重要任務因此，在整個應用程序的使用過程當中重復的打開直接連接將導致性能的下降。而池連接只在服務器啟動時打開一次，從而消除了這種性能問題。另外，因為連接只用于很短的時間，所以，連接可以被有效共享，而且有關連接參數的特有信息，只對池驅動程序有效，如數據庫用戶名稱和密碼，從而增強了系統的安全性和可管理性。
打個比方：
一輛汽車想從河的此岸到彼岸，這之間沒有橋，怎么辦呢？架橋吧。
橋架好了，車過去了。
然后呢？這個橋是拆掉呢？還是接著供以后使用呢？
如果是拆掉，那么就相當于數據庫的直連，數據庫的每一個連接，都需要架一所橋，數據操作之后也就是說“車”通過之后，拆掉此橋。
如果是保留，那么就相當于使用了“連接池”技術，不過也并非“一座橋”這么簡單。
主要思想：
是基于JDBC而來的
JDBC方法：開啟一個Connection,使用一個連接,關閉一個連接。
再次操作重復上面的。
而開啟一個連接對象浪費很多服務器資源。
數據庫連接池：通過參數配置（參數看你需要綜合考慮）開啟N個連接 放在容器中(Tomcat,weblogic等)
使用連接，
釋放連接。注意不是關閉，從新放回容器中，等待下次使用，無需再次開啟連接。
實現其基本功能的核心代碼：
1 package com.linying;
2
3 import java.sql.Connection;
4 import java.sql.DriverManager;
5 import java.sql.SQLException;
6 import java.util.LinkedList;
7
8 /**
9 * 加工數據源，實現連接池
10 * @author Ying-er
11 * @time 2010-2-1下午06:47:03
12 * @version 1.0
13 */
14 public class MyDataSource {
15 /**
16 * 指定數據庫的URL
17 */
18 private String url = "jdbc:mysql://127.0.0.1/test";
19
20 /**
21 * 指定登陸用戶名
22 */
23 private String user = "root";
24
25 /**
26 * 指定登陸用戶的密碼
27 */
28 private String password = "1234";
29
30 /**
31 * 初始連接數（一次性創建50個連接）
32 */
33 private int initCount = 50;
34
35 /**
36 * 記錄當前連接數
37 */
38 int currentCount = 0;
39
40 /**
41 * 使用LinkedList的connectionPool存儲MyConnection對象
42 */
43 LinkedList<Connection> connectionPool = new LinkedList<Connection>();
44
45 /**
46 * 構造函數 創建MyDataSource時創建initCount個連接
47 *
48 */
49 public MyDataSource() {
50 try {
51 for (int i = 0; i < initCount; i++) {
52 this.connectionPool.addLast(this.createConnection());
53 this.currentCount++;
54 }
55 } catch (SQLException e) {
56 throw new ExceptionInInitializerError(e);
57 }
58 }
59
60 /**
61 * 創建連接
62 *
63 * @return
64 * @throws SQLException
65 */
66 private Connection createConnection() throws SQLException {
67 Connection realConnection = DriverManager.getConnection(url, user,
68 password);
69 MyConnection myConnection = new MyConnection(realConnection, this);
70 return myConnection;
71 }
72
73 /**
74 * 從連接池里獲得連接
75 *
76 * @return
77 * @throws SQLException
78 */
79 public Connection getConnection() throws SQLException {
80 synchronized (connectionPool) {
81 if (this.connectionPool.size() > 0) {
82 return this.connectionPool.removeFirst();
83 } else {
84 this.currentCount++;
85 return this.createConnection();
86 }
87
88 }
89 }
90
91 /**
92 * 釋放連接
93 *
94 * @param conn
95 */
96 public void free(Connection conn) {
97 this.connectionPool.addLast(conn);
98 }
99 }
1 package com.linying;
2
3 import java.sql.Array;
4 import java.sql.Blob;
5 import java.sql.CallableStatement;
6 import java.sql.Clob;
7 import java.sql.Connection;
8 import java.sql.DatabaseMetaData;
9 import java.sql.NClob;
10 import java.sql.PreparedStatement;
11 import java.sql.SQLClientInfoException;
12 import java.sql.SQLException;
13 import java.sql.SQLWarning;
14 import java.sql.SQLXML;
15 import java.sql.Savepoint;
16 import java.sql.Statement;
17 import java.sql.Struct;
18 import java.util.Map;
19 import java.util.Properties;
20 /**
21 * 自定義Connection
22 * @author Ying-er
23 * @time 2010-2-1下午06:36:24
24 * @version 1.0
25 */
26 public class MyConnection implements Connection{
27
28 private Connection realConnection;
29 private MyDataSource dataSource;
30 private int maxUserCount=200;
31 private int currentUserCount=0;
32
33 MyConnection(Connection connection,MyDataSource dataSource){
34 this.realConnection=connection;
35 this.dataSource=dataSource;
36 }
37
38 public void clearWarnings() throws SQLException {
39 // TODO Auto-generated method stub
40 this.realConnection.clearWarnings();
41
42 }
43
44 /**
45 * 重寫close方法，
46 * close的時候
47 * 將此已用過的數據源添加到LinkedList尾部
48 * 此LinkedList在MyDataSource文件中定義
49 * 注意：目的是釋放而不是不是關閉數據源
50 */
51 public void close() throws SQLException {
52 // TODO Auto-generated method stub
53 this.currentUserCount++;
54 if(this.currentUserCount<this.maxUserCount){
55 this.dataSource.connectionPool.addLast(this);
56 }
57 else{
58 this.realConnection.close();
59 this.dataSource.currentCount--;
60 }
61
62 }
63
64 /**
65 * 實現Connection中的所有方法
66 * ……
67 */
68
69 public void commit() throws SQLException {
70 // TODO Auto-generated method stub
71 this.realConnection.commit();
72
73 }
74 /**
75 * 以下代碼略掉
76 */
此實例工程下載地址：
http://m.tkk7.com/Files/crazycoding/DBConnectionPool.rar
注：只是個人研究成果，有錯誤和不準確之處請諒解。
posted on 2010-02-01 19:06
Ying-er 閱讀(372)
評論(0) 編輯 收藏