我需要使用 MongoDB 和 Golang 进行聚合和查找来查找重复项。 这是我的 Event 结构。

// Event describes the model of an Event
type Event struct {
    ID            string      `bson:"_id" json:"_id" valid:"alphanum,printableascii"`
    OldID         string      `bson:"old_id" json:"old_id" valid:"alphanum,printableascii"`
    ParentID      string      `bson:"_parent_id" json:"_parent_id" valid:"alphanum,printableascii"`
    Name          string      `bson:"name" json:"name"`
    Content       string      `bson:"content" json:"content"`
    Slug          string      `bson:"slug" json:"slug"`
    LocationID    string      `bson:"_location_id" json:"_location_id"`
    Price         string      `bson:"price" json:"price"`
    CreatedBy     string      `bson:"created_by" json:"created_by"`
    CreatedAt     time.Time   `bson:"created_at" json:"created_at"`
    ModifiedAt    time.Time   `bson:"modified_at" json:"modified_at"`
}

这是我已有的请求:

// Create the pipeline
    pipeline := []bson.M{
        bson.M{
            "$group": bson.M{
                "_id": bson.M{
                    "_location_id": "$_location_id",
                    "start_date":   "$start_date",
                },
                "docs":  bson.M{"$push": "$_id"},
                "count": bson.M{"$sum": 1},
            },
        },
        bson.M{
            "$match": bson.M{
                "count": bson.M{"$gt": 1.0},
            },
        },
    }

    // Do the request
    dupes := []bson.M{}
    err := session.DB(shared.DatabaseNamespace).C(dao.collection).Pipe(pipeline).All(&dupes)

事件不得具有相同的start_date 和相同的_location_id。 这是我能得到的:

/* 1 */
{
    "_id" : {
        "_location_id" : "4okPZllaoueYC3U2",
        "start_date" : ISODate("2018-04-22T18:00:00.000Z")
    },
    "count" : 2.0,
    "docs" : [ 
        "FFSC2sJcrWgj2FsU", 
        "lwHknTHFfVAzB8ui"
    ]
}

/* 2 */
{
    "_id" : {
        "_location_id" : "pC8rlLVao5c2CeBh",
        "start_date" : ISODate("2018-04-03T19:00:00.000Z")
    },
    "count" : 2.0,
    "docs" : [ 
        "jPRbkINiCExzh2tT", 
        "C8hx92QSZEl7HUIz"
    ]
}

很好，它正在工作，但是.. 我想直接从 Mongo 获取我的事件类型的数组，如果可能的话，获取事件数组的数组:[][]*Event。 换句话说，一组重复项(在它们之间)。

例如:

// Pipeline
...

// Do the request
events := [][]*Events
err := session.DB(shared.DatabaseNamespace).C(dao.collection).Pipe(pipeline).All(&events)

或者，我是否需要使用 Golang 执行逻辑来实现我需要的？

我使用的库是:

"gopkg.in/mgo.v2"
"gopkg.in/mgo.v2/bson"

仅注意:无需关心 _location_id，我在 Golang 逻辑中使用 DTO 查找它。

编辑:如果我无法查找 ID，我至少可以直接在结果中获取 ID 作为数组吗？例如:

[ 
    "jPRbkINiCExzh2tT", 
    "C8hx92QSZEl7HUIz"
]

这是我试图添加到请求中的内容:{$out: "uniqueIds"}。但它不起作用。

最佳答案

是的，您需要使用 Golang 执行逻辑才能实现您的需求。

你可以这样做:

    type DublesAgregate struct {
    Id        IdStruct        `bson:"_id"`
    Docs      []bson.ObjectId `bson:"docs"`
    Count     string          `bson:"count,omitempty"`
}

type IdStruct struct {
    Location_id      string `bson:"_location_id,omitempty"`
    Start_date       string `bson:"start_date,omitempty"`
}

// Create the pipeline
    pipeline := []bson.M{
        bson.M{
            "$group": bson.M{
                "_id": bson.M{
                    "_location_id": "$_location_id",
                    "start_date":   "$start_date",
                },
                "docs":  bson.M{"$push": "$_id"},
                "count": bson.M{"$sum": 1},
            },
        },
        bson.M{
            "$match": bson.M{
                "count": bson.M{"$gt": 1.0},
            },
        },
    }

// Do the request
    dupes := []DublesAgregate{}
    err := session.DB(shared.DatabaseNamespace).C(dao.collection).Pipe(pipeline).All(&dupes)

// Get Docs slice
    result := []bson.ObjectId{}
    for _, group := range dupes {
        result = append(result, group.Docs...)
    }

关于mongodb - 使用 MongoDB 和 Golang 通过聚合和查找查找重复项，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/49940849/