閱讀(3.4k) 書簽贊(0) 我要糾錯(cuò)

SDK數(shù)據(jù)庫 Command·聚合操作符·累記器操作符

2022-05-12 17:04 更新

AggregateCommand.addToSet(value: Expression): Object

聚合操作符。聚合運(yùn)算符。向數(shù)組中添加值，如果數(shù)組中已存在該值，不執(zhí)行任何操作。它只能在 group stage 中使用。

參數(shù)

value: Expression

表達(dá)式

返回值

Object

API 說明

addToSet 語法如下：

db.command.aggregate.addToSet(<表達(dá)式>)

表達(dá)式是形如 $ + 指定字段的字符串。如果指定字段的值是數(shù)組，那么整個(gè)數(shù)組會(huì)被當(dāng)作一個(gè)元素。

示例代碼

假設(shè)集合 passages 的記錄如下：

{ "category": "web", "tags": [ "JavaScript", "CSS" ], "title": "title1" }
{ "category": "System", "tags": [ "C++", "C" ], "title": "title2" }

非數(shù)組字段

每條記錄的 category 對應(yīng)值的類型是非數(shù)組，利用 addToSet 統(tǒng)計(jì)所有分類：

const $ = db.command.aggregate
db
  .collection('passages')
  .aggregate()
  .group({
    _id: null,
    categories: $.addToSet('$category')
  })
  .end()

返回的結(jié)果如下：

{ "_id": null, "categories": [ "System", "web" ] }

數(shù)組字段

每條記錄的 tags 對應(yīng)值的類型是數(shù)組，數(shù)組不會(huì)被自動(dòng)展開：

const $ = db.command.aggregate
db
  .collection('passages')
  .aggregate()
  .group({
    _id: null,
    tagsList: $.addToSet('$tags')
  })
  .end()

返回的結(jié)果如下：

{ "_id": null, "tagsList": [ [ "C++", "C" ], [ "JavaScript", "CSS" ] ] }

AggregateCommand.avg(value: Expression<number>): Object

聚合操作符。返回一組集合中，指定字段對應(yīng)數(shù)據(jù)的平均值。

參數(shù)

value: Expression<number>

number

返回值

Object

API 說明

avg 的語法如下：

db.command.aggregate.avg(<number>)

avg 傳入的值除了數(shù)字常量外，也可以是任何最終解析成一個(gè)數(shù)字的表達(dá)式。它會(huì)忽略非數(shù)字值。

示例代碼

假設(shè)集合 students 的記錄如下：

{ "group": "a", "name": "stu1", "score": 84 }
{ "group": "a", "name": "stu2", "score": 96 }
{ "group": "b", "name": "stu3", "score": 80 }
{ "group": "b", "name": "stu4", "score": 100 }

借助 avg 可以計(jì)算所有記錄的 score 的平均值：

const $ = db.command.aggregate
db
  .collection('students')
  .aggregate()
  .group({
    _id: null,
    average: $.avg('$score')
  })
  .end()

返回的結(jié)果如下：

{ "_id": null, "average": 90 }

AggregateCommand.first(value: Expression): Object

聚合操作符。返回指定字段在一組集合的第一條記錄對應(yīng)的值。僅當(dāng)這組集合是按照某種定義排序（ sort ）后，此操作才有意義。

參數(shù)

value: Expression

表達(dá)式

返回值

Object

API 說明

first 的語法如下：

db.command.aggregate.first(<表達(dá)式>)

表達(dá)式是形如 $ + 指定字段的字符串。

first 只能在 group 階段被使用，并且需要配合 sort 才有意義。

示例代碼

假設(shè)集合 students 的記錄如下：

{ "group": "a", "name": "stu1", "score": 84 }
{ "group": "a", "name": "stu2", "score": 96 }
{ "group": "b", "name": "stu3", "score": 80 }
{ "group": "b", "name": "stu4", "score": 100 }

如果需要得到所有記錄中 score 的最小值，可以先將所有記錄按照 score 排序，然后取出第一條記錄的 first。

const $ = db.command.aggregate
db
  .collection('students')
  .aggregate()
  .sort({
    score: 1
  })
  .group({
    _id: null,
    min: $.first('$score')
  })
  .end()

