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

PostgreSQL递归遍历JSON字段【CTE】

liuian 2025-07-06 14:04 21 浏览

我最近遇到了一个有趣的挑战,试图使用 Postgres 来处理 JSON 树。 具体来说,我必须弄清楚如何在 Postgres 表中导航存储为 JSONB 的树结构。 我是这样做的。

推荐:用 NSDT设计器 快速搭建可编程3D场景。

1、实验环境搭建

让我们从定义模式开始。 我们将创建一个表,将组织结构图存储为 JSONB 对象:

CREATE TABLE org_charts (
  id    BIGSERIAL PRIMARY KEY,
  chart JSONB
);

接下来,让我们定义 JSON。 它将是员工节点的递归结构,其中包含包含员工直接下属的报告集合。 由于可以有多个级别的报告,我们的组织结构图可以任意深:

{
    "id": 1,
    "name": "Charles Montgomery Burns",
    "title": "Owner",
    "reports": [
        {
            "id": 2,
            "name": "Waylon Smithers, Jr."
        },
        {
            "id": 3,
            "name": "Inanimate carbon rod",
            "reports": [
                {
                    "id": 4,
                    "name": "Homer Simpson",
                    "title": "Safety Engineer"
                }
            ]
        },
        {
            "id": 5,
            "name": "Lenny Leonard"
        },
        {
            "id": 6,
            "name": "Carl Carlson"
        },
        {
            "id": 7,
            "name": "Frank Grimes",
            "status": "deceased"
        }
    ]
}

2、递归查询

我们想编写一个查询来遍历这棵树,例如,打印出所有员工的姓名。 为此,我们需要使用 Postgres 强大的递归公用表表达式 (CTE)。 递归 CTE 听起来很吓人,但实际上写起来相当简单。 这是我为此写的:

WITH RECURSIVE reports (id, json_element) AS (
  -- non recursive term
  SELECT
    id,
    chart
  FROM org_charts
 
  UNION
 
  -- recursive term
  SELECT
    id,
    CASE
    WHEN jsonb_typeof(json_element) = 'array'
      THEN jsonb_array_elements(json_element)
    WHEN jsonb_exists(json_element, 'reports')
      THEN jsonb_array_elements(json_element -> 'reports')
    END AS json_element
  FROM
    reports
  WHERE
    jsonb_typeof(json_element) = 'array' OR jsonb_typeof(json_element) = 'object'
)

让我们仔细分析一下。 查询开始于:

