java 自己實現DataSource實現代碼
DataSource 對象所表示的物理數據源的連接。作為 DriverManager 工具的替代項。DataSource能提供最高性能的對數據庫的并發訪問,數據源技術是Java操作數據庫的一個很關鍵技術，流行的持久化框架都離不開數據源的應用。
數據源提供了一種簡單獲取數據庫連接的方式，并能在內部通過一個池的機制來復用數據庫連接，這樣就大大減少了創建數據庫連接的次數，提高了系統性能。下面，我們自己動手實現個精簡的數據源，代碼如下：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
public class MyDataSource { private LinkedList<Connection> connectionPool = new LinkedList<Connection>(); public MyDataSource() { for (int i = 0; i < 10; i++) { connectionPool.add(new MyConnection(creatConnection(),this)); } } private Connection creatConnection() { try { return DriverManager.getConnection( "jdbc:mysql://localhost:3306/test", "root", "root"); } catch (SQLException e) { // TODO Auto-generated catch block throw new ExceptionInInitializerError(); } } public Connection getConnection(){ System.out.println(connectionPool.size()); return connectionPool.removeFirst(); } public void freeConnection(Connection conn){ System.out.println("DataSource Close Connection"); connectionPool.addLast(conn); } } |
Java代碼
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
|
public class MyConnection implements Connection{ private Connection connection; private MyDataSource datasource; public Connection getConnection() { return connection; } public void setConnection(Connection connection) { this.connection = connection; } public MyConnection(Connection realconnection,MyDataSource datasource){ this.connection=realconnection; this.datasource=datasource; } @Override public void close() throws SQLException { // TODO Auto-generated method stub System.out.println("MyConnection Close"); datasource.freeConnection(this); } ... } |
我們通過DataSource獲得的Connection是經過包裹后的對象，這里應用到了代理模式。下面我們使用jdk的動態代理來改寫MyDataSource：
Java代碼
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
|
public class MyDataSource { private LinkedList<Connection> connectionPool = new LinkedList<Connection>(); public MyDataSource() { for (int i = 0; i < 10; i++) { connectionPool.add(GetProxy(creatConnection())); } } private Connection GetProxy(final Connection connection) { // TODO Auto-generated method stub return (Connection)Proxy.newProxyInstance(this.getClass().getClassLoader(), new Class[]{Connection.class}, new InvocationHandler(){ @Override public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { // TODO Auto-generated method stub Object value; if(method.getName().equalsIgnoreCase("close")){ connectionPool.addLast((Connection)proxy); System.out.println(connectionPool.size()); return null; }else{ value=method.invoke(connection, args); } System.out.println(connectionPool.size()); return value; } }); } private Connection creatConnection() { try { return DriverManager.getConnection( "jdbc:mysql://localhost:3306/test", "root", "root"); } catch (SQLException e) { // TODO Auto-generated catch block throw new ExceptionInInitializerError(); } } public Connection getConnection(){ System.out.println(connectionPool.size()); return connectionPool.removeFirst(); } public void freeConnection(Connection conn){ System.out.println("DataSource Close Connection"); connectionPool.addLast(conn); } } |
通過這種方式獲得的Connection是通過jdk的動態代理生成的一個代理對象，該代理對象實現了Connection接口。
以上兩種方式實現了我們自己的DataSource，在我們通過DataSource獲得的Connection對象的close方法都已經被改寫過了。在Connection對象調用close方法時，會將該Connection對象放入到緩存池中，而不是關閉對象。
感謝閱讀，希望能幫助到大家，謝謝大家對本站的支持！
原文鏈接：http://xm-king.iteye.com/blog/800519
