Java8-Stream-練習

這一篇用來記錄對前面學習的Lambda和Stream的綜合訓練

練習題取值尚硅谷教學視頻，由於中文的博大精深，有一些題理解不同，求出來的結果也不同，只求達到複習和提升知識掌握度，下面直接上代碼

先來Bean

package com.jv.java8.stream;
//交易員
public class Trader {

	private String name;
	private String city;

	public Trader() {
	}

	public Trader(String name, String city) {
		this.name = name;
		this.city = city;
	}

	public String getName() {
		return name;
	}

	public void setName(String name) {
		this.name = name;
	}

	public String getCity() {
		return city;
	}

	public void setCity(String city) {
		this.city = city;
	}

	@Override
	public String toString() {
		return "Trader [name=" + name + ", city=" + city + "]";
	}

}

package com.jv.java8.stream;
//交易
public class Transaction {

	//交易員
	private Trader trader;
	//交易日期
	private int year;
	//交易金額
	private int value;

	public Transaction() {
	}

	public Transaction(Trader trader, int year, int value) {
		this.trader = trader;
		this.year = year;
		this.value = value;
	}

	public Trader getTrader() {
		return trader;
	}

	public void setTrader(Trader trader) {
		this.trader = trader;
	}

	public int getYear() {
		return year;
	}

	public void setYear(int year) {
		this.year = year;
	}

	public int getValue() {
		return value;
	}

	public void setValue(int value) {
		this.value = value;
	}

	@Override
	public String toString() {
		return "Transaction [trader=" + trader + ", year=" + year + ", value="
				+ value + "]";
	}

}

再來測試代碼，代碼中使用到了過濾，排序，歸約，分組，求平均值，最大值，最小值，最小值對應記錄等等，並且有的實現提供了多種方式。

package com.jv.java8.stream;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Map;
import java.util.Optional;
import java.util.stream.Collectors;
import java.util.stream.Stream;

import org.junit.Before;
import org.junit.Test;

import com.jv.bean.Cust;

/*
 * Stream API練習
 */
public class StreamPractice {
	List<Transaction> transactions = null;
	
	@Before
	public void before(){
		Trader raoul = new Trader("Raoul", "Cambridge");
		Trader mario = new Trader("Mario", "Milan");
		Trader alan = new Trader("Alan", "Cambridge");
		Trader brian = new Trader("Brian", "Cambridge");
		
		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)
		);
	}
	
	List<Cust> custs = Arrays.asList(
			new Cust(101,"梅西",30,33000000L),
			new Cust(102,"伊布",35,23000000L),
			new Cust(103,"哈維",34,20000000L),
			new Cust(104,"伊列斯塔",33,18000000L),
			new Cust(105,"小羅",37,15000000L),
			new Cust(106,"內馬爾",27,32000000L),
			new Cust(106,"內馬爾",27,32000000L),
			new Cust(106,"姆巴佩",23,30500000L)
			);
	
	@Test
	public void test0() {
		/*
		 * 給定一個數字列表，返回每一個數字平反的列表
		 */
		List<Integer> l1 = Arrays.asList(1,2,3,4).stream().map(x->x*x).collect(Collectors.toList());
		System.out.println(l1);
		System.out.println("##########################");
		/*
		 * 用Map和Reduce計算流中有多少個Cust對象
		 * 固然你能夠有不少種方法均可以統計列表中對象的個數，只是爲了更進一步瞭解Stream API的用法，纔要求這樣作
		 */
		Integer ic1 = custs.stream().map(Cust::getAge).reduce(0, (x,y)->x+1);
		System.out.println(ic1);
		Integer ic2 = custs.stream().map(e -> 1).reduce(0, Integer::sum);
		System.out.println(ic2);
		
	}
	
	
	//1. 找出2011年發生的全部交易， 並按交易額排序（從低到高）
	@Test
	public void test1() {
		transactions.stream().filter(x->x.getYear()==2011).sorted((x,y)->{
			if(x.getValue()>y.getValue()) {
				return 1;
			}else if(x.getValue()<y.getValue()) {
				return -1;
			}else {
				return 0;
			}
			
		}).forEach(System.out::println);
	}
	
	
	//2. 交易員都在哪些不一樣的城市工做過？
	@Test
	public void test2() {
		//實際上就是找出全部交易員工做的城市並排重
		//方式1
		transactions.stream().map(Transaction::getTrader).map(Trader::getCity).distinct().forEach(System.out::println);
		//方式2
		transactions.stream().map(x->x.getTrader().getCity()).distinct().forEach(System.out::println);
	}
	
	
	//3. 查找全部來自劍橋的交易員，並按姓名排序
	@Test
	public void test3() {
		transactions.stream().filter(x->x.getTrader().getCity().equals("Cambridge")).sorted((x,y)->{
			return x.getTrader().getName().compareTo(y.getTrader().getName());
		}).forEach(System.out::println);
	}
	
	//4. 返回全部交易員的姓名字符串，按字母順序排序
	@Test
	public void test4() {
		//方式1
		String s = transactions.stream().map(x->x.getTrader().getName()).distinct().sorted().collect(Collectors.joining(","));
		System.out.println(s);
		//方式2
		String s1 = transactions.stream().map(x->x.getTrader().getName()).distinct().sorted().reduce("", (x,y)->x+","+y).replaceFirst(",", "");
		System.out.println(s1);
	}
	
	//5. 有沒有交易員是在米蘭工做的？
	@Test
	public void test5() {
		Boolean b = transactions.stream().anyMatch(x->x.getTrader().getCity().equals("Milan"));
		System.out.println(b);
	}
	
	
	//6. 打印生活在劍橋的交易員的全部交易額
	@Test
	public void test6() {
		//方式1
		Map<Object, List<Transaction>> mt = transactions.stream().filter(x->x.getTrader().getCity().equals("Cambridge"))
							 .collect(Collectors.groupingBy(x->x.getTrader().getName()));
		//System.out.println(mt);
		for(Object obj:mt.keySet()) {
			Integer i = mt.get(obj.toString()).stream().collect(Collectors.summingInt(x->x.getValue()));
			System.out.println(obj+":"+i);
		}
		
		//方式2
		Map<Object,Integer> mt1 = transactions.stream().filter(x->x.getTrader().getCity().equals("Cambridge"))
							 .collect(Collectors.groupingBy(x->x.getTrader().getName(), Collectors.summingInt(x->x.getValue())));
		System.out.println(mt1);
		
		//很明顯流提供的支持確實很強大，第二種方式要簡單好多好多
	}
	
	
	//7. 全部交易中，最高的交易額是多少
	@Test
	public void test7() {
		Optional<Integer> i = transactions.stream().map(Transaction::getValue).collect(Collectors.maxBy(Integer::compare));
		System.out.println(i.get());
	}
	
	//8. 找到交易額最小的交易
	@Test
	public void test8() {
		Optional<Transaction> op = transactions.stream().min((x,y)->Integer.compare(x.getValue(), y.getValue()));
		System.out.println(op.get());
	}
	
}

再次感嘆Stream結合Lambda確實很牛啊。之前在公司解除的代碼都是JDK1.4 JDK1.6的，真是土到渣了（這固然是能夠理解的，由於換JDK成本過高，沒人買單）