Go语言与MongoDB：使用mgo库构建与插入BSON文档的教程

package account

import "gopkg.in/mgo.v2/bson" // 推荐使用v2版本

// RecoveryInfo 嵌套结构体，用于认证信息中的恢复详情
type RecoveryInfo struct {
    Mobile string `bson:"mobile"`
    Email  string `bson:"email"`
}

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

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

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

package dbEngine

import (
    "log"
    "gopkg.in/mgo.v2" // 推荐使用v2版本
)

// Insert 函数用于将文档插入到MongoDB
// document 参数通常是一个Go结构体的指针，mgo会自动将其序列化为BSON
func Insert(document interface{}) error {
    // 建立MongoDB连接
    // 在生产环境中，通常会使用连接池来管理session，而不是每次操作都创建新session
    session, err := mgo.Dial("localhost:27017") // 默认端口通常是27017
    if err != nil {
        log.Printf("Error connecting to MongoDB: %v", err)
        return err
    }
    defer session.Close() // 确保会话在使用后关闭，释放资源

    // 选择数据库和集合
    // 请根据您的实际情况替换 "your_database_name" 和 "your_collection_name"
    c := session.DB("your_database_name").C("your_collection_name")

    // 插入文档
    // mgo的Insert方法会自动将Go结构体序列化为BSON
    err = c.Insert(document)
    if err != nil {
        log.Printf("Error inserting document: %v", err)
        return err
    }
    log.Println("Document inserted successfully.")
    return nil
}

package main

import (
    "fmt"
    "gopkg.in/mgo.v2/bson"
    "your_project/account"   // 替换为您的account包的实际路径
    "your_project/dbEngine" // 替换为您的dbEngine包的实际路径
)

func main() {
    // 创建一个Account结构体实例
    acc := account.Account{
        BalanceAmount: 3,
        Type:          "reg",
        Authentication: account.AuthenticationInfo{ // 使用定义的嵌套结构体
            AuthMode: "10",
            AuthVal:  "sd",
            Recovery: account.RecoveryInfo{ // 使用定义的嵌套结构体
                Mobile: "sdfsd",
                Email:  "user@example.com", // 替换为实际邮箱
            },
        },
        Stamps: account.StampsInfo{ // 使用定义的嵌套结构体
            In: "x",
            Up: "y",
        },
    }

    // 为_id字段生成一个新的ObjectId。
    // 如果不手动生成，mgo在插入时也会自动生成一个。
    // 但手动生成可以提前获取ID，方便后续操作或日志记录。
    acc.Id = bson.NewObjectId()

    // 调用dbEngine的Insert函数，传入Account结构体的指针
    // 传递指针是mgo的惯例，允许mgo在插入成功后更新结构体（例如，如果_id是自动生成的）
    err := dbEngine.Insert(&acc)
    if err != nil {
        fmt.Printf("Document insertion failed: %v\n", err)
    } else {
        fmt.Printf("Document inserted successfully with ID: %s\n", acc.Id.Hex())
    }
}