简介

窗口函数（window functions），也叫分析函数和OLAP函数，MySQL在8.0之后开始支持窗口函数。窗口函数可以用来对数据进行实时分析处理，和group by有类似之处，其区别在于窗口会对每个分组之后的数据按行进行分别操作，而group by一般对分组之后的函数使用聚合函数汇总，做不到对不同的group中的行数据进行分别操作。这就简单介绍几种常见的MySQL窗口函数。下表中列出了几种常见的窗口函数，并对其基本功能进行了描述。接下来我们会以一段示例，来展示MySQL中窗口函数的用途和效果。

数据准备

假设我们存在一张如下的员工工资表，接下来我们将以这张表对窗口函数的使用方法进行简单的演示。

DROP TABLE employee;CREATE TABLE IF NOT EXISTS employee
(
    emp_no       varchar(32)   comment '员工id',
    emp_name     varchar(32)   comment '员工姓名',
    dept_name    varchar(32)   comment '部门名', 
    hire_date    date          comment '入职日期',
    salary       double        comment '薪资')ENGINE=InnoDB DEFAULT CHARSET=utf8;insert into employeevalues ('1001', '刘备', '蜀国', '2021-11-01', 1000);insert into employeevalues ('1002', '关羽', '蜀国', '2021-11-02', 5000);insert into employeevalues ('1003', '张飞', '蜀国', '2021-11-04', 7000);insert into employeevalues ('1004', '赵云', '蜀国', '2021-11-03', 7000);insert into employeevalues ('1006', '黄忠', '蜀国', '2021-11-06', 4000);insert into employeevalues ('1007', '孙权', '吴国', '2021-11-07', 4000);insert into employeevalues ('1008', '周瑜', '吴国', '2021-11-05', 8000);insert into employeevalues ('1009', '黄盖', '吴国', '2021-11-02', 6000);insert into employeevalues ('1010', '曹操', '魏国', '2021-11-01', 2000);insert into employeevalues ('1011', '许褚', '魏国', '2021-11-07', 3000);insert into employeevalues ('1012', '典韦', '魏国', '2021-11-05', 5000);insert into employeevalues ('1013', '张辽', '魏国', '2021-11-04', 6000);

语法及示例

  窗口函数的语法如下，所有的窗口函数均遵循以下语法：

function (expression) 
OVER (
  [ PARTITION BY expr_list ]
  [ ORDER BY order_list 
    [ frame_clause ] 
  ] 
)

其中frame_clause语法如下。

ROWS{ UNBOUNDED PRECEDING | unsigned_value PRECEDING | CURRENT ROW } |
{BETWEEN{ UNBOUNDED PRECEDING | unsigned_value { PRECEDING | FOLLOWING } |
CURRENT ROW}
AND
{ UNBOUNDED FOLLOWING | unsigned_value { PRECEDING | FOLLOWING } |
CURRENT ROW }}

接下来我们将展示一些场景的窗口函数的用法和效果。

1.ROW_NUMBER()、RANK()、DENSE_RANK()、NTILE()

• ROW_NUMBER()：主要用于对当前窗口内的数据，按照分区进行和排序规则生成行号。这里的行号是不重复，连续且递增的。

• RANK()：主要用于对当前窗口内的数据，按照分区进行和排序规则生成序号。这里的序号是可重复且不连续的，即如果有两行的数据一样，那么它们将具有一样的Rank值，而下一个不同的值的需要将从当前已有的行数开始算起，即类似于1，2，2，4，4，4，7...这种。

• DENSE_RANK()：主要用于对当前窗口内的数据，按照分区进行和排序规则生成序号。这里的序号是可重复且连续的，即如果有两行的数据一样，那么它们将具有一样的Rank值，而下一个不同的值的需要将从当前的Rank值开始算起，即类似于1，2，2，3，3，3，4...这种。

• NTILE()：将分区中的有序数据分为n个等级，记录等级序号。

示例:对所有员工按照薪资降序排序，并给出对应的row_number、rank和dense_rank的排名

SELECT 
    emp_no,
    emp_name,
    dept_name,
    salary,
    ROW_NUMBER() over (ORDER BY salary DESC) as rowNumber,    RANK() OVER(ORDER BY salary DESC) as rankNumber,    DENSE_RANK() OVER(ORDER BY salary DESC) as denseNumberFROM employee e;

示例:对每个部门的员工按照薪资降序排序，并给出对应的row_number、rank和dense_rank的排名

SELECT 
    emp_no,
    emp_name,
    dept_name,
    salary,
    ROW_NUMBER() over (PARTITION BY dept_name ORDER BY salary DESC) as rowNumber,    RANK() OVER(PARTITION BY dept_name ORDER BY salary DESC) as rankNumber,    DENSE_RANK() OVER(PARTITION BY dept_name ORDER BY salary DESC) as denseNumberFROM employee e;

示例:对所有员工按照薪资降序排序，并给出对应的row_number、rank和dense_rank的排名，最终结果按照员工号进行排序输出。

SELECT 
    emp_no,
    emp_name,
    dept_name,
    salary,
    ROW_NUMBER() over (ORDER  BY salary desc) as rowNumber,    RANK() OVER(ORDER BY salary desc) as rankNumber,    DENSE_RANK() OVER(ORDER BY salary desc) as denseNumberFROM employee eORDER  BY emp_no

示例:找出每个部门工资最高的人。