返回的數(shù)據(jù)結(jié)果如下：

{ "_id": null, "min": 80 }

AggregateCommand.last(value: Expression): Object

聚合操作符。返回指定字段在一組集合的最后一條記錄對應(yīng)的值。僅當(dāng)這組集合是按照某種定義排序（ sort ）后，此操作才有意義。

參數(shù)

value: Expression

表達(dá)式

返回值

Object

API 說明

last 的語法如下：

db.command.aggregate.last(<表達(dá)式>)

表達(dá)式是形如 $ + 指定字段的字符串。

last 只能在 group 階段被使用，并且需要配合 sort 才有意義。

示例代碼

假設(shè)集合 students 的記錄如下：

{ "group": "a", "name": "stu1", "score": 84 }
{ "group": "a", "name": "stu2", "score": 96 }
{ "group": "b", "name": "stu3", "score": 80 }
{ "group": "b", "name": "stu4", "score": 100 }

如果需要得到所有記錄中 score 的最大值，可以先將所有記錄按照 score 排序，然后取出最后一條記錄的 last。

const $ = db.command.aggregate
db
  .collection('students')
  .aggregate()
  .sort({
    score: 1
  })
  .group({
    _id: null,
    max: $.last('$score')
  })
  .end()

返回的數(shù)據(jù)結(jié)果如下：

{ "_id": null, "max": 100 }

AggregateCommand.max(value: Expression): Object

聚合操作符。返回一組數(shù)值的最大值。

參數(shù)

value: Expression

表達(dá)式

返回值

Object

API 說明

max 的語法如下：

db.command.aggregate.max(<表達(dá)式>)

表達(dá)式是形如 $ + 指定字段的字符串。

示例代碼

假設(shè)集合 students 的記錄如下：

{ "group": "a", "name": "stu1", "score": 84 }
{ "group": "a", "name": "stu2", "score": 96 }
{ "group": "b", "name": "stu3", "score": 80 }
{ "group": "b", "name": "stu4", "score": 100 }

借助 max 可以統(tǒng)計(jì)不同組（ group ）中成績的最高值，代碼如下：

const $ = db.command.aggregate
db
  .collection('students')
  .aggregate()
  .group({
    _id: '$group',
    maxScore: $.max('$score')
  })
  .end()

返回的數(shù)據(jù)結(jié)果如下：

