mybatis统计每条SQL的执行时间的方法示例
背景
最近面试经常被问到关于数据库的事务的问题,可能平时我就知道加个注解@Transactional之后就一脸懵逼的。现在发现这一块真的是常常被忽略了,然而面试官就是最喜欢这种看是不常用,但是非常重要的问题,进而达到出其不意攻其不备。不吹水了,开始正文。
方案一:切面编程@Aspect
此方案主要是通过环绕切面的方式将mapper包下的接口方法,然后前后计算时间差即可。这就是典型的AOP知识,不过这种计算比较粗糙,但是也是个办法。具体方法如下:
@Aspect @Component @Slf4j publicclassMapperAspect{ @AfterReturning("execution(*cn.xbmchina.mybatissqltime.mapper.*Mapper.*(..))") publicvoidlogServiceAccess(JoinPointjoinPoint){ log.info("Completed:"+joinPoint); } /** *监控cn.xbmchina.mybatissqltime.mapper..*Mapper包及其子包的所有public方法 */ @Pointcut("execution(*cn.xbmchina.mybatissqltime.mapper.*Mapper.*(..))") privatevoidpointCutMethod(){ } /** *声明环绕通知 * *@parampjp *@return *@throwsThrowable */ @Around("pointCutMethod()") publicObjectdoAround(ProceedingJoinPointpjp)throwsThrowable{ longbegin=System.nanoTime(); Objectobj=pjp.proceed(); longend=System.nanoTime(); log.info("调用Mapper方法:{},参数:{},执行耗时:{}纳秒,耗时:{}毫秒", pjp.getSignature().toString(),Arrays.toString(pjp.getArgs()), (end-begin),(end-begin)/1000000); returnobj; } }
方案二:mybatis的插件
MyBatis在四大对象的创建过程中,都会有插件进行介入。插件可以利用动态代理机制一层层的包装目标对象,而实现在目标对象执行目标方法之前进行拦截的效果。
MyBatis允许在已映射语句执行过程中的某一点进行拦截调用。
默认情况下,MyBatis允许使用插件来拦截的方法调用包括:
①Executor(update,query,flushStatements,commit,rollback,getTransaction,close,isClosed)
②ParameterHandler(getParameterObject,setParameters)
③ResultSetHandler(handleResultSets,handleOutputParameters)
④StatementHandler(prepare,parameterize,batch,update,query)
下面是代码:
importorg.apache.ibatis.executor.statement.StatementHandler; importorg.apache.ibatis.mapping.BoundSql; importorg.apache.ibatis.mapping.ParameterMapping; importorg.apache.ibatis.plugin.Interceptor; importorg.apache.ibatis.plugin.Intercepts; importorg.apache.ibatis.plugin.Invocation; importorg.apache.ibatis.plugin.Plugin; importorg.apache.ibatis.plugin.Signature; importorg.apache.ibatis.session.ResultHandler; importorg.slf4j.Logger; importorg.slf4j.LoggerFactory; importorg.springframework.stereotype.Component; importjava.sql.Statement; importjava.util.List; importjava.util.Properties; /** *Sql执行时间记录拦截器 * *@authorzero *2019年12月13日17:05:28 */ @Intercepts({@Signature(type=StatementHandler.class,method="query",args={Statement.class,ResultHandler.class}), @Signature(type=StatementHandler.class,method="update",args={Statement.class}), @Signature(type=StatementHandler.class,method="batch",args={Statement.class})}) @Component publicclassSqlExecuteTimeCountInterceptorimplementsInterceptor{ privatestaticLoggerlogger=LoggerFactory.getLogger(SqlExecuteTimeCountInterceptor.class); /** *打印的参数字符串的最大长度 */ privatefinalstaticintMAX_PARAM_LENGTH=50; /** *记录的最大SQL长度 */ privatefinalstaticintMAX_SQL_LENGTH=200; @Override publicObjectintercept(Invocationinvocation)throwsThrowable{ Objecttarget=invocation.getTarget(); longstartTime=System.currentTimeMillis(); StatementHandlerstatementHandler=(StatementHandler)target; try{ returninvocation.proceed(); }finally{ longendTime=System.currentTimeMillis(); longtimeCount=endTime-startTime; BoundSqlboundSql=statementHandler.getBoundSql(); Stringsql=boundSql.getSql(); ObjectparameterObject=boundSql.getParameterObject(); ListparameterMappingList=boundSql.getParameterMappings(); //格式化Sql语句,去除换行符,替换参数 sql=formatSQL(sql,parameterObject,parameterMappingList); logger.info("执行SQL:[,{}]执行耗时[{}ms]",sql,timeCount); } } /** *格式化/美化SQL语句 * *@paramsqlsql语句 *@paramparameterObject参数的Map *@paramparameterMappingList参数的List *@return格式化之后的SQL */ privateStringformatSQL(Stringsql,ObjectparameterObject,List parameterMappingList){ //输入sql字符串空判断 if(sql==null||sql.length()==0){ return""; } //美化sql sql=beautifySql(sql); //不传参数的场景,直接把sql美化一下返回出去 if(parameterObject==null||parameterMappingList==null||parameterMappingList.size()==0){ returnsql; } returnLimitSQLLength(sql); } /** *返回限制长度之后的SQL语句 * * *@paramsql原始SQL语句 */ privateStringLimitSQLLength(Stringsql){ if(sql==null||sql.length()==0){ return""; } if(sql.length()>MAX_SQL_LENGTH){ returnsql.substring(0,MAX_SQL_LENGTH); }else{ returnsql; } } @Override publicObjectplugin(Objecttarget){ returnPlugin.wrap(target,this); } @Override publicvoidsetProperties(Propertiesproperties){ } /** *替换SQL中?所对应的值,只保留前50个字符 * *@paramsqlsql语句 *@paramvalueOf?对应的值 */ privateStringreplaceValue(Stringsql,StringvalueOf){ //超过50个字符只取前50个 if(valueOf!=null&&valueOf.length()>MAX_PARAM_LENGTH){ valueOf=valueOf.substring(0,MAX_PARAM_LENGTH); } sql=sql.replaceFirst("\\?",valueOf); returnsql; } /** *美化sql * *@paramsqlsql语句 */ privateStringbeautifySql(Stringsql){ sql=sql.replaceAll("[\\s\n]+",""); returnsql; } }
方案三:直接用druid
这种就是我们平时用的最多的,但是面试的话说一下就得了,估计也没有怎么好问的了。
Springboot+druid的配置application.yml文件如下:
spring: datasource: url:jdbc:mysql://localhost:3306/testdb1?characterEncoding=utf-8&useUnicode=true&useSSL=false&serverTimezone=UTC driver-class-name:com.mysql.jdbc.Driver#mysql8.0以前使用com.mysql.jdbc.Driver username:root password:root platform:mysql #通过这句配置将druid连接池引入到我们的配置中,spring会尽可能判断类型是什么,然后根据情况去匹配驱动类。 type:com.alibaba.druid.pool.DruidDataSource druid: initial-size:5#初始化大小 min-idle:5#最小 max-active:100#最大 max-wait:60000#配置获取连接等待超时的时间 time-between-eviction-runs-millis:60000#配置间隔多久才进行一次检测,检测需要关闭的空闲连接,单位是毫秒 min-evictable-idle-time-millis:300000#指定一个空闲连接最少空闲多久后可被清除,单位是毫秒 validationQuery:select'x' test-while-idle:true#当连接空闲时,是否执行连接测试 test-on-borrow:false#当从连接池借用连接时,是否测试该连接 test-on-return:false#在连接归还到连接池时是否测试该连接 filters:config,wall,stat#配置监控统计拦截的filters,去掉后监控界面sql无法统计,'wall'用于防火墙 poolPreparedStatements:true#打开PSCache,并且指定每个连接上PSCache的大小 maxPoolPreparedStatementPerConnectionSize:20 maxOpenPreparedStatements:20 #通过connectProperties属性来打开mergeSql功能;慢SQL记录 connectionProperties:druid.stat.slowSqlMillis=200;druid.stat.logSlowSql=true;config.decrypt=false #合并多个DruidDataSource的监控数据 #use-global-data-source-stat:true #WebStatFilter配置,说明请参考DruidWiki,配置_配置WebStatFilter web-stat-filter: enabled:true#是否启用StatFilter默认值true url-pattern:/* exclusions:/druid/*,*.js,*.gif,*.jpg,*.bmp,*.png,*.css,*.ico session-stat-enable:true session-stat-max-count:10 #StatViewServlet配置,说明请参考DruidWiki,配置_StatViewServlet配置 stat-view-servlet: enabled:true#是否启用StatViewServlet默认值true url-pattern:/druid/* reset-enable:true login-username:admin login-password:admin
总结
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。
声明:本文内容来源于网络,版权归原作者所有,内容由互联网用户自发贡献自行上传,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任。如果您发现有涉嫌版权的内容,欢迎发送邮件至:czq8825#qq.com(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。