Stream, 람다식 DB 연동 활용

저번에 했던 람다식을 이어서 자바를 이용해 db와 연동하여 활용하는 실습을 해보았다.

 

package lambda;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.Arrays;
import java.util.List;
import java.util.function.Consumer;

public class MyLambda5Db {
	
	public MyLambda5Db() {
		// Consumer 인터페이스는 accept()를 갖고있다.
		// 주로 Collection API의 forEach에서 주로 사용
		abc();
		
		System.out.println();
		try {
			Class.forName("org.mariadb.jdbc.Driver");
		} catch (Exception e) {
			System.out.println("Driver loading fail : " + e);
			return;
		}
		
		queryTable("select * from sangdata", rs -> {
			try {
				while(rs.next()) {
					System.out.println(rs.getString("code") + " " + rs.getString("sang") + " "
										+ rs.getString("su") + " " + rs.getString("dan"));
				}
			} catch (Exception e) {
				System.out.println("error : " + e);
			}
		});
		
	}
	
	private void abc() {
		Consumer<Integer> printInt = i -> System.out.println(i);
		
		List<Integer> numbers = Arrays.asList(1,2,3,4,5);
		numbers.forEach(printInt);
	}
	
	private void queryTable(String sql, Consumer<ResultSet> consumer) {
		// try 문에 매개변수를 줄 수 있다. try with resource 문법에 준함
		try(Connection conn = DriverManager.getConnection("jdbc:mariadb://localhost:3306/test","root","123");
				PreparedStatement pstmt = conn.prepareStatement(sql);
				ResultSet rs = pstmt.executeQuery()) {
			System.out.println("처리1");
			consumer.accept(rs);
			System.out.println("처리2");
			
			rs.close();
			pstmt.close();
			conn.close();
		} catch (Exception e) {
			System.out.println("error : " + e);
		}
		
	}
	
	public static void main(String[] args) {
		new MyLambda5Db();
	}

}

 

 

스트림(Stream)

Stream 인터페이스는 컬렉션, 배열 등의 저장 요소를 하나씩 참조하여 인터페이스(람다식)를 적용하며, 반복 처리가 가능하게 한다. (반복자 역할)
정렬, 집계, 빅데이터 처리 등도 가능하다.
1회용. 내부 반복으로 작업 처리. 원본 데이터를 변경하지 않는다

 

스트림 관련 실습

 

package lambda;

import java.util.Arrays;
import java.util.Comparator;
import java.util.Iterator;
import java.util.List;
import java.util.OptionalDouble;
import java.util.stream.Collector;
import java.util.stream.Collectors;
import java.util.stream.IntStream;
import java.util.stream.Stream;

// Stream 인터페이스 : 컬렉션, 배열 등의 저장 요소를 하나씩 참조하여
// 인터페이스(람다식)를 적용하며, 반복 처리가 가능하게 한다. 반복자 역할.
// 정렬, 집계, 빅데이터 처리 등도 가능하다.
// 1회용. 내부 반복으로 작업 처리. 원본 데이터를 변경하지 않음

public class MyStream {

	public MyStream() {
		test1(); // Stream 생성
		test2(); // 컬렉션에 스트림 적용
		test3(); // VO 클래스 사용

	}

	private void test1() {
		// 1) Collection의 스트림 생성
		List<String> list = Arrays.asList("a");
		Stream<String> listStream = list.stream();
		
		// 2) 배열의 스트림 생성
		Stream<String> stream1 = Stream.of("a","b","c");
		Stream<String> stream2 = Stream.of(new String[] {"a","b","c"});
		Stream<String> stream3 = Arrays.stream(new String[] {"a","b","c"});
		Stream<String> stream4 = Arrays.stream(new String[] {"a","b","c"}, 0, 3);
		
		// 3) 원시(기본형 데이터) stream 생성
		IntStream istream = IntStream.range(5, 10);
		// DoubleStream ...
		istream.forEach(para -> System.out.println(para + " "));
		
		System.out.println();
		
		
	}

