Mongodb 减法聚合Mongo文档Golang

"$subtract": []interface{}{"test_value", 1}

请注意，这里的"test_value"是字面意思.表达式的意思是从字符串test_value中减go 数字1，这是无效的，也不是您想要的.您希望改为引用字段路径.因此，您应该在其前面加上$(参见aggregation expressions).以下是更正后的代码:

"$subtract": []interface{}{"$test_value", 1}

PS 1:

为了方便其他人调查这个问题，请在future 提供一个最小的可执行复制器，例如:

package main

import (
    "context"
    "fmt"

    "go.mongodb.org/mongo-driver/bson"
    "go.mongodb.org/mongo-driver/mongo"
    "go.mongodb.org/mongo-driver/mongo/options"
)

func main() {
    jsonInput := []map[string]interface{}{
        {
            "$match": map[string]interface{}{
                "test_value": 10,
            },
        },
        {
            "$set": map[string]interface{}{
                "test_value": map[string]interface{}{
                    "$subtract": []interface{}{"test_value", 1},
                    // `test_value` should be prefixed with $ like this:
                    // "$subtract": []interface{}{"$test_value", 1},
                },
            },
        },
    }

    typ, buf, err := bson.MarshalValue(jsonInput)
    if err != nil {
        panic(err)
    }
    fmt.Println(typ)

    var bsonD bson.A

    if err := bson.UnmarshalValue(typ, buf, &bsonD); err != nil {
        panic(err)
    }

    client, err := mongo.Connect(context.Background(), options.Client().ApplyURI("mongodb://localhost"))
    if err != nil {
        panic(err)
    }
    collection := client.Database("demo").Collection("values")
    cur, err := collection.Aggregate(context.Background(), bsonD)
    if err != nil {
        panic(err)
    }
    defer cur.Close(context.Background())
    for cur.Next(context.Background()) {
        fmt.Printf("%+v", cur.Current)
    }
}

并使用以下参数初始化集合数据:

db.values.insert({ _id: ObjectId('649d3d688a1f30bf82e77342'), test_value: 10 })

(公元MongoDB Shell年执行)

对于包go.mongodb.org/mongo-driver@v1.12.0和mongo:5.0.8，我得到的错误是:

panic: (TypeMismatch) Failed to optimize pipeline :: caused by :: can't $subtract int from string

PS 2:个

如果您不知道，可以直接创建bsonD变量，如下所示:

bsonD := bson.A{
    bson.M{
        "$match": bson.M{
            "test_value": 10,
        },
    },
    bson.M{
        "$set": bson.M{
            "test_value": bson.M{
                "$subtract": bson.A{"$test_value", 1},
            },
        },
    },
}

PS 3:

您显示的代码有一个语法错误(短声明jsonInput的末尾多了一个)).更正此错误后，我认为它不会导致您在问题中显示的错误.我相信这个错误是因为另一个jsonInput的值.