Java中统计SQL执行耗时并识别慢日志的核心思路是:在SQL执行前后打点计时,结合阈值判断是否为“慢SQL”,再按需记录、聚合或告警;最常用方式是拦截JDBC或利用MyBatis Interceptor,在Executor的update/query方法中用System.nanoTime()计算高精度耗时,获取SQL与参数并按阈值(如500ms)记录WARN日志,建议输出至独立slow-sql.log文件。

Java 中统计 SQL 执行耗时并识别慢日志,核心思路是:在 SQL 执行前后打点计时,结合阈值判断是否为“慢 SQL”,再按需记录、聚合或告警。不依赖数据库代理或 APM 工具时,最常用且可控的方式是通过 拦截 JDBC Statement/PreparedStatement 执行 或 利用 ORM 框架的插件机制(如 MyBatis 的 Interceptor)实现。
用 MyBatis Interceptor 拦截 SQL 执行耗时
这是 Spring Boot + MyBatis 项目中最轻量、侵入性最小的方案。通过自定义 Interceptor,在 SQL 执行前后获取纳秒级时间戳,计算耗时并记录。
- 实现
org.apache.ibatis.plugin.Interceptor接口,拦截Executor的update和query方法 - 使用
System.nanoTime()获取高精度起止时间,避免System.currentTimeMillis()的毫秒级误差 - 从
MappedStatement获取 SQL(可调用getBoundSql().getSql()),注意参数未替换,如需脱敏可正则过滤敏感字段 - 设置慢 SQL 阈值(如 500ms),超过即记录 WARN 日志,并附带执行 SQL、参数、耗时、线程名、调用栈(可选)
- 建议将慢 SQL 日志单独输出到
slow-sql.log文件,便于运维筛选和监控
用 Spring AOP 统一拦截 JdbcTemplate / NamedParameterJdbcTemplate
若项目主要使用 Spring JDBC 模板而非 MyBatis,可用 AOP 在方法层面切面增强,无需修改 DAO 层代码。
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
- 定义切点匹配
JdbcTemplate.query*、update、execute等方法 - 在
@Around通知中记录开始时间,执行原方法后计算耗时 - 通过
JoinPoint.getArgs()获取 SQL 字符串(第一个参数通常是 SQL);参数对象可通过反射提取或直接打印 toString(注意避免大对象 toString 阻塞) - 推荐配合
@Order(Ordered.HIGHEST_PRECEDENCE)保证顺序,避免被其他 AOP 干扰 - 可扩展支持统计维度:按 SQL 模板(去掉参数值)、按 Mapper 类名、按 HTTP 请求 ID(结合 MDC)做聚合分析
借助 DataSource 代理实现全链路 SQL 监控
对底层更透明,适用于多框架共存(MyBatis + JPA + JDBC 直连)场景。原理是包装原始数据源,代理 Connection → PreparedStatement → execute 流程。
立即学习“Java免费学习笔记(深入)”;
- 使用
HikariCP时可配置dataSourceProperties启用com.zaxxer.hikari.metrics.MetricsTrackerFactory(仅基础指标) - 更灵活的做法是自定义
DataSource包装器(继承DelegatingDataSource),重写getConnection()返回代理 Connection - 逐层代理
Connection → PreparedStatement → executeQuery/executeUpdate,在最终执行处埋点计时 - 优势:不依赖上层框架,SQL 拦截彻底;缺点:代码稍重,需处理 CallableStatement、Batch 等边界情况
- 可集成 Micrometer,将慢 SQL 耗时作为 Timer 指标上报 Prometheus
日志格式与后续处理建议
慢 SQL 日志不是记下来就结束,结构化才利于分析。推荐统一字段和格式:
- 固定前缀:
[SLOW-SQL],方便 grep 或日志系统 tag - 关键字段:耗时(ms)、SQL 摘要(如
SELECT * FROM user WHERE id = ?)、参数列表(JSON 格式,脱敏手机号/身份证)、执行线程、类方法(com.xxx.UserDao.selectById)、TraceID(如有链路追踪) - 示例日志:[SLOW-SQL] cost=1286ms, sql="SELECT * FROM order WHERE status = ? AND create_time > ?", args=[1,"2024-01-01"], method=UserMapper.listRecent, traceId=abc123
- 进阶:用 Logback 的
SiftingAppender按 SQL 模板动态分文件;或通过AsyncAppender异步写入,避免阻塞业务线程 - 生产环境建议关闭全量 SQL 日志,只开慢 SQL 记录;开发/测试环境可开启 DEBUG 级别打印绑定参数

















