Go语言与MongoDB：使用bson:"-"标签控制结构体字段的持久化

package main

import (
    "crypto/sha1"
    "encoding/base64"
    "fmt"
    "log"

    "gopkg.in/mgo.v2" // 推荐使用 gopkg.in/mgo.v2
    "gopkg.in/mgo.v2/bson" // 导入 bson 包
)

// Person 结构体定义，演示如何使用 bson:"-" 标签排除字段
type Person struct {
    ID        bson.ObjectId `bson:"_id,omitempty"` // MongoDB _id 字段，通常由驱动自动生成
    Name      string        `bson:"name"`
    SSN       string        `bson:"-"`             // 使用 bson:"-" 标签，此字段将不会被持久化到MongoDB
    HashedSSN string        `bson:"hashedSSN"`
}

func main() {
    // 1. 初始化 Person 对象
    bob := Person{
        ID:        bson.NewObjectId(), // 手动生成一个ID，或让MongoDB自动生成
        Name:      "Bob",
        SSN:       "fake_ssn_12345", // 这个字段包含数据，但不会被持久化
        HashedSSN: "",
    }

    // 2. 计算 HashedSSN
    hasher := sha1.New()
    hasher.Write([]byte(bob.SSN))
    sha := base64.URLEncoding.EncodeToString(hasher.Sum(nil))
    bob.HashedSSN = sha

    fmt.Printf("准备插入数据（SSN字段不会被持久化）：%+v\n", bob)

    // 3. 连接 MongoDB
    // 请确保本地 MongoDB 实例正在运行
    mgoSession, err := mgo.Dial("mongodb://localhost:27017")
    if err != nil {
        log.Fatalf("无法连接到 MongoDB: %v", err)
    }
    defer mgoSession.Close() // 确保会话在程序结束时关闭

    // 设置读写一致性，确保数据写入后立即可读
    mgoSession.SetMode(mgo.Monotonic, true)

    // 4. 获取集合并插入数据
    c := mgoSession.DB("testdb").C("person") // 使用一个明确的数据库名和集合名

    err = c.Insert(bob)
    if err != nil {
        log.Fatalf("插入数据失败: %v", err)
    }
    fmt.Println("数据插入成功！")

    // 5. 验证数据：从数据库中读取并检查 SSN 字段是否被排除
    var result Person
    err = c.Find(bson.M{"name": "Bob"}).One(&result) // 使用 bson.M 进行查询
    if err != nil {
        log.Fatalf("查询数据失败: %v", err)
    }
    fmt.Printf("从数据库中读取到的数据: %+v\n", result)

    // 预期：result.SSN 应该是其默认值（空字符串），因为我们将其排除在持久化之外
    if result.SSN == "" {
        fmt.Println("验证成功：SSN 字段未被持久化到数据库。")
    } else {
        fmt.Printf("验证失败：SSN 字段意外地被持久化：%s\n", result.SSN)
    }

    // 6. （可选）清理数据
    // _, err = c.RemoveAll(bson.M{"name": "Bob"})
    // if err != nil {
    //  log.Printf("清理数据失败: %v", err)
    // } else {
    //  fmt.Println("数据清理成功。")
    // }
}