Java List stream数据筛选、去重、分组、统计、排序，按小时、天、周、月、年分组统计

Java 8 API添加了一个新的抽象称为流Stream，可以让你以一种声明的方式处理数据。

（）

Stream 使用一种类似用 SQL 语句从数据库查询数据的直观方式来提供一种对 Java 集合运算和表达的高阶抽象。

1.过滤元素 - filter()

（）

filter()方法根据给定的条件筛选出符合条件的元素，返回一个新的流。

示例：

List dictionaries = list.stream().filter( s -> s.getType().equals("0")).collect(Collectors.toList());

2.去重元素 - distinct()

distinct()方法对流中的元素进行去重

示例：

 // 去重List dictionaries = list.stream().distinct().collect(Collectors.toList());// 根据名称去重List dictionaries = list.stream().collect(                    Collectors.collectingAndThen(                            Collectors.toCollection(() -> new TreeSet(Comparator.comparing(Work::getRepairDepart))), ArrayList::new)            );

3.排序元素 - sorted()

sorted()方法对流中的元素进行排序，默认是按照自然顺序排序，也可以传入自定义的比较器；

示例：

// 升序排序List dictionaries = list.stream().sorted().collect(Collectors.toList());// 降序排序List dictionaries = list.stream().sorted(Comparator.reverseOrder()).collect(Collectors.toList());// 定制升序排序List dictionaries = list.stream().sorted(Comparator.comparing(Student::getAge)).collect(Collectors.toList());// 定制降序排序List dictionaries = list.stream().sorted(Comparator.comparing(Student::getAge).reverseOrder()).collect(Collectors.toList());

4.收集结果-collect()

collect()方法将流中的元素收集到一个集合中。

示例：

（1）按时间统计：

// 按小时统计Map stationHH = list.stream().collect(Collectors.groupingBy(item -> new SimpleDateFormat("yyyy-MM-dd HH").format(item.getTime()), Collectors.summingDouble(Sensorrealtime::getValue)));// 按天统计Map stationHH = list.stream().collect(Collectors.groupingBy(item -> new SimpleDateFormat("yyyy-MM-dd").format(item.getTime()), Collectors.summingDouble(Sensorrealtime::getValue)));// 按周统计Map stationHH = list.stream().collect(Collectors.groupingBy(item -> getWeekNumber(item.getTelTime()), Collectors.summingDouble(Sensorrealtime::getValue)));// 按月统计Map stationHH = list.stream().collect(Collectors.groupingBy(item -> new SimpleDateFormat("yyyy-MM").format(item.getTime()), Collectors.summingDouble(Sensorrealtime::getValue)));// 按年统计Map stationHH = list.stream().collect(Collectors.groupingBy(item -> new SimpleDateFormat("yyyy").format(item.getTime()), Collectors.summingDouble(Sensorrealtime::getValue)));// 获取周数public String getWeekNumber(Date date){    LocalDate localDate = date.toInstant().atZone(ZoneId.systemDefault()).toLocalDate();    int weekNumber = localDate.get(WeekFields.ISO.weekOfMonth());    return Integer.toString(weekNumber);}

（2）按时间分组：

// 按小时分组Map listHH = list.stream().collect(Collectors.groupingBy(item -> new SimpleDateFormat("yyyy-MM-dd HH").format(item.getTelTime())));// 按天分组Map listDD = list.stream().collect(Collectors.groupingBy(item -> new SimpleDateFormat("yyyy-MM-dd").format(item.getTelTime())));// 按周分组Map listWW = list.stream().collect(Collectors.groupingBy(item -> getWeekNumber(item.getTelTime()))); // 按月分组Map listWW = list.stream().collect(Collectors.groupingBy(item -> new SimpleDateFormat("yyyy-MM").format(item.getTelTime()))); // 按年分组Map listWW = list.stream().collect(Collectors.groupingBy(item -> new SimpleDateFormat("yyyy").format(item.getTelTime()))); // 获取周数public String getWeekNumber(Date date){    LocalDate localDate = date.toInstant().atZone(ZoneId.systemDefault()).toLocalDate();    int weekNumber = localDate.get(WeekFields.ISO.weekOfMonth());    return Integer.toString(weekNumber);}                               

其他：

SQL 分时间查询：

下面例子中表名为tablename,条件字段名为inputdate

查询今天

SELECT * FROM tablename where DATEDIFF(day,inputdate,GETDATE())=0

查询昨天

SELECT * FROM tablename where DATEDIFF(day,inputdate,GETDATE())=1

查询本周

SELECT * FROM tablename where datediff(week,inputdate,getdate())=0

查询上周

SELECT * FROM tablename where datediff(week,inputdate,getdate())=1

查询本月

SELECT * FROM tablename where DATEDIFF(month,inputdate,GETDATE())=0

查询上月

SELECT * FROM tablename where DATEDIFF(month,inputdate,GETDATE())=1

查询本季度的

select * from T_InterViewInfo where datediff(QQ,inputdate,getdate())=0