百度360必应搜狗淘宝本站头条
当前位置:网站首页 > IT技术 > 正文

MongoDB关于内嵌数组文档的整理(mongodb内嵌查询指定字段)

wptr33 2025-05-02 13:51 24 浏览

一、关于索引

1】索引数组

假如有一个博客文章的集合,其中每个文档表示一篇文章。每篇文章都有一个"comments"字段,这是一个数组,其中每个元素都是一个评论的子文档。如果想要找出最近被评论次数最多的博客文章,可以在博客文章集合中嵌套的"comments"数组的“date”键上建立索引:

db.blog.createIndex({"comments.date": 1}})

对数组创建索引,实际上是对数组的每一个元素建立一个索引条目,所以如果一篇文章有20条评论,那么它就拥有20个索引条目。因此数组索引的代价比单值索引高:对于单次插入、更新或者删除,每一个数组条目可能都需要更新(可能有上千个索引条目)

与索引对象不同,无法将整个数组作为一个实体创建索引:对数组创建索引,实际上是对数组中的每个元素建立索引,而不是对数组本身建立索引。

在数组上建立的索引并不包含任何位置信息:无法使用数组索引查找特定位置的数组元素,比如:"comments.4"

少数特殊情况下,可以对某个特定的数组条目进行索引,比如:

db.blog.createIndex({"comments.10.votes": 1}})

然而,只有在精确匹配第11个数组元素时这个索引才有用

一个索引中的数组字段最多只能有一个。这是为了避免在多键索引中索引条目爆炸性增长:每一对可能的元素都要被索引,这样导致每个文档拥有"n*m"个索引条目。假如有一个{"x":1, "Y":1}上的索引:

//x是一个数组————这是合法的
db.multi.insert({"x" : [1,2,3], "y" : 1})

//y是一个数组————这是合法的
db.multi.insert({"x" : 1, "y" : [1,2,3]})

//x和y都是数组————这是非法的!
db.multi.insert({"x" : [1,2,3], "y" : [4,5,6]})

如果MongoDB要为上面的最后一个例子创建索引,它必须要创建这么多的索引条目:

{"x" : 1, "y" : 4}、{"x" : 1, "y" : 5}、{"x" : 1, "y" : 6}
{"x" : 2, "y" : 4}、{"x" : 2, "y" : 5}、{"x" : 2, "y" : 6}
{"x" : 3, "y" : 4}、{"x" : 3, "y" : 5}、{"x" : 3, "y" : 6}

尽管这些数组只有3个元素。

2】多键索引

对于某个索引的键,如果这个键在某个文档中是一个数组,那么这个索引就会被标记为多键索引(multikey index)。可以从explain()的输出中看到一个索引是否为多键索引:如果使用了多键索引,"isMultikey"字段的值为true。索引只要被标记为多键索引,就无法再变成非多键索引了,即使这个字段为数组的所有文档都从集合中删除。要将多键索引恢复为非多键索引,唯一的方法就是删除再重新创建这个索引。

多键索引可能会比非多键索引慢一些。可能会有多个索引条目指向同一个文档,因此MongoDB在返回结果集时必须要先去除重复的内容。

二、关于单值数组的操作

1】查询

1、操作符:$all

如果需要通过多个元素来匹配数组,就要用"$all"了。这样就会匹配一组元素。例如,假设创建了一个包含3个元素的集合

db.food.insert({"_id" : 1, "fruit": ["apple", "banana", "peach"]})
db.food.insert({"_id" : 2, "fruit": ["apple", "kumquat", "orange"]})
db.food.insert({"_id" : 3, "fruit": ["cherry", "banana", "apple"]})

要找到既有"apple"又有"banana"的文档,可以使用"$all"来查询:

db.food.find({"fruit": {"$all": ["apple", "banana"]}})

---查询结果
db.food.insert({"_id" : 1, "fruit": ["apple", "banana", "peach"]})
db.food.insert({"_id" : 3, "fruit": ["cherry", "banana", "apple"]})

