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);}}
}