|
|
|
|
|
|
|
|
MongoAggregationPipeline (Function) In french: MongoPipelineAgrégation Used to retrieve documents that enter a multi-stage pipeline and are transformed into aggregated results.
sPipeline is string = ...
"["+CR+...
" { ""$group"":"+CR+...
" {"+CR+...
" ""_id"": { ""state"": ""$state"", ""city"": ""$city"" },"+CR+...
" ""pop"": { ""$sum"": ""$pop"" }"+CR+...
" }"+CR+...
" },"+CR+...
" { ""$sort"": { ""pop"": 1 } },"+CR+...
" { ""$group"":"+CR+...
" {"+CR+...
" ""_id"": ""$_id.state"","+CR+...
" ""biggestCity"": { ""$last"": ""$_id.city"" },"+CR+...
" ""biggestPop"": { ""$last"": ""$pop"" },"+CR+...
" ""smallestCity"": {""$first"": ""$_id.city"" },"+CR+...
" ""smallestPop"": {""$first"": ""$pop"" }"+CR+...
" }"+CR+...
" },"+CR+...
" { ""$project"":"+CR+...
" {"+CR+...
" ""_id"": 0,"+CR+...
" ""state"": ""$_id"","+CR+...
" ""biggestCity"": {""nom"": ""$biggestCity"", ""pop"": ""$biggestPop"" },"+CR+...
" ""smallestCity"": {""nom"": ""$smallestCity"", ""pop"": ""$smallestPop"" }"+CR+...
" }"+CR+...
" }"+CR+...
"]"
let r = MongoAggregationPipeline(gCnt.Database["db"].Collection["zipcodes"], sPipeline)
FOR EACH v OF r
Trace(VariantToJSON(v))
END
Syntax
<Result> = MongoAggregationPipeline(<Collection> , <Pipeline>)
<Result>: mongoResult variable mongoResult variable corresponding to the result. If a problem occurs, ErrorInfo is used to identify the error. <Collection>: mongoCollection variable Name of the mongoCollection variable corresponding to the MongoDB collection where the document search will be performed. <Pipeline>: Character string json(string), bson(buffer) or variant document that describes the pipeline in mongoDB format.
This page is also available for…
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|