您现在的位置是：测试开发营 > 电脑教程

如何在 ES 中实现嵌套json对象查询，一次讲明白！

测试开发营2025-11-26 20:46:46【电脑教程】3人已围观

简介一、简介实际的软件项目开发过程中，因为业务上的需要，我们的数据库表与表之间的结构是一对多的关系，以订单表与订单项表为例，在 mysql 数据库里面，他们的关系如下图：如果我们想查询哪些商品在某个时间段

一、实现简介

实际的嵌套软件项目开发过程中，因为业务上的对象需要，我们的查询次讲数据库表与表之间的结构是一对多的关系，以订单表与订单项表为例，明白在 mysql 数据库里面，实现他们的嵌套关系如下图：

如果我们想查询哪些商品在某个时间段内被购买过，可以通过如下join连表的对象方式进行查询。

复制select t.*from

tb_order t

left join tb_order_item tt on 查询次讲t.order_id = tt.order_idwhere tt.product_name like %商品名称%and t.createTime >= 2022-06-01 00:00:00and t.createTime <= 2022-06-16 00:00:00;1.2.3.4.5.6.

然后，免费模板ElasticsSearch 和大多数 NoSQL 数据库类似，明白是实现扁平化的存储结构，不能像关系型数据库那样，嵌套可以通过join方式进行连表搜索。对象

不过 ElasticsSearch （以下简称 ES）目前毕竟发展到 8.x 版本了，查询次讲已经有几种可选的明白方式能够高效的支持这种一对多关系的映射和搜索。

比较常用的实践方案，有以下三种：

嵌套对象嵌套文档父子文档

其中第二种，是我们今天要重点介绍的香港云服务器部分，废话也不多说了，下面我们一起以实际案例的方式给大家讲解具体的实践思路。

二、案例实践

2.1 、嵌套对象

所谓嵌套对象，就是当前json对象内嵌了一个json对象，以订单数据为例，包含多个订单项数据，格式如下：

复制{ "orderId":"1", "orderNo":"123456", "orderUserName":"张三", "orderItems":[ { "orderItemId":"12234", "orderId":"1", "productName":"火腿肠", "brandName":"双汇", "sellPrice":"28" }, { "orderItemId":"12235", "orderId":"1", "productName":"果冻", "brandName":"汇源", "sellPrice":"12" } ]}1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.

创建一个order_index的索引，我们将上面的文档数据存储到 ES 中，服务器租用看看索引文档结构的mapping长啥样，内容如下：

复制{ "order_index":{ "mappings":{ "_doc":{ "properties":{ "orderId":{ "type":"keyword" }, "orderNo":{ "type":"keyword" }, "orderUserName":{ "type":"keyword" }, "orderItems":{ "properties":{ "orderItemId":{ "type":"keyword" }, "orderId":{ "type":"keyword" }, "productName":{ "type":"keyword" }, "brandName":{ "type":"keyword" }, "sellPrice":{ "type":"keyword" } } } } } } }}1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.27.28.29.30.31.32.33.34.35.36.37.38.

可以很清晰的看到，订单索引映射字段里面，包含了一个orderItems的字段，它是对象类型，内部有自己的字段属性。这其实就是一个包含关系，表示一个订单可以有多个订单项信息。

我们可以查询下索引结果集看看结果，使用postman执行查询索引下的高防服务器所有文档数据！

复制

POST order_index/

_search

{ "query": { "match_all": { } }}1.2.3.4.5.6.7.

返回结果如下（去掉了部分非重要的数据，方便观察）：

复制[ { "_index":"order_index", "_type":"_doc", "_id":"1", "_score":1, "_source":{ "orderId":"1", "orderNo":"123456", "orderUserName":"张三", "orderItems":[ { "orderItemId":"12234", "orderId":"1", "productName":"火腿肠", "brandName":"双汇", "sellPrice":"28" }, { "orderItemId":"12235", "orderId":"1", "productName":"果冻", "brandName":"汇源", "sellPrice":"12" } ] } }]1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.27.28.29.

可以很清晰的看到，返回结果也是完美呈现，orderItems其实是个list ，包含两个对象，所有的信息都在一个文档中。

我们再来试试在 ES 中通过商品名称和品牌名称，两个并集的条件筛选，来查询客户的亿华云订单信息，编写DSL查询语句，搜索商品名称为火腿肠并且品牌为汇源的订单，内容如下：

复制POST order_index/

_search

{ "query":{ "bool":{ "must":[ { "match":{ "orderItems.productName":"火腿肠" } }, { "match":{ "orderItems.brandName":"汇源" } } ] } }}1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.

返回结果如下（去掉了部分非重要的数据，方便观察）：

从预计结果上分析，没有客户购买过品牌名称为汇源并且商品名称为火腿肠的订单，理论上，应该是无任何数据的！

