Go Mgo驱动中MongoDB ObjectId的生成与最佳实践

package main

import (
    "fmt"
    "log"
    "time"

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

// 定义一个结构体来表示MongoDB文档
type MyDocument struct {
    ID        bson.ObjectId `bson:"_id,omitempty"` // _id 字段，使用 bson.ObjectId 类型
    Name      string        `bson:"name"`
    Value     int           `bson:"value"`
    CreatedAt time.Time     `bson:"created_at"`
}

func main() {
    // 1. 连接到MongoDB
    // 请根据您的MongoDB配置修改连接字符串
    session, err := mgo.Dial("mongodb://localhost:27017")
    if err != nil {
        log.Fatalf("Failed to connect to MongoDB: %v", err)
    }
    defer session.Close()

    // 设置会话模式，例如一致性模式
    // mgo.Monotonic 提供了一个在主从切换时保持读取一致性的保证
    session.SetMode(mgo.Monotonic, true)

    // 获取集合
    c := session.DB("mydatabase").C("mycollection")

    // 2. 手动生成 ObjectId
    newID := bson.NewObjectId()

    // 3. 创建文档实例并赋值 _id
    doc := MyDocument{
        ID:        newID, // 将手动生成的 ObjectId 赋值给 ID 字段
        Name:      "Example Document",
        Value:     123,
        CreatedAt: time.Now(),
    }

    // 4. 插入文档
    err = c.Insert(&doc)
    if err != nil {
        log.Fatalf("Failed to insert document: %v", err)
    }

    fmt.Printf("Document inserted successfully with ID: %s\n", doc.ID.Hex())

    // 验证插入（可选）：通过手动生成的ID查找文档
    var result MyDocument
    err = c.FindId(doc.ID).One(&result)
    if err != nil {
        log.Fatalf("Failed to find inserted document: %v", err)
    }
    fmt.Printf("Found document: %+v\n", result)
}