WITH (Common Table Expressions)

语法说明

公共表达式（CTE，common table expression），它是在单个语句的执行范围内定义的临时结果集，只在查询期间有效。它可以自引用，也可在同一查询中多次引用。作用是简化复杂的查询，提高代码的可读性和可维护性。公共表达式可以被视为一个临时视图，只在查询的执行周期内存在，对于外部查询是不可见的。

定义 CTE 后，可以像 SELECT，INSERT，UPDATE，DELETE 或 CREATE VIEW 语句一样引用它。

使用 WITH 从句指定通用表表达式，WITH 从句可以使用一个或多个逗号分隔。每个从句提供一个子查询，该子查询生成一个结果集，并将名称与子查询关联起来。

应用场景：

  • CTE 可以用于多个地方复用相同的子查询，避免重复编写相同的逻辑。
  • 可以用于简化递归查询，例如查找树形结构数据。
  • 可以将复杂的查询拆分为多个较小的部分，使查询逻辑更清晰易懂。

通用表表达式分为非递归和递归两种类型：

  • 非递归公共表达式：是指 CTE 中不引用自身的表达式，它只用于构建一次性的临时结果集，不涉及递归操作。

  • 递归公共表达式：是指 CTE 中引用自身的表达式，用于处理具有递归结构的数据，例如树形结构、图形等。递归 CTE 在定义中包含一个基本查询（起始条件），然后在该基本查询的结果上进行递归操作，直到满足停止条件为止。

非递归 CTE

语法结构

  1. WITH <query_name> AS (
  2.     <query_definition>
  3. )
  4. SELECT ... FROM <query_name>;

参数释义

  • <query_name>：为 CTE 结果集指定的临时名称。它可以是任何有效的标识符，类似于表名或列名。

  • <query_definition>：这是定义 CTE 结果集的查询语句。它可以是任何有效的 SELECT 查询，用于创建 CTE 的结果集。

  • SELECT ... FROM <query_name>：这是在 CTE 上执行的查询，你可以在这里使用 CTE 的名称。

递归 CTE

语法结构

  1. WITH RECURSIVE <query_name> AS (
  2.     <query_definition>
  3. )
  4. SELECT ... FROM <query_name>;

参数释义

  • WITH RECURSIVE：用于指示这是一个递归 CTE。

  • <query_name>：为递归 CTE 结果集指定的临时名称。它可以是任何有效的标识符，类似于表名或列名。

  • <query_definition>：这是定义递归 CTE 结果集的查询语句。它包含两部分：

    • 初始部分：定义了递归的起始条件和初始结果集。
    • 递归部分：定义了如何从初始结果集递归地生成下一轮的结果集。
  • SELECT ... FROM <query_name>：在递归 CTE 上使用递归 CTE 的名称进行查询。

递归 CTE 使用规则

锚定成员与递归成员

递归 CTE 必须包含至少两个查询定义，一个是锚定成员（anchor member），一个是递归成员（recursive member）。锚定成员必须位于第一个递归成员之前，可以定义多个锚定和递归成员。所有 CTE 查询定义都被视为锚定成员，除非它们引用 CTE 本身。

假设有一个名为 Employee 的表，包含员工的信息，其中包括 EmployeeID、Name 和 ManagerID 字段，表示员工的 ID、姓名和上级经理的 ID。我们可以使用递归 CTE 来查询员工及其下属的层级关系。

假设表中的数据如下：

EmployeeIDNameManagerID
1AliceNULL
2Bob1
3Charlie1
4David2
5Eve2
6Frank3

以下是使用递归 CTE 来查询员工及其下属的层级关系的示例：

  1. WITH RECURSIVE EmployeeHierarchy AS (
  2.     -- 锚定成员：查找顶层员工
  3.     SELECT EmployeeID, Name, ManagerID, 0 AS Level
  4.     FROM Employee
  5.     WHERE ManagerID IS NULL
  7.     UNION ALL
  9.     -- 递归成员：递归查询下属员工
  10.     SELECT e.EmployeeID, e.Name, e.ManagerID, eh.Level + 1
  11.     FROM Employee AS e
  12.     JOIN EmployeeHierarchy AS eh ON e.ManagerID = eh.EmployeeID
  13. )
  14. SELECT Name, Level
  15. FROM EmployeeHierarchy;

