1. 为什么你需要掌握dense_rank()函数记得去年我接手一个电商平台的用户活跃度分析项目当时需要给平台上的百万用户做活跃度排名。最初我用的是简单的order by配合limit结果发现当大量用户活跃度相同时排名结果完全不符合业务需求——第100名的用户实际活跃度可能和第50名一样。这时候我才意识到**dense_rank()**这个看似简单的窗口函数在真实业务场景中能解决大问题。dense_rank()是SQL中的一种窗口函数它最大的特点就是处理并列排名时不会跳过后续名次。举个例子如果有3个用户并列第一那么下一个用户会是第二名而不是第四名。这种密集排名的特性在销售业绩排名、学生成绩统计、竞赛结果计算等场景中特别实用。与它类似的还有rank()和row_number()函数三者的区别其实很直观row_number()不管数值是否相同都给连续编号1,2,3,4...rank()相同数值给相同排名但会跳过后续名次1,1,3,4...dense_rank()相同数值给相同排名且不跳名次1,1,2,3...在实际业务中我发现dense_rank()的使用频率远高于其他两个特别是在需要公平展示排名的场景。比如销售团队的业绩榜单如果两个销售并列第一用rank()会让第三名显示为第三而dense_rank()会让他显示为第二——后者显然更符合业务直觉。2. MySQL中的dense_rank()实战技巧2.1 基础用法与性能陷阱在MySQL 8.0版本中dense_rank()的使用语法很直观SELECT employee_name, sales_amount, DENSE_RANK() OVER(ORDER BY sales_amount DESC) AS sales_rank FROM sales_data;这个查询会给销售数据按金额降序排列并且处理并列情况。但这里有个新手常踩的坑窗口函数的执行是在WHERE、GROUP BY之后。也就是说如果你需要先筛选数据再排名正确的写法是SELECT * FROM ( SELECT employee_name, sales_amount, DENSE_RANK() OVER(ORDER BY sales_amount DESC) AS sales_rank FROM sales_data WHERE department East ) AS ranked_data WHERE sales_rank 10;我曾在一个包含500万条记录的销售表上测试发现这种写法比先筛选再排名的性能要好30%左右因为MySQL优化器能更好地处理子查询中的窗口函数。2.2 分区排名的妙用更强大的功能是结合PARTITION BY进行分组排名。比如我们要统计每个地区的销售排名SELECT region, employee_name, sales_amount, DENSE_RANK() OVER( PARTITION BY region ORDER BY sales_amount DESC ) AS region_rank FROM sales_data;这里有个实用技巧当PARTITION BY的字段有很多唯一值时比如用户ID性能会明显下降。我建议先用CTE或者子查询先缩小数据范围比如WITH region_sales AS ( SELECT * FROM sales_data WHERE quarter Q2 AND region IN (East,West) ) SELECT region, employee_name, sales_amount, DENSE_RANK() OVER( PARTITION BY region ORDER BY sales_amount DESC ) AS region_rank FROM region_sales;在我的测试中这种写法对百万级数据可以提升50%的查询速度。3. Hive中dense_rank()的特殊考量3.1 语法差异与优化策略HiveQL中的dense_rank()语法与MySQL类似但大数据环境下需要特别注意性能问题。基本用法SELECT user_id, login_count, DENSE_RANK() OVER(ORDER BY login_count DESC) AS activity_rank FROM user_behavior;在大数据场景下我强烈建议加上分区限制。比如按日期分区查询SELECT user_id, login_count, DENSE_RANK() OVER(PARTITION BY dt ORDER BY login_count DESC) AS daily_rank FROM user_behavior WHERE dt BETWEEN 2023-01-01 AND 2023-01-31;这里有个血泪教训我曾经在一个未分区的10亿级表上直接跑dense_rank()查询跑了2小时都没结果。后来改用分区字段过滤后同样的查询只需要3分钟。3.2 处理数据倾斜的实战技巧Hive中经常遇到数据倾斜问题。比如某些分区的数据量特别大会导致dense_rank()计算非常慢。我总结了几种应对方案预过滤法先用简单查询找出需要的关键字段再关联回原表WITH top_users AS ( SELECT user_id FROM user_behavior WHERE dt 2023-01-01 ORDER BY login_count DESC LIMIT 1000 ) SELECT a.user_id, a.login_count, DENSE_RANK() OVER(ORDER BY a.login_count DESC) AS rank FROM user_behavior a JOIN top_users b ON a.user_id b.user_id WHERE a.dt 2023-01-01;分桶法对倾斜键先做分桶处理SET hive.enforce.bucketingtrue; CREATE TABLE user_behavior_bucketed ( user_id STRING, login_count INT ) CLUSTERED BY (user_id) INTO 32 BUCKETS; INSERT OVERWRITE TABLE user_behavior_bucketed SELECT user_id, login_count FROM user_behavior WHERE dt 2023-01-01; SELECT user_id, login_count, DENSE_RANK() OVER(ORDER BY login_count DESC) AS rank FROM user_behavior_bucketed;两阶段法先局部排序再全局排序-- 第一阶段按mapper局部排序 SELECT user_id, login_count, DENSE_RANK() OVER(PARTITION BY mapper_id ORDER BY login_count DESC) AS local_rank FROM ( SELECT user_id, login_count, PMOD(HASH(user_id), 50) AS mapper_id FROM user_behavior WHERE dt 2023-01-01 ) t; -- 第二阶段取各mapper的top N再做全局排序4. 性能优化与进阶应用4.1 索引与分区的最佳实践在MySQL中要为dense_rank()的排序列和分区列建立合适的索引。比如ALTER TABLE sales_data ADD INDEX idx_region_sales (region, sales_amount DESC);但要注意窗口函数本身不能直接利用索引但WHERE条件中的过滤可以利用。我推荐使用复合索引把分区字段和排序字段都包含进去。对于Hive分区设计更为关键。一个好的实践是按时间和业务维度做多级分区CREATE TABLE user_activity ( user_id STRING, activity_count INT ) PARTITIONED BY (year INT, month INT, day INT);4.2 实时排名系统的实现我曾经用dense_rank()实现过一个实时销售排行榜系统核心思路是创建物化视图存储排名结果CREATE MATERIALIZED VIEW sales_rank_view AS SELECT product_id, sales_count, DENSE_RANK() OVER(ORDER BY sales_count DESC) AS rank FROM product_sales WHERE dt CURRENT_DATE();设置定时刷新MySQL 8.0ALTER MATERIALIZED VIEW sales_rank_view REFRESH COMPLETE ON DEMAND;应用层缓存排名结果设置短时间TTL这种方案在千万级数据量下查询性能可以从秒级降到毫秒级。4.3 跨数据库的兼容方案有些项目需要同时在MySQL和Hive中使用dense_rank()。我建议封装一个统一的数据访问层处理语法差异。比如对于分页查询MySQL写法SELECT * FROM ( SELECT *, DENSE_RANK() OVER(ORDER BY score DESC) AS rnk FROM students ) t WHERE rnk BETWEEN 11 AND 20;Hive写法低版本可能需要这样SELECT * FROM ( SELECT *, DENSE_RANK() OVER(ORDER BY score DESC) AS rnk, ROW_NUMBER() OVER() AS row_num FROM students ) t WHERE row_num BETWEEN 11 AND 20;可以在应用层自动识别数据库类型生成对应的SQL。