Per MongoDB 3.6 e versioni successive, utilizzare $expr
operatore che consente l'utilizzo di espressioni di aggregazione all'interno del linguaggio di query:
var followers_count = 30;
db.locations.find({
"$expr": {
"$and": [
{ "$eq": ["$name", "development"] },
{ "$gte": [{ "$size": "$followers" }, followers_count ]}
]
}
});
Per le versioni non compatibili, puoi utilizzare sia $match
e $redact
pipeline per interrogare la tua collezione. Ad esempio, se vuoi interrogare le locations
raccolta dove il nome è 'sviluppo' e followers_count
è maggiore di 30, eseguire la seguente operazione di aggregazione:
const followers_count = 30;
Locations.aggregate([
{ "$match": { "name": "development" } },
{
"$redact": {
"$cond": [
{ "$gte": [ { "$size": "$followers" }, followers_count ] },
"$$KEEP",
"$$PRUNE"
]
}
}
]).exec((err, locations) => {
if (err) throw err;
console.log(locations);
})
o all'interno di una singola pipeline come
Locations.aggregate([
{
"$redact": {
"$cond": [
{
"$and": [
{ "$eq": ["$name", "development"] },
{ "$gte": [ { "$size": "$followers" }, followers_count ] }
]
},
"$$KEEP",
"$$PRUNE"
]
}
}
]).exec((err, locations) => {
if (err) throw err;
console.log(locations);
})
Quanto sopra restituirà le posizioni con solo il _id
riferimenti degli utenti. Per restituire i documenti degli utenti come mezzo per "popolare" l'array dei follower, puoi quindi aggiungere il $lookup
tubatura.
Se la versione del server Mongo sottostante è 3.4 e successive, puoi eseguire la pipeline come
let followers_count = 30;
Locations.aggregate([
{ "$match": { "name": "development" } },
{
"$redact": {
"$cond": [
{ "$gte": [ { "$size": "$followers" }, followers_count ] },
"$$KEEP",
"$$PRUNE"
]
}
},
{
"$lookup": {
"from": "users",
"localField": "followers",
"foreignField": "_id",
"as": "followers"
}
}
]).exec((err, locations) => {
if (err) throw err;
console.log(locations);
})
altrimenti dovresti $unwind
l'array dei follower prima di applicare $lookup
e poi raggruppati con $group
pipeline dopo di che:
let followers_count = 30;
Locations.aggregate([
{ "$match": { "name": "development" } },
{
"$redact": {
"$cond": [
{ "$gte": [ { "$size": "$followers" }, followers_count ] },
"$$KEEP",
"$$PRUNE"
]
}
},
{ "$unwind": "$followers" },
{
"$lookup": {
"from": "users",
"localField": "followers",
"foreignField": "_id",
"as": "follower"
}
},
{ "$unwind": "$follower" },
{
"$group": {
"_id": "$_id",
"created": { "$first": "$created" },
"name": { "$first": "$name" },
"followers": { "$push": "$follower" }
}
}
]).exec((err, locations) => {
if (err) throw err;
console.log(locations);
})