我在mongoose中有一个Inspection模型:
var InspectionSchema = new Schema({
business_id: {
type: String,
required: true
},
score: {
type: Number,
min: 0,
max: 100,
required: true
},
date: {
type: Number, // in format YYYYMMDD
required: true
},
description: String,
type: String
});
InspectionSchema.index({business_id: 1, date: 1}, {unique: true});
对同一个业务可能有多个检查(每个业务由唯一的business_id表示)。但是,每个业务每天只能检查一次,这就是为什么在business_id + date上有一个唯一的索引。
我还在Inspection对象上创建了一个静态方法,在给定business_id列表的情况下,该方法检索底层业务的所有检查。
InspectionSchema.statics.getAllForBusinessIds = function(ids, callback) {
this.find({'business_id': {$in: ids}}, callback);
};
此函数获取所请求业务的所有检查。但是,我还想创建一个函数,该函数只获取每个business_id的最新检查
。InspectionSchema.statics.getLatestForBusinessIds = function(ids, callback) {
// query to get only the latest inspection per business_id in "ids"?
};
我该如何实现这个呢?
您可以使用.aggregate()
方法,以便在一个请求中获得所有最新数据:
Inspection.aggregate(
[
{ "$sort": { "buiness_id": 1, "date": -1 } },
{ "$group": {
"_id": "$business_id",
"score": { "$first": "$score" },
"date": { "$first": "$date" },
"description": { "$first": "$description" },
"type": { "$first": "$type" }
}}
],
function(err,result) {
}
);
先 $sort
,然后 $group
,以"business_id"作为分组键。 $first
从分组边界获得第一个结果,我们已经在每个id中按日期排序。
如果你只想要日期,那么使用 $max
:
Inspection.aggregate(
[
{ "$group": {
"_id": "$business_id",
"date": { "$max": "$date" }
}}
],
function(err,result) {
}
);
如果您想在执行此操作时"预过滤"业务id值或任何其他条件,请参见 $match
。
try this:
Inpection.aggregate(
[
{ $match : { _id : { "$in" : ids} } },
{ $group: { "_id" : "$business_id", lastInspectionDate: { $last: "$date" } } }
],
function(err,result) {
}
);