使用Go语言与MongoDB交互：正确构造和插入BSON文档

// account.go
package account

import (
    "gopkg.in/mgo.v2/bson" // 注意：mgo的bson包路径
)

// Account 代表MongoDB中的一个账户文档
type Account struct {
    Id            bson.ObjectId `bson:"_id,omitempty"` // _id 字段，omitempty表示如果为空则不插入
    BalanceAmount int           `bson:"balanceamount"`
    Type          string        `bson:"type"`
    Authentication AuthInfo      `bson:"authentication"`
    Stamps        StampInfo     `bson:"stamps"`
}

// AuthInfo 嵌套结构体，用于认证信息
type AuthInfo struct {
    AuthMode string   `bson:"authmode"`
    AuthVal  string   `bson:"authval"`
    Recovery Recovery `bson:"recovery"`
}

// Recovery 嵌套结构体，用于恢复信息
type Recovery struct {
    Mobile string `bson:"mobile"`
    Email  string `bson:"email"`
}

// StampInfo 嵌套结构体，用于时间戳信息
type StampInfo struct {
    In string `bson:"in"`
    Up string `bson:"up"`
}

// dbEngine.go
package dbEngine

import (
    "fmt"
    "gopkg.in/mgo.v2" // mgo驱动
    "gopkg.in/mgo.v2/bson"
)

var globalSession *mgo.Session

// InitDB 初始化数据库连接
func InitDB(mongoURI string) error {
    var err error
    globalSession, err = mgo.Dial(mongoURI)
    if err != nil {
        return fmt.Errorf("无法连接到MongoDB: %v", err)
    }
    // 可选：设置连接模式，如ReadPreference等
    globalSession.SetMode(mgo.Monotonic, true)
    return nil
}

// CloseDB 关闭数据库连接
func CloseDB() {
    if globalSession != nil {
        globalSession.Close()
    }
}

// Insert 插入文档到指定的集合
// document 应该是一个Go结构体的指针，mgo会将其序列化为BSON
func Insert(dbName, collectionName string, document interface{}) error {
    if globalSession == nil {
        return fmt.Errorf("数据库连接未初始化")
    }

    // 复制会话，每个请求使用独立的会话，用完即关闭
    session := globalSession.Copy()
    defer session.Close() // 确保会话在使用后关闭

    c := session.DB(dbName).C(collectionName)
    err := c.Insert(document)
    if err != nil {
        return fmt.Errorf("插入文档失败: %v", err)
    }
    fmt.Printf("文档插入成功: %+v\n", document)
    return nil
}

// main.go (示例用法)
package main

import (
    "fmt"
    "log"
    "mgo_tutorial/account" // 假设account包在当前模块下
    "mgo_tutorial/dbEngine" // 假设dbEngine包在当前模块下
    "gopkg.in/mgo.v2/bson"
)

func main() {
    // 1. 初始化数据库连接
    mongoURI := "mongodb://localhost:27017"
    err := dbEngine.InitDB(mongoURI)
    if err != nil {
        log.Fatalf("数据库初始化失败: %v", err)
    }
    defer dbEngine.CloseDB() // 确保程序退出时关闭连接

    // 2. 构造Account文档实例
    acc := account.Account{
        Id:            bson.NewObjectId(), // 为新文档生成一个新的ObjectId
        BalanceAmount: 3,
        Type:          "reg",
        Authentication: account.AuthInfo{
            AuthMode: "10",
            AuthVal:  "sd",
            Recovery: account.Recovery{
                Mobile: "sdfsd",
                Email:  "test@example.com",
            },
        },
        Stamps: account.StampInfo{
            In: "x",
            Up: "y",
        },
    }

    // 3. 调用dbEngine的Insert方法插入文档
    err = dbEngine.Insert("db_name", "collection_name", &acc) // 注意：传入的是结构体指针
    if err != nil {
        log.Fatalf("插入账户失败: %v", err)
    }

    fmt.Println("账户文档插入成功！")
}