如何解码 Aggregate() 的返回值

来到golang学习网的大家，相信都是编程学习爱好者，希望在这里学习Golang相关编程知识。下面本篇文章就来带大家聊聊《如何解码 Aggregate() 的返回值》，介绍一下，希望对大家的知识积累有所帮助，助力实战开发！

我正在尝试在 mongodb 中进行查询，就像 sql 中的 group by 一样。因此，我使用 aggregate() api 来查找所有唯一的 _id(markettype+symbol)。

aggregate() 运行成功，但是当我解码返回值时，我什么也没得到。 aggregate() 返回类型与 find() 相同，当 find() 有用时我以这种方式解码。为什么当我aggregate()时它不起作用。

type MarketSymbol struct {
    MarketType  string  `json:"Market,omitempty" bson:"MarketType"`
    Symbol      string  `json:"Symbol,omitempty" bson:"Symbol"`
}

func GetSymbol() {
    pipeline := bson.M {
        "$group"    :    
        bson.M{"_id":bson.M{"MarketType":"$MarketType","Symbol":"$Symbol"}},
    }
    cur,err := mongoSt.Collection.Aggregate(context.TODO(), []bson.M{pipeline})
    if err != nil {
        fmt.Println("Aggregate Error:", err)
    } else {
        fmt.Println("Aggregate Success!")    //this line works
    }
    var results []MarketSymbol
    count := 1

    for cur.Next(context.TODO()) {
        var elem MarketSymbol
        err := cur.Decode(&elem)
        if err != nil {
            fmt.Printf("[count]=%d   Decode Error\n", count)
            count++
            continue
        }
        fmt.Printf("[count]=%d, [MarketType]:%s , [Symbol]:%s\n", count, elem.MarketType, elem.Symbol)    //this line works,but value is nil
        count++
        results = append(results, elem)
    }
}

解决方案

我明白了。我之前也尝试过使用_id来保存decode值，但失败了。所以我认为这不起作用。但确实如此，实际上导致错误的是我给出了错误的 markettype 类型，它应该是 int32 但我给了它一个字符串。所以...

无论如何，问题解决了，这是代码。

type ID struct {
    Id  MarketSymbol    `json:"ID,omitempty" bson:"_id"`
}

type MarketSymbol struct {
    MarketType  int32   `json:"Market,omitempty" bson:"MarketType"`
    Symbol      string  `json:"Symbol,omitempty" bson:"Symbol"`
}

func GetSymbol{
    pipeline := bson.M {
        "$group"    :   bson.M{"_id":bson.M{"MarketType":"$MarketType","Symbol":"$Symbol"}},
    }

    cur,err := mongoSt.Collection.Aggregate(context.TODO(), []bson.M{pipeline})
    if err != nil {
        fmt.Println("Aggregate Error:", err)
    } else {
        fmt.Println("Aggregate Success!")
    }

    var results []ID
    count := 1

    for cur.Next(context.TODO()) {
        var elem ID
        err := cur.Decode(&elem)
        if err != nil {
            fmt.Printf("[count]=%d   Decode Error\n", count)
            count++
            continue
        }
        fmt.Printf("[count]=%d, [MarketType]:%d , [Symbol]:%s\n", count, elem.Id.MarketType, elem.Id.Symbol)
        count++
        results = append(results, elem)
    }
}

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于Golang的相关知识，也可关注golang学习网公众号。