Go语言mgo驱动：灵活处理MongoDB动态文档结构的策略

package main

import (
    "fmt"
    "log"

    "gopkg.in/mgo.v2"
    "gopkg.in/mgo.v2/bson" // 引入bson包
)

func main() {
    session, err := mgo.Dial("mongodb://localhost:27017")
    if err != nil {
        log.Fatalf("连接MongoDB失败: %v", err)
    }
    defer session.Close()

    // 选择数据库和集合
    c := session.DB("testdb").C("dynamic_docs")

    // 插入一些动态文档作为测试数据
    // 文档1
    err = c.Insert(bson.M{
        "name": "Alice",
        "age":  30,
        "tags": []string{"developer", "go"},
    })
    if err != nil {
        log.Printf("插入文档1失败: %v", err)
    }

    // 文档2，结构与文档1不同
    err = c.Insert(bson.M{
        "product_id": "P001",
        "price":      99.99,
        "details":    bson.M{"color": "red", "size": "M"},
        "in_stock":   true,
    })
    if err != nil {
        log.Printf("插入文档2失败: %v", err)
    }

    // 查询一个文档并解码到 map[string]interface{}
    var result map[string]interface{}
    query := bson.M{"name": "Alice"} // 查询条件
    err = c.Find(query).One(&result)
    if err != nil {
        log.Fatalf("查询文档失败: %v", err)
    }

    fmt.Println("查询结果 (map[string]interface{}):")
    for key, value := range result {
        fmt.Printf("  %s: %v (类型: %T)\n", key, value, value)
    }

    // 访问动态字段需要类型断言
    if name, ok := result["name"].(string); ok {
        fmt.Printf("名称: %s\n", name)
    }
    if age, ok := result["age"].(int); ok { // 注意：MongoDB的数字可能会被解码为float64
        fmt.Printf("年龄: %d\n", age)
    } else if ageFloat, ok := result["age"].(float64); ok {
        fmt.Printf("年龄 (float64): %.0f\n", ageFloat)
    }
}

type D []struct {
    Key   string
    Value interface{}
}

package main

import (
    "fmt"
    "log"

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

func main() {
    session, err := mgo.Dial("mongodb://localhost:27017")
    if err != nil {
        log.Fatalf("连接MongoDB失败: %v", err)
    }
    defer session.Close()

    c := session.DB("testdb").C("ordered_docs")

    // 插入一个文档，字段顺序明确
    err = c.Insert(bson.D{
        {"first_name", "John"},
        {"last_name", "Doe"},
        {"age", 30},
        {"city", "New York"},
    })
    if err != nil {
        log.Printf("插入文档失败: %v", err)
    }

    // 查询并解码到 bson.D
    var orderedResult bson.D
    query := bson.M{"first_name": "John"}
    err = c.Find(query).One(&orderedResult)
    if err != nil {
        log.Fatalf("查询文档失败: %v", err)
    }

    fmt.Println("\n查询结果 (bson.D):")
    for i, item := range orderedResult {
        fmt.Printf("  [%d] %s: %v (类型: %T)\n", i, item.Key, item.Value, item.Value)
    }

    // 访问特定键的值（需要遍历或辅助函数）
    // 注意：访问 bson.D 中的值不如 map[string]interface{} 直观，通常需要遍历
    for _, item := range orderedResult {
        if item.Key == "last_name" {
            if lastName, ok := item.Value.(string); ok {
                fmt.Printf("姓氏: %s\n", lastName)
            }
        }
    }
}