在上面的示例中：

  • 锚定成员选择顶层员工（ManagerID 为 NULL）并将其级别（Level）设置为 0。
  • 递归成员基于上一轮的结果（EmployeeHierarchy）查询下属员工，并将级别递增。
  • 查询最终使用 SELECT 从递归 CTE 中检索员工姓名和层级。

执行此查询后，将获得员工及其下属的层级关系信息，其中锚定成员和递归成员共同构成了递归查询的结构。非递归 CTE 用于创建临时的查询结果集，你只需要提供一个查询定义，然后在查询中引用这个 CTE，而无需关心锚定成员和递归成员的问题。

运算符与语句要求

  • 集合运算符：锚定成员必须使用集合运算符（如 UNION ALL、UNION、INTERSECT 或 EXCEPT）进行组合。只有在最后一个锚定成员与第一个递归成员之间，以及在组合多个递归成员时，允许使用 UNION ALL。

  • 列匹配：锚定成员和递归成员中的列数量必须相同。

  • 数据类型：递归成员中的列的数据类型必须与锚定成员中相应列的数据类型相匹配。

  • FROM 子句：递归成员的 FROM 子句只能一次引用 CTE expression_name。

  • 不支持的特性：在递归成员的 CTE_query_definition 中不允许使用某些特性，包括：

    • 使用 SELECT DISTINCT 关键字进行去重查询。
    • 使用 GROUP BY 对结果进行分组。
    • 使用 HAVING 筛选分组后的结果。
    • 进行标量聚合，即对一组行应用聚合函数（如 SUM、AVG 等）得到一个单一的值。
    • 使用 LEFT、RIGHT、OUTER JOIN 等外连接操作（但是 INNER JOIN 是允许的）。
    • 使用子查询。

示例

  • 非递归 CTE 示例：
  1. CREATE TABLE employees (
  2.     id INT PRIMARY KEY,
  3.     name VARCHAR(50),
  4.     salary INT
  5. );
  7. INSERT INTO employees (id, name, salary) VALUES
  8. (1, 'Alice', 50000),
  9. (2, 'Bob', 60000),
  10. (3, 'Charlie', 75000),
  11. (4, 'David', 55000),
  12. (5, 'Eve', 80000);
  14. -- 查找工资高于平均工资的员工
  15. mysql> WITH avg_salary AS (
  16.        SELECT AVG(salary) AS avg_salary FROM employees)
  17.        SELECT name, salary
  18.        FROM employees
  19.        JOIN avg_salary ON salary > avg_salary.avg_salary;
  20. +---------+--------+
  21. | name    | salary |
  22. +---------+--------+
  23. | Charlie |  75000 |
  24. | Eve     |  80000 |
  25. +---------+--------+
  26. 2 rows in set (0.00 sec)
  • 递归 CTE 示例：
  1. CREATE TABLE employees_hierarchy (
  2.     id INT PRIMARY KEY,
  3.     name VARCHAR(50),
  4.     manager_id INT
  5. );
  7. INSERT INTO employees_hierarchy (id, name, manager_id) VALUES
  8. (1, 'Alice', NULL),
  9. (2, 'Bob', 1),
  10. (3, 'Charlie', 1),
  11. (4, 'David', 2),
  12. (5, 'Eve', 2),
  13. (6, 'Frank', 3);
  15. -- 查找某个员工及其所有下属员工
  16. mysql> WITH RECURSIVE employee_hierarchy_cte (id, name, manager_id, level) AS (
  17.     SELECT id, name, manager_id, 0
  18.     FROM employees_hierarchy
  19.     WHERE name = 'Alice'
  20.     UNION ALL
  21.     SELECT e.id, e.name, e.manager_id, eh.level + 1
  22.     FROM employees_hierarchy AS e
  23.     JOIN employee_hierarchy_cte AS eh ON e.manager_id = eh.id
  24. )
  25. SELECT name, level
  26. FROM employee_hierarchy_cte;
  27. +---------+-------+
  28. | name    | level |
  29. +---------+-------+
  30. | Alice   |     0 |
  31. | Bob     |     1 |
  32. | Charlie |     1 |
  33. | David   |     2 |
  34. | Eve     |     2 |
  35. | Frank   |     2 |
  36. +---------+-------+
  37. 6 rows in set (0.00 sec)