spring动态代理

package com.lxt008; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.util.Vector; public class ConnectionPool { private static Connection conn; private static Vector pool; private static int POOL_MAX_SIZE; public static Connection createConnection() { try { Class.forName("oracle.jdbc.driver.OracleDriver"); conn=DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:accp","scott","tiger"); } catch (ClassNotFoundException e) { e.printStackTrace(); } catch (SQLException e) { e.printStackTrace(); } return conn; } public static synchronized Connection getConnection() { Connection newCon=null; if(pool==null) { pool=new Vector(); } if(pool.size()==0) { newCon=createConnection(); } else { //获取的连接必须从池中删除． int last_idx=pool.size()-1; conn=(Connection)pool.get(last_idx); pool.remove(pool.get(last_idx)); } //因为需要对Connection的close()方法进行拦截 //所以需要要给Connection接口动态加入代理，getConnection()是加入代理的好地方 //cp是动态代理对象 ConnectionProxy cp=new ConnectionProxy(newCon); return cp.bind(newCon); } public static synchronized void releaseConnection(Connection con) { if(pool.size()>POOL_MAX_SIZE) { try { con.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } else { pool.add(con); } } }