vibe.d beta banner
get vibe.d
0.7.30

Function MongoCollection.aggregate

Calculates aggregate values for the data in a collection.

Prototype

Bson aggregate(ARGS...)(
  ARGS pipeline
);

Parameters

NameDescription
pipeline A sequence of data aggregation processes. These can either be given as separate parameters, or as a single array parameter.

Returns

An array of documents returned by the pipeline

Throws

Exception if a DB communication error occured

See Also

http://docs.mongodb.org/manual/reference/method/db.collection.aggregate

Example

Example taken from the MongoDB documentation

import vibe.db.mongo.mongo;

void test() {
	auto db = connectMongoDB("127.0.0.1").getDatabase("test");
	auto results = db["coll"].aggregate(
		["$match": ["status": "A"]],
		["$group": ["_id": Bson("$cust_id"),
			"total": Bson(["$sum": Bson("$amount")])]],
		["$sort": ["total": -1]]);
}

Example

The same example, but using an array of arguments

import vibe.db.mongo.mongo;

void test() {
	auto db = connectMongoDB("127.0.0.1").getDatabase("test");

	Bson[] args;
	args ~= serializeToBson(["$match": ["status": "A"]]);
	args ~= serializeToBson(["$group": ["_id": Bson("$cust_id"),
			"total": Bson(["$sum": Bson("$amount")])]]);
	args ~= serializeToBson(["$sort": ["total": -1]]);

	auto results = db["coll"].aggregate(args);
}

Authors

Sönke Ludwig

Copyright

© 2012-2016 RejectedSoftware e.K.

License

Subject to the terms of the MIT license, as written in the included LICENSE.txt file.