在Go语言中使用mgo处理MongoDB动态或无固定模式文档

package main

import (
    "fmt"
    "log"
    "time"

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

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

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

    // 插入一些动态文档作为示例
    c.Insert(bson.M{"name": "Alice", "age": 30, "city": "New York"})
    c.Insert(bson.M{"product": "Laptop", "price": 1200.50, "specs": bson.M{"cpu": "i7", "ram": 16}})
    c.Insert(bson.M{"event": "meeting", "timestamp": time.Now(), "participants": []string{"Bob", "Charlie"}})

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

    fmt.Println("--- 使用 map[string]interface{} ---")
    fmt.Printf("查询结果: %+v\n", result)

    // 访问和类型断言字段
    if name, ok := result["name"].(string); ok {
        fmt.Printf("姓名: %s\n", name)
    }
    if age, ok := result["age"].(int); ok {
        fmt.Printf("年龄: %d\n", age)
    }

    // 查询另一个文档，可能包含嵌套结构
    var productDoc map[string]interface{}
    queryProduct := bson.M{"product": "Laptop"}
    err = c.Find(queryProduct).One(&productDoc)
    if err != nil {
        log.Fatalf("Failed to find product document: %v", err)
    }
    fmt.Printf("产品文档: %+v\n", productDoc)

    if specs, ok := productDoc["specs"].(map[string]interface{}); ok {
        if cpu, ok := specs["cpu"].(string); ok {
            fmt.Printf("产品CPU: %s\n", cpu)
        }
    }

    // 清理数据
    c.RemoveAll(nil)
}

// bson.M 的定义 (概念上)
// type M map[string]interface{}

// bson.D 的定义 (概念上)
// type D []struct {
//     Key   string
//     Value interface{}
// }

package main

import (
    "fmt"
    "log"
    "time"

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

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

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

    // 插入一个文档，字段顺序可能重要
    // 注意：使用bson.D插入时，mgo会保留其顺序
    c.Insert(bson.D{
        {"first_name", "John"},
        {"last_name", "Doe"},
        {"age", 30},
        {"occupation", "Engineer"},
    })
    c.Insert(bson.M{"_id": bson.NewObjectId(), "a": 1, "b": 2}) // 插入一个无序的，看解码效果

    // 查询一个文档并解码到 bson.D
    var resultD bson.D
    query := bson.M{"first_name": "John"}
    err = c.Find(query).One(&resultD)
    if err != nil {
        log.Fatalf("Failed to find document: %v", err)
    }

    fmt.Println("\n--- 使用 bson.D ---")
    fmt.Printf("查询结果 (bson.D): %+v\n", resultD)

    // 遍历 bson.D 访问字段
    for _, item := range resultD {
        fmt.Printf("Key: %s, Value: %v (Type: %T)\n", item.Key, item.Value, item.Value)
        // 同样需要进行类型断言
        if item.Key == "age" {
            if age, ok := item.Value.(int); ok {
                fmt.Printf("  年龄 (断言后): %d\n", age)
            }
        }
    }

    // 尝试查询一个使用bson.M插入的文档
    var resultD2 bson.D
    err = c.Find(bson.M{"a": 1}).One(&resultD2)
    if err != nil {
        log.Fatalf("Failed to find document with bson.M: %v", err)
    }
    fmt.Printf("\n查询 bson.M 插入的文档 (解码到 bson.D): %+v\n", resultD2)
    // 注意：即使源文档在MongoDB中没有严格顺序，解码到bson.D也会按MongoDB内部存储顺序返回

    // 清理数据
    c.RemoveAll(nil)
}