Java模拟rank/over函数实现获取分组排名的方法详解

更新时间：2023年04月10日 14:24:18 作者：chz613

这篇文章主要为大家详细介绍了Java模拟rank()、over()函数获取分组排名的方法设计及实现，文中的示例代码讲解详细，感兴趣的小伙伴可以了解一下

背景

考试批次	班级	姓名	语文
202302	三年一班	张小明	130.00
202302	三年一班	王二小	128.00
202302	三年一班	谢春花	136.00
202302	三年二班	冯世杰	129.00
202302	三年二班	马功成	130.00
202302	三年二班	魏翩翩	136.00

假设我们有如上数据，现在有一个需求需要统计各学生语文单科成绩在班级中的排名和全年段排名，你会如何实现？

很容易的我们想到了 rank() over() 实现

over()是分析函数，可以和 rank()、 dense_rank() 、 row_number() 配合使用。

使用语法如下：

RANK() OVER(PARTITION BY COLUMN ORDER BY COLUMN)
dense_rank() OVER(PARTITION BY COLUMN ORDER BY COLUMN)
ROW_NUMBER() OVER(PARTITION BY COLUMN ORDER BY COLUMN)

解释：partition by用于给结果集分组，如果没有指定那么它把整个结果集作为一个分组。

rank()涵数主要用于排序，并给出序号，对于排序并列的数据给予相同序号，并空出并列所占的名次。
dense_rank() 功能同rank()一样，区别在于不空出并列所占的名次
row_number()涵数则是按照顺序依次使用，不考虑并列

rank 结果为 1,2,2,4 dense_rank 结果为 1,2,2,3 row_number 结果为 1,2,3,4

实际应用中，会存在数据从其他外部系统接入且数据量不大等多种情况，那么使用Java代码的方式实现分组排名的功能则显得更加方便。

详细设计及实现

排序定义类 OrderBy

public class OrderBy {
    private String orderByEL;
    /**
     * 是否升序
     */
    private boolean ascend;

    public OrderBy(){
        //默认升序
        this.ascend = true;
    }

    public String orderByEL(){
        return this.orderByEL;
    }

    public OrderBy orderByEL(String orderByEL){
        this.orderByEL = orderByEL;
        return this;
    }

    public OrderBy ascend(boolean ascend){
        this.ascend = ascend;
        return this;
    }

    public boolean ascend(){
        return this.ascend;
    }
}

该类定义了如下属性：

排序的fileld
是否升序

获取排名方法

该方法定义如下：

<T> void rankOver(List<T> dataList, String[] partitionByFields, List<OrderBy> orderByList, String resultField, int rankType);

该方法提供了5个入参：

dataList 排序的数据集

partitionByFields 分组field的数组

orderByList 排序字段集合

resultField 排名结果存放的字段

rankType 排名方式

1:不考虑并列（row_number 结果为 1,2,3,4）
2:考虑并列，空出并列所占的名次（rank 结果为 1,2,2,4）
3:考虑并列，不空出并列所占的名次（dense_rank 1,2,2,3）

该方法具体实现如下

    public static <T> void rankOver(List<T> dataList, String[] partitionByFields, List<OrderBy> orderByList, String resultField, int rankType) {
        if (CollectionUtils.isEmpty(orderByList)) {
            return;
        }
        //STEP_01 剔除掉不参与排名的数据
        List<T> tempList = new ArrayList<>();
        for (T data : dataList) {
            boolean part = true;
            for (OrderBy rptOrderBy : orderByList) {
                Object o1 = executeSpEL(rptOrderBy.orderByEL(), data);
                if (o1 == null) {
                    //参与排序的值为null的话则不参与排名
                    part = false;
                    break;
                }
            }
            if (part) {
                tempList.add(data);
            }
        }
        if (CollectionUtils.isEmpty(tempList)) {
            return;
        }
        //STEP_02 分组
        Map<String, List<T>> groupMap = group(tempList, null, partitionByFields);
        for (List<T> groupDataList : groupMap.values()) {
            order(orderByList, groupDataList);
            if (rankType == 1) {
                int rank = 1;
                for (T temp : groupDataList) {
                    setFieldValue(temp, resultField, rank);
                    rank++;
                }
            } else {
                int prevRank = Integer.MIN_VALUE;
                int size = groupDataList.size();
                for (int i = 0; i < size; i++) {
                    T current = groupDataList.get(i);
                    if (i == 0) {
                        //第一名
                        setFieldValue(current, resultField, 1);
                        prevRank = 1;
                    } else {
                        T prev = groupDataList.get(i - 1);
                        boolean sameRankWithPrev = true;//并列排名
                        for (OrderBy rptOrderBy : orderByList) {
                            Object o1 = executeSpEL(rptOrderBy.orderByEL(), current);
                            Object o2 = executeSpEL(rptOrderBy.orderByEL(), prev);
                            if (!o1.equals(o2)) {
                                sameRankWithPrev = false;
                                break;
                            }
                        }
                        if (sameRankWithPrev) {
                            setFieldValue(current, resultField, getFieldValue(prev, resultField));
                            if (rankType == 2) {
                                ++prevRank;
                            }
                        } else {
                            setFieldValue(current, resultField, ++prevRank);
                        }
                    }
                }
            }
        }
    }

