Sailsjs MongoDB Aggregation Query

Question

I'm trying to do an aggregation query to the db for objects with a specific id, and sum it all up and as well give me an average.

My Scenario

I've a model that looks like this:

attributes: {

    user: {
        model: 'user',
        required: true
    },

    rating: {
        type: 'integer',
        enum: [0, 1, 2, 3, 4, 5],
        defaultsTo: 0,
        required: true
    },

    inventory: {
        model: 'subItem'
    },

    size: {
        model: 'size',
        required: true
    },

    isDeleted: {
        type: 'boolean',
        defaultsTo: false
    }
}

Aggregating for the average rating like this:

const aggQuery = [
    {
        $match: {"size" : theRating.data[0].size, "isDeleted": false}
    },
    {
        $group: {
            _id: "$size",
            total: { $sum: 1 },
            average: { $avg: "$rating" }
        }
    }
]

My Function

module.exports = {

    aggregateQuery: (model, aggregate) => {
        return new Promise((resolve, reject) => {

            model.native(function (err, collection) {
                if (err) return reject(err);

                collection.aggregate(aggregate, function (err, result) {
                    if (err) return reject(err);

                    return resolve(result);
                })
            })
        })
    }
}

Use Case I populate the db with 16 records while writing the test, but, after running the aggregate query, I get an empty array

NativeQueryService.aggregateQuery(Rating, aggQuery).then(result => {
    console.log(result)
}).catch(err => {
    console.log(err)
})

Any help on what I'm doing wrong would be appreciated. Thanks.

The aggregation query looks good. Check for obvious things like collection name, query filter and input values. — s7vr
– s7vr, Commented Mar 5, 2017 at 22:29
can you confirm theRating.data[0].size is also an ObjectId and not a document (object)? — Leo
– Leo, Commented Mar 5, 2017 at 22:43
there it is, you are passing a string instead of an ObjectId, it should be ObjectId('58bc93f08efcbf950019ef1b') instead of '58bc93f08efcbf950019ef1b' — Leo
– Leo, Commented Mar 5, 2017 at 22:49

Leo · Accepted Answer · 2017-03-05 23:46:38Z

1

Make sure to pass a valid ObjectId and not a string to your $match stage.

{
    $match: {"size" : ObjectId(theRating.data[0].size), "isDeleted": false}
}

answered Mar 5, 2017 at 23:46

Leo

8448 silver badges15 bronze badges

Sign up to request clarification or add additional context in comments.

Collectives™ on Stack Overflow

Sailsjs MongoDB Aggregation Query

1 Answer 1

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Related