Можем да направим множество условия за присъединяване с $lookup
оператор на конвейер за агрегиране във версия 3.6 и по-нова.
Трябва да присвоим стойностите на полетата на променлива с помощта на let
незадължително поле; след това имате достъп до тези променливи в pipeline
етапи на полето, където определяте тръбопровода, който да се изпълнява върху колекциите.
Имайте предвид, че в $match
етап, ние използваме $expr
оператор на заявка за оценка, за да сравни стойността на полетата.
Последният етап в конвейера е $replaceRoot
Етап на конвейера на агрегация, където просто обединяваме $lookup
резултат с част от $$ROOT
документ с помощта на $mergeObjects
оператор.
db.collection2.aggregate([
{
$lookup: {
from: "collection1",
let: {
firstUser: "$user1",
secondUser: "$user2"
},
pipeline: [
{
$match: {
$expr: {
$and: [
{
$eq: [
"$user1",
"$$firstUser"
]
},
{
$eq: [
"$user2",
"$$secondUser"
]
}
]
}
}
}
],
as: "result"
}
},
{
$replaceRoot: {
newRoot: {
$mergeObjects:[
{
$arrayElemAt: [
"$result",
0
]
},
{
percent1: "$$ROOT.percent1"
}
]
}
}
}
]
)
Този тръбопровод дава нещо, което изглежда така:
{
"_id" : ObjectId("59e1ad7d36f42d8960c06022"),
"user1" : 1,
"user2" : 2,
"percent" : 0.3,
"percent1" : 0.56
}
Ако не сте на версия 3.6+, можете първо да се присъедините, като използвате едно от полето си, нека каже „user1“, след което оттам развивате масива от съответстващия документ, като използвате $unwind
оператор на тръбопровод за агрегация. Следващият етап в тръбопровода е $redact
етап, в който филтрирате онези документи, при които стойността на "user2" от колекцията "joined" и на входния документ не са равни с помощта на $$KEEP
и $$PRUNE
системни променливи. След това можете да промените формата на документа си в $project
етап.
db.collection1.aggregate([
{ "$lookup": {
"from": "collection2",
"localField": "user1",
"foreignField": "user1",
"as": "collection2_doc"
}},
{ "$unwind": "$collection2_doc" },
{ "$redact": {
"$cond": [
{ "$eq": [ "$user2", "$collection2_doc.user2" ] },
"$$KEEP",
"$$PRUNE"
]
}},
{ "$project": {
"user1": 1,
"user2": 1,
"percent1": "$percent",
"percent2": "$collection2_doc.percent"
}}
])
което произвежда:
{
"_id" : ObjectId("572daa87cc52a841bb292beb"),
"user1" : 1,
"user2" : 2,
"percent1" : 0.56,
"percent2" : 0.3
}
Ако документите във вашите колекции имат една и съща структура и вие извършвате тази операция често, тогава трябва да помислите за обединяване на двете колекции в една или вмъкване на документите от тези колекции в нова колекция.
db.collection3.insertMany(
db.collection1.find({}, {"_id": 0})
.toArray()
.concat(db.collection2.find({}, {"_id": 0}).toArray())
)
След това $group
вашите документи от "user1" и "user2"
db.collection3.aggregate([
{ "$group": {
"_id": { "user1": "$user1", "user2": "$user2" },
"percent": { "$push": "$percent" }
}}
])
което дава:
{ "_id" : { "user1" : 1, "user2" : 2 }, "percent" : [ 0.56, 0.3 ] }