Mongodb过滤器filter选择要返回的数组子集操作方法

 更新时间:2023年07月19日 14:36:18   作者:Ethanchen's notes  
Mongodb使用过滤器 $filter根据指定条件选择要返回的数组子集,这篇文章主要介绍了Mongodb对嵌套文档数组进行查询操作,需要的朋友可以参考下

Mongodb过滤器

Mongodb使用过滤器 $filter 根据指定条件选择要返回的数组子集。返回仅包含与条件匹配的元素的数组。返回的元素按原始顺序排列。也就是说,这个是选择你要的文档,而不是排除。 如果该数组没有符合条件 ,则为 空 []

$filter: 选择数组的子集以返回仅包含与过滤条件匹配的元素的数组。

插入测试数据

sit_rs1:PRIMARY> db.user.insertMany([
...  { name: "user1", age: 10, letter: [{"x":"X1", "y":"Y1"}, {"x":"X2", "y":"Y2"}, {"x":"X3", "y":"Y3"}], number: [ { "n1":2, "n2":6 }, { "n1":3, "n2":3 }, { "n1":5, "n2":6 } ] },
...  { name: "user2", age: 20, letter: [{"V":"V1", "y":"Y1"}, {"V":"V2", "y":"Y2"}, {"V":"V3", "y":"Y3"}], number: [ { "n1":1, "n2":3 }, { "n1":4, "n2":5 }, { "n1":7, "n2":6 } ] },
...  { name: "user3", age: 30, letter: [{"V":"V1", "w":"W1"}, {"V":"V2", "w":"W2"}, {"V":"V3", "w":"W3"}], number: [ { "n1":1, "n2":8 }, { "n1":2, "n2":6 }, { "n1":2, "n2":6 } ] },
...  { name: "user4", age: 45, letter: [{"z":"Z1", "w":"W1"}, {"z":"Z2", "w":"W2"}, {"z":"Z3", "w":"W3"}], number: [ { "n1":9, "n2":8 }, { "n1":2, "n2":4 }, { "n1":3, "n2":6 } ] },
...  { name: "user5", age: 55, letter: [{"z":"Z1", "u":"U1"}, {"z":"Z2", "u":"U2"}, {"z":"Z3", "u":"U3"}], number: [ { "n1":7, "n2":8 }, { "n1":8, "n2":4 }, { "n1":4, "n2":6 } ] },
...  { name: "user6", age: 55, letter: [{"t":"T1", "u":"U1"}, {"t":"T2", "u":"U2"}, {"t":"T3", "u":"U3"}], number: [ { "n1":5, "n2":8 }, { "n1":8, "n2":5 }, { "n1":7, "n2":6 } ] },
... ])
{
        "acknowledged" : true,
        "insertedIds" : [
                ObjectId("64b661869be837dc8e997b74"),
                ObjectId("64b661869be837dc8e997b75"),
                ObjectId("64b661869be837dc8e997b76"),
                ObjectId("64b661869be837dc8e997b77"),
                ObjectId("64b661869be837dc8e997b78"),
                ObjectId("64b661869be837dc8e997b79")
        ]
}
sit_rs1:PRIMARY> db.user.find()
{ "_id" : ObjectId("64b661869be837dc8e997b74"), "name" : "user1", "age" : 10, "letter" : [ { "x" : "X1", "y" : "Y1" }, { "x" : "X2", "y" : "Y2" }, { "x" : "X3", "y" : "Y3" } ], "number" : [ { "n1" : 2, "n2" : 6 }, { "n1" : 3, "n2" : 3 }, { "n1" : 5, "n2" : 6 } ] }
{ "_id" : ObjectId("64b661869be837dc8e997b75"), "name" : "user2", "age" : 20, "letter" : [ { "V" : "V1", "y" : "Y1" }, { "V" : "V2", "y" : "Y2" }, { "V" : "V3", "y" : "Y3" } ], "number" : [ { "n1" : 1, "n2" : 3 }, { "n1" : 4, "n2" : 5 }, { "n1" : 7, "n2" : 6 } ] }
{ "_id" : ObjectId("64b661869be837dc8e997b76"), "name" : "user3", "age" : 30, "letter" : [ { "V" : "V1", "w" : "W1" }, { "V" : "V2", "w" : "W2" }, { "V" : "V3", "w" : "W3" } ], "number" : [ { "n1" : 1, "n2" : 8 }, { "n1" : 2, "n2" : 6 }, { "n1" : 2, "n2" : 6 } ] }
{ "_id" : ObjectId("64b661869be837dc8e997b77"), "name" : "user4", "age" : 45, "letter" : [ { "z" : "Z1", "w" : "W1" }, { "z" : "Z2", "w" : "W2" }, { "z" : "Z3", "w" : "W3" } ], "number" : [ { "n1" : 9, "n2" : 8 }, { "n1" : 2, "n2" : 4 }, { "n1" : 3, "n2" : 6 } ] }
{ "_id" : ObjectId("64b661869be837dc8e997b78"), "name" : "user5", "age" : 55, "letter" : [ { "z" : "Z1", "u" : "U1" }, { "z" : "Z2", "u" : "U2" }, { "z" : "Z3", "u" : "U3" } ], "number" : [ { "n1" : 7, "n2" : 8 }, { "n1" : 8, "n2" : 4 }, { "n1" : 4, "n2" : 6 } ] }
{ "_id" : ObjectId("64b661869be837dc8e997b79"), "name" : "user6", "age" : 55, "letter" : [ { "t" : "T1", "u" : "U1" }, { "t" : "T2", "u" : "U2" }, { "t" : "T3", "u" : "U3" } ], "number" : [ { "n1" : 5, "n2" : 8 }, { "n1" : 8, "n2" : 5 }, { "n1" : 7, "n2" : 6 } ] }

