|
/** * Statement的自封装，屏蔽了getResultSet，executeQuery，getGeneratedKeys方法 返回自己的接管类 * 目的适记录SQl的动作和设置相应连接最后活动时间。 * @author Liudong */ package com.drsl.db; import java.io.*; import java.sql.*; import java.util.*; import java.util.Date; import java.lang.reflect.*; import sun.jdbc.odbc.*; public class StatementObject implements InvocationHandler{ private Statement stm=null; private Statement stm_proxy=null; private final static String GETRESULTSET_METHOD_NAME = "getResultSet"; private final static String EXECUTEQUERY_METHOD_NAME = "executeQuery"; private final static String GETGENERATEDKEYS_METHOD_NAME = "getGeneratedKeys"; private ResultSetObject rso=null; public StatementObject(Statement stm){ this.stm=stm; } public Statement getStatement(){ if(stm_proxy==null){ ClassLoader classloader=stm.getClass().getClassLoader(); Class[] interfaces = stm.getClass().getInterfaces(); if(interfaces==null||interfaces.length==0){ interfaces = new Class[1]; interfaces[0] = Statement.class; } try{ stm_proxy= (Statement)Proxy.newProxyInstance(classloader,interfaces,this); }catch(NullPointerException e){ log(e,"StatementObject getStatement()--error"); } if(stm_proxy!=null) log("StatementObject getStatement()--success"); } return stm_proxy; } public Object invoke(Object proxy, Method m, Object[] args) throws Throwable { Object obj = null; log("StatementObject--invoke:Method: \""+m.getName()+"\""); //判断是否调用了getResultSet or executeQuery or getGeneratedKeys //是就截获 if(GETRESULTSET_METHOD_NAME.equals(m.getName()) || EXECUTEQUERY_METHOD_NAME.equals(m.getName()) || GETGENERATEDKEYS_METHOD_NAME.equals(m.getName())){ ResultSet rs=(ResultSet)m.invoke(stm, args); if(rs!=null && rso==null){ rso=new ResultSetObject(rs); obj=rso.getResultSet(); }else if(rso!=null) obj=rso.getResultSet(); else log("StatementObject--invoke:Method: \""+m.getName()+"\"--失败"); }else{ obj = m.invoke(stm, args); } //设置最后一次访问时间，以便及时清除超时的连接 setLastAccessTime( new Date().getTime()); return obj; } /** * 将文本信息写入日志文件 */ private void log(String msg) { ConnectionManager.log(msg); } /** * 将文本信息与异常写入日志文件 */ private void log(Throwable e, String msg) { ConnectionManager.log(e,msg); } //设置最后一次访问时间 private void setLastAccessTime(long ltime){ ConnectionObject.setLastAccessTime(ltime); } } ///////////////////////////////////////////////////////////////////////////////// /** * PreparedStatement 的自封装，屏蔽了executeQuery方法 返回自己的接管类 * 目的适记录SQl的动作和设置相应连接最后活动时间。 * @author Liudong */ package com.drsl.db; import java.io.*; import java.sql.*; import java.util.*; import java.util.Date; import java.lang.reflect.*; public class PreparedStatementObject implements InvocationHandler{ private PreparedStatement ps=null; private PreparedStatement ps_proxy =null; private final static String EXECUTEQUERY_METHOD_NAME = "executeQuery"; private ResultSetObject rso=null; PreparedStatementObject(PreparedStatement ps){ this.ps=ps; } public PreparedStatement getPreparedStatement(){ if(ps_proxy==null){ ClassLoader classloader=ps.getClass().getClassLoader(); Class[] interfaces = ps.getClass().getInterfaces(); if(interfaces==null||interfaces.length==0){ interfaces = new Class[1]; interfaces[0] = PreparedStatement.class; } try{ ps_proxy= (PreparedStatement) Proxy.newProxyInstance(classloader,interfaces,this); }catch(NullPointerException e){ log(e,"PreparedStatementObject getPreparedStatement()--error"); } if(ps_proxy!=null) log("PreparedStatementObject getPreparedStatement()--success"); } return ps_proxy; } public Object invoke(Object proxy, Method m, Object[] args) throws Throwable { Object obj = null; log("PreparedStatementObject--invoke:Method: \""+m.getName()+"\""); //是否调用了executeQuery 如果是 则接管 if(EXECUTEQUERY_METHOD_NAME.equals(m.getName())){ ResultSet rs=(ResultSet)m.invoke(ps, args); if(rs!=null && rso==null){ rso=new ResultSetObject(rs); obj=rso.getResultSet(); }else if(rso!=null) obj=rso.getResultSet(); else log("PreparedStatementObject--invoke:Method: \""+m.getName()+"\"--失败"); }else{ obj = m.invoke(ps, args); } obj = m.invoke(ps, args); //设置最后一次访问时间，以便及时清除超时的连接 setLastAccessTime( new Date().getTime()); return obj; } /** * 将文本信息写入日志文件 */ private void log(String msg) { ConnectionManager.log(msg); } /** * 将文本信息与异常写入日志文件 */ private void log(Throwable e, String msg) { ConnectionManager.log(e,msg); } //设置最后一次访问时间 private void setLastAccessTime(long ltime){ ConnectionObject.setLastAccessTime(ltime); } } //////////////////////////////////////////////////////////////////////// /** * Statement的自封装，屏蔽了getStatement方法 返回自己的接管类 * 目的适记录SQl的动作和设置相应连接最后活动时间。 * @author Liudong */ package com.drsl.db; import java.io.*; import java.sql.*; import java.util.*; import java.util.Date; import java.lang.reflect.*; public class ResultSetObject implements InvocationHandler{ private ResultSet rs=null; private ResultSet rs_proxy =null |