अंत में इसे काम करने में कामयाब रहे। अधिकांश उदाहरणों में connect()
छोड़ दिया गया है भाग।
मेरा कार्य कोड:
Book.getDataSource().connector.connect(function(err, db) {
var collection = db.collection('Book');
var author = Book.getDataSource().ObjectID(authorId);
collection.aggregate([
{ $match: { authorId: author } },
{ $group: {
_id: authorId,
total: { $sum: "$price" }
}}
], function(err, data) {
if (err) return callback(err);
return callback(null, data);
});
});