建设网站的总结,桂林网站开发公司电话,八戒财税,vue做的项目网站文章目录背景具体实现MySQL5MySQL6MySQL8使用方法测试结果背景 公司的一个需求#xff0c;公司既有的链路追踪日志组件要支持MySQL的sql执行时间打印#xff0c;要实现链路追踪常用的手段就是实现第三方框架或工具提供的拦截器接口或者是过滤器接口#xff0c;对于MySQL也不…
文章目录背景具体实现MySQL5MySQL6MySQL8使用方法测试结果背景 公司的一个需求公司既有的链路追踪日志组件要支持MySQL的sql执行时间打印要实现链路追踪常用的手段就是实现第三方框架或工具提供的拦截器接口或者是过滤器接口对于MySQL也不例外实际上就是实现了MySQL驱动的拦截器接口而已。
具体实现 MySQL的渠道有不同的版本不同版本的拦截器接口是不同的所以要针对你所使用的不同版本的MySQL驱动去实现响应的拦截器接下来分别介绍下MySQL渠道5,6,8版本的实现方式。
MySQL5 这里以MySQL渠道5.1.18版本为例实现实现StatementInterceptorV2接口主要实现逻辑在preProcess和postProcess方法这两个方法是sql执行前后要执行的方法我所使用的框架是logback这里使用MDC来记录sql执行前的一个时间戳代码在postProcess方法MDC.put(sql_exec_time, start);自己也可以使用ThreadLocal等来实现然后在postProcess方法中使用MDC.get(sql_exec_time)将记录的sql执行前的时间取出来最后再用当前时间戳减去sql执行前的时间就算出了sql执行的时间。
import static net.logstash.logback.marker.Markers.append;import com.mysql.jdbc.Connection;
import com.mysql.jdbc.ResultSetInternalMethods;
import com.mysql.jdbc.Statement;
import com.mysql.jdbc.StatementInterceptorV2;
import com.redick.util.LogUtil;
import java.sql.SQLException;
import java.util.Properties;
import lombok.extern.slf4j.Slf4j;
import org.slf4j.MDC;/*** author Redick01*/
Slf4j
public class Mysql5StatementInterceptor implements StatementInterceptorV2 {Overridepublic void init(Connection connection, Properties properties) throws SQLException {}Overridepublic ResultSetInternalMethods preProcess(String s, Statement statement, Connection connection)throws SQLException {String start String.valueOf(System.currentTimeMillis());MDC.put(sql_exec_time, start);log.info(LogUtil.customizeMarker(LogUtil.kLOG_KEY_TRACE_TAG, sql_exec_before), 开始执行sql);return null;}Overridepublic boolean executeTopLevelOnly() {return false;}Overridepublic void destroy() {}Overridepublic ResultSetInternalMethods postProcess(String s, Statement statement,ResultSetInternalMethods resultSetInternalMethods, Connection connection, int i,boolean b, boolean b1, SQLException e) throws SQLException {long start Long.parseLong(MDC.get(sql_exec_time));long end System.currentTimeMillis();log.info(LogUtil.customizeMarker(LogUtil.kLOG_KEY_TRACE_TAG, sql_exec_after).and(append(LogUtil.kLOG_KEY_SQL_EXEC_DURATION, end - start)), 结束执行sql);return null;}
}MySQL6 MySQL6和MySQL5基本一样只是接口不是同一个直接放代码
import static net.logstash.logback.marker.Markers.append;import com.mysql.cj.api.MysqlConnection;
import com.mysql.cj.api.jdbc.Statement;
import com.mysql.cj.api.jdbc.interceptors.StatementInterceptor;
import com.mysql.cj.api.log.Log;
import com.mysql.cj.api.mysqla.result.Resultset;
import com.redick.util.LogUtil;
import java.sql.SQLException;
import java.util.Properties;
import lombok.extern.slf4j.Slf4j;
import org.slf4j.MDC;/*** author Redick01*/
Slf4j
public class Mysql6StatementInterceptor implements StatementInterceptor {Overridepublic StatementInterceptor init(MysqlConnection mysqlConnection, Properties properties,Log log) {return null;}Overridepublic T extends Resultset T preProcess(String s, Statement statement) throws SQLException {String start String.valueOf(System.currentTimeMillis());MDC.put(sql_exec_time, start);log.info(LogUtil.customizeMarker(LogUtil.kLOG_KEY_TRACE_TAG, sql_exec_before), 开始执行sql);return null;}Overridepublic boolean executeTopLevelOnly() {return false;}Overridepublic void destroy() {}Overridepublic T extends Resultset T postProcess(String s, Statement statement, T t, int i, boolean b,boolean b1, Exception e) throws SQLException {long start Long.parseLong(MDC.get(sql_exec_time));long end System.currentTimeMillis();log.info(LogUtil.customizeMarker(LogUtil.kLOG_KEY_TRACE_TAG, sql_exec_after).and(append(LogUtil.kLOG_KEY_SQL_EXEC_DURATION, end - start)), 结束执行sql);return null;}
}MySQL8 MySQL8和MySQL5/6的拦截器接口又不一样了MySQL8的拦截器接口是com.mysql.cj.interceptors.QueryInterceptor统计sql执行时间的方式还是一样的代码如下
import static net.logstash.logback.marker.Markers.append;import com.mysql.cj.MysqlConnection;
import com.mysql.cj.Query;
import com.mysql.cj.interceptors.QueryInterceptor;
import com.mysql.cj.log.Log;
import com.mysql.cj.protocol.Resultset;
import com.mysql.cj.protocol.ServerSession;
import com.redick.util.LogUtil;
import java.util.Properties;
import java.util.function.Supplier;
import lombok.extern.slf4j.Slf4j;
import org.slf4j.MDC;/*** author Redick01*/
Slf4j
public class Mysql8QueryInterceptor implements QueryInterceptor {Overridepublic QueryInterceptor init(MysqlConnection mysqlConnection, Properties properties, Log log) {return null;}Overridepublic T extends Resultset T preProcess(SupplierString supplier, Query query) {String start String.valueOf(System.currentTimeMillis());MDC.put(sql_exec_time, start);log.info(LogUtil.customizeMarker(LogUtil.kLOG_KEY_TRACE_TAG, sql_exec_before), 开始执行sql);return null;}Overridepublic boolean executeTopLevelOnly() {return false;}Overridepublic void destroy() {}Overridepublic T extends Resultset T postProcess(SupplierString supplier, Query query, T t,ServerSession serverSession) {long start Long.parseLong(MDC.get(sql_exec_time));long end System.currentTimeMillis();log.info(LogUtil.customizeMarker(LogUtil.kLOG_KEY_TRACE_TAG, sql_exec_after).and(append(LogUtil.kLOG_KEY_SQL_EXEC_DURATION, end - start)), 结束执行sql);return null;}
}使用方法 MySQL5和6的使用方式一样在数据库链接的url中增加如下statementInterceptors参数例如 url: jdbc:mysql://127.0.0.1:3316/log-helper?useUnicodetruecharacterEncodingUTF8statementInterceptorscom.redick.support.mysql.Mysql5StatementInterceptorserverTimezoneCSTMySQL8则是在url中增加queryInterceptors参数例如 url: jdbc:mysql://127.0.0.1:3316/log-helper?useUnicodetruecharacterEncodingUTF8queryInterceptorscom.redick.support.mysql.Mysql8QueryInterceptorserverTimezoneCST测试结果 sql执行前日志
{timestamp:2023-02-28T17:16:29.23408:00,version:0.0.1,message:开始执行sql,logger_name:com.redick.support.mysql.Mysql5StatementInterceptor,thread_name:http-nio-3321-exec-4,level:INFO,level_value:20000,traceId:9ed930dc-4cc6-4719-bf33-9fcb618fd65b,spanId:1,request_type:getName,parentId:0,trace_tag:sql_exec_before}sql执行后日志sql_duration标识执行sql耗时3ms
{timestamp:2023-02-28T17:16:29.23708:00,version:0.0.1,message:结束执行sql,logger_name:com.redick.support.mysql.Mysql5StatementInterceptor,thread_name:http-nio-3321-exec-4,level:INFO,level_value:20000,traceId:9ed930dc-4cc6-4719-bf33-9fcb618fd65b,spanId:1,request_type:getName,parentId:0,trace_tag:sql_exec_after,sql_duration:3}具体实现代码参考基于Spring AOP logstash-logback-encoder日志链路追踪工具LogHelper