-- 找出每个部门工资最高的人。SELECT 
    emp_no,
    emp_name,
    dept_name,
    salary  
FROM ( 
    SELECT 
        emp_no,
        emp_name,
        dept_name,
        salary,        DENSE_RANK() OVER (PARTITION BY dept_name ORDER BY salary DESC) AS dr    FROM employee e
) rWHERE r.dr <= 1

示例:a.将所有员工按照工资递增的顺序分成4组。b.根据员工入职日期升序分成7组。

SELECT 
    emp_no,
    emp_name,
    dept_name,
    salary,
    hire_date,
    NTILE (4) OVER(ORDER BY salary) AS 4_tile,
    NTILE (7) OVER(ORDER BY hire_date) AS 7_tileFROM employee e;

2.聚合窗口函数

• SUM()：用于计算当前窗口内，累计到当前行的列的和，类似于running total的概念。

• AVG()：对sum（）的结果求平均。

示例:获取每个部门，按工资从低到高得累计和。

SELECT 
    emp_no,
    emp_name,
    dept_name,
    salary,    SUM(salary) OVER(PARTITION BY dept_name ORDER BY salary) AS totalFROM employee e;

示例:获取每个部门得工资累计和。

SELECT 
    emp_no,
    emp_name,
    dept_name,
    salary,    SUM(salary) OVER(PARTITION BY dept_name) AS totalFROM employee e;

示例:获取整个公司的薪资按照薪资递增的累计和。

SELECT 
    emp_no,
    emp_name,
    dept_name,
    salary,    SUM(salary) OVER(ORDER BY salary) AS totalFROM employee e;

示例:获取整个公司的薪资按照薪资递增的前两行和后一行范围内的薪资和。

SELECT 
    emp_no,
    emp_name,
    dept_name,
    salary,    SUM(salary) OVER(ORDER BY salary 
    ROWS BETWEEN 2 PRECEDING AND 1 FOLLOWING) AS totalFROM employee e;

示例:每个部门的平均工资。

SELECT 
    emp_no,
    emp_name,
    dept_name,
    salary,    AVG(salary) OVER(PARTITION BY dept_name) AS avgFROM employee e;

示例:获取整个公司的薪资按照薪资递增的前两行和后一行范围内的薪资平均值。

SELECT 
    emp_no,
    emp_name,
    dept_name,
    salary,    AVG(salary) OVER(ORDER BY salary 
    ROWS BETWEEN 2 PRECEDING AND 1 FOLLOWING) AS avgFROM employee e;

3. CUME_DIST()、PERCENT_RANK()

• CUME_DIST()：分组内小于、等于当前rank值的行数 / 分组内总行数

• PERCENT_RANK()：每行按照公式(rank - 1) / (rows - 1)进行计算。其中，rank为RANK()函数产生的序号，rows为当前窗口的记录总行数。

示例:根据薪资排序，获取CUME_DIST()和PERCENT_RANK()

SELECT 
    emp_no,
    emp_name,
    dept_name,
    salary,    CUME_DIST() OVER(ORDER BY salary ) AS cd1,    PERCENT_RANK() OVER(ORDER BY salary) AS cd2FROM employee e;

4.LAG()、LEAD()

• LAG()：获取第前N行的值，如果不存在的话，可以指定默认值，若不指定默认值，则为null。

• LEAD()：获取第后N行的值，如果不存在的话，可以指定默认值，若不指定默认值，则为null。

示例:a. 获取每个人入职前一行的数据，默认值为"2021-01-01";b. 获取每个人入职前两行的数据，不设置默认值;c. 获取每个人入职后一行的数据，默认值为"2022-01-01";d. 获取每个人入职后两行的数据，不设置默认值;

SELECT 
    emp_no,
    emp_name,
    dept_name,
    hire_date,
    LAG (hire_date, 1, '2021-01-01') OVER(ORDER BY hire_date) AS next_1_time,
    LAG (hire_date, 2) OVER(ORDER BY hire_date) AS next_2_time,    LEAD (hire_date, 1, '2022-01-01') OVER(ORDER BY hire_date) AS last_1_time,    LEAD (hire_date, 2) OVER(ORDER BY hire_date) AS last_2_timeFROM employee e;

5.FIRST_VALUE ()、LAST_VALUE() 、NTH_VALUE()

• FIRST_VALUE()：获取其分区内指定列的第一行的值

• LAST_VALUE()：获取其分区内指定列的最后一行的值

• NTH_VALUE()：获取其分区内指定列的第N行的值

示例:a. 按照入职日期顺序排序，找出当前每个部门最先入职的人的薪资。b. 按照入职日期顺序排序，找出当前每个部门最后入职的人的薪资。

SELECT 
    emp_no,
    emp_name,
    dept_name,
    salary,
    hire_date,    FIRST_VALUE (salary) OVER(PARTITION BY dept_name ORDER BY hire_date) AS first,    LAST_VALUE (salary) OVER(PARTITION BY dept_name ORDER BY hire_date) AS lastFROM employee e;

示例:a.获取截至当前工资第二高的人的工资。b.获取第二个入职的人的工资。

SELECT 
    emp_no,
    emp_name,
    dept_name,
    salary,
    hire_date,    NTH_VALUE (salary, 2) OVER(ORDER BY salary) AS 2_th,    NTH_VALUE (salary, 2) OVER(ORDER BY hire_date) AS 3_thFROM employee e;