4. 慢查询定义与识别：什么是慢查询、慢查询日志配置、慢查询对连接池的影响

在 Go Web 服务中，慢查询是连接池性能恶化的主要诱因之一。本章将明确慢查询的定义边界、日志配置方法，并深入分析慢查询如何通过“连接独占”机制拖垮整个连接池的分配效率。

4.1 什么是慢查询

慢查询（Slow Query）是指执行时间超过预设阈值的数据库操作语句。在连接池视角下，慢查询意味着一个连接被长时间占用而无法归还到池中，导致其他请求等待或超时。

4.2 慢查询日志配置

MySQL 和 PostgreSQL 均提供慢查询日志机制。正确配置后，可以精准捕获影响连接池的“元凶”。

4.2.1 MySQL 慢查询日志配置

-- 查看当前配置
SHOW VARIABLES LIKE 'slow_query_log%';
SHOW VARIABLES LIKE 'long_query_time';

-- 开启慢查询日志（动态生效）
SET GLOBAL slow_query_log = ON;
SET GLOBAL long_query_time = 0.1;        -- 单位：秒，0.1 = 100ms
SET GLOBAL log_queries_not_using_indexes = ON;

-- 推荐生产配置（my.cnf）
[mysqld]
slow_query_log = 1
slow_query_log_file = /var/log/mysql/slow-query.log
long_query_time = 0.1
log_queries_not_using_indexes = 1
min_examined_row_limit = 100

4.2.2 PostgreSQL 慢查询日志配置

-- postgresql.conf 配置
log_min_duration_statement = 100ms      -- 记录执行超过 100ms 的语句
log_duration = on
log_statement = 'ddl'                   -- 可选：记录所有 DDL
log_line_prefix = '%t [%p] %u@%d '      -- 时间、进程、用户、数据库

-- 查看当前慢查询设置
SHOW log_min_duration_statement;

4.2.3 日志分析关键字段

4.3 慢查询对连接池的影响

慢查询对连接池的破坏是系统性的，并非仅仅消耗一个连接。下图展示了慢查询如何引发连接池的“雪崩效应”。

4.4 慢查询对连接分配的具体影响

慢查询对连接池分配机制的影响体现在以下四个层面：

1. 连接饥饿（Connection Starvation）：慢查询占用的连接无法及时归还，池中可用连接数迅速归零，新请求必须排队等待。
2. 连接泄漏风险：慢查询执行过程中如果发生 panic 或超时未处理，连接可能未正确归还，导致连接池永久性容量损失。
3. 连接池扩容失效：当所有连接都被慢查询占用时，即使 SetMaxOpenConns 允许创建新连接，数据库端也可能因负载过高而拒绝新连接。
4. 连接复用率下降：慢查询导致连接周转时间从毫秒级变为秒级，连接复用率（Queries per Connection per Second）急剧下降。

4.5 慢查询识别实战：Go 代码中的监控

除了数据库日志，在 Go 应用层也可以实时识别慢查询：

// 使用装饰器模式包装数据库操作，自动记录慢查询
func slowQueryMiddleware(db *sql.DB, threshold time.Duration) *sql.DB {
    // 注意：实际生产环境建议使用 database/sql 的 Stats 或第三方库
    // 此处展示原理
    return &wrappedDB{DB: db, threshold: threshold}
}

type wrappedDB struct {
    *sql.DB
    threshold time.Duration
}

func (w *wrappedDB) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error) {
    start := time.Now()
    rows, err := w.DB.QueryContext(ctx, query, args...)
    elapsed := time.Since(start)
    if elapsed > w.threshold {
        log.Printf("[SLOW QUERY] %s | duration: %v | args: %v", query, elapsed, args)
        // 可在此处上报 metrics 到 Prometheus / Datadog
    }
    return rows, err
}