1、获取对象集合中的一个字段生成新的集合,【List<BeanA> List<Long>List<BeanA> Set<Long>List<BeanA> String

//查询结果

List<MnsBusinessMessageVO> list = businessMessageMapper.list(query);

//对象集合 转 Long集合

List<Long> userList = list.stream().map(head -> {return head.getCreateUserId();}).collect(Collectors.toList());

List<Long> teacherIdList = conflictData.stream().distinct().collect(Collectors.mapping(item -> item.getTeacherId(), Collectors.toList()));

//对象集合 id,id,id,id字符串

String ids = list.stream().map(e->getCreateUserId()).collect(Collectors.joining(","));

String ids = param.getStudentIdList().stream().map(String::valueOf).collect(Collectors.joining(","))

 

 

//Long集合 转 Long数组

Long[] userIds = userList.toArray(new Long[userList.size()]);

Long[] userIds = userList.stream().toArray(Long[]::new);

 

List<Long>result=Arrays.stream(str.split(",\\s*")).map(Long::parseLong)//将每个字符串转换成长整型

.collect(Collectors.toList());

 

 

 

//对象集合 Long集合

List<Long> userList = list.stream().map(MnsBusinessMessageVO::getCreateUserId).collect(Collectors.toList());

//对象集合的多个字段合并成一个集合

List<Long> ids = modelList.stream().flatMap(item -> Stream.of(item.getCreateUserId(), item.getUpdateUserId())).filter(Objects::nonNull).distinct().collect(Collectors.toList());

 

 

//对象集合 Long集合

List<Long> userList = list.stream().map(e->getCreateUserId()).collect(Collectors.toList());

 

 

//对象集合 Long set集合

Set<Long> userSet = list.stream().map(MnsBusinessMessageVO::getCreateUserId).collect(Collectors.toSet());

 

2、获取对象集合中的(一个或者某个字段)生成新的对象集合 List<BeanA> List<BeanB>

//查询结果

List<MnsVO> list = businessMessageMapper.list(query);

//List<MnsVO> List<Mns>

//Mns需要有多参构造函数

List<Mns> newObjList = list.stream().map(e -> new Mns(e.getId(),e.getBusinessName(),e.getBusinessCode())).collect(Collectors.toList());

 

3toMapList<obj>  map<Long,obj> map<Long,String>

/**

*  List<obj> map<Long,obj>

*  使用Collectors.toMap的时候,如果有可以重复会报错,所以需要加(k1, k2) -> k1

*  (k1, k2) -> k1 表示,如果有重复的key,则用新的 k1替换旧的 K2

*   Function.identity()也可以写成user -> user

*/

 

Map<Long, User> maps = userList.stream().collect(Collectors.toMap(User::getId, Function.identity(), (key1, key2) -> key2));

//List<obj> map<Long,String>

Map<Long, String> maps = userList.stream().collect(Collectors.toMap(User::getId, User::getAge, (key1, key2) -> key2));

4、对象集合深拷贝

//深拷贝(对象地址不同)

List<StartUpTimeIntervalVO> sourceList = new ArrayList<>();

List<StartUpTimeIntervalVO> copyList = sourceList.stream().map(e -> {

    StartUpTimeIntervalVO copy = new StartUpTimeIntervalVO();

    BeanUtils.copyProperties(e, copy);

    return copy;

}).collect(Collectors.toList());

5、skip()跟limit()实现分页

List<EverydayStartupVO> resultList = allList.stream().skip(pageSize * (pageNum - 1)).limit(pageSize).collect(Collectors.toList());

6groupingBy分组【List<Obj> Map<Long,List<Obj>>

//Java8之前

List<UserInfo> originUserInfoList = new ArrayList<>();

originUserInfoList.add(new UserInfo(1L, "吴半杯", 18,"深圳"));

originUserInfoList.add(new UserInfo(3L, "吴半半", 26,"湛江"));

originUserInfoList.add(new UserInfo(2L, "吴半桶", 27,"深圳"));

Map<String, List<UserInfo>> result = new HashMap<>();

for (UserInfo userInfo : originUserInfoList) {

  String city = userInfo.getCity();

  List<UserInfo> userInfos = result.get(city);

  if (userInfos == null) {

      userInfos = new ArrayList<>();

      result.put(city, userInfos);

    }

  userInfos.add(userInfo);

}

Map<Long, List<CalculateVO>> calculateMap = calculateList.stream().collect(Collectors.groupingBy(CalculateVO::getEquipmentId));

报错:java.lang.UnsupportedOperationException: nullcalculateMap中的集合无法做add操作,变更为