$filter 具有以下语法:

{ $filter: { input: <array>, as: <string>, cond: <expression> } }
  • input: 解析为数组的表达式。
  • as: 可选的。代表数组中每个单独元素的变量名称input。如果未指定名称,则变量名称默认为this。
  • cond: 解析为布尔值的表达式,用于确定是否应将某个元素包含在输出数组中。表达式使用as中指定的变量名分别引用输入数组的每个元素。
# 以下示例选择 number 数组 n1 字段 仅包含 “大于5” 的文档:
sit_rs1:PRIMARY> db.user.aggregate([
...    {
...       $project: {
...          number: {
...             $filter: {
...                input: "$number",
...                as: "number",
...                cond: { $gt: [ "$$number.n1", 5 ] }
...             }
...          }
...       }
...    }
... ])
{ "_id" : ObjectId("64b661869be837dc8e997b74"), "number" : [ ] }
{ "_id" : ObjectId("64b661869be837dc8e997b75"), "number" : [ { "n1" : 7, "n2" : 6 } ] }
{ "_id" : ObjectId("64b661869be837dc8e997b76"), "number" : [ ] }
{ "_id" : ObjectId("64b661869be837dc8e997b77"), "number" : [ { "n1" : 9, "n2" : 8 } ] }
{ "_id" : ObjectId("64b661869be837dc8e997b78"), "number" : [ { "n1" : 7, "n2" : 8 }, { "n1" : 8, "n2" : 4 } ] }
{ "_id" : ObjectId("64b661869be837dc8e997b79"), "number" : [ { "n1" : 8, "n2" : 5 }, { "n1" : 7, "n2" : 6 } ] }

as: 是可选的。如果未指定名称,则变量名称默认为this。下面使用 this 代替。

sit_rs1:PRIMARY> db.user.aggregate([
...    {
...       $project: {
...          number: {
...             $filter: {
...                input: "$number",
...                cond: { $gt: [ "$$this.n1", 5 ] }
...             }
...          }
...       }
...    }
... ])
{ "_id" : ObjectId("64b661869be837dc8e997b74"), "number" : [ ] }
{ "_id" : ObjectId("64b661869be837dc8e997b75"), "number" : [ { "n1" : 7, "n2" : 6 } ] }
{ "_id" : ObjectId("64b661869be837dc8e997b76"), "number" : [ ] }
{ "_id" : ObjectId("64b661869be837dc8e997b77"), "number" : [ { "n1" : 9, "n2" : 8 } ] }
{ "_id" : ObjectId("64b661869be837dc8e997b78"), "number" : [ { "n1" : 7, "n2" : 8 }, { "n1" : 8, "n2" : 4 } ] }
{ "_id" : ObjectId("64b661869be837dc8e997b79"), "number" : [ { "n1" : 8, "n2" : 5 }, { "n1" : 7, "n2" : 6 } ] }

聚合管道更新

从 MongoDB 4.2 开始,您可以使用聚合管道进行更新:使用聚合管道可以实现更具表现力的更新语句,例如基于当前字段值表达条件更新或使用另一个字段的值更新一个字段。

以下示例,使用 filter 选择数组的子集, 再更新原来的数组。

