关于mongodb:MongoDB按需物化视图介绍

留神

本页的内容探讨了按需物化视图。无关视图的探讨，请参阅视图。

从4.2版本开始，MongoDB为aggregation pipeline增加了$merge阶段。此阶段能够将管道后果合并到现有汇合中，而不是齐全替换现有汇合。此性能容许用户创立按需物化视图，每次运行管道时都能够更新输入汇合的内容。

示例

假如当初靠近2019年1月末，汇合bakesales蕴含按我的项目分类的销售信息：

db.bakesales.insertMany( [   { date: new ISODate("2018-12-01"), item: "Cake - Chocolate", quantity: 2, amount: new NumberDecimal("60") },   { date: new ISODate("2018-12-02"), item: "Cake - Peanut Butter", quantity: 5, amount: new NumberDecimal("90") },   { date: new ISODate("2018-12-02"), item: "Cake - Red Velvet", quantity: 10, amount: new NumberDecimal("200") },   { date: new ISODate("2018-12-04"), item: "Cookies - Chocolate Chip", quantity: 20, amount: new NumberDecimal("80") },   { date: new ISODate("2018-12-04"), item: "Cake - Peanut Butter", quantity: 1, amount: new NumberDecimal("16") },   { date: new ISODate("2018-12-05"), item: "Pie - Key Lime", quantity: 3, amount: new NumberDecimal("60") },   { date: new ISODate("2019-01-25"), item: "Cake - Chocolate", quantity: 2, amount: new NumberDecimal("60") },   { date: new ISODate("2019-01-25"), item: "Cake - Peanut Butter", quantity: 1, amount: new NumberDecimal("16") },   { date: new ISODate("2019-01-26"), item: "Cake - Red Velvet", quantity: 5, amount: new NumberDecimal("100") },   { date: new ISODate("2019-01-26"), item: "Cookies - Chocolate Chip", quantity: 12, amount: new NumberDecimal("48") },   { date: new ISODate("2019-01-26"), item: "Cake - Carrot", quantity: 2, amount: new NumberDecimal("36") },   { date: new ISODate("2019-01-26"), item: "Cake - Red Velvet", quantity: 5, amount: new NumberDecimal("100") },   { date: new ISODate("2019-01-27"), item: "Pie - Chocolate Cream", quantity: 1, amount: new NumberDecimal("20") },   { date: new ISODate("2019-01-27"), item: "Cake - Peanut Butter", quantity: 5, amount: new NumberDecimal("80") },   { date: new ISODate("2019-01-27"), item: "Tarts - Apple", quantity: 3, amount: new NumberDecimal("12") },   { date: new ISODate("2019-01-27"), item: "Cookies - Chocolate Chip", quantity: 12, amount: new NumberDecimal("48") },   { date: new ISODate("2019-01-27"), item: "Cake - Carrot", quantity: 5, amount: new NumberDecimal("36") },   { date: new ISODate("2019-01-27"), item: "Cake - Red Velvet", quantity: 5, amount: new NumberDecimal("100") },   { date: new ISODate("2019-01-28"), item: "Cookies - Chocolate Chip", quantity: 20, amount: new NumberDecimal("80") },   { date: new ISODate("2019-01-28"), item: "Pie - Key Lime", quantity: 3, amount: new NumberDecimal("60") },   { date: new ISODate("2019-01-28"), item: "Cake - Red Velvet", quantity: 5, amount: new NumberDecimal("100") },] );

定义按需物化视图

上面的updateMonthlySales函数定义了一个monthlybakesales物化视图，其中蕴含累积的每月销售信息。在示例中，该函数采纳了一个日期参数来更新从特定日期开始的每月销售信息。

updateMonthlySales = function(startDate) {   db.bakesales.aggregate( [      { $match: { date: { $gte: startDate } } },      { $group: { _id: { $dateToString: { format: "%Y-%m", date: "$date" } }, sales_quantity: { $sum: "$quantity"}, sales_amount: { $sum: "$amount" } } },      { $merge: { into: "monthlybakesales", whenMatched: "replace" } }   ] );};

$match阶段过滤数据以仅解决那些销售额大于或等于startDate

阶段按年-月对销售信息进行分组。此阶段输入的文档具备以下模式：

