MySql实现ROW_NUMBER()开窗函数

本文咱们使用mysql实现开窗函数row_number() over (partition by xxx,xxx order by xxx),废话不多说,直接开干

准备数据
select * from test_biz_policy_policy;
platform_id(平台id) publish_time(政策发布时间) policy_name(政策名称)
2 2019-04-01 15:11:06 test0
2 2019-04-01 19:11:06 test9
2 2019-04-01 19:11:06 test8
2 2019-04-01 18:11:06 test7
2 2019-04-01 15:11:06 test1
2 2019-04-01 15:11:06 test2
2 2019-04-01 16:11:06 test3
2 2019-04-01 16:11:06 test4
2 2019-04-01 16:11:06 test5
2 2019-04-01 17:11:06 test6
8 2019-04-02 19:17:31 fengyu
8 2019-04-02 19:17:31 新建政策1111111
8 2019-04-02 19:17:31 1218测试
8 2019-04-02 19:17:31 xxx
8 2019-04-02 19:17:31 ccc
8 2019-04-02 19:17:31 测试114
8 2019-04-02 19:17:31 测试mmm
8 2019-04-02 19:17:31 k k k k k k k
8 2019-04-02 19:17:31 k k k k k k k明明
8 2019-04-02 19:17:31 ceshi111
需求

简而言之,就是以「平台id」,「政策发布时间」分组,根据「政策名称」进行排序,取政策前三名。

代码
SELECT
    t.platform_id,
    t.publish_time,
    t.policy_name,
    t.rank_no 
FROM
    (
    SELECT
        a.platform_id,
        a.publish_time,
        a.policy_name,
    IF
        (
            @str1 = a.platform_id 
            AND @str2 = a.publish_time,
            @rank := @rank + 1,
            @rank := 1 
        ) AS rank_no,
        @str1 := a.platform_id,
        @str2 := a.publish_time 
    FROM
        (
        SELECT
            platform_id,
            publish_time,
            policy_name 
        FROM
            test_biz_policy_policy 
        ORDER BY
            platform_id,
            publish_time,
            policy_name ASC 
        ) a,
        (
        SELECT
            @str1 := 0,
            @str2 := NULL,
            @rank := 0 
        ) tmp 
    ) t 
WHERE
    t.rank_no <= 5
结果
platform_id(平台id) publish_time(政策发布时间) policy_name(政策名称)
2 2019-04-01 15:11:06 test0
2 2019-04-01 15:11:06 test1
2 2019-04-01 15:11:06 test2
2 2019-04-01 16:11:06 test3
2 2019-04-01 16:11:06 test4
2 2019-04-01 16:11:06 test5
2 2019-04-01 17:11:06 test6
2 2019-04-01 18:11:06 test7
2 2019-04-01 19:11:06 test8
2 2019-04-01 19:11:06 test9
8 2019-04-02 19:17:31 1218测试
8 2019-04-02 19:17:31 ccc
8 2019-04-02 19:17:31 ceshi111
8 2019-04-02 19:17:31 fengyu
8 2019-04-02 19:17:31 k k k k k k k
总结

从上面的结果看来,需求已实现。

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 窗口函数是 SQL2003 标准才开始有的一系列 SQL 函数,用于应付一些复杂运算是比较方便。但是普遍使用的 M...
    小黄鸭呀阅读 5,502评论 0 0
  • pyspark.sql模块 模块上下文 Spark SQL和DataFrames的重要类: pyspark.sql...
    mpro阅读 13,150评论 0 13
  • 这一周主要学习了 Hive 的一些基础知识,学习了多个 Hive 窗口函数,虽然感觉这些窗口函数没有实际的应用...
    大石兄阅读 7,796评论 2 8
  • 分析函数,也称为窗口函数,通常被认为仅对数据仓库SQL有用。使用分析函数的查询,基于对数据行的分组来计算总量值。与...
    猫猫_tomluo阅读 8,654评论 3 18
  • 杉乡神韵 文/龙行空 移动历史的坐标 那繁荣的木材时代 似乎是 定格的辉煌| 春风仍旧不减当年 一个 演绎生命的绿...
    游离尘埃阅读 1,859评论 9 32