这里的顺序无关紧要。注意,第二个结果中"banana"在"apple"之前。要是对只有一个元素的数组使用"$all",就和不用"$all"一样了。

也可以使用整个数组进行精确匹配。但是,精确匹配对于缺少元素或者元素冗余的情况就不太灵了。例如,下面的方法会匹配之前的第一个文档:

db.food.find({"fruit": ["apple", "banana", "peach"]})

但是下面这个就不会匹配:

db.food.find({"fruit": ["apple", "banana"]})

这个也不会匹配:

db.food.find({"fruit": ["banana", "apple", "peach"]})

要是想查询数组特定位置的元素,需使用key.index语法指定下标:

db.food.find({"fruit.2": "peach"]})

2、操作符:$size

"$size"对于查询数组来说也是非常有用的,顾名思义,可以用它查询特定长度的数组。例如:

db.food.find({"fruit": {"$size": 1}})

得到一个长度范围内的文档是一种常见的查询。"$size"并不能与其他查询条件(比如 $lte)组合使用,但是这种查询可以通过在文档中添加一个"size"键的方式来实现。这样每一次向指定数组添加元素时,同时增加"size"的值。比如,原本这样的更新:

db.food.update(criteria, {"$push": {"$fruit": "strawberry"}})

就要变成下面这样:

db.food.update(criteria, {"$push": {"$fruit": "strawberry"}, "$inc": {"size": 1}})

自增操作的速度非常快,所以对性能的影响微乎其微。这样存储文档后,就可以像下面这样查询了:

db.food.find({"size": {"$gt": 3}})

很遗憾,这种技巧并不能与"$addToSet"操作符同时使用。

3、操作符:$slice

"$slice"操作符可以返回某个键匹配的数组元素的一个子集。

例如,假设现在有一个博客文章的文档,我们希望返回前10条评论,可以这样做:

db.blog.posts.findOne(criteria, {"comments": {"$slice": 10}})

也可以返回后10条评论,只要在查询条件中使用-10就可以了

db.blog.posts.findOne(criteria, {"comments": {"$slice": -10}})

"$slice"也可以指定偏移值以及希望返回的元素数量,来返回元素集合中间位置的某些结果:

db.blog.posts.findOne(criteria, {"comments": {"$slice": [23, 10]}})

这个操作会跳过前23个元素,返回第24~33个元素。如果数组不够33个元素,则返回23个元素后面的所有元素。

2】新增

如果数组已经存在,"$push"会向已有的数组末尾加入一个元素,要是没有就创建一个新的数组。比如:

db.food.update(criteria, {"$push": {"$fruit": "strawberry"}})

这种一种比较简单的"$push"使用形式,也可以将它应用在一些比较复杂的数组操作中。使用"$each"子操作符,可以通过一次"$push"操作添加多个值。

db.food.update({"_id" : 3}, {"$push": {"fruit" : {"$each" : ["apricot", "grape"]}}})

如果希望数组的最大长度是固定的,那么可以将"$slice"和"$push"组合一起使用,这样就可以保证数组不会超出设定好的最大长度,这实际上就得到了一个最多包含N个元素的数组:

db.food.update({"_id" : 3}, {"$push": {"fruit" : {"$each" : ["apricot", "grape"], "$slice": -10} } })

这个例子会限制数组只包含最后加入的10个元素。"$slice"的值必须是负整数。

如果数组的元素数量小于10("$push"之后),那么所有元素都会保留。如果数组的元素数量大于10,那么只有最后的10个元素会保留。因此,"$slice"可以用来在文档中创建一个队列。

最后,可以在清理元素之前使用"$sort",只要向数组中添加子对象就需要清理,例如:

db.movies.update({"genre" :  "horror"}, {
	"$push": {
		"top10" : {
			"$each": [
				{"name": "Nightmare on Elm street", "rating": 5.5},
				{"name": "Saw", "rating": 4.3}
			],
			"$slice": -10,
			"$sort": {"rating": -1}
		} 
	} 
})

