go - 带有$ lookup查询的MGO Pipe将不附加 “joined”集合中的匹配文档

我的模特儿

type (
    //Category implements item category in database
    Category struct {
        ID          bson.ObjectId `bson:"_id,omitempty" json:"id"`
        Name        string        `bson:"name" json:"name" form:"name" valid:"Required"`
        IsActive    bool          `bson:"is_active" json:"is_active" form:"is_active" valid:"Required"`
        Slug        string        `bson:"slug" json:"slug"`
        Icon        string        `bson:"icon" json:"icon" form:"icon"`
        SidebarIcon string        `bson:"sidebar_icon" json:"sidebar_icon" form:"sidebar_icon"`
        Parent      bson.ObjectId `bson:"parent,omitempty" json:"parent,omitempty" form:"parent"`
        CreatedAt   time.Time     `bson:"created_at" json:"-"`
        UpdatedAt   time.Time     `bson:"updated_at" json:"-"`
        IsDeleted   bool          `bson:"is_deleted" json:"-"`
    }
)

我的获取集合查询:

categories := []models.Category{}

f := func(collection *mgo.Collection) error {
        query := []bson.M{
            {
                "$match": bson.M{
                    "is_deleted": bson.M{
                        "$ne": true,
                    },
                },
            },
            {
                "$sort": bson.M{
                    orderBy: pipeOrder,
                },
            },
            {
                "$limit": limit,
            },
            {
                "$skip": skip,
            },
            {
                "$lookup": bson.M{
                    "from":         "categories",
                    "localField":   "_id",
                    "foreignField": "parent",
                    "as":           "parentlist",
                },
            },
        }

        return collection.Pipe(query).All(&categories)

目标:如果其父ID与集合中的文档之一匹配，则连同其父一起检索所有类别。

问题:检索了所有类别，但缺少“parentlist”联接属性

堆栈:与DB和golang版本1.8交互的mgo

最佳答案

在您的聚合中，您查找 parent ，他们将被存储在一个名为parentlist的字段中。然后，您尝试将结果解码为Category的一部分，但是Category类型没有与parentlist匹配的字段。因此，在拆组过程中该字段将“丢失”。

有很多方法可以获取附加的parentlist，此答案中详细介绍了一些可能性:Mgo aggregation: how to reuse model types to query and unmarshal "mixed" results?

一种选择是使用像这样的包装器结构:

type CategoryWithParents struct {
    Category models.Category    `bson:",inline"`
    Parents  []*models.Category `bson:"parentlist"`
}

并解码到其中:

var results []CategoryWithParents

err := collection.Pipe(query).All(&results)

这将得到所有 parent 的支持。

如果所有类别最多只能有一个父级，则可以将聚合修改为$unwind到parentlist，并且Parents可以是单个*model.Category而不是 slice :

type CategoryWithParents struct {
    Category       models.Category  `bson:",inline"`
    OptionalParent *models.Category `bson:"parentlist"`
}

var results []CategoryWithParents

f := func(collection *mgo.Collection) error {
    query := []bson.M{
        {
            "$match": bson.M{
                "is_deleted": bson.M{
                    "$ne": true,
                },
            },
        },
        {
            "$sort": bson.M{
                orderBy: pipeOrder,
            },
        },
        {"$limit": limit},
        {"$skip": skip},
        {
            "$lookup": bson.M{
                "from":         "categories",
                "localField":   "_id",
                "foreignField": "parent",
                "as":           "parentlist",
            },
        },
        {
            "$unwind": bson.M{
                "path":                       "parentlist",
                "preserveNullAndEmptyArrays": true,
            },
        },
    }

    return collection.Pipe(query).All(&results)
}