Go语言与MongoDB：使用mgo库高效构建与插入BSON文档

package account

import (
    "time"

    "gopkg.in/mgo.v2/bson" // 注意：mgo库通常使用v2版本
)

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

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

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

package dbEngine

import (
    "log"

    "gopkg.in/mgo.v2"
)

// Insert 用于将文档插入指定的MongoDB集合
// document 参数预期是一个Go结构体实例的指针
func Insert(collectionName string, document interface{}) error {
    // 建立MongoDB连接
    session, err := mgo.Dial("localhost:27017") // 根据实际情况修改连接字符串
    if err != nil {
        log.Printf("Error connecting to MongoDB: %v", err)
        return err
    }
    defer session.Close() // 确保会话在使用后关闭

    // 选择数据库和集合
    c := session.DB("db_name").C(collectionName) // 替换为你的数据库名和集合名

    // 插入文档
    err = c.Insert(document)
    if err != nil {
        log.Printf("Error inserting document into collection %s: %v", collectionName, err)
        return err
    }

    log.Printf("Document successfully inserted into collection %s.", collectionName)
    return nil
}

package main

import (
    "fmt"
    "log"

    "your_project/account" // 假设你的account包路径
    "your_project/dbEngine" // 假设你的dbEngine包路径

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

func main() {
    // 创建一个Account实例
    acc := account.Account{
        ID:            bson.NewObjectId(), // 为新文档生成一个新的ObjectId
        BalanceAmount: 3,
        Type:          "reg",
        Authentication: account.Authentication{
            AuthMode: "10",
            AuthVal:  "sd",
            Recovery: struct {
                Mobile string `bson:"mobile"`
                Email  string `bson:"email"`
            }{
                Mobile: "sdfsd",
                Email:  "email@example.com",
            },
        },
        Stamps: account.Stamps{
            In: "x",
            Up: "y",
        },
    }

    // 调用dbEngine的Insert方法插入文档
    err := dbEngine.Insert("accounts", &acc) // 注意：这里传递的是结构体的指针
    if err != nil {
        log.Fatalf("Failed to insert account: %v", err)
    }

    fmt.Println("Account inserted successfully!")
}