这样会根据"rating"字段的值对数组中的所有对象进行排序,然后保留前10个。注意,不能将"$slice"或者"$sort"与"$push"配合使用,且必须使用"$each"。

如果将数组作为数据集使用,保证数组内的元素不会重复,可以用"$addToSet"来实现,如:

db.food.update({"_id" : 3}, {"$addToSet": {"fruit" : "apricot"}})

将"$addToSet"和"$each"组合起来,可以添加多个不同的值,例如:

db.food.update({"_id" : 3}, { "$addToSet": { "fruit" : { "$each" : ["apricot", "grape"] } } })

3】修改

若数组有多个值,而我们只想对其中的一部分进行操作,就需要一些技巧。有两种方法操作数组中的值,通过位置或者定位操作符("#34;)

通过下标修改数组,如:

db.blog.update({"post" : "postId_1001"}, { "$inc": {"comments.0.votes": 1} })

但是很多情况下,不预先查询文档就不能知道要修改的数组的下标。为了克服这个困难,MongoDB提供了定位操作符"#34;,用来定位查询文档已经匹配的数组元素,并进行更新。例如:

db.blog.update({"comments.author" : "John"}, { "$set": {"comments.$.author": "Jim"} })

4】删除

有几个从数组中删除元素的方法。若是把数组看成队列或者栈,可以用"$pop",这个修改器可以从数组任何一端删除元素。{"$pop": {"key": 1}}从数组末尾删除一个元素,{"$pop": {"key": -1}}则从头部删除。

有时需要基于特定条件来删除元素,而不仅仅是依据元素的位置,这时可以使用"$pull"。例如:

db.food.update({"_id" : 3}, {"$pull": {"fruit" : "apricot"}})

"$pull"会将所有匹配的文档删除,而不只是删除一个。对数组[1 ,1, 2, 1]执行 pull 1,结果得到只有一个元素的数组 [2]。

三、关于内嵌文档数组的操作

demo订单数据:

{ 
    "total_goods_num" : 3, 
    "goods" : [
        {
            "amount" : 3, 
            "goods_code" : "100009464821", 
            "price" : { "$numberDecimal" : "9999.00" }, 
            "wait_num" : NumberInt(3), 
            "goods_id" : "1007"
        }, 
        {
            "amount" : 4, 
            "goods_code" : "100016079918", 
            "price" : { "$numberDecimal" : "5899.59" }, 
            "wait_num" : NumberInt(4), 
            "goods_id" : "1006"
        }, 
        {
            "amount" : 5, 
            "goods_code" : "100008699547", 
            "price" : { "$numberDecimal" : "4798.37" }, 
            "wait_num" : NumberInt(5), 
            "goods_id" : "1005"
        }
    ], 
    "bill_no" : "D20210712174", 
    "address" : {
        "province" : "安徽省", 
        "city" : "", 
		"area" : "", 
        "detail" : ""
    }, 
    "bill_status" : "1", 
    "pay_time" : ISODate("2022-10-05T03:19:34.506+0000"), 
    "total_money" : { "$numberDecimal" : "15496.33000" }, 
}

1】查询

1、直接使用嵌套字段查询

这样的匹配结果,只要数据组中有包含查询条件的数据,就会返回文档数据

db.getCollection("bill").find({ 'goods.goods_code': "100009464821" })

2、只返回匹配的嵌套数组数据

2.1:可以用$elemMatch操作符 (从mongodb 2.2开始支持)

2.2:可以用$操作符(从mongodb 2.2开始支持)

---- 使用$elemMatch操作符
db.bill.find(
{
   'goods.goods_code': "100009464821" 
},
{
    "goods": {$elemMatch:{"goods_code":"100009464821"}}
}
)

---- 使用$操作符
db.bill.find({'goods.goods_code': "100009464821"}, {_id: 0, 'goods.#39;: 1});

上面两个操作符,官方有这样的说明:the $elemMatch projection returns only the first matching element from the array。也就是说,只会返回匹配到的第一个数据元素。(操作符说明:
https://docs.mongodb.com/manual/reference/operator/projection/elemMatch/#proj._S_elemMatch

3、使用$filter对数组进行过滤:

3.1:$match中仅过滤主对象字段

3.2:将子对象过滤条件,放在$project中通过"$filter"进行过滤

3.3:若是$match中带着数组字段的查询,当数组没有符合条件的数据时,结果集不返回任何文档信息。当将数组过滤放在$project中通过$filter处理之后,就可以返回文档,而不符合条件的数组键标注的是一个空数组

db.erp_sales_order.aggregate([
 {
	"$match": {
		"$and": [
			{
			"order_id": "orde202209141279id"
			}
		]
	}
 },
 {
	"$project": {
		"perpetual_order": 1,
		"contract_code": 1,
		"erp_sales_order_product": {
			"$filter": {
				"input": "$erp_sales_order_product",
				"as": "erp_sales_order_product",
				"cond": {
					"$or": [
						 {
							"$eq": [
								"$erp_sales_order_product.product_detail_id",
								"espdi20220914331"
							]
						}
					]
				}
			}
		}
	}
 }
])

$filter与$elemMatch和$相比,会把匹配到的所有数组数据都返回。而且排除了不符合条件条件的文档数据。另外,若是数组中没有符合的元素,则返回一个空数组,保留了返回的键,而$elemMatch和$是不会返回键的。比如上面的查询,结果可能如下:

{ 
    "_id" : ObjectId("63218dcd768a5a421db1bfcd"), 
    "perpetual_order" : "0", 
    "contract_code" : "SCON2022081454", 
    "erp_sales_order_product" : []
}

erp_sales_order_product 没有符合条件的数据,仍然返回键

2】修改

1、使用$对数组进行更新

1.1:$操作符只会匹配修改第一条文档

db.bill.update(
{
    "bill_no" : "D20210623173",
    "goods.amount":  {'$gte':4 , '$lte':5}
}, 
{
"$set": {"goods.$.wait_num": 56} 
}
)

按照上面这条语句的查询,"goods.amount"符合条件的数据有2条,但是执行之后,只会更新第一条文档数据( "goods_id" : "1006"的文档)

2、使用arrayFilters对数组进行更新

2.1:设置 arrayFilters 修改嵌套数组中的一个或者多个元素

2.2:'goods.$[tt].wait_num'中的"$[tt]",其中"tt"相当于给元素起了一个别名,可以是任何字符串

2.3:在2.2的基础上,arrayFilters中的过滤操作,一定要跟起的别名字符串符合,比如:'tt.amount',否则就会修改失败

db.bill.updateMany(
{
    "bill_no" : "D20210623173"
},
{
    '$set': {
        'goods.$[tt].wait_num': 36
    }
},
{
	arrayFilters: [
		{'tt.amount': {'$gte':4 , '$lte':5}}
	]
}
)

假设将上面的执行语句调整一下,如下:

db.bill.updateMany(
{
    "bill_no" : "D20210623173"
},
{
    '$set': {
        'goods.$[tt].wait_num': 6
    }
},
{
	arrayFilters: [
		{'elem.amount': {'$gte':4 , '$lte':5}}
	]
}
)

执行之后,会有如下类似的报错:

2022-10-05T11:46:26.597+0800 E QUERY    [js] WriteError: No array filter found for identifier 'tt' in path 'goods.$[tt].wait_num' :

WriteError({
	"index" : 0,
	"code" : 2,
	"errmsg" : "No array filter found for identifier 'tt' in path 'goods.$[tt].wait_num'",
	"op" : {

		"q" : {
			"bill_no" : "D20210623173"
		},

		"u" : {

			"$set" : {
				"goods.$[tt].wait_num" : 6
			}

		},

		"multi" : true,

		"upsert" : false,

		"arrayFilters" : [

			{

				"elem.amount" : {
					"$gte" : 4,
					"$lte" : 5
				}

			}

		]

	}
})

3】删除

3.1:使用$pull操作符

db.bill.update(
{
    "bill_no" : "D20210623173"
}, 
{
"$pull": {"goods": { "amount":  {'$gte':4 , '$lte':5} }} 
}
)

相关推荐

MySQL进阶五之自动读写分离mysql-proxy

自动读写分离目前,大量现网用户的业务场景中存在读多写少、业务负载无法预测等情况,在有大量读请求的应用场景下,单个实例可能无法承受读取压力,甚至会对业务产生影响。为了实现读取能力的弹性扩展,分担数据库压...

Postgres vs MySQL_vs2022连接mysql数据库

...

3分钟短文 | Laravel SQL筛选两个日期之间的记录,怎么写?

引言今天说一个细分的需求,在模型中,或者使用laravel提供的EloquentORM功能,构造查询语句时,返回位于两个指定的日期之间的条目。应该怎么写?本文通过几个例子,为大家梳理一下。学习时...

一文由浅入深带你完全掌握MySQL的锁机制原理与应用

本文将跟大家聊聊InnoDB的锁。本文比较长,包括一条SQL是如何加锁的,一些加锁规则、如何分析和解决死锁问题等内容,建议耐心读完,肯定对大家有帮助的。为什么需要加锁呢?...

验证Mysql中联合索引的最左匹配原则

后端面试中一定是必问mysql的,在以往的面试中好几个面试官都反馈我Mysql基础不行,今天来着重复习一下自己的弱点知识。在Mysql调优中索引优化又是非常重要的方法,不管公司的大小只要后端项目中用到...

MySQL索引解析(联合索引/最左前缀/覆盖索引/索引下推)

目录1.索引基础...

你会看 MySQL 的执行计划(EXPLAIN)吗?

SQL执行太慢怎么办?我们通常会使用EXPLAIN命令来查看SQL的执行计划,然后根据执行计划找出问题所在并进行优化。用法简介...

MySQL 从入门到精通(四)之索引结构

索引概述索引(index),是帮助MySQL高效获取数据的数据结构(有序),在数据之外,数据库系统还维护者满足特定查询算法的数据结构,这些数据结构以某种方式引用(指向)数据,这样就可以在这些数据结构...

mysql总结——面试中最常问到的知识点

mysql作为开源数据库中的榜一大哥,一直是面试官们考察的重中之重。今天,我们来总结一下mysql的知识点,供大家复习参照,看完这些知识点,再加上一些边角细节,基本上能够应付大多mysql相关面试了(...

mysql总结——面试中最常问到的知识点(2)

首先我们回顾一下上篇内容,主要复习了索引,事务,锁,以及SQL优化的工具。本篇文章接着写后面的内容。性能优化索引优化,SQL中索引的相关优化主要有以下几个方面:最好是全匹配。如果是联合索引的话,遵循最...

MySQL基础全知全解!超详细无废话!轻松上手~

本期内容提醒:全篇2300+字,篇幅较长,可搭配饭菜一同“食”用,全篇无废话(除了这句),干货满满,可收藏供后期反复观看。注:MySQL中语法不区分大小写,本篇中...

深入剖析 MySQL 中的锁机制原理_mysql 锁详解

在互联网软件开发领域,MySQL作为一款广泛应用的关系型数据库管理系统,其锁机制在保障数据一致性和实现并发控制方面扮演着举足轻重的角色。对于互联网软件开发人员而言,深入理解MySQL的锁机制原理...

Java 与 MySQL 性能优化:MySQL分区表设计与性能优化全解析

引言在数据库管理领域,随着数据量的不断增长,如何高效地管理和操作数据成为了一个关键问题。MySQL分区表作为一种有效的数据管理技术,能够将大型表划分为多个更小、更易管理的分区,从而提升数据库的性能和可...

MySQL基础篇:DQL数据查询操作_mysql 查

一、基础查询DQL基础查询语法SELECT字段列表FROM表名列表WHERE条件列表GROUPBY分组字段列表HAVING分组后条件列表ORDERBY排序字段列表LIMIT...

MySql:索引的基本使用_mysql索引的使用和原理

一、索引基础概念1.什么是索引?索引是数据库表的特殊数据结构(通常是B+树),用于...