Go语言sql.Conn调用Close()时始终阻塞问题排查求助

你的conn.Close()阻塞大概率是因为未完全消费查询结果集——即使调用了rows.Close()，如果没有遍历完所有结果行，部分ODBC驱动（比如你使用的ADS）会在连接归还时等待结果集处理完成，导致无法释放连接，最终引发阻塞。

核心问题分析 #

当调用conn.QueryContext()获取rows后，驱动会在数据库端保留结果集资源，直到你完全遍历所有行或者显式取消查询。仅仅调用rows.Close()并不一定能立即释放这些资源，部分驱动要求必须消费完所有结果，才允许连接归还到连接池。

修复步骤 #

1. 强制遍历所有结果行
   即使不需要查询返回的数据，也要通过rows.Next()循环遍历完所有行，确保驱动释放结果集资源。
2. 检查rows.Err()
   遍历完成后必须检查rows.Err()，因为Next()过程中可能出现错误，导致结果集未正常关闭。
3. 用defer管理资源
   优先通过defer注册conn.Close()和rows.Close()，避免后续逻辑分支遗漏资源释放，减少连接泄漏风险。

修改后的testQuery函数示例：

func testQuery(c *gin.Context) {
    ctx := c.Copy()
    conn, err := db.Conn(ctx)
    if err != nil {
        log.Printf("获取连接失败: %v", err)
        c.AbortWithStatus(500)
        return
    }
    // 提前注册连接关闭逻辑，避免后续出错导致连接泄漏
    defer func() {
        if err := conn.Close(); err != nil {
            log.Printf("关闭连接失败: %v", err)
        }
    }()

    rows, err := conn.QueryContext(ctx, "SELECT * FROM testTable;")
    if err != nil {
        log.Printf("查询失败: %v", err)
        c.AbortWithStatus(500)
        return
    }
    defer rows.Close() // 确保结果集一定会被关闭

    // 遍历所有结果行，即使不需要数据也要执行
    for rows.Next() {
        // 如需扫描数据则保留scan逻辑，不需要则空着
        // err = rows.Scan(...)
        // if err != nil {
        //     log.Printf("扫描数据失败: %v", err)
        //     break
        // }
    }

    // 检查遍历过程中是否出现错误
    if err := rows.Err(); err != nil {
        log.Printf("结果集遍历出错: %v", err)
        c.AbortWithStatus(500)
        return
    }
}

额外优化建议 #

• 调整连接池参数：初始化sql.DB后，设置合理的连接池上限，避免连接堆积：

  db.SetMaxOpenConns(10) // 根据数据库实际配置调整
  db.SetMaxIdleConns(5)
  db.SetConnMaxLifetime(time.Hour)
  

• 避免用log.Fatal()处理请求错误：log.Fatal()会直接终止进程，应该返回HTTP错误给客户端，保证服务持续运行。

内容的提问来源于stack exchange，提问作者MisterMirko