{ "_id" : "<YYYY-mm>", "sales_quantity" : <num>, "sales_amount" : <NumberDecimal> }
$merge阶段将输入写入到monthlybakesales汇合

基于on_id字段（未分片输入汇合的默认值），此阶段会查看聚合后果中的文档是否 匹配 汇合中的现有文档：

当匹配时（即同年月的文档曾经存在于汇合中），此阶段会应用来自聚合后果的文档替换现有文档；

当不匹配时，此阶段将聚合后果中的文档插入到汇合中（不匹配时的默认行为）。

执行初始运行

对于初始运行，你能够传入一个日期new ISODate("1970-01-01")：

updateMonthlySales(new ISODate("1970-01-01"));
初始运行后，monthlybakesales蕴含以下文档；即db.monthlybakesales.find().sort( { _id: 1 } )返回以下内容：

{ "_id" : "2018-12", "sales_quantity" : 41, "sales_amount" : NumberDecimal("506") }{ "_id" : "2019-01", "sales_quantity" : 86, "sales_amount" : NumberDecimal("896") }

刷新物化视图

假如到了2019年2月的第一周，bakesales汇合更新了新的销售信息；具体来说就是一月和二月新增的销售。

db.bakesales.insertMany( [   { date: new ISODate("2019-01-28"), item: "Cake - Chocolate", quantity: 3, amount: new NumberDecimal("90") },   { date: new ISODate("2019-01-28"), item: "Cake - Peanut Butter", quantity: 2, amount: new NumberDecimal("32") },   { date: new ISODate("2019-01-30"), item: "Cake - Red Velvet", quantity: 1, amount: new NumberDecimal("20") },   { date: new ISODate("2019-01-30"), item: "Cookies - Chocolate Chip", quantity: 6, amount: new NumberDecimal("24") },   { date: new ISODate("2019-01-31"), item: "Pie - Key Lime", quantity: 2, amount: new NumberDecimal("40") },   { date: new ISODate("2019-01-31"), item: "Pie - Banana Cream", quantity: 2, amount: new NumberDecimal("40") },   { date: new ISODate("2019-02-01"), item: "Cake - Red Velvet", quantity: 5, amount: new NumberDecimal("100") },   { date: new ISODate("2019-02-01"), item: "Tarts - Apple", quantity: 2, amount: new NumberDecimal("8") },   { date: new ISODate("2019-02-02"), item: "Cake - Chocolate", quantity: 2, amount: new NumberDecimal("60") },   { date: new ISODate("2019-02-02"), item: "Cake - Peanut Butter", quantity: 1, amount: new NumberDecimal("16") },   { date: new ISODate("2019-02-03"), item: "Cake - Red Velvet", quantity: 5, amount: new NumberDecimal("100") }] )

为了刷新1月和2月的monthlybakesales数据，须要再次运行该函数以从新运行聚合管道，日期参数值从new ISODate("2019-01-01")开始。

updateMonthlySales(new ISODate("2019-01-01"));

monthlybakesales的内容已更新，并能反映出bakesales汇合中的最新数据；即db.monthlybakesales.find().sort( { _id: 1 } )返回以下内容：

{ "_id" : "2018-12", "sales_quantity" : 41, "sales_amount" : NumberDecimal("506") }{ "_id" : "2019-01", "sales_quantity" : 102, "sales_amount" : NumberDecimal("1142") }{ "_id" : "2019-02", "sales_quantity" : 15, "sales_amount" : NumberDecimal("284") }

附加信息

$merge阶段:

能够输入到雷同或不同数据库中的汇合。

如果输入汇合不存在，则会创立一个新汇合。

能够将后果（插入新文档、合并文档、替换文档、保留现有文档、操作失败、应用自定义更新管道解决文档）合并到现有汇合中。

能够输入到分片的汇合中。输出汇合也能够是分片汇合。

参考$merge：

无关$merge和可用选项的更多信息

示例：按需物化视图：初始创立

示例：按需物化视图：更新/替换数据

示例：仅插入新数据

原文链接：https://docs.mongodb.com/manu...

译者：李正洋

DBA一枚，善于oracle/mongodb//tidb等多种数据库。

现阶段对开源分布式数据库、云计算等畛域有很大趣味；平时喜爱打羽毛球、看电影等。