5

我在本地工作 - 这永远不会在实时网站上完成。我构建了一个 node/express 服务器，它将接受 Mongo 的字符串化聚合管道，并将结果返回给浏览器：

app.get('/aggregate/:collection', function(req, res) {

    var queryObject = JSON.parse(req.param('q'));

    var recProvider = getProviderForTable(req.params.collection);
    recProvider.getCollection(function(err, collection) {

        collection.aggregate(queryObject, {}, function(err, data) {
            res.json(data);
        });
    });

});

这使得在我正在构建数据可视化的浏览器中进行一些快速查询变得很方便：

$.get(LOCAL_SERVER + '/aggregate/my_records?q=' + JSON.stringify(pipeline));

我几乎开始构建像 Mongoose 一样的查询构建器，但只是构建聚合管道数组。我想知道我是否可以在浏览器中使用 Mongoose 的查询构建器来制作数组，然后使用它来访问我的快速服务器以获取数据，如上所述？

我想构建一个可链接的对象，例如...

pipeline()
    .where('value').gt(1000)
    .where('category').in([1, 2, 3])
    .sort('-date')
    .skip(100).limit(10);

...将返回聚合管道：

[
    {
        $match: {
            value: {
                $gt: 1000
            },
            category: {
                $in: [1, 2, 3]
            }
        }
    },
    {
        $sort: {
            date: -1
        }
    },
    {
        $skip: 100,
        $limit: 10
    }
]
4

1 回答 1

1

查看源代码，看起来每当您使用该aggregate()函数时，管道都存储在一个名为_pipeline.

使用您的示例，如果您编写这样的聚合管道...

var myAggregation = Model  // "Model" should actually be the name of your model
    .aggregate()
    .match({ value: { $gt: 1000 } })
    .match({ category: { $in: [1, 2, 3] } })
    .sort('-date')
    .skip(100)
    .limit(10);

然后myAggregation._pipeline会是这个样子...

[ { '$match': { value: { $gt: 1000 } } },
  { '$match': { category: { $in: [1, 2, 3] } } },
  { '$sort': { date: -1 } },
  { '$skip': 100 },
  { '$limit': 10 } ]

但是，我注意到您正在使用该where()函数，它实际上创建了一个Queryin mongoose 而不是聚合管道。如果您设置为 using where()，则条件和选项的设置会有所不同。而不是myAggregation._pipeline，它们将被拆分为myAggregation._conditions和myAggregation.options。它们的编写方式并不完全相同，但也许您可以将其转换为您想要的格式。

于 2013-11-20T16:05:23.937 回答