mysql 8 开窗

在MySQL 8.0中，开窗函数是一种用于在查询结果集中执行计算的函数。它允许我们在不改变查询结果的情况下，对结果集中的行进行分组、排序和聚合操作。

下面是一个示例，演示如何在MySQL 8.0中使用开窗函数：

SELECT 
    customer_id,
    order_date,
    order_amount,
    ROW_NUMBER() OVER (PARTITION BY customer_id ORDER BY order_date) AS row_number,
    RANK() OVER (PARTITION BY customer_id ORDER BY order_amount DESC) AS rank
FROM
    orders;

在上面的示例中，我们使用了两个开窗函数：ROW_NUMBER()和RANK()。ROW_NUMBER()函数为每个客户ID分配一个行号，按照订单日期进行排序。RANK()函数为每个客户ID分配一个排名，按照订单金额进行降序排序。

通过使用PARTITION BY子句，我们可以将结果集分成不同的分区。在上面的示例中，我们按照customer_id进行分区。

相关问题

mysql的开窗函数

MySQL的开窗函数是一种用于在查询结果中执行分析和聚合操作的功能。它可以在查询结果集中创建一个窗口，并对窗口内的数据进行排序、排名、聚合等操作。

MySQL支持以下几种常见的开窗函数：
1. ROW_NUMBER()：为每一行分配一个唯一的序号。
2. RANK()：为每一行分配一个排名，相同值的行将获得相同的排名，下一个排名将被跳过。
3. DENSE_RANK()：为每一行分配一个排名，相同值的行将获得相同的排名，下一个排名不会被跳过。
4. NTILE()：将结果集划分为指定数量的桶，并为每个桶分配一个编号。
5. LAG()：获取当前行之前指定偏移量的行的值。
6. LEAD()：获取当前行之后指定偏移量的行的值。
7. FIRST_VALUE()：获取窗口内第一行的值。
8. LAST_VALUE()：获取窗口内最后一行的值。
9. SUM()、AVG()、MIN()、MAX()等聚合函数：可以与开窗函数一起使用，对窗口内的数据进行聚合操作。

使用开窗函数需要在查询语句中使用OVER子句，并指定窗口的排序方式、分区方式等。例如，以下是一个使用开窗函数计算销售额排名的示例查询：

SELECT
product_name,
sales_amount,
RANK() OVER (ORDER BY sales_amount DESC) AS rank
FROM
sales_data;

这个查询将返回每个产品的销售额以及对应的排名。

MYSQL 开窗函数

### 使用开窗函数在 MySQL 中实现累加

自 MySql 8.0 版本起引入了对开窗函数的支持，这使得执行复杂的分析操作变得更加简便。开窗函数允许在一个查询的结果集上定义窗口或分区，并在此基础上计算聚合值而不影响原始表的数据[^1]。

#### 基础语法结构
开窗函数的一般形式如下：

function_name([expression]) OVER ([partition_clause] [order_by_clause])

其中 `function_name` 是指支持作为开窗函数使用的特定 SQL 函数；`OVER()` 子句用于指定要应用此功能的数据范围以及排序方式。

#### 实际案例展示
考虑一个聊天记录表 (`chat_history`) 的场景，在这里想要获取每一对对话者之间最新的未读消息数量。可以利用 ROW_NUMBER() 这样的开窗函数来完成这一需求:

WITH RankedMessages AS (
    SELECT 
        from_id,
        to_id,
        msg,
        isRead,
        time,
        ROW_NUMBER() OVER(PARTITION BY from_id, to_id ORDER BY time DESC) as rn
    FROM chat_history
)
SELECT *
FROM RankedMessages
WHERE rn = 1 AND isRead = 0;

上述代码通过 PARTITION BY 对话双方 ID 创建分组，并按照时间降序排列每条消息，最后只保留每个会话里最新一条的消息并筛选出那些尚未被阅读过的项。

对于更早版本如 MySQL 5.7 并不支持这些特性，则需采用用户变量的方法模拟类似行为[^2]:

SELECT * FROM (
    SELECT 
        CASE WHEN @prev <> CONCAT(from_id,to_id) THEN @rn := 1 ELSE @rn := @rn + 1 END AS rownum,
        @prev := CONCAT(from_id,to_id),
        ch.*
    FROM chat_history ch,
         (SELECT @rn := 0, @prev := '') vars
    WHERE ...
    ORDER BY from_id, to_id, time DESC
) subq
WHERE rownum = 1;

这段脚本同样实现了按发信人和收件人的组合进行编号的功能，但是采用了不同的技术手段。