但是，结果却返回有这条订单数据！模板下载这是为什么呢？

原来 ES 对于json对象数组的做了压扁处理，比如上面的例子在 ES 存储的结构是这样的：

复制{ "orderId": [ 1 ], "orderItems.productName":["火腿肠","果冻"], "orderItems.brandName": ["双汇","汇源"],

...

}1.2.3.4.5.6.

很明显，这样的结构丢失了商品名称和品牌名称的关联，导致查询的时候，出现失效，如果业务要求实现精准搜索，那么这种方案是不满足要求的。

如果你的业务场景对这个问题不是敏感，就可以选择这种方式，因为它足够简单并且效率也比下面要介绍的两种方案高。

2.2、嵌套文档

很明显上面对象数组的方案没有处理好内部对象的边界问题，JSON数组对象被 ES 强行存储成扁平化的键值对列表。为了解决这个问题，ES 推出了一种所谓的嵌套文档的方案，官方对这种方案的介绍是这样的：

The nested type is a specialised version of the object datatype that allows arrays of objects to be indexed in a way that they can be queried independently of each other.

可以看到嵌套文档的方案其实是对普通内部对象方案的补充。我们将上面的订单索引结构中的orderItems数据类型，将其改成nested类型，重新创建索引。

复制{ "properties":{ "orderItems":{ "properties":{

....

}, "type":"nested" }

....

}}1.2.3.4.5.6.7.8.9.10.11.

orderItems数据类型，改成是nested，表示是个内嵌文档，其它的属性保持不变。

我们再来试试通过商品名称和品牌名称来查询客户的订单信息，**不同的地方在于，在查询的时候，需要指定nested关键字和路径path** ，查询姿势如下：

复制POST order_index/

_search

{ "query":{ "nested":{ "path":"orderItems", "query":{ "bool":{ "must":[ { "match":{ "orderItems.productName":"火腿肠" } }, { "match":{ "orderItems.brandName":"汇源" } } ] } } } }}1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.

查询结果为空[] ，与预期结果一致！

我们再将查询条件换一下，查询商品名称为火腿肠和品牌名称为双汇的订单。

复制POST order_index/

_search

{ "query":{ "nested":{ "path":"orderItems", "query":{ "bool":{ "must":[ { "match":{ "orderItems.productName":"火腿肠" } }, { "match":{ "orderItems.brandName":"双汇" } } ] } } } }}1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.

查询结果如下：

与预期的结果一致，说了这么多，似乎嵌套文档很好用啊。没有前面那个方案对象边界缺失的问题，用起来似乎也不复杂。那么它没有缺点吗？当然，我们先来做个试验。

先看看当前索引的文档数量。

复制GET _cat/indices?v1.

查询结果。

复制green open order_index FJsEIFf_QZW4Q4SlZBsqJg 1 1 3 0 17.7kb 8.8kb1.

你可能已经注意到我这里查看文档数量并不是用的下面这个。

复制GET order_index/_count1.

而是直接查看的索引信息，他们的区别在于：

第一个查询，是查询索引库里面每个索引总的文档数。

第二个查询，是查询当前索引的文档数，不包括嵌套文档数量。

可以很清晰的看到，order_index索引，在 ES 中总的文档数据是 3 ，为啥不是 1 呢？

这是因为nested子文档在 ES 内部其实也是独立的 lucene 文档，只是我们在查询的时候，ES 内部帮我们做了类似数据库的join处理。最终看起来好像是一个独立的文档一样。

如果一个订单，有1000个订单项，那么在 ES 中存在的文档数就是1001，会随着订单数的增加而成倍上升。

那可想而知，同样的条件下，这个性能肯定不如普通内部对象的方案。在实际的业务应用中要根据实际情况决定是否选择这种方案。

有一点是可以肯定的是，他能满足内部对象数据精准搜索的要求！

2.3、父子文档

我们还是看上面那个例子，假如我需要更新文档的orderNo属性的值，ES 对于文档的更新，操作原理是：把原来的数据删掉，再重新插入一条，但索引 id 是相同的。

这就意味，即使orderItems字段，我不需要更新，它也会随着主文档一起被重新索引。

还有就是如果某个表跟某个表有多对多的关系，比如一个子文档可以属于多个主文档的场景，用nested无法实现，此时可以考虑采用父子文档结构来处理。

下面我们以考试题为例，一个问题可能有多个答案，一个答案可能对应多个问题。

首先我们定义索引文档结构，如下：

复制PUT exam_index

{ "mappings":{ "_doc":{ "properties":{ "my_id":{ "type":"keyword" }, "parent_join_child":{ "type":"join", "relations":{ "question":"answer" } } } } }}1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.

my_id是自定义的字段，parent_join_child是给我们的父子文档关系的名字，这个可以自定义，join表示这是一个父子文档关系，relations里面表示question是父，answer是子。

首先我们插入两个父文档。

