mirror of
https://github.com/wahyd4/pinpoint.git
synced 2026-08-23 11:46:46 +10:00
[유치수] [NOBTS] add Apache httpclient modifier.
git-svn-id: http://svn.bds.nhncorp.com/pe/hippo-tomcat-profiler/trunk@557 84d0f5b1-2673-498c-a247-62c4ff18d310
This commit is contained in:
@@ -5,11 +5,15 @@ import java.util.logging.Level;
|
||||
import java.util.logging.Logger;
|
||||
|
||||
import javassist.ByteArrayClassPath;
|
||||
import javassist.CtClass;
|
||||
import javassist.CtMethod;
|
||||
|
||||
import com.profiler.config.TomcatProfilerConstant;
|
||||
import com.profiler.interceptor.Interceptor;
|
||||
import com.profiler.interceptor.bci.ByteCodeInstrumentor;
|
||||
import com.profiler.interceptor.bci.InstrumentClass;
|
||||
import com.profiler.modifier.AbstractModifier;
|
||||
import com.profiler.trace.DatabaseRequestTracer;
|
||||
|
||||
public class MySQLStatementModifier extends AbstractModifier {
|
||||
|
||||
@@ -45,37 +49,36 @@ public class MySQLStatementModifier extends AbstractModifier {
|
||||
// return changeMethod(javassistClassName, classFileBuffer);
|
||||
}
|
||||
|
||||
// private byte[] changeMethod(String javassistClassName, byte[]
|
||||
// classfileBuffer) {
|
||||
// try {
|
||||
// CtClass cc = classPool.get(javassistClassName);
|
||||
//
|
||||
// updateExecuteQueryMethod(cc);
|
||||
//
|
||||
// printClassConvertComplete(javassistClassName);
|
||||
//
|
||||
// return cc.toBytecode();
|
||||
// } catch (Exception e) {
|
||||
// if (logger.isLoggable(Level.WARNING)) {
|
||||
// logger.log(Level.WARNING, e.getMessage(), e);
|
||||
// }
|
||||
// }
|
||||
// return null;
|
||||
// }
|
||||
//
|
||||
// private void updateExecuteQueryMethod(CtClass cc) throws Exception {
|
||||
// CtClass[] params = new CtClass[1];
|
||||
// params[0] = classPool.getCtClass("java.lang.String");
|
||||
// CtMethod method = cc.getDeclaredMethod("executeQuery", params);
|
||||
//
|
||||
// StringBuilder sb = new StringBuilder();
|
||||
// sb.append("{");
|
||||
// sb.append(DatabaseRequestTracer.FQCN + ".putSqlQuery(" +
|
||||
// TomcatProfilerConstant.REQ_DATA_TYPE_DB_QUERY + ",$1);");
|
||||
// sb.append(DatabaseRequestTracer.FQCN + ".put(" +
|
||||
// TomcatProfilerConstant.REQ_DATA_TYPE_DB_EXECUTE_QUERY + ");");
|
||||
// sb.append("}");
|
||||
//
|
||||
// method.insertAfter(sb.toString());
|
||||
// }
|
||||
@Deprecated
|
||||
private byte[] changeMethod(String javassistClassName, byte[] classfileBuffer) {
|
||||
try {
|
||||
CtClass cc = classPool.get(javassistClassName);
|
||||
|
||||
updateExecuteQueryMethod(cc);
|
||||
|
||||
printClassConvertComplete(javassistClassName);
|
||||
|
||||
return cc.toBytecode();
|
||||
} catch (Exception e) {
|
||||
if (logger.isLoggable(Level.WARNING)) {
|
||||
logger.log(Level.WARNING, e.getMessage(), e);
|
||||
}
|
||||
}
|
||||
return null;
|
||||
}
|
||||
|
||||
@Deprecated
|
||||
private void updateExecuteQueryMethod(CtClass cc) throws Exception {
|
||||
CtClass[] params = new CtClass[1];
|
||||
params[0] = classPool.getCtClass("java.lang.String");
|
||||
CtMethod method = cc.getDeclaredMethod("executeQuery", params);
|
||||
|
||||
StringBuilder sb = new StringBuilder();
|
||||
sb.append("{");
|
||||
sb.append(DatabaseRequestTracer.FQCN + ".putSqlQuery(" + TomcatProfilerConstant.REQ_DATA_TYPE_DB_QUERY + ",$1);");
|
||||
sb.append(DatabaseRequestTracer.FQCN + ".put(" + TomcatProfilerConstant.REQ_DATA_TYPE_DB_EXECUTE_QUERY + ");");
|
||||
sb.append("}");
|
||||
|
||||
method.insertAfter(sb.toString());
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user