스트림 활용 예제 소스

스트림 활용 에제 Model

- Transaction

/** * Chapter5 예제 객체 */ public class Transaction { private final Trader trader; private final int year; private final int value; public Transaction(Trader trader, int year, int value) { super(); this.trader = trader; this.year = year; this.value = value; } public Trader getTrader() { return trader; } public int getYear() { return year; } public int getValue() { return value; } @Override public String toString() { return "Transaction [trader=" + trader + ", year=" + year + ", value=" + value + "]"; } }

- Trader

/** * Chapter5 예제 객체 */ public class Trader { private final String name; private final String city; public Trader(String name, String city) { super(); this.name = name; this.city = city; } public String getName() { return name; } public String getCity() { return city; } @Override public String toString() { return "Trader [name=" + name + ", city=" + city + "]"; } }

- 예제 소스

import java.util.Arrays; import java.util.List; import java.util.Optional; import chapter5.model.Trader; import chapter5.model.Transaction; public class chapter5 { public static void main(String[] args) { //예제 데이터 생성 //거래자 데이터 생성 Trader raoul = new Trader("Raoul", "Cambridge"); Trader mario = new Trader("Mario", "Milan"); Trader alan = new Trader("Alan", "Cambridge"); Trader brian = new Trader("Brian", "Cambridge"); //트랜잭션 데이터 생성 List<Transaction> transactions = Arrays.asList( new Transaction(brian, 2011, 300), new Transaction(raoul, 2012, 1000), new Transaction(raoul, 2011, 400), new Transaction(mario, 2012, 710), new Transaction(mario, 2012, 700), new Transaction(alan, 2012, 950)); //1. 2011년에 일어난 모든 트랜잭션 검색 후 값을 오름차순 검색 List<Transaction> trans01 = transactions.stream() .filter(item -> item.getYear() == 2011) .sorted(java.util.Comparator.comparing(Transaction::getValue)) .collect(java.util.stream.Collectors.toList()); System.out.println("1. 2011년 발생 트랜잭션의 값 오름차순 정렬" + trans01); //2. 거래자 근무하는 모든 도시 중복 없이 나열 List<String> trader02 = transactions.stream() .map(item -> item.getTrader().getCity()) .distinct() .collect(java.util.stream.Collectors.toList()); System.out.println("2. 거래자가 근무하는 모든 도시(중복 제거): " + trader02); //3. 케임브리지에 근무하는 모든 거래자를 찾아서 이름순 정렬 List<Trader> trader03 = transactions.stream() .map(Transaction::getTrader) .filter(item -> "Cambridge".equals(item.getCity())) .sorted(java.util.Comparator.comparing(Trader::getName)) .distinct() .collect(java.util.stream.Collectors.toList()); System.out.println("3. 케임브리지에 근무하는 모든 거래자 이름순 정렬: " + trader03); //4. 모든 거래자의 이름 알파벳순 정렬. List<String> trader04 = transactions.stream() .map(item -> item.getTrader().getName()) .distinct() .sorted() .collect(java.util.stream.Collectors.toList()); System.out.println("4. 모든 거래자의 이름 알파벳 순으로 정렬 후 출력: " + trader04); //5. 밀라노에 거래자가 있는가? boolean trader05 = transactions.stream() .anyMatch(item -> "Milan".equals(item.getTrader().getCity())); System.out.println("5. 밀라노에 거래자가 있는지 여부: " + trader05); //6. 케임브리지에 거주하는 거래자의 모든 트랜잭션 값을 출력 List<Integer> trans06 = transactions.stream() .filter(item -> "Cambridge".equals(item.getTrader().getCity())) .map(Transaction::getValue) .collect(java.util.stream.Collectors.toList()); System.out.println("6. 케임브리지에 거주하는 거래자의 모든 트랜잭션 값 출력: " + trans06); //7. 전체 트랜잭션 중 최댓값은? Optional<Integer> highestValue = transactions.stream() .map(Transaction::getValue) .reduce(Integer::max); System.out.println("7. 전체 트랜잭션 중 최대값: " + highestValue); //8. 전체 트랜잭션 중 최솟값은? Optional<Integer> lowValue = transactions.stream() .map(Transaction::getValue) .reduce(Integer::min); System.out.println("8. 전체 트랜잭션 중 최소값: " + lowValue); } }