{ "_id": "b", "maxScore": 100 }
{ "_id": "a", "maxScore": 96 }
```.

AggregateCommand.mergeObjects(value: Expression<document>): Object

聚合操作符。將多個(gè)文檔合并為單個(gè)文檔。

參數(shù)

value: Expression<document>

Document 表達(dá)式

返回值

Object

API 說明

使用形式如下：在 group() 中使用時(shí)：

mergeObjects(<document>)

在其它表達(dá)式中使用時(shí)：

mergeObjects([<document1>, <document2>, ...])

示例代碼

搭配 group() 使用

假設(shè)集合 sales 存在以下文檔：

{ "_id": 1, "year": 2018, "name": "A", "volume": { "2018Q1": 500, "2018Q2": 500 } }
{ "_id": 2, "year": 2017, "name": "A", "volume": { "2017Q1": 400, "2017Q2": 300, "2017Q3": 0, "2017Q4": 0 } }
{ "_id": 3, "year": 2018, "name": "B", "volume": { "2018Q1": 100 } }
{ "_id": 4, "year": 2017, "name": "B", "volume": { "2017Q3": 100, "2017Q4": 250 } }

下面的代碼使用 mergeObjects()，將用相同 name 的文檔合并：

const $ = db.command.aggregate
db.collection('sales').aggregate()
  .group({
    _id: '$name',
    mergedVolume: $.mergeObjects('$volume')
  })
  .end()

輸出如下：

{ "_id": "A", "mergedVolume": { "2017Q1": 400, "2017Q2": 300, "2017Q3": 0, "2017Q4": 0, "2018Q1": 500, "2018Q2": 500 } }
{ "_id": "B", "mergedVolume": { "2017Q3": 100, "2017Q4": 250, "2018Q1": 100 } }

一般用法

假設(shè)集合 test 存在以下文檔：

{ "_id": 1, "foo": { "a": 1 }, "bar": { "b": 2 } }
{ "_id": 2, "foo": { "c": 1 }, "bar": { "d": 2 } }
{ "_id": 3, "foo": { "e": 1 }, "bar": { "f": 2 } }

下面的代碼使用 mergeObjects()，將文檔中的 foo 和 bar 字段合并為 foobar：

const $ = db.command.aggregate
db.collection('sales').aggregate()
  .project({
    foobar: $.mergeObjects(['$foo', '$bar'])
  })
  .end()

輸出結(jié)果如下：

{ "_id": 1, "foobar": { "a": 1, "b": 2 } }
{ "_id": 2, "foobar": { "c": 1, "d": 2 } }
{ "_id": 3, "foobar": { "e": 1, "f": 2 } }

AggregateCommand.min(value: Expression): Object

聚合操作符。返回一組數(shù)值的最小值。

參數(shù)

value: Expression

表達(dá)式

返回值

Object

API 說明

min 的語法如下：

db.command.aggregate.min(<表達(dá)式>)

表達(dá)式是形如 $ + 指定字段的字符串。

示例代碼

假設(shè)集合 students 的記錄如下：

{ "group": "a", "name": "stu1", "score": 84 }
{ "group": "a", "name": "stu2", "score": 96 }
{ "group": "b", "name": "stu3", "score": 80 }
{ "group": "b", "name": "stu4", "score": 100 }

借助 min 可以統(tǒng)計(jì)不同組（ group ）中成績的最低值，代碼如下：

const $ = db.command.aggregate
db
  .collection('students')
  .aggregate()
  .group({
    _id: '$group',
    minScore: $.min('$score')
  })
  .end()

返回的數(shù)據(jù)結(jié)果如下：

{ "_id": "b", "minScore": 80 }
{ "_id": "a", "minScore": 84 }

AggregateCommand.push(value: any): Object

聚合操作符。在 group 階段，返回一組中表達(dá)式指定列與對應(yīng)的值，一起組成的數(shù)組。

參數(shù)

value: any

返回值

Object

API 說明

push 語法如下：

db.command.aggregate.push({
  <字段名1>: <指定字段1>,
  <字段名2>: <指定字段2>,
  ...
})

示例代碼

假設(shè)集合 students 的記錄如下：

{ "group": "a", "name": "stu1", "score": 84 }
{ "group": "a", "name": "stu2", "score": 96 }
{ "group": "b", "name": "stu3", "score": 80 }
{ "group": "b", "name": "stu4", "score": 100 }

借助 push 操作，對不同分組( group )的所有記錄，聚合所有數(shù)據(jù)并且將其放入一個(gè)新的字段中，進(jìn)一步結(jié)構(gòu)化和語義化數(shù)據(jù)。

const $ = db.command.aggregate
db
  .collection('students')
  .aggregate()
  .group({
    _id: '$group',
    students: $.push({
      name: '$name',
      score: '$score'
    })
  })
  .end()

輸出結(jié)果如下：

{ "_id": "b", "students": [{ "name": "stu3", "score": 80 }, { "name": "stu4", "score": 100 }] }
{ "_id": "a", "students": [{ "name": "stu1", "score": 84 }, { "name": "stu2", "score": 96 }] }

AggregateCommand.stdDevPop(value: Expression): Object

聚合操作符。返回一組字段對應(yīng)值的標(biāo)準(zhǔn)差。

參數(shù)

value: Expression

表達(dá)式

返回值

Object

API 說明

stdDevPop 的使用形式如下：

db.command.aggregate.stdDevPop(<表達(dá)式>)

表達(dá)式傳入的是指定字段，指定字段對應(yīng)的值的數(shù)據(jù)類型必須是 number ，否則結(jié)果會(huì)返回 null。

示例代碼

假設(shè)集合 students 的記錄如下：a 組同學(xué)的成績分別是84和96，b組同學(xué)的成績分別是80和100。

{ "group":"a", "score":84 }
{ "group":"a", "score":96 }
{ "group":"b", "score":80 }
{ "group":"b", "score":100 }

可以用 stdDevPop 來分別計(jì)算 a 和 b 兩組同學(xué)成績的標(biāo)準(zhǔn)差，以此來比較哪一組同學(xué)的成績更穩(wěn)定。代碼如下：

const $ = db.command.aggregate
db.collection('students').aggregate()
  .group({
    _id: '$group',
    stdDev: $.stdDevPop('$score')
  })
  .end()

返回的數(shù)據(jù)結(jié)果如下：

{ "_id": "b", "stdDev": 10 }
{ "_id": "a", "stdDev": 6 }

AggregateCommand.stdDevSamp(value: Expression): Object

聚合操作符。計(jì)算輸入值的樣本標(biāo)準(zhǔn)偏差。如果輸入值代表數(shù)據(jù)總體，或者不概括更多的數(shù)據(jù)，請改用 db.command.aggregate.stdDevPop。

參數(shù)

value: Expression

表達(dá)式

返回值

Object

API 說明

stdDevSamp 的使用形式如下：

db.command.aggregate.stdDevSamp(<表達(dá)式>)

表達(dá)式傳入的是指定字段，stdDevSamp 會(huì)自動(dòng)忽略非數(shù)字值。如果指定字段所有的值均是非數(shù)字，那么結(jié)果返回 null。

示例代碼

假設(shè)集合 students 的記錄如下：

{ "score": 80 }
{ "score": 100 }

可以用 stdDevSamp 來計(jì)算成績的標(biāo)準(zhǔn)樣本偏差。代碼如下：

const $ = db.command.aggregate
db.collection('students').aggregate()
  .group({
    _id: null,
    ageStdDev: $.stdDevSamp('$score')
  })
  .end()

返回的數(shù)據(jù)結(jié)果如下：

{ "_id": null, "ageStdDev": 14.142135623730951 }

如果向集合 students 添加一條新記錄，它的 score 字段類型是 string：

{ "score": "aa" }

用上面代碼計(jì)算標(biāo)準(zhǔn)樣本偏差時(shí)，stdDevSamp 會(huì)自動(dòng)忽略類型不為 number 的記錄，返回結(jié)果保持不變。

AggregateCommand.sum(value: Expression): Object

聚合操作符。計(jì)算并且返回一組字段所有數(shù)值的總和。

參數(shù)

value: Expression

表達(dá)式

返回值

Object

API 說明

sum 的使用形式如下：

db.command.aggregate.sum(<表達(dá)式>)

表達(dá)式可以傳入指定字段，也可以傳入指定字段組成的列表。sum 會(huì)自動(dòng)忽略非數(shù)字值。如果字段下的所有值均是非數(shù)字，那么結(jié)果返回 0。若傳入數(shù)字常量，則當(dāng)做所有記錄該字段的值都給給定常量，在聚合時(shí)相加，最終值為輸入記錄數(shù)乘以常量。

示例代碼

假設(shè)代表商品的集合 goods 的記錄如下：price 代表商品銷售額，cost 代表商品成本

{ "cost": -10, "price": 100 }
{ "cost": -15, "price": 1 }
{ "cost": -10, "price": 10 }

單獨(dú)字段

借助 sum 可以計(jì)算所有商品的銷售總和，代碼如下：

const $ = db.command.aggregate
db
  .collection('goods')
  .aggregate()
  .group({
    _id: null,
    totalPrice: $.sum('$price')
  })
  .end()

返回的數(shù)據(jù)結(jié)果如下：銷售額是 111

{ "_id": null, "totalPrice": 111 }

字段列表

如果需要計(jì)算所有商品的利潤總額，那么需要將每條記錄的 cost 和 price 相加得到此記錄對應(yīng)商品的利潤。最后再計(jì)算所有商品的利潤總額。

借助 sum，代碼如下：

const $ = db.command.aggregate
db
  .collection('goods')
  .aggregate()
  .group({
    _id: null,
    totalProfit: $.sum(
      $.sum(['$price', '$cost'])
    )
  })
  .end()

返回的數(shù)據(jù)結(jié)果如下：利潤總額為 76

{ "_id": null, "totalProfit": 76 }

以上內(nèi)容是否對您有幫助：

← SDK數(shù)據(jù)庫 Command·聚合操作符·字符串操作符

SDK數(shù)據(jù)庫 Command·聚合操作符·變量操作符 →

寫筆記

我要補(bǔ)充