[Spring] 6.스프링 DB 접근 기술

[Spring] 6.스프링 DB 접근 기술

 

1. H2 데이터베이스 설치

- 교육용으로좋음

- download (1.4.200) -> all platforms)

- cd h2 -> cd bin -> chmod 755 h2.sh (권한) -> ./h2.sh (실행)

- 실행되고 아이피 안잡힐때 (아이피:8082 -> localhost:8082)

- JDBC URL -> jdbc:h2~/test -> 연결

- ll -> ls -all -> test.mv.db 파일이 있어야함

- 파일 직접 접근 안하고 여러군데서 접근하도록 -> JDBC URL ->  jdbc:h2:tcp://localhost/~/test

- create table

- DDL 관리 ->src밖에 sql 폴더 만들어서 ddl.sql 만들어서 관리 (명령어) ex) drop table, create table~

 

2. 순수 Jdbc

- 환경설정

- JdbcMemberRepository

public class JdbcMemberRepository implements MemberRepository {
  @Override
  public Member save(Member member) {
    return null;
  }
  
  @Override
  public Optional<Member> findById(Long id) {
    return Optional.empty();
  }
}

 

* 조심해야할점

-> DataSourceUtils 통해서 getConnection & releaseConnection (connect, release 해줄때)

-> 이렇게 해야 database 트랜잭션 유지시켜줌

 

SpringConfig

-> @Bean 레포지토리 return 부분 수정 -> MemoryMemberRepo -> JdbcMemberRepo(dataSource)

 

datasource

private DataSource dataSource;

@Autowired
public SpringConfig(DataSource dataSource) {
  this.dataSource = dataSource;
}

-> 스프링 자체로 데이터소스 만들어주고 주입해줌

Controller가 Service 의존하고, Service가 Repo 의존

-> Jdbc로 쉽게 바꿔줄수있음

 

** 개방폐쇄원칙 (OCP, open closed principle)

= 확장에 열려있고 수정/변경에는 닫혀있다.

= 기능 변경해도 동작코드 수정안할수있음 (기존코드)

= 스프링의 DI

 

3. 스프링 통합 테스트

@SpringBootTest 어노테이션 + @Transactional 어노테이션

@SpringBootTest
@Transactional
class MemberServiceIntegrationTest {
  @Autowired MemberService memberService;
  @Autowired MemberRepository memberRepository;
  
  @Test
  public void 회원가입() throws Exception {
    //Given
    Member member = new Member();
    member.setName("hello");
    
    //When
    Long saveId = memberService.join(member);

    //Then
    Member findMember = memberRepository.findById(saveId).get();
    assertEquals(member.getName(), findMember.getName());
  }
  
  @Test
  public void 중복_회원_예외() throws Exception {
    //Given
    Member member1 = new Member();
    member1.setName("spring");
    Member member2 = new Member();
    member2.setName("spring");
    
    //When
    memberService.join(member1);
    IllegalStateException e = assertThrows(IllegalStateException.class,
      () -> memberService.join(member2));//예외가 발생해야 한다. 
    
    assertThat(e.getMessage()).isEqualTo("이미 존재하는 회원입니다.");
  } 
}

@SpringBootTest : 스프링 컨테이너와 테스트를 함께 실행한다.

@Transactional : 테스트 케이스에 이 애노테이션이 있으면, 테스트 시작 전에 트랜잭션을 시작하고, 테스트 완료 후에 항상 롤백한다.

이렇게 하면 DB에 데이터가 남지 않으므로 다음 테스트에 영향을 주지 않는다.

-> aftereach, beforeeach 필요없음!

 

* 순수 단위 테스트가 좋음 (통합테스트보다)

* 스프링 컨테이너 없이 테스트하는게 좋음

 

4. 스프링 JdbcTemplate (Mybatis 비슷)

- 라이브러리 (실무에서 많이 씀!)

- JDBC API에서 반복코드를 대부분 제거해줌

- SQL은 직접 작성해야함

 

- 스프링 JdbcTemplate

public class JdbcTemplateMemberRepository implements MemberRepository {
  private final JdbcTemplate jdbcTemplate;
  public JdbcTemplateMemberRepository(DataSource dataSource) {
    jdbcTemplate = new JdbcTemplate(dataSource);
  }

  @Override
  public Member save(Member member) {
    SimpleJdbcInsert jdbcInsert = new SimpleJdbcInsert(jdbcTemplate);
    jdbcInsert.withTableName("member").usingGeneratedKeyColumns("id");
 
    Map<String, Object> parameters = new HashMap<>();
    parameters.put("name", member.getName());
    Number key = jdbcInsert.executeAndReturnKey(new MapSqlParameterSource(parameters));
    member.setId(key.longValue());
    return member;
  }
  
  @Override
  public Optional<Member> findById(Long id) {
    List<Member> result = jdbcTemplate.query("select * from member where id = ?", memberRowMapper(), id);
    return result.stream().findAny();
  }
    
  @Override
  public List<Member> findAll() {
    return jdbcTemplate.query("select * from member", memberRowMapper());
  }
  
  @Override
  public Optional<Member> findByName(String name) {
    List<Member> result = jdbcTemplate.query("select * from member where name = ?", memberRowMapper(), name);
    return result.stream().findAny();
  }
    
