Go语言中使用mgo驱动处理MongoDB错误并映射为HTTP状态码的完整指南-Golang-PHP中文网

Go语言中使用mgo驱动处理MongoDB错误并映射为HTTP状态码的完整指南

本文详解如何在go（使用mgo库）中对mongodb操作返回的错误进行类型断言与分类，从而精准映射为404、500等http状态码，提升api错误响应的专业性与可调试性。

本文详解如何在go（使用mgo库）中对mongodb操作返回的错误进行类型断言与分类，从而精准映射为404、500等http状态码，提升api错误响应的专业性与可调试性。

在基于Go + mgo + MongoDB构建RESTful API时，仅将原始error字符串透传给HTTP层会导致错误处理粗粒度、状态码不准确（如所有数据库错误统一返回500），严重削弱客户端容错能力和服务可观测性。关键在于：mgo的错误是接口类型，但其具体实现（如mgo.ErrNotFound、*mgo.QueryError、*mgo.LastError）携带语义化信息，需通过类型断言（type switch）提取并决策。

以下为推荐实践方案：

✅ 正确做法：使用类型断言区分错误语义

mgo库预定义了多种错误类型，常见且具业务意义的包括：

mgo.ErrNotFound：查询无匹配文档（对应HTTP 404）
*mgo.QueryError：查询语法或执行异常（如无效字段、超时，通常映射为500或400）
*mgo.LastError：写操作失败（如唯一键冲突、权限不足，可细分为409冲突、403禁止等）

示例代码（修正版，含完整错误分支与健壮处理）：

import (
    "gopkg.in/mgo.v2"
    "net/http"
)

func (s *State) Index(c *gin.Context) {
    res, err := s.DB.GetArticles()
    if err != nil {
        var statusCode int
        var statusStr string
        var title string

        switch e := err.(type) {
        case *mgo.ErrNotFound:
            statusCode = http.StatusNotFound
            statusStr = "404"
            title = "Record not found"
        case *mgo.QueryError:
            // 可根据e.Code进一步细分，例如e.Code == 13507 表示sort key too large
            statusCode = http.StatusInternalServerError
            statusStr = "500"
            title = "Database query error"
        case *mgo.LastError:
            if e.Code == 11000 || e.Code == 11001 { // MongoDB duplicate key error
                statusCode = http.StatusConflict
                statusStr = "409"
                title = "Duplicate record"
            } else {
                statusCode = http.StatusInternalServerError
                statusStr = "500"
                title = "Database operation failed"
            }
        default:
            // 未知错误兜底为500
            statusCode = http.StatusInternalServerError
            statusStr = "500"
            title = "Internal server error"
        }

        d := gin.H{
            "error": gin.H{
                "status":  statusStr,
                "title":   title,
                "detail":  err.Error(),
                "code":    e.Code, // 若e支持Code字段（如*LastError），可透传DB错误码
            },
        }
        c.JSON(statusCode, d)
        return // ⚠️ 切记return，避免后续逻辑执行
    }

    // 成功响应
    content := gin.H{
        "data": gin.H{
            "type": "records",
            "id":   res.Id,
            "attributes": gin.H{
                "Phone": res.Phone,
            },
        },
    }
    c.JSON(http.StatusOK, content)
}

⚠️ 重要注意事项

mgo已归档，生产环境建议迁移至官方驱动：mgo自2018年起不再维护，存在兼容性与安全风险。新项目应使用 go.mongodb.org/mongo-driver/mongo。其错误体系更现代（如mongo.IsDuplicateKeyError()、mongo.IsNoDocumentsError()），推荐用法为：

mongodb-query
用于调试和故障排查，查询MongoDB数据库。用户需要时可以： (1) 列出所有数据库； (2) 列出数据库中的集合； (3) 执行MongoDB查询或命令。

下载
```
if mongo.IsNoDocumentsError(err) {
    statusCode = http.StatusNotFound
} else if mongo.IsDuplicateKeyError(err) {
    statusCode = http.StatusConflict
}
```
避免仅依赖err.Error()字符串匹配：MongoDB错误消息可能随版本变化，且国际化后不可靠；始终优先使用结构化错误类型和Code字段。
*ErrNotFound是值类型，类型断言时勿加`**：mgo.ErrNotFound是变量（非指针），err.(mgo.ErrNotFound)正确；而mgo.QueryError是结构体指针，必须带`。
日志记录不可省略：即使返回404，也应在服务端记录完整错误堆栈（如用log.Printf("DB error: %+v", err)），便于排查。