Map<Long, List<CalculateVO>> calculateMap = calculateList.stream()

.collect(Collectors.groupingBy(CalculateVO::getEquipmentId,Collectors.toCollection(ArrayList::new))));

 

Map<Long,List<Obj>> List<Obj>

Map<Long, List<String>> listMap = new HashMap<>();

listMap.put(1L, Arrays.asList("a", "b", "c"));

listMap.put(2L, Arrays.asList("d", "e", "f"));

listMap.put(3L, Arrays.asList("g", "h", "i"));

//转换

List<String> streamResult = listMap.values().stream().flatMap(Collection::stream).collect(Collectors.toList());

 

Map<Long,Obj>List<Obj>

 List<SportsTypeStatisticalVO> itemList = itemMap.entrySet().stream()

                        .map(entry -> entry.getValue())

                        .collect(Collectors.toList());

 

 

 

7、sorted+Comparator排序

List<UserInfo> userInfoList = new ArrayList<>();

userInfoList.add(new UserInfo(1L, "吴半杯", 18));

userInfoList.add(new UserInfo(3L, "吴半", 26));

userInfoList.add(new UserInfo(2L, "", 27));

/**

 *  sorted + Comparator.comparing 排序列表,

 */

//根据用户年龄升序排序

userInfoList = userInfoList.stream().sorted(Comparator.comparing(UserInfo::getAge)).collect(Collectors.toList());

//根据创建时间的毫秒值排序升序

userInfoList = userInfoList.stream().sorted(Comparator.comparing(s->s.getCreateTime().getTime())).collect(Collectors.toList())

 

userInfoList.forEach(a -> System.out.println(a.toString()));

/**

 * 如果想降序排序,则可以使用加reversed()

 */

System.out.println("开始降序排序");

userInfoList = userInfoList.stream().sorted(Comparator.comparing(UserInfo::getAge).reversed()).collect(Collectors.toList());

userInfoList.forEach(a -> System.out.println(a.toString()));

//运行结果

UserInfo{userId=1, userName='吴半杯', age=18}

UserInfo{userId=3, userName='吴半', age=26}

UserInfo{userId=2, userName='', age=27}

开始降序排序

UserInfo{userId=2, userName='', age=27}

UserInfo{userId=3, userName='吴半', age=26}

UserInfo{userId=1, userName='吴半杯', age=18}

 
多个字段排序
年龄降序,班级降序

//方法1:先对年龄进行升序,升序结果进行反转,再对班级进行降序

userList = userList.stream().sorted(Comparator.comparing(User::getAge).reversed().thenComparing(User::getClassNo, Comparator.reverseOrder())).collect(Collectors.toList());

//方法2:直接对年龄进行降序,再对班级进行降序

userList = userList.stream().sorted(Comparator.comparing(User::getAge, Comparator.reverseOrder()).thenComparing(User::getClassNo,Comparator.reverseOrder())).collect(Collectors.toList());

//方式3:先对年龄进行升序,再对班级进行升序,最后对结果进行反转

userList = userList.stream().sorted(Comparator.comparing(User::getAge).thenComparing(User::getClassNo).reversed()).collect(Collectors.toList());

年龄升序,班级降序

//方法1:先对年龄进行升序,升序结果进行反转,再进行班级升序,结果进行反转(有点绕,年龄被排了三次升--)

userList = userList.stream().sorted(Comparator.comparing(User::getAge).reversed().thenComparing(User::getClassNo).reversed()).collect(Collectors.toList());

//方法2:直接对年龄进行升序,再对班级进行降序

userList = userList.stream().sorted(Comparator.comparing(User::getAge).thenComparing(User::getClassNo, Comparator.reverseOrder())).collect(Collectors.toList());

//单纯的反转排序

list=list.stream().sorted(Comparator.reverseOrder()).collect(Collectors.toList());

如果只进行单个字段的升序降序排列,我们使用reversed() 或者 Comparator.reverseOrder() 都可以

如果要进行多个字段的升序降序排列,我们还是使用 Comparator.reverseOrder() 会更优雅、更好理解一些

reversed():是对排序结果进行反转

Comparator.reverseOrder():是排序值的降序排序

 

 

 

8、distinct可以去除重复的元素:

List<String> list = Arrays.asList("A", "B", "F", "A", "C");

List<String> temp = list.stream().distinct().collect(Collectors.toList());

9、findFirst 返回第一个元素(ifPresent判断类对象是否存在)

List<String> list = Arrays.asList("A", "B", "F", "A", "C");