  private RowMapper<Member> memberRowMapper() {
    return (rs, rowNum) -> {
      Member member = new Member();
      member.setId(rs.getLong("id"));
      member.setName(rs.getString("name"));
      return member;
    }; 
  }
}

* 생성자 하나면 @Autowired 생략가능

 

5. JPA

- 기존의 반복코드 + 기본 sql 직접 만들어서 실행

- sql과 데이터 중심 설계 -> 객체 중심의 설계로 패러다임 전환 가능

- 개발 생산성 향상

 

설정

dependencies

dependencies {
    implementation 'org.springframework.boot:spring-boot-starter-thymeleaf'
    implementation 'org.springframework.boot:spring-boot-starter-web'
    //implementation 'org.springframework.boot:spring-boot-starter-jdbc' implementation 'org.springframework.boot:spring-boot-starter-data-jpa' runtimeOnly 'com.h2database:h2' testImplementation('org.springframework.boot:spring-boot-starter-test') {
    exclude group: 'org.junit.vintage', module: 'junit-vintage-engine'
  }

resources/application.properties

spring.datasource.url=jdbc:h2:tcp://localhost/~/test
spring.datasource.driver-class-name=org.h2.Driver
spring.datasource.username=sa
spring.jpa.show-sql=true // jpa가 날린 sql을 볼수있음
spring.jpa.hibernate.ddl-auto=none // jpa 사용하면 회원객체(테이블로) 자동으로 생성해주는데 여기서는 상관없음

 

- JPA 쓰려면 엔티티랑 맵핑해야됨

- JPA = 인터페이스(자바진영 표준 인터페이스) / 하이버네이트 = 구현체

- ORM(Object Relational Mapping) 기술, 어떻게? 어노테이션

 

Member

 

@Entity
public class Member {

  @Id @GeneratedValue(strategy = GenerationType.IDENTITY)
  private Long id;
  
  @Column(name = "username")
  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;
  }
}

 

* @Id / @GenerateValue -> identity 전략 & id 자동 생성

* @Column -> db 칼럼명이랑 매칭  

 

JPA repo 생성

public class JpaMemberRepository implements MemberRepository {
  private final EntityManager em;
  
  public JpaMemberRepository(EntityManager em) {
    this.em = em;
  }

  public Member save(Member member) {
    em.persist(member);
    return member;
  }

  public Optional<Member> findById(Long id) {
    Member member = em.find(Member.class, id);
    return Optional.ofNullable(member);
  }
  
  public List<Member> findAll() {
    return em.createQuery("select m from Member m", Member.class).getResultList();
  }
  
  public Optional<Member> findByName(String name) {
    List<Member> result = em.createQuery("select m from Member m where m.name = :name", Member.class)
                  .setParameter("name", name)
                  .getResultList();
    return result.stream().findAny();
  }
}

- 스프링부트가 내부적으로(자동) Entity Manager 만들어줌

- 그래서 Entity Manager 주입받아야함

 

서비스 계층에 트랜잭션 추가

import org.springframework.transaction.annotation.Transactional

@Transactional
public class MemberService {}

 

Configuration

@Configuration
public class SpringConfig {
  
  private final DataSource dataSource;
  private final EntityManager em;
  
  public SpringConfig(DataSource dataSource, EntityManager em) {
    this.dataSource = dataSource;
    this.em = em;
  }
  
  @Bean
  public MemberService memberService() {
    return new MemberService(memberRepository());
  }
  
  @Bean
  public MemberRepository memberRepository() {
    // return new MemoryMemberRepository();
    // return new JdbcMemberRepository(dataSource);
    // return new JdbcTemplateMemberRepository(dataSource);
    return new JpaMemberRepository(em);
  }
}

 

6. 스프링 데이터 JPA

- JPA 배우고 스프링 데이터 JPA 배우는 것이 좋음! 

 

스프링 데이터 JPA 회원 리포지토리

public interface SpringDataJpaMemberRepository extends JpaRepository<Member,Long>, MemberRepository {
        Optional<Member> findByName(String name);
    }

- <Member, Long> : 멤버의 pk

- 인터페이스 다중상속 가능

 

스프링 데이터 JPA 회원 리포지토리를 사용하도록 스프링 설정 변경

 @Configuration
public class SpringConfig {
  private final MemberRepository memberRepository;
  
  public SpringConfig(MemberRepository memberRepository) {
    this.memberRepository = memberRepository;
  }
  
  @Bean
  public MemberService memberService() {
    return new MemberService(memberRepository);
  }
  
}

- 스프링 데이터 JPA가 SpringDataJpaMemberRepository 를 스프링 빈으로 자동 등록해준다.

 

[원리]

스프링 데이터 JPA 제공 클래스

- jpa + 스프링 데이터 jpa 기본내장된거 가져다 쓰는것

- 통용되지 않는 것들 (name으로 찾는 것 등등)

-> 인터페이스에 추가

public interface SpringDataJpaMemberRepository extends JpaReopository<Member, Long>, MemberRepository {
  @Override
  Optional<Member> findByName(String name):
}

 

-> 실무에서는 동적쿼리의 경우 Querydsl 활용 (JPA + Spring Data JPA + Querydsl)

->  위 세조합이 안통하면 JPA 순수 기술도 제공하긴함 (JPA 네이티브 쿼리) or JdbcTemplate