使用案例

定义一个学生类：

public class Student {
    private String batch;
    private String banji;
    private String name;
    private Double yuwen;
    //extra
    private Integer rank1;
    private Integer rank2;
    
    public Student(String batch, String banji, String name, Double yuwen) {
        this.batch = batch;
        this.banji = banji;
        this.name = name;
        this.yuwen = yuwen;
    }
}

我们写一个方法，返回如下数据：

public List<Student> getDataList() {
    List<Student> dataList = new ArrayList<>();
    dataList.add(new Student("202302", "三年一班", "张小明", 130.0));
    dataList.add(new Student("202302", "三年一班", "王二小", 128.0));
    dataList.add(new Student("202302", "三年一班", "谢春花", 136.0));
    dataList.add(new Student("202302", "三年二班", "冯世杰", 129.0));
    dataList.add(new Student("202302", "三年二班", "马功成", 130.0));
    dataList.add(new Student("202302", "三年二班", "魏翩翩", 136.0));
    return dataList;
}

获取学生语文成绩的班级排名和年段排名，排名采用并列并空出并列所占用名次的方式。

List<Student> dataList = getDataList();
List<OrderBy> orderByList = new ArrayList<>();
orderByList.add(new OrderBy().orderByEL("yuwen").ascend(false));
//获取全校排名
DataProcessUtil.rankOver(dataList, new String[]{"batch"}, orderByList, "rank1", 2);
//获取班级排名
DataProcessUtil.rankOver(dataList, new String[]{"batch", "banji"}, orderByList, "rank2", 2);
log("语文单科成绩排名情况如下：");

Map<String, List<Student>> groupMap = DataProcessUtil.group(dataList, null, new String[]{"batch"});
for (Map.Entry<String, List<Student>> entry : groupMap.entrySet()) {
    log("考试批次：" + entry.getKey());
    for (Student s : entry.getValue()) {
        log(String.format("班级：%s 学生：%s 语文成绩：%s 班级排名：%s 全校排名：%s", s.getBanji(), s.getName(), s.getYuwen(), s.getRank2(), s.getRank1()));
    }
    log("");
}

结果如下：

语文单科成绩排名情况如下：
考试批次：202302
班级：三年一班学生：张小明语文成绩：130.0 班级排名：2 全校排名：3
班级：三年一班学生：王二小语文成绩：128.0 班级排名：3 全校排名：6
班级：三年一班学生：谢春花语文成绩：136.0 班级排名：1 全校排名：1
班级：三年二班学生：冯世杰语文成绩：129.0 班级排名：3 全校排名：5
班级：三年二班学生：马功成语文成绩：130.0 班级排名：2 全校排名：3
班级：三年二班学生：魏翩翩语文成绩：136.0 班级排名：1 全校排名：1

可以看到全校排名中有两个并列第一名两个并列第三名，且空出了并列所占用的名次2 和名次4

到此这篇关于Java模拟rank/over函数实现获取分组排名的方法详解的文章就介绍到这了,更多相关Java获取分组排名内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

MyBatis实现多表联查的详细代码
这篇文章主要介绍了MyBatis如何实现多表联查，通过实例代码给大家介绍使用映射配置文件实现多表联查，使用注解的方式实现多表联查,需要的朋友可以参考下
2022-08-08
Java框架Quartz中的Trigger简析
这篇文章主要介绍了Java框架Quartz中的Trigger简析,所有类型的trigger都有TriggerKey这个属性,表示trigger的身份；除此之外,trigger还有很多其它的公共属性,这些属性,在构建trigger的时候可以通过TriggerBuilder设置,需要的朋友可以参考下
2023-11-11
JAVA学习之一步步搭建spring框架
这篇文章主要介绍了JAVA学习之一步步搭建spring框架,小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2017-10-10
SpringBoot与rabbitmq的结合的示例
这篇文章主要介绍了SpringBoot与rabbitmq的结合的示例，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2018-03-03
mybatis中mapper-locations的作用
这篇文章主要介绍了mybatis中mapper-locations的具体作用，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2022-06-06
springboot 集成activemq项目配置方法
这篇文章主要介绍了springboot 集成activemq项目配置方法,e-car项目配置通过引入activemq依赖,本文结合实例代码给大家介绍的非常详细,感兴趣的朋友跟随小编一起看看吧
2024-04-04
本地编译打包项目部署到服务器并且启动方式
这篇文章主要介绍了本地编译打包项目部署到服务器并且启动方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2023-02-02
使用ByteArrayOutputStream写入字符串方式
这篇文章主要介绍了使用ByteArrayOutputStream写入字符串方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2021-12-12
spring boot使用sharding jdbc的配置方式
这篇文章主要介绍了spring boot使用sharding jdbc的配置方式，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2017-12-12
SpringBoot使用Nacos进行application.yml配置管理详解
Nacos是阿里巴巴开源的一个微服务配置管理和服务发现的解决方案,下面我们来看看在SpringBoot中如何使用Nacos进行application.yml配置管理吧
2025-03-03