在 go mongodb 中的 From Table 上匹配阶段

Question

我的 mongodb 收藏

employee

{

  _id:ObjectId(),

  "emp_name":"qwert",

  "emp_id":111,

  "emp_dept":"XYZ"

  "qualification":"PHD"

}

{

_id:ObjectId(),

  "emp_name":"asdfg",

  "emp_id":121,

  "emp_dept":"XYZ"

 "qualification":"MBA"

}

department{

_id:ObjectId(),

"dept_id":11,

"dept_name":"XYZ",

"description":"decs",

}

我的 Go 代码是

 type Employee struct {

    EmployeeName  string             `json:"emp_name" bson:"emp_name"`

    EmployeeID    int                `json:"emp_id" bson:"emp_id"`

    EmployeeDept  string             `json:"emp_dept" bson:"emp_dept"`

    EmpQualification string          `json:"qualification" bson:"quaification"` 

    EmpDepartment Department         `json:"department" bson:"department"` 

}

 type Department struct {

    DepartmentID    int                `json:"dept_id" bson:"dept_id"`

    DepartmentName  string             `json:"dept_name" bson:"dept_name"` 

    Description     string             `json:"description" bson:"description"` 

    EmployeeList    []Employee         `json:"employee_list" bson:"employee_list"`

}

collection := session.DB("db").C("department")

pipeline := collection.Pipe([]bson.M{

        {"$lookup": bson.M{

        "from":         "employee",

        "localField":   "dept_name",

        "foreignField": "emp_dept",

        "as":           "employee_list",

    }},

      {"$match": bson.M{

        "qualification": "PHD",

          }},

    })

err = pipeline.All(&departmentEmployees)

它显示空结果

我想从我的部门集合中获取所有部门，每个部门都有“PHD”资格的员工列表。我已将我的集合和结构上传为示例。如何在查找表中使用匹配字段。

我想得到像

{

    dept_id:11,

   dept_name:'XYZ'

   description:'desc'

   employee_list:[

     {

     emp_name:"qwerty"

     emp_id:111,

     qualification:'PHD' 

     }

     {

     emp_name:"asdfg"

     emp_id:222,

     qualification:'PHD' 

     }

...

]}

 {

    dept_id:12,

   dept_name:'ABC'

   description:'descwe'

   employee_list:[

     {

     emp_name:"bjgk"

     emp_id:865,

     qualification:'PHD' 

     }

     {

     emp_name:"hkj"

     emp_id:967,

     qualification:'PHD' 

     }

...

]}

对于第一所大学，让所有员工获得博士学位，然后在第二所大学获得博士学位，依此类推。我很困惑我是否必须在查找中使用 group by in 从集合中？

Answer 1

首先，您的Employee.EmpQualification字段标签中有错字：EmpQualification string `json:"qualification" bson:"quaification"`它应该是：EmpQualification string `json:"qualification" bson:"qualification"`接下来，当您将员工查找为 时employee_list，这将是结果中的一个新字段，因此qualification将引用员工的字段department而不是员工的字段。既然employee_list是一个数组，你不能简单地匹配，你必须过滤数组，并用employee_list新的过滤数组替换。最后，您可能希望排除没有任何具有“PHD”资格的员工的部门。最终的聚合如下所示：pipeline := collection.Pipe([]bson.M{    {"$lookup": bson.M{        "from":         "employee",        "localField":   "dept_name",        "foreignField": "emp_dept",        "as":           "employee_list",    }},    {        "$addFields": bson.M{            "employee_list": bson.M{                "$filter": bson.M{                    "input": "$employee_list",                    "as":    "emp",                    "cond":  bson.M{                        "$eq": []interface{}{"$$emp.qualification", "PHD"},                    },                },            },        },    },    {"$match": bson.M{        "employee_list": bson.M{"$not": bson.M{"$size": 0}},    }},})另请注意，上述聚合必须搜索所有部门及其员工。更好的方法是从员工开始，按资格筛选，然后按部门分组。扩展第二种方法：一旦您拥有拥有 PHD 的员工，将员工分组emp_dept并聚集在 中employee_list，然后查找部门。然后你必须“构建”结果文档，即查找的部门必须是附加的emplyee_list（在阶段期间收集的$group）的“根”。这就是它的样子：pipeline := collection.Pipe([]bson.M{    {"$match": bson.M{        "qualification": "PHD",    }},    {"$group": bson.M{        "_id":           "$emp_dept",        "employee_list": bson.M{"$push": "$$ROOT"},    }},    {"$lookup": bson.M{        "from":         "department",        "localField":   "_id",        "foreignField": "dept_name",        "as":           "department",    }},    {"$unwind": "$department"},    {"$replaceRoot": bson.M{        "newRoot": bson.M{            "$mergeObjects": []interface{}{                "$department",                bson.M{"employee_list": "$employee_list"},            },        },    }},})第二种方法的优点是它只处理拥有 PHD 的员工（确保有一个索引），只加载拥有此类员工的部门。另请注意，最好将部门 ID 存储在员工中而不是部门名称中，如果将来必须重命名部门，则只需在一个地方（在部门文档中）更改它。