mongo
db.getCollection("tn_distribute_log_aggregate").deleteMany({ distributeBusinessType: "EMPLOYEE_DISTRIBUTE" })
db.getCollection("tn_distribute_employee_log_aggregate").deleteMany({ "headAggregate.taskNo": { $regex: /EMPLOYEE_DISTRIBUTE/ } })
-- 查询在文档 tn_distribute_log_aggregate 里面存在的 taskNo 但是在 tn_distribute_employee_log_aggregate 中的 headAggregate.taskNo 字段中不存在,并且只看tn_distribute_log_aggregate 的 headAggregate.distributeBusinessType 是 EMPLOYEE_DISTRIBUTE 这个类型的
db.tn_distribute_log_aggregate.aggregate([
{
$match: {
"distributeBusinessType": "EMPLOYEE_DISTRIBUTE" // 过滤出指定类型
}
},
{
$lookup: {
from: "tn_distribute_employee_log_aggregate",
localField: "taskNo",
foreignField: "headAggregate.taskNo",
as: "employeeLog"
}
},
{
$match: {
"employeeLog": { $eq: [] } // 只保留没有匹配的条目
}
},
{
$project: {
_id: 0, // 不显示 _id 字段
taskNo: 1 // 显示 taskNo 字段
}
}
]);
要查询在文档 tn_distribute_log_aggregate 中存在的 taskNo,并且满足以下条件:
headAggregate.distributeBusinessType 是 EMPLOYEE_DISTRIBUTE
在 tn_distribute_employee_log_aggregate 的 headAggregate.taskNo 字段中不存在
可以使用如下的 MongoDB 聚合查询:
查询步骤说明:
$match:首先筛选 tn_distribute_log_aggregate 集合中 headAggregate.distributeBusinessType 为 EMPLOYEE_DISTRIBUTE 的文档。
lookup:使用‘lookup将过滤后的结果与tn_distribute_employee_log_aggregate集合连接,基于taskNo和headAggregate.taskNo` 进行匹配。
$match:再次筛选出 employeeLog 数组为空的文档,这意味着这些 taskNo 在 tn_distribute_employee_log_aggregate 中没有对应的条目。
$project:选择输出字段,只输出 taskNo。