2. 数据库慢查询基础：什么是慢查询、慢查询的常见原因

在 Go 后端服务中，数据库查询的响应时间直接决定了接口的延迟。当一条 SQL 语句的执行时间超过预设阈值（通常为 100ms 或 1s），它就被定义为 慢查询。慢查询不仅是性能瓶颈的“信号灯”，更是连接池耗尽、系统雪崩的导火索。

2.1 慢查询的判定标准

不同业务场景对“慢”的定义不同，但业界通常采用以下分级标准：

2.2 慢查询的三大常见原因

根据对数百个 Go 生产项目的慢查询分析，超过 85% 的慢查询可归因于以下三类问题：

2.2.1 索引缺失或设计不当

索引是数据库查询加速的核心手段。当查询条件列没有索引时，数据库必须执行 全表扫描，逐行匹配数据。随着表数据量增长，扫描成本呈线性甚至指数级上升。

• 典型表现： EXPLAIN 输出中 type = ALL（全表扫描），rows 值接近表总行数。
• 常见误区： 只为 WHERE 条件建索引，忽略 ORDER BY、GROUP BY、JOIN 关联列的索引需求。
• 复合索引最左前缀失效： 查询条件未从复合索引的最左列开始，导致索引无法被使用。

-- 错误示例：查询 status 和 created_at，但索引顺序为 (created_at, status)
-- 索引 (created_at, status) 无法加速 status 单独查询
SELECT * FROM orders WHERE status = 'pending' ORDER BY created_at DESC;

-- 正确做法：创建复合索引 (status, created_at) 或单独索引 status

2.2.2 数据量过大且未做分页/分区优化

当单表数据量超过千万级别时，即使索引存在，深度分页、大范围扫描也会导致大量随机 IO。

• 深度分页问题： LIMIT 1000000, 20 需要扫描前 1000020 行，然后丢弃前 1000000 行。
• 未使用覆盖索引： 查询需要回表获取非索引列数据，增加额外 IO 开销。
• 表分区缺失： 没有按时间、地域等维度对表进行物理分区，导致查询扫描全表。

2.2.3 锁竞争与事务冲突

在高并发 Go 服务中，多个请求同时操作同一行或同一张表时，数据库的锁机制会导致查询等待。

• 行锁等待： 事务 A 未提交，持有某行的排他锁，事务 B 的更新或 SELECT ... FOR UPDATE 必须等待。
• 间隙锁（Gap Lock）： InnoDB 在可重复读隔离级别下，为防止幻读会锁定索引间隙，导致并发插入被阻塞。
• 元数据锁（MDL）： DDL 操作（如 ALTER TABLE）会阻塞后续所有 DML 查询。
• 死锁： 两个事务互相等待对方释放锁，数据库检测到后强制回滚其中一个事务，造成查询失败。

-- 锁等待示例：事务1 未提交
BEGIN;
UPDATE orders SET status = 'shipped' WHERE id = 1001;
-- 此时事务2 执行以下语句会被阻塞
UPDATE orders SET status = 'cancelled' WHERE id = 1001;
-- 直到事务1 COMMIT 或 ROLLBACK

2.3 慢查询原因分类与排查优先级

以下表格总结了三大原因的核心特征、排查工具和修复方向：

2.4 慢查询影响链路全景图

下图展示了慢查询如何从单条 SQL 逐步传导至整个 Go 服务集群，最终导致连接池耗尽和系统雪崩：

2.5 慢查询的发现与监控

在 Go 项目中，建议从以下三个层面建立慢查询发现机制：

1. 数据库层： 开启 MySQL 慢查询日志（slow_query_log = 1），设置 long_query_time = 0.2（200ms），并定期使用 pt-query-digest 分析日志。
2. 应用层： 在 Go 的数据库驱动回调中埋点，记录每次查询的耗时、SQL 指纹、调用栈。
3. 监控层： 将慢查询指标上报到 Prometheus，配置告警规则：当单接口慢查询比例超过 5% 时触发告警。

db.Callback().Query().After("gorm:query").Register("slow_query_logger", func(db *gorm.DB) {
    if db.Statement.SQL.String() != "" && db.Statement.Duration > 200*time.Millisecond {
      log.Warn().
        Str("sql", db.Statement.SQL.String()).
        Dur("duration_ms", db.Statement.Duration).
        Int64("rows", db.Statement.RowsAffected).
        Msg("slow query detected")
    }
  })