	private void test2() {
		List<String> list = Arrays.asList("레밍스", "팩맨", "마리오");
		// list.add("소닉");		// 새로운 요소 추가 X, 기존 요소 삭제 X
		Iterator<String> iter = list.iterator(); // 외부 반복자 사용. 전통적 방법
		while(iter.hasNext()) {
			System.out.println(iter.next());
		}
		
		System.out.println();
		for(String str:list) {	// 향상된 for문. 전통적
			System.out.println(str);
		}
		for(String str:list) {	// 향상된 for문. 전통적
			System.out.println(str);
		}
		
		System.out.println();
		Stream<String> stream = list.stream(); // Stream 객체 생성
		stream.forEach(str -> System.out.println(str)); // 내부 반복으로 작업 처리
		// stream.forEach(str -> System.out.println(str)); // error : 일회용으로만 쓸 수 있음
		
		list.stream().forEach(str -> System.out.println(str)); // Stream 객체 생성 후 출력
		System.out.println();
		list.stream().forEach(System.out::println);
		System.out.println();
		
		// 스트림을 사용하여 체이닝 작업 : 모든 필요한 작업을 단일 스트림 파이프라인에서 처리 가능. 일련의 작업 연속 처리
		// 어떤 스트림의 요소들의 합을 구하는 과정에서 요소 값을 먼저 출력하고 싶은 경우
		int sum = IntStream.of(1,3,5,7).peek(System.out::println).sum();	// count, max ...
		System.out.println("합은 : " + sum);
		
		list.stream().peek(System.out::println).forEach(System.out::println);
		
		System.out.println("\n병렬 처리");
		Stream<String> streamPar = list.parallelStream(); // 병렬 스트림 객체 생성
		streamPar.forEach(str -> System.out.println(str));
		
		System.out.println("\n정렬");
		Stream<String> streamSort = list.stream().sorted();	// ascending(오름차순)
		Stream<String> streamSort2 = list.stream().sorted(Comparator.reverseOrder());	// descending(내림차순)
		streamSort.forEach(System.out::println);
		streamSort2.forEach(System.out::println);
		
		Stream<String> streamSort3 = list.stream().distinct().sorted(); // 중복 제거
		
	}

	private void test3() {
		System.out.println("\n\nVO 클래스로 컬렉션 작성");
		List<Student> slist = Arrays.asList
				(new Student("레밍스", "남", 22),
				(new Student("팩맨", "남", 22)),
				(new Student("마리오", "남", 28)),
				(new Student("피치", "여", 20)),
				(new Student("마라라", "여", 22))
			);
		
		Stream<Student> stream = slist.stream();
		stream.forEach(p -> {
			System.out.println(p.getName() + " " + p.getGender() + " " + p.getAge());
		});
		
		System.out.println("컬렉션 자료에 대한 중간 처리, 최종 처리가 가능함");
		// 각 개인의 나이를 출력하고, 최종 나이의 평균 출력
		// 방법 1
		double avg = slist.stream().mapToInt(Student :: getAge) // Student 객체를 age 값으로 매핑해 age로 새 스트림 생성
				.average() // age 요소의 평균을 OptionalDouble에 저장. 값이 없을 수도 있다는 가정
				.getAsDouble(); // OptionalDouble에 저장
		System.out.println("나이 전체 평균은 " + avg);
		
		// 방법 2
		Double avg2 = slist.stream().collect(Collectors.averagingInt(Student :: getAge));
		System.out.println("나이 전체 평균은 " + avg2);
		
		// 방법 3
		OptionalDouble result = slist.stream()
				.mapToDouble(Student :: getAge)
				.average();
		result.ifPresent(res -> System.out.println("나이 전체 평균은 " + res));
		
		
		// 필터 처리
		// 남자 나이 평균
		double avgM = slist.stream()
				.filter(m -> m.getGender().equals("남"))
				.mapToInt(Student :: getAge)
				.average()
				.getAsDouble(); // OptionalDouble에 저장된 값 읽ㄱ
		System.out.println("남자 나이 평균은 " + avgM);
		
		// '마' 성을 가진 자료 출력
		
		slist.stream().filter(ir -> ir.getName().startsWith("마")).forEach(irum -> System.out.println(irum.getName()));
		
		
	}

	class Student {
		private String name;
		private String gender;
		private int age;
		
		public Student(String name, String gender, int age) {
			this.name = name;
			this.gender = gender;
			this.age = age;
		}

		public String getName() {
			return name;
		}

		public String getGender() {
			return gender;
		}

		public int getAge() {
			return age;
		}
		
		
		
	}
	
	public static void main(String[] args) {
		new MyStream();
	}

}