WITH RECURSIVE reports (id, json_element) AS (

在这里,我们声明了一个名为 reports 的递归 CTE,它有两个参数 id 和 json_element。 请注意,参数表示由整个查询以及内部子查询返回的列。

接下来,我们定义非递归项:

-- non recursive term
  SELECT
    id,
    chart
  FROM org_charts

这个查询告诉 Postgres 如何开始评估 CTE。 它首先被评估(并且只有一次),其结果驱动其余的查询。 请注意,此查询必须返回与 CTE 定义的列相匹配的两列(在本例中为 id 和 json_element)。

在非递归项之后,我们需要定义递归项:

-- recursive term
  SELECT
    id,
    CASE
    WHEN jsonb_typeof(json_element) = 'array'
      THEN jsonb_array_elements(json_element)
    WHEN jsonb_exists(json_element, 'reports')
      THEN jsonb_array_elements(json_element -> 'reports')
    END AS json_element
  FROM
    reports
  WHERE
    jsonb_typeof(json_element) = 'array' OR jsonb_typeof(json_element) = 'object'

这里有几点需要注意:

  • 此查询引用 CTE 本身(FROM 报告),这使得它可以递归。
  • 此查询还必须返回代表 id 和 json_element 的两列。
  • 必须使用 UNION 或 UNION ALL 组合非递归项和递归项的结果。

现在,让我们谈谈这个查询在做什么。 本质上,它是将嵌套的 JSON 结构展开成行。 如果遇到 JSON 数组,它会使用 jsonb_array_elements() 函数为每个成员创建一行。 如果它遇到包含报告集合的元素,它也会使用 jsonb_array_elements() 展开该元素。 最后,它只查看 JSON 数组或对象(而不是值或 NULL)。

3、查询结果

那么,我们实际上如何运行这个 CTE? 通过简单地将报告视为任何其他表:

SELECT * FROM reports;

运行上面的查询结果如下:

{
    "id": 1,
    "name": "Charles Montgomery Burns",
    "title": "Owner",
    "reports": [
        {
            "id": 2,
            "name": "Waylon Smithers, Jr."
        },
        {
            "id": 3,
            "name": "Inanimate carbon rod",
            "reports": [
                {
                    "id": 4,
                    "name": "Homer Simpson",
                    "title": "Safety Engineer"
                }
            ]
        },
        {
            "id": 5,
            "name": "Lenny Leonard"
        },
        {
            "id": 6,
            "name": "Carl Carlson"
        },
        {
            "id": 7,
            "name": "Frank Grimes",
            "status": "deceased"
        }
    ]
}
{
    "id": 2, 
    "name": "Waylon Smithers, Jr."
}
{
    "id": 3, 
    "name": "Inanimate carbon rod", 
    "reports": [
        {
            "id": 4, 
            "name": "Homer Simpson", 
            "title": "Safety Engineer"
        }
    ]
}
{
    "id": 5, 
    "name": "Lenny Leonard"
}
{
    "id": 6, 
    "name": "Carl Carlson"
}
{
    "id": 7, 
    "name": "Frank Grimes", 
    "status": "deceased"
}
NULL
{    
    "id": 4, 
    "name": "Homer Simpson", 
    "title": "Safety Engineer"
}

正如您在这里看到的,我们的查询为每个员工创建了一行加上一个 NULL。 老实说,我不确定为什么会返回 NULL 行(我尝试过但未能摆脱它)。 也就是说,很容易过滤掉 NULL 行。

要获取名称列表(这是我们最初的目标),我们可以这样做:

SELECT json_element -> 'name' AS employee_name
FROM reports
WHERE jsonb_exists(json_element, 'name');

这里我们只查看那些包含元素名称的行,然后返回名称的值:

employee_name
“Charles Montgomery Burns”
“Waylon Smithers, Jr.”
“Inanimate carbon rod”
“Lenny Leonard”
“Carl Carlson”
“Frank Grimes”
“Homer Simpson”

总的来说,使用 Postgres 递归 CTE 来导航 JSON 树被证明是一项具有挑战性但有益的练习。 如果你掌握了基础知识,那么构建复杂查询是相当简单的。


原文链接:
http://www.bimant.com/blog/postgres-json-traverse/

相关推荐

总结下SpringData JPA 的常用语法

SpringDataJPA常用有两种写法,一个是用Jpa自带方法进行CRUD,适合简单查询场景、例如查询全部数据、根据某个字段查询,根据某字段排序等等。另一种是使用注解方式,@Query、@Modi...

解决JPA在多线程中事务无法生效的问题

在使用SpringBoot2.x和JPA的过程中,如果在多线程环境下发现查询方法(如@Query或findAll)以及事务(如@Transactional)无法生效,通常是由于S...

PostgreSQL系列(一):数据类型和基本类型转换

自从厂子里出来后,数据库的主力就从Oracle变成MySQL了。有一说一哈,贵确实是有贵的道理,不是开源能比的。后面的工作里面基本上就是主MySQL,辅MongoDB、ES等NoSQL。最近想写一点跟...

基于MCP实现text2sql

目的:基于MCP实现text2sql能力参考:https://blog.csdn.net/hacker_Lees/article/details/146426392服务端#选用开源的MySQLMCP...

ORACLE 错误代码及解决办法

ORA-00001:违反唯一约束条件(.)错误说明:当在唯一索引所对应的列上键入重复值时,会触发此异常。ORA-00017:请求会话以设置跟踪事件ORA-00018:超出最大会话数ORA-00...

从 SQLite 到 DuckDB:查询快 5 倍,存储减少 80%

作者丨Trace译者丨明知山策划丨李冬梅Trace从一开始就使用SQLite将所有数据存储在用户设备上。这是一个非常不错的选择——SQLite高度可靠,并且多种编程语言都提供了广泛支持...

010:通过 MCP PostgreSQL 安全访问数据

项目简介提供对PostgreSQL数据库的只读访问功能。该服务器允许大型语言模型(LLMs)检查数据库的模式结构,并执行只读查询操作。核心功能提供对PostgreSQL数据库的只读访问允许L...

发现了一个好用且免费的SQL数据库工具(DBeaver)

缘起最近Ai不是大火么,想着自己也弄一些开源的框架来捣腾一下。手上用着Mac,但Mac都没有显卡的,对于学习Ai训练模型不方便,所以最近新购入了一台4090的拯救者,打算用来好好学习一下Ai(呸,以上...

微软发布.NET 10首个预览版:JIT编译器再进化、跨平台开发更流畅

IT之家2月26日消息,微软.NET团队昨日(2月25日)发布博文,宣布推出.NET10首个预览版更新,重点改进.NETRuntime、SDK、libraries、C#、AS...

数据库管理工具Navicat Premium最新版发布啦

管理多个数据库要么需要使用多个客户端应用程序,要么找到一个可以容纳你使用的所有数据库的应用程序。其中一个工具是NavicatPremium。它不仅支持大多数主要的数据库管理系统(DBMS),而且它...

50+AI新品齐发,微软Build放大招:拥抱Agent胜算几何?

北京时间5月20日凌晨,如果你打开微软Build2025开发者大会的直播,最先吸引你的可能不是一场原本属于AI和开发者的技术盛会,而是开场不久后的尴尬一幕:一边是几位微软员工在台下大...

揭秘:一条SQL语句的执行过程是怎么样的?

数据库系统能够接受SQL语句,并返回数据查询的结果,或者对数据库中的数据进行修改,可以说几乎每个程序员都使用过它。而MySQL又是目前使用最广泛的数据库。所以,解析一下MySQL编译并执行...

各家sql工具,都闹过哪些乐子?

相信这些sql工具,大家都不陌生吧,它们在业内绝对算得上第一梯队的产品了,但是你知道,他们都闹过什么乐子吗?首先登场的是Navicat,这款强大的数据库管理工具,曾经让一位程序员朋友“火”了一把。Na...

详解PG数据库管理工具--pgadmin工具、安装部署及相关功能

概述今天主要介绍一下PG数据库管理工具--pgadmin,一起来看看吧~一、介绍pgAdmin4是一款为PostgreSQL设计的可靠和全面的数据库设计和管理软件,它允许连接到特定的数据库,创建表和...

Enpass for Mac(跨平台密码管理软件)

还在寻找密码管理软件吗?密码管理软件有很多,但是综合素质相当优秀且完全免费的密码管理软件却并不常见,EnpassMac版是一款免费跨平台密码管理软件,可以通过这款软件高效安全的保护密码文件,而且可以...