Mgo/BSON 字段持久化控制：如何忽略非空字段

type Person struct {
  Name string
  SSN string // 假设这个字段不希望被持久化
  HashedSSN string
}

package main

import (
    "crypto/sha1"
    "encoding/base64"
    "fmt"
    "log" // 使用 log 包进行错误处理
    "time" // 引入 time 包用于设置连接超时
    "context" // 引入 context 包用于设置操作上下文

    "go.mongodb.org/mongo-driver/bson" // 推荐使用官方驱动
    "go.mongodb.org/mongo-driver/mongo"
    "go.mongodb.org/mongo-driver/mongo/options"
)

// Person 结构体定义，SSN 字段通过 bson:"-" 标签被忽略
type Person struct {
    ID        interface{} `bson:"_id,omitempty"` // MongoDB _id 字段
    Name      string      `bson:"name"`
    SSN       string      `bson:"-"`             // 这个字段将不会被持久化到MongoDB
    HashedSSN string      `bson:"hashedSSN"`
}

func main() {
    // 连接 MongoDB
    clientOptions := options.Client().ApplyURI("mongodb://localhost:27017")
    ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
    defer cancel()

    client, err := mongo.Connect(ctx, clientOptions)
    if err != nil {
        log.Fatalf("无法连接到 MongoDB: %v", err)
    }
    defer func() {
        if err = client.Disconnect(ctx); err != nil {
            log.Fatalf("断开 MongoDB 连接失败: %v", err)
        }
    }()

    // 检查连接
    err = client.Ping(ctx, nil)
    if err != nil {
        log.Fatalf("MongoDB 连接失败: %v", err)
    }
    fmt.Println("成功连接到 MongoDB!")

    // 获取数据库和集合
    collection := client.Database("testdb").Collection("people")

    // 创建 Person 实例
    bob := Person{
        Name: "Bob",
        SSN:  "fake_ssn_12345", // 这是一个敏感字段，不应存储
    }

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

    // 插入数据
    insertResult, err := collection.InsertOne(ctx, bob)
    if err != nil {
        log.Fatalf("插入文档失败: %v", err)
    }
    fmt.Printf("文档插入成功，ID: %v\n", insertResult.InsertedID)

    // 验证：从数据库中查询并打印结果
    var retrievedPerson Person
    filter := bson.M{"_id": insertResult.InsertedID}
    err = collection.FindOne(ctx, filter).Decode(&retrievedPerson)
    if err != nil {
        log.Fatalf("查询文档失败: %v", err)
    }

    fmt.Println("\n从数据库检索到的 Person:")
    fmt.Printf("ID: %v\n", retrievedPerson.ID)
    fmt.Printf("Name: %s\n", retrievedPerson.Name)
    fmt.Printf("SSN (应为空，因为未持久化): %s\n", retrievedPerson.SSN) // 验证 SSN 是否为空
    fmt.Printf("HashedSSN: %s\n", retrievedPerson.HashedSSN)

    // 手动检查数据库，确认 SSN 字段不存在
    fmt.Println("\n请手动检查 MongoDB 数据库中 'testdb.people' 集合的文档，确认 'SSN' 字段不存在。")
}