的对象

我有一个树形结构的阵列MongoDB的递归搜索这个样子的对象

{ 
    "_id" : ObjectId("59aebe21f002a8556ca78310"), 
    "fid" : ObjectId("59aebe216b96002252a89d7b"), 
    "pr" : [ 

    ], 
    "ch" : [ 
     { 
      "_id" : ObjectId("59aebe326b96002252a89d7d"), 
      "trashed" : false 
     }, 
     { 
      "_id" : ObjectId("59aebe376b96002252a89d7f"), 
      "trashed" : false 
     } 
    ] 
} 
{ 
    "_id" : ObjectId("59aebe33f002a8556ca78347"), 
    "fid" : ObjectId("59aebe326b96002252a89d7d"), 
    "pr" : [ 
     { 
      "_id" : ObjectId("59aebe216b96002252a89d7b"), 
      "trashed" : false 
     } 
    ], 
    "ch" : [ 
     { 
      "_id" : ObjectId("59aebe3b6b96002252a89d81"), 
      "trashed" : false 
     } 
    ] 
}

的FID是一个文件夹ID和CH是文件夹的孩子，所以我想做一个递归搜索获取文件夹和文件的树。在我来说，我有一个用$graphLookup做递归搜索，但结果我收到的其他文件夹也基于Golang

pipeline := []bson.M{ 
     {"$match": bson.M{"fid": id}}, 
     {"$graphLookup": bson.M{ 
      "from":    "tree", 
      "startWith":  "$fid", 
      "connectFromField": "fid", 
      "connectToField": "ch._id", 
      "as":    "parents", 
     }}, 
     {"$match": bson.M{"ch.trashed": false}}, 
    } 

    Connection.Session.DB("cctv_storage").C("tree").Pipe(pipeline).All(&tData)

我的项目。

来源

2017-09-06 Khazar Amjer

请阅读'$ graphLookup'如何工作：https://docs.mongodb.com/manual/reference/operator/aggregation/graphLookup/如果''connectToField“：”ch._id“那么''应该真的是“孩子”，而不是“父母”。第二个“$匹配”仅过滤顶级文档，而不是所有的孩子/父母。此外，示例中的所有文档都有''ch.trashed'：false'。 –

我认为你需要使用$unwind第一位，比$graphLookup，所以你需要做递归搜索这个样子

var tData struct { 
     Id bson.ObjectId  `bson:"_id"` 
     Child [][]bson.ObjectId `bson:"child"` 
    } 

pipeline := []bson.M{ 
     {"$unwind": bson.M{ 
      "path": "$pr", 
      "preserveNullAndEmptyArrays": true, 
     }}, 
     {"$graphLookup": bson.M{ 
      "from":    "tree", 
      "startWith":  "$fid", 
      "connectFromField": "fid", 
      "connectToField": "pr._id", 
      "as":    "child", 
     }}, 
     {"$match": bson.M{"fid": id}}, 
     {"$group": bson.M{"_id": id, "child": bson.M{"$addToSet": "$child.fid"}}}, 
    } 
Connection.Session.DB("cctv_storage").C("tree").Pipe(pipeline).One(&tData)

因此，作为一个结果，你会得到的根文件夹的ID和孩子的ID

来源

2017-09-06 08:50:25

回答

相关问题