list.stream().findFirst().ifPresent(System.out::println);

10、 anyMatch是否至少匹配一个元素

anyMatch 检查流是否包含至少一个满足给定谓词的元素。

Stream<String> stream = Stream.of("A", "B", "C", "D");

boolean match = stream.anyMatch(s -> s.contains("C"));

System.out.println(match);

//输出

true

11、allMatch 匹配所有元素

allMatch 检查流是否所有都满足给定谓词的元素。

Stream<String> stream = Stream.of("A", "B", "C", "D");

boolean match = stream.allMatch(s -> s.contains("C"));

System.out.println(match);

//输出

false

12、foreach 遍历list,遍历map

/**

 * forEach 遍历集合List列表

 */

List<String> userNameList = Arrays.asList("吴半杯", "吴半", "");

userNameList.forEach(item->{System.out.println(item);});

 

/**

 *  forEach 遍历集合Map

 */

HashMap<String, String> hashMap = new HashMap<>();

hashMap.put("博客", "吴半杯");

hashMap.put("职业", "吴半");

hashMap.put("昵称", "捡瓶子的小男孩");

hashMap.forEach((k, v) -> System.out.println(k + ":\t" + v));

//运行结果

捡田螺的小男孩

程序员田螺

捡瓶子的小男孩

职业: 程序员田螺

公众号: 捡田螺的小男孩

昵称: 捡瓶子的小男孩

13、 Max,Min最大最小

使用lambda流求最大,最小值

List<UserInfo> userInfoList = new ArrayList<>();

userInfoList.add(new UserInfo(1L, "吴半杯", 18));

userInfoList.add(new UserInfo(3L, "吴半", 26));

userInfoList.add(new UserInfo(2L, "", 27));

Optional<UserInfo> maxAgeUserInfoOpt = userInfoList.stream().max(Comparator.comparing(UserInfo::getAge));

maxAgeUserInfoOpt.ifPresent(userInfo -> System.out.println("max age user:" + userInfo));

Optional<UserInfo> minAgeUserInfoOpt = userInfoList.stream().min(Comparator.comparing(UserInfo::getAge));

minAgeUserInfoOpt.ifPresent(userInfo -> System.out.println("min age user:" + userInfo));

//运行结果

max age user:UserInfo{userId=2, userName='程序员田螺', age=27}

min age user:UserInfo{userId=1, userName='捡田螺的小男孩', age=18}

一般count()表示获取流数据元素总数。

List<UserInfo> userInfoList = new ArrayList<>();

userInfoList.add(new UserInfo(1L, "吴半杯", 18));

userInfoList.add(new UserInfo(3L, "吴半", 26));

userInfoList.add(new UserInfo(2L, "", 27));

long count = userInfoList.stream().filter(user -> user.getAge() > 18).count();

System.out.println("大于18岁的用户:" + count);

//输出

大于18岁的用户:2

14、map转换

map方法可以帮我们做元素转换,比如一个元素所有字母转化为大写,又或者把获取一个元素对象的某个属性,demo如下:

List<String> list = Arrays.asList("jay", "tianluo");

//转化为大写

List<String> upperCaselist = list.stream().map(String::toUpperCase).collect(Collectors.toList());

upperCaselist.forEach(System.out::println);

Reduce可以合并流的元素,并生成一个值

int sum = Stream.of(1, 2, 3, 4).reduce(0, (a, b) -> a + b);

System.out.println(sum);

//peek()方法是一个中间Stream操作,有时候我们可以使用peek来打印日志。

List<String> result = Stream.of("吴半杯", "吴半", "")

            .filter(a -> a.contains(""))

            .peek(a -> System.out.println("关注:" + a)).collect(Collectors.toList());

System.out.println(result);

15、filter()过滤

从数组集合中,过滤掉不符合条件的元素,留下符合条件的元素。

List<UserInfo> userInfoList = new ArrayList<>();

userInfoList.add(new UserInfo(1L, "吴半杯", 18));

userInfoList.add(new UserInfo(2L, "吴半", 27));

userInfoList.add(new UserInfo(3L, "", 26));

       

/**

 * filter 过滤,留下超过18岁的用户

 */

List<UserInfo> userInfoResultList = userInfoList.stream().filter(user -> user.getAge() > 18).collect(Collectors.toList());

 

userInfoResultList.forEach(a -> System.out.println(a.getUserName()));

       

点赞(0) 打赏

评论列表 共有 0 条评论

暂无评论

微信公众账号

微信扫一扫加关注

发表
评论
返回
顶部