# 以下示例选择 number 数组 n1 字段 仅包含 “大于5” 的文档:并更新替换原来的数组 
sit_rs1:PRIMARY> db.user.updateMany(
...   { "number": { $exists: true } }, 
...   [{ 
...       $set: { 
...           "number": { 
...               $filter: { 
...   			      input: "$number", 
...   			      as: "number", 
...   			      cond: { $gt: [ "$$number.n1", 5 ] }
...   			  } 
...   		   } 
...    	  } 
...   }] 
... )
{ "acknowledged" : true, "matchedCount" : 6, "modifiedCount" : 6 }
sit_rs1:PRIMARY> db.user.find()
{ "_id" : ObjectId("64b661869be837dc8e997b74"), "name" : "user1", "age" : 10, "letter" : [ { "x" : "X1", "y" : "Y1" }, { "x" : "X2", "y" : "Y2" }, { "x" : "X3", "y" : "Y3" } ], "number" : [ ] }
{ "_id" : ObjectId("64b661869be837dc8e997b75"), "name" : "user2", "age" : 20, "letter" : [ { "V" : "V1", "y" : "Y1" }, { "V" : "V2", "y" : "Y2" }, { "V" : "V3", "y" : "Y3" } ], "number" : [ { "n1" : 7, "n2" : 6 } ] }
{ "_id" : ObjectId("64b661869be837dc8e997b76"), "name" : "user3", "age" : 30, "letter" : [ { "V" : "V1", "w" : "W1" }, { "V" : "V2", "w" : "W2" }, { "V" : "V3", "w" : "W3" } ], "number" : [ ] }
{ "_id" : ObjectId("64b661869be837dc8e997b77"), "name" : "user4", "age" : 45, "letter" : [ { "z" : "Z1", "w" : "W1" }, { "z" : "Z2", "w" : "W2" }, { "z" : "Z3", "w" : "W3" } ], "number" : [ { "n1" : 9, "n2" : 8 } ] }
{ "_id" : ObjectId("64b661869be837dc8e997b78"), "name" : "user5", "age" : 55, "letter" : [ { "z" : "Z1", "u" : "U1" }, { "z" : "Z2", "u" : "U2" }, { "z" : "Z3", "u" : "U3" } ], "number" : [ { "n1" : 7, "n2" : 8 }, { "n1" : 8, "n2" : 4 } ] }
{ "_id" : ObjectId("64b661869be837dc8e997b79"), "name" : "user6", "age" : 55, "letter" : [ { "t" : "T1", "u" : "U1" }, { "t" : "T2", "u" : "U2" }, { "t" : "T3", "u" : "U3" } ], "number" : [ { "n1" : 8, "n2" : 5 }, { "n1" : 7, "n2" : 6 } ] }

到此这篇关于Mongodb过滤器filter选择要返回的数组子集的文章就介绍到这了,更多相关Mongodb数组子集内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • MongoDB固定集合(capped collection)的知识小结

    MongoDB固定集合(capped collection)的知识小结

    固定集合指的是事先创建,并且大小固定的集合。下面这篇文章主要给大家总结介绍了MongoDB固定集合(capped collection)的知识,文中介绍的非常详细,需要的朋友可以参考借鉴,下面来一起学习学习吧
    2018-10-10
  • MongoDb的

    MongoDb的"not master and slaveok=false"错误及解决方法

    今天小编就为大家分享一篇关于MongoDb的"not master and slaveok=false"错误及解决方法,小编觉得内容挺不错的,现在分享给大家,具有很好的参考价值,需要的朋友一起跟随小编来看看吧
    2018-10-10
  • MongoDB的备份(mongodump)与恢复(mongorestore)

    MongoDB的备份(mongodump)与恢复(mongorestore)

    在使用MongoDB时,数据备份与恢复是非常重要的一环,以防止数据丢失或意外删除,本文就来介绍一下MongoDB的备份(mongodump)与恢复(mongorestore),感兴趣的可以了解一下
    2023-12-12
  • MongoDB对数组进行增删改查操作

    MongoDB对数组进行增删改查操作

    与关系型数据库相比,MongoDB支持数组,将数组存储到文档之中,下面这篇文章主要给大家介绍了关于MongoDB对数组进行增删改查操作的相关资料,文中通过实例代码介绍的非常详细,需要的朋友可以参考下
    2023-05-05
  • MongoDB按时间分组操作实战

    MongoDB按时间分组操作实战

    MongoDB支持使用聚合操作来统计数据,下面这篇文章主要给大家介绍了关于MongoDB按时间分组操作的相关资料,文中通过实例代码介绍的非常详细,需要的朋友可以参考下
    2023-05-05
  • mongodb linux下集群搭建过程

    mongodb linux下集群搭建过程

    这篇文章主要介绍了mongodb linux下集群搭建过程,本例中,为每个集群(shard config)三个mongo实例,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2022-02-02
  • MongoDb优化指南

    MongoDb优化指南

    在大数据时代中,大数据量的处理已经成了考量一个数据库最重要的原因之一。这篇文章给大家分享MongoDb优化指南,感兴趣的朋友一起看看吧
    2018-11-11
  • mongodb driver使用代码详解

    mongodb driver使用代码详解

    MongoDB 是一个基于分布式文件存储的数据库,由 C++ 语言编写,这篇文章主要介绍了mongodb driver使用,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2020-03-03
  • 使用命令方式安装MongoDB指南(Windows、Linux)

    使用命令方式安装MongoDB指南(Windows、Linux)

    这篇文章主要介绍了使用命令方式安装MongoDB指南,本文分别介绍Windows、Linux下使用命令的方式安装mongodb,需要的朋友可以参考下
    2015-04-04
  • MongoDB运行日志实现自动分割的方法实例

    MongoDB运行日志实现自动分割的方法实例

    这篇文章主要给大家介绍了关于MongoDB运行日志实现自动分割的方法,文中以一个MongoDB实例为例,写了一个脚本来实现自动分割MongoDB日志,有需要的朋友可以参考借鉴,下面来一起看看吧。
    2017-01-01

最新评论