复制PUT exam_index/_doc/1{ "my_id":"1", "text":"这是一个问题1", "parent_join_child":{ "name":"question" }}PUT exam_index/_doc/2{ "my_id":"2", "text":"这是一个问题2", "parent_join_child":{ "name":"question" }}1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.

其中"name":"question"表示插入的是父文档。

然后插入两个子文档。

复制PUT exam_index/_doc/3?routing=1{ "my_id":"3", "text":"这是一个回答1，对应问题1", "parent_join_child":{ "name":"answer", "parent":"1" }}PUT exam_index/_doc/4?routing=1{ "my_id":"4", "text":"这是一个回答2，对应问题1", "parent_join_child":{ "name":"answer", "parent":"1" }}1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.

子文档要解释的东西比较多，首先从文档id我们可以判断子文档都是独立的文档（跟nested不一样）。其次routing关键字指明了路由的id是父文档1 ，这个id和下面的parent关键字对应的id是一致的。

需要强调的是，索引子文档的时候，routing是必须的，因为要确保子文档和父文档在同一个分片上。

"name":"answer"关键字指明了这是一个子文档。

现在exam_index索引中有四个独立的文档，我们来看父子文档在搜索的时候是什么姿势。

先来一个无条件查询，返回所有的文档数据。

复制POST exam_index/

_search

{ "query":{ "match_all":{ } }, "sort":["my_id"]}1.2.3.4.5.6.7.8.

返回的结果如下：

复制[ { "_index":"crm_exam_index", "_type":"_doc", "_id":"1", "_score":null, "_source":{ "my_id":"1", "text":"这是一个问题1", "parent_join_child":{ "name":"question" } } }, { "_index":"crm_exam_index", "_type":"_doc", "_id":"2", "_score":null, "_source":{ "my_id":"2", "text":"这是一个问题2", "parent_join_child":{ "name":"question" } } }, { "_index":"crm_exam_index", "_type":"_doc", "_id":"3", "_score":null, "_routing":"1", "_source":{ "my_id":"3", "text":"这是一个回答1，对应问题1", "parent_join_child":{ "name":"answer", "parent":"1" } } }, { "_index":"crm_exam_index", "_type":"_doc", "_id":"4", "_score":null, "_routing":"1", "_source":{ "my_id":"4", "text":"这是一个回答2，对应问题1", "parent_join_child":{ "name":"answer", "parent":"1" } } }]1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.27.28.29.30.31.32.33.34.35.36.37.38.39.40.41.42.43.44.45.46.47.48.49.50.51.52.53.54.55.56.57.58.

可以看到返回的结果带了parent_join_child关键字，指明这是个父文档还是子文档。

如果我们想通过子文档信息，查询父文档，可以通过如下方式实现：

复制POST exam_index/

_search

{ "query":{ "has_child":{ "type":"answer", "query":{ "match":{ "text":"回答" } } } }}1.2.3.4.5.6.7.8.9.10.11.12.13.14.

返回结果：

复制[ { "_index":"exam_index", "_type":"_doc", "_id":"1", "_score":1, "_source":{ "my_id":"1", "text":"这是一个问题1", "parent_join_child":{ "name":"question" } } }]1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.

如果我们想通过父文档信息，查询子文档，可以通过如下方式实现：

复制POST exam_index/

_search

{ "query":{ "has_parent":{ "parent_type":"question", "query":{ "match":{ "text":"问题" } } } }}1.2.3.4.5.6.7.8.9.10.11.12.13.14.

返回结果：

复制[ { "_index":"crm_exam_index", "_type":"_doc", "_id":"3", "_score":1, "_routing":"1", "_source":{ "my_id":"3", "text":"这是一个回答1 ，对应问题1", "parent_join_child":{ "name":"answer", "parent":"1" } } }, { "_index":"crm_exam_index", "_type":"_doc", "_id":"4", "_score":1, "_routing":"1", "_source":{ "my_id":"4", "text":"这是一个回答2，对应问题1", "parent_join_child":{ "name":"answer", "parent":"1" } } }]1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.27.28.29.30.31.32.

如果我们想通过父 ID 查询子文档，可以通过如下方式实现：

复制POST exam_index/

_search

{ "query":{ "parent_id":{ "type":"answer", "id":"1" } }}1.2.3.4.5.6.7.8.9.10.

返回结果和上面一样，区别在于parent_id搜索默认使用相关性算分，而has_parent默认情况下不使用算分。

使用父子文档的模式有一些需要特别关注的点：

每一个索引只能定义一个join field。父子文档必须在同一个分片上，意味着查询，更新操作都需要加上routing。可以向一个已经存在的join field上新增关系。父子文档，适合那种数据结构基本一致的场景，如果两个表结构完全不一致，不建议使用这种结构。父子文档也有缺点，查询速度是这三个方案里面最慢的一个。