在mongo-go- UpdateOne中将json参数转换为bson

import (
    "context"
    "encoding/json"
    "fmt"
    "go.mongodb.org/mongo-driver/bson"
    "go.mongodb.org/mongo-driver/mongo"
    "go.mongodb.org/mongo-driver/mongo/options"
)

type Person struct {
    Name  string `json:"name"`
    Age   int    `json:"age"`
    Email string `json:"email"`
}

func main() {
    // 假设有一个JSON参数
    jsonData := `{"name": "John", "age": 30, "email": "john@example.com"}`

    // 将JSON参数解析为Person结构体
    var person Person
    err := json.Unmarshal([]byte(jsonData), &person)
    if err != nil {
        fmt.Println("JSON解析错误:", err)
        return
    }

    // 将Person结构体转换为BSON格式
    bsonData, err := bson.Marshal(person)
    if err != nil {
        fmt.Println("BSON转换错误:", err)
        return
    }

    // 创建MongoDB客户端
    client, err := mongo.Connect(context.TODO(), options.Client().ApplyURI("mongodb://localhost:27017"))
    if err != nil {
        fmt.Println("MongoDB连接错误:", err)
        return
    }
    defer client.Disconnect(context.TODO())

    // 选择数据库和集合
    collection := client.Database("mydb").Collection("people")

    // 构建更新操作
    filter := bson.D{{"name", "John"}}
    update := bson.D{{"$set", bson.D{{"age", 31}}}}

    // 执行更新操作
    result, err := collection.UpdateOne(context.TODO(), filter, update)
    if err != nil {
        fmt.Println("更新错误:", err)
        return
    }

    fmt.Println("更新的文档数:", result.ModifiedCount)
}