mongodb改写nodejs

90后爱国 发布于 2014/09/09 11:53
阅读 345
收藏 1

@Arrowing 你好,想跟你请教个问题:我想把这段mongodb查询

db.subscriber.aggregate({$match:{starId:"534ba1488ccd99bf7a63ad75"}},{$group:{_id:"$starId",num:{$sum:1}}})

代码改成nodejs的查询语句但不好使能帮我看看是那些错了吗

mongodbPool.acquire(function (err,db) {
        if (err) {
            return callback(err);
        }
        db.collection('subscriber', function (err, collection) {
            if (err) {
                mongodbPool.release(db);
                return callback(err);
            }
            collection.aggregate({$match: {'starId': starId}},
                {$group: {_id: '$starId', num: {$sum: 1}}}).toArray(
                function (err, docs) {
                    console.log(docs);
                    mongodbPool.release(db);
                    if (err) {
                        return callback(err);
                    }
                    else {
                        return callback(null,docs);
                    }
                });
        });
    });

加载中
0
Arrowing
Arrowing

自己调试下

再者,没出错信息吗?

Arrowing
Arrowing
回复 @90后爱国 : 我看了好像也没错误啊,你不行是什么情况啊,完全没反应?
90后爱国
90后爱国
我用collection.find()或collection.update()都没有问题,我觉得collection.aggregate()有问题但我不知道怎么解决?我上网上看了很多是可以怎么写的
返回顶部
顶部