[springboot] 스프링 입문 - 6. 스프링 DB 연동

create table member ( id bigint not null auto_increment, name varchar(255), primary key (id) );

implementation 'mysql:mysql-connector-java' implementation 'org.springframework.boot:spring-boot-starter-data-jpa'

spring: datasource: driver-class-name: com.mysql.cj.jdbc.Driver url: jdbc:mysql://localhost:3306/test?serverTimezone=Asia/Seoul username: <username> password: <pw> jpa: show-sql: true hibernate: ddl-auto: none

@Entity public class Member { @Id @GeneratedValue(strategy = GenerationType.IDENTITY) private Long id; // PK private String name; public Long getId() { return id; } public void setId(Long id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } }

@Configuration public class SpringConfig { private final EntityManager em; // 1️⃣ @Autowired public SpringConfig(EntityManager em) { this.em = em; } @Bean public MemberService memberService() { return new MemberService(memberRepository()); } @Bean public MemberRepository memberRepository() { // return new MemoryMemberRepository(); return new JpaMemberRepository(em); // 2️⃣ 객체지향 다형성의 장점 } }

public class JpaMemberRepository implements MemberRepository{ private final EntityManager em; // JPA 를 쓰려면 em 에 DI 를 받아야한다. public JpaMemberRepository(EntityManager em) { this.em = em; } @Override public Member save(Member member) { em.persist(member); // 영속화(영구저장) return member; } @Override public Optional<Member> findById(Long id) { // Member.class : 조회할 타입 // id : 조회할 타입의 값 Member member = em.find(Member.class, id); return Optional.ofNullable(member); } @Override public Optional<Member> findByName(String name) { // jpql 쿼리 언어 ( 엔티티 객체를 대상으로 날리는 쿼리 ) // 쿼리 결과도 객체가 됨 List<Member> result = em.createQuery("select m from Member as m where m.name = :name", Member.class) .setParameter("name", name) .getResultList(); return result.stream().findAny(); } @Override public List<Member> findAll() { // jpql 쿼리 언어 ( 엔티티 객체를 대상으로 날리는 쿼리 ) // 쿼리 결과도 객체가 됨 return em.createQuery("select m from Member as m", Member.class) .getResultList(); } }

@Transactional // JPA 를 사용한 모든 데이터 변경은 트랙잭션 안에서 실행되어야 함 public class MemberService { private final MemberRepository memberRepository; @Autowired // MemberService 객체를 생성할 때, memberRepository 의존성 주입 public MemberService(MemberRepository memberRepository) { this.memberRepository = memberRepository; } // 회원가입 public Long join(Member member) { // 같은 이름이 있는 중복 회원 검증 후 중복 있으면 예외처리 validateDuplicateMember(member); memberRepository.save(member); return member.getId(); } private void validateDuplicateMember(Member member) { // ifPresent : optional 객체 메서드 memberRepository.findByName(member.getName()) .ifPresent(m -> { throw new IllegalStateException("이미 존재하는 회원입니다."); }); } // 회원 전체 조회 public List<Member> findMembers() { return memberRepository.findAll(); } // 회원 한 명 조회 public Optional<Member> findOne(Long memberId) { return memberRepository.findById(memberId); } }

@SpringBootTest // 1️⃣ 스프링 컨테이너까지 띄우는 통합테스트 @Transactional // 2️⃣ 테스트 실행 후에 롤백을 해줘서 각 테스트가 끝난 후에 DB 다시 원상복구 public class MemberServiceIntegrationTest { // 3️⃣ 필드 기반 auto injection 받음 @Autowired MemberService memberService; @Autowired MemberRepository memberRepository; @Test // @Commit // 4️⃣ @Transactional 어노테이션이 있더라도 DB에 커밋까지 해서 테스트가 끝나도 DB에 남음 void 회원가입() { // given (주어진 상황) Member member = new Member(); member.setName("hello"); // when (검증하려고 하는 상황) Long saveId = memberService.join(member); // then (검증) Member findMember = memberService.findOne(saveId).get(); assertThat(member.getName()).isEqualTo(findMember.getName()); } @Test public void 중복_회원가입_예외() { // given Member member1 = new Member(); member1.setName("spring"); // member1 과 중복된 이름으로 설정 Member member2 = new Member(); member2.setName("spring"); // when memberService.join(member1); // then IllegalStateException e = assertThrows(IllegalStateException.class, () -> memberService.join(member2)); assertThat(e.getMessage()).isEqualTo("이미 존재하는 회원입니다."); /* 같은 로직 try{ memberService.join(member2); fail(); } catch (IllegalStateException e) { assertThat(e.getMessage()).isEqualTo("이미 존재하는 회원입니다."); } */ } }

// 인터페이스에서 인터페이스를 받아올 땐 extends 를 사용 // 인터페이스는 다중상속이 가능 // @Bean 설정 안해줘도 스프링이 알아서 등록해줌 public interface SpringDataJpaMemberRepository extends JpaRepository<Member, Long>, MemberRepository { // 커스텀 메서드 추가 // 인터페이스만 만들어줘도 스프링 데이터 JPA 가 알아서 구현해줌 // select m from Member as m where m.name = ? JPQL 로 번역돼서 실행됨 @Override Optional<Member> findByName(String name); }

@Configuration public class SpringConfig { private final MemberRepository memberRepository; // 1️⃣ 스프링 데이터 JPA 가 등록해준 MemberRepository bean 을 이용해서 DI 받음 @Autowired public SpringConfig(MemberRepository memberRepository) { this.memberRepository = memberRepository; } @Bean public MemberService memberService() { return new MemberService(memberRepository); } }