duanmanpi9358 2014-09-26 15:04
浏览 178
已采纳

Golang中的Mongodb聚合

I have a mongodb collection like this:

{
    source: "...",
    url:  "...",
    comments: [
        .....
    ]
}

I would like to find the top 5 documents based on the number of comments. I can find the desired result using the following query in the command prompt:

db.gmsNews.aggregate([
  {
     $match:{source:"..."}
  },
  {
     $unwind: "$comments"
  },
  {
     $group: {
        _id: "$url",
        size: {
           $sum: 1
        },
     }
  },
  {
     $sort : { size : -1 } 
  },
  { 
     $limit : 5
  }
])

This gives me the following output:

{ "_id" : "...", "size" : 684 }
{ "_id" : "...", "size" : 150 }

Now I would like to translate this query into golang using the mgo driver. I am using the pipe for this in the following way:

o1 := bson.M{
        "$match" :bson.M {"source":"..."},
}

o2 := bson.M{
    "$unwind": "$comments",
}

o3 := bson.M{
    "$group": bson.M{
        "_id": "$url",
        "size": bson.M{
            "$sum": 1,
        },
    },
}

o4 := bson.M{
    "sort": bson.M{
        "size": -1,
    },
}

o5 := bson.M{
    "$limit": 5,
}

operations := []bson.M{o1, o2, o3, o4, o5}

pipe := c.Pipe(operations)

// Run the queries and capture the results
results := []bson.M{}
err1 := pipe.One(&results)

if err1 != nil {
    fmt.Printf("ERROR : %s
", err1.Error())
    return
}

fmt.Printf("URL : %s, Size: %sn", results[0]["_id"], results[0]["size"])

Unfortunately this is not working and I am getting the following output:

ERROR : Unsupported document type for unmarshalling: []bson.M

Just wondering what I'm doing wrong and how to resolve this.

Any help will be highly appreciated.

Thanks in advance.

Ripul

  • 写回答

1条回答 默认 最新

  • dongsha2792 2014-09-26 21:58
    关注

    Change

     err1 := pipe.One(&results)
    

    to

    err1 := pipe.All(&results)
    
    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论

报告相同问题?

悬赏问题

  • ¥20 求解答(matlab)
  • ¥30 ffmpeg库使用过程中遇到的问题
  • ¥15 pyqt5 中python如何通过Qtwebchannel主动发消息给web前端
  • ¥15 关于HTML中title获取xml内容的问题
  • ¥15 fanuc机器人PRIO083数字信号未复原错误,如何解决?
  • ¥20 如何为现有电路板增加远程控制功能
  • ¥15 C#点击按钮的时候的循环次数就是最后一次,如何是循环第几次的值?
  • ¥15 UE5打包失败,求解决
  • ¥15 请问STM32G431的CANOPEN协议函数怎么写
  • ¥15 graphpad prism 三因素重复测定报错