Go语言：将MongoDB文档直接转换为JSON API响应

package main

import (
    "fmt"
    "log"
    "net/http"
    "encoding/json"

    "gopkg.in/mgo.v2" // mgo v1
    "gopkg.in/mgo.v2/bson" // bson v1
)

// myCollection 变量用于存储MongoDB集合的句柄
var myCollection *mgo.Collection

func init() {
    // 实际应用中需要配置MongoDB连接字符串和数据库/集合名称
    // 示例代码仅为演示目的，省略了生产环境中的详细连接池管理和错误处理
    session, err := mgo.Dial("mongodb://localhost:27017")
    if err != nil {
        log.Fatalf("Failed to connect to MongoDB: %v", err)
    }
    // 设置会话模式，确保读写一致性
    session.SetMode(mgo.Monotonic, true)
    myCollection = session.DB("testdb").C("mycollection")

    // 插入一些测试数据，如果集合为空
    count, _ := myCollection.Count()
    if count == 0 {
        _ = myCollection.Insert(bson.M{"name": "Alice", "age": 30, "city": "New York"})
        _ = myCollection.Insert(bson.M{"name": "Bob", "age": 25, "city": "London"})
        log.Println("Inserted test data into MongoDB.")
    }
}

// getDocumentsRaw 演示了使用 bson.Raw 反序列化文档并尝试转换为JSON
func getDocumentsRaw(w http.ResponseWriter, r *http.Request) {
    name := r.URL.Query().Get("name")
    if name == "" {
        http.Error(w, "Name parameter is required", http.StatusBadRequest)
        return
    }

    var raw []bson.Raw
    err := myCollection.Find(bson.M{"name": name}).All(&raw)
    if err != nil {
        http.Error(w, fmt.Sprintf("Failed to query documents: %v", err), http.StatusInternalServerError)
        return
    }

    // 尝试将 []bson.Raw 转换为 JSON。
    // 结果通常不是期望的文档JSON数组，而是BSON原始字节的JSON表示。
    // 例如：[{"type":"Buffer","data":[..., byte values ...,]}]
    jsonBytes, err := json.Marshal(raw)
    if err != nil {
        http.Error(w, fmt.Sprintf("Failed to marshal raw BSON to JSON: %v", err), http.StatusInternalServerError)
        return
    }

    w.Header().Set("Content-Type", "application/json")
    w.WriteHeader(http.StatusOK)
    w.Write(jsonBytes)
}

func main() {
    // 启动一个简单的HTTP服务器来演示API
    // http.HandleFunc("/api/raw-docs", getDocumentsRaw) // 演示 bson.Raw 的局限性
    // log.Println("Server starting on port 8080...")
    // log.Fatal(http.ListenAndServe(":8080", nil))
}

package main

import (
    "fmt"
    "log"
    "net/http"
    "encoding/json"

    "gopkg.in/mgo.v2" // mgo v1
    "gopkg.in/mgo.v2/bson" // bson v1
)

// myCollection 变量用于存储MongoDB集合的句柄
var myCollection *mgo.Collection

func init() {
    // 实际应用中需要配置MongoDB连接字符串和数据库/集合名称
    // 示例代码仅为演示目的，省略了生产环境中的详细连接池管理和错误处理
    session, err := mgo.Dial("mongodb://localhost:27017")
    if err != nil {
        log.Fatalf("Failed to connect to MongoDB: %v", err)
    }
    // 设置会话模式，确保读写一致性
    session.SetMode(mgo.Monotonic, true)
    myCollection = session.DB("testdb").C("mycollection")

    // 插入一些测试数据，如果集合为空
    count, _ := myCollection.Count()
    if count == 0 {
        _ = myCollection.Insert(bson.M{"name": "Alice", "age": 30, "city": "New York", "tags": []string{"developer", "traveler"}})
        _ = myCollection.Insert(bson.M{"name": "Bob", "age": 25, "city": "London", "isActive": true})
        log.Println("Inserted test data into MongoDB.")
    }
}

// getDocumentsAsJSON 使用 bson.M 反序列化文档并直接转换为JSON
func getDocumentsAsJSON(w http.ResponseWriter, r *http.Request) {
    name := r.URL.Query().Get("name")
    if name == "" {
        http.Error(w, "Name parameter is required", http.StatusBadRequest)
        return
    }

    var maps []bson.M // 使用 bson.M 切片来存储文档
    err := myCollection.Find(bson.M{"name": name}).All(&maps)
    if err != nil {
        if err == mgo.ErrNotFound {
            // 如果没有找到匹配文档，可以返回空数组或特定状态码
            w.Header().Set("Content-Type", "application/json")
            w.WriteHeader(http.StatusOK)
            w.Write([]byte("[]")) // 返回空JSON数组
            return
        }
        http.Error(w, fmt.Sprintf("Failed to query documents: %v", err), http.StatusInternalServerError)
        return
    }

    // 将 bson.M 切片直接转换为 JSON
    jsonBytes, err := json