2019獨角獸企業重金招聘Python工程師標準>>>

import java.sql.Types;import com.alibaba.druid.filter.FilterEventAdapter; import com.alibaba.druid.proxy.jdbc.JdbcParameter; import com.alibaba.druid.proxy.jdbc.PreparedStatementProxy; import com.alibaba.druid.proxy.jdbc.StatementProxy; import com.alibaba.druid.util.JdbcUtils; import com.dominos.cloud.common.util.SpringBeanUtils;public class TracerDruidFilter extends FilterEventAdapter {@Overrideprotected void statementExecuteBefore(StatementProxy statement, String sql) {outLog(sql);logParameter(statement);super.statementExecuteBefore(statement, sql);}@Overrideprotected void statementExecuteUpdateBefore(StatementProxy statement, String sql) {// TODO Auto-generated method stuboutLog(sql);logParameter(statement);super.statementExecuteUpdateBefore(statement, sql);}@Overrideprotected void statementExecuteQueryBefore(StatementProxy statement, String sql) {// TODO Auto-generated method stuboutLog(sql);logParameter(statement);super.statementExecuteQueryBefore(statement, sql);}protected void statementExecuteBatchAfter(StatementProxy statement, int[] result) {String sql;if (statement instanceof PreparedStatementProxy) {sql = ((PreparedStatementProxy) statement).getSql();} else {sql = statement.getBatchSql();}outLog(sql);super.statementExecuteQueryBefore(statement, sql);} private void logParameter(StatementProxy statement) {if (!(statement instanceof PreparedStatementProxy)) {return;}TracerUtils tracer = SpringBeanUtils.getBean(TracerUtils.class);if (tracer == null) {return;}{StringBuffer buf = new StringBuffer();buf.append(" Parameters : [");for (int i = 0, parametersSize = statement.getParametersSize(); i < parametersSize; ++i) {JdbcParameter parameter = statement.getParameter(i);if (i != 0) {buf.append(", ");}if (parameter == null) {continue;}int sqlType = parameter.getSqlType();Object value = parameter.getValue();switch (sqlType) {case Types.NULL:buf.append("NULL");break;default:buf.append(String.valueOf(value));break;}}buf.append("]");tracer.addTag("sql.Parameters", buf.toString());}{StringBuffer buf = new StringBuffer();buf.append(" Types : [");for (int i = 0, parametersSize = statement.getParametersSize(); i < parametersSize; ++i) {JdbcParameter parameter = statement.getParameter(i);if (i != 0) {buf.append(", ");}if (parameter == null) {continue;}int sqlType = parameter.getSqlType();buf.append(JdbcUtils.getTypeName(sqlType));}buf.append("]");tracer.addTag("sql.Types", buf.toString());}}private void outLog(String sql) {TracerUtils tracer = SpringBeanUtils.getBean(TracerUtils.class);if (tracer != null) {tracer.addTag("sql.sql", sql);}} }

?

轉載于:https://my.oschina.net/xiaominmin/blog/3049471

總結

以上是生活随笔為你收集整理的Tracer Druid 记录sql 以及参数的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。