스프링 DB 접근 기술

이가현·2022년 9월 30일

스프링

목록 보기

5/6

✍️ h2 데이터베이스

값을 세팅하지 않고 DB에 넣으면 자동으로 generated by default as identity로 들어감

✍️ 스프링 통합 테스트

@SpringBootTest : 스프링 컨테이너와 테스트를 함께 실행한다.
@Transactional : 테스트 케이스에 이 애노테이션이 있으면, 테스트 시작 전에 트랜잭션을 시작하고, 테스트 완료 후에 항상 롤백한다. 이렇게 하면 DB에 데이터가 남지 않으므로 다음 테스트에 영향을 주지 않는다.

✍️ 스프링 JdbcTemplate

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

SQL은 직접 작성해야 한다.
✅ but ❗️ 나중에 SQL query도 작성해주는 JPA 존재.

public class JdbcTemplateMemberRepository implements MemberRepository {
    private final JdbcTemplate jdbcTemplate;
    public JdbcTemplateMemberRepository(DataSource dataSource) {
          jdbcTemplate = new JdbcTemplate(dataSource);  // 생성자가 한 개면 @Autowired 생략 가능
	}
    @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;
		}; 
	}
}

JPA

SQL과 데이터 중심의 설계에서 객체 중심의 설계로 패러다임을 전환을 할 수 있다.
-> 개발 생산성을 크게 높일 수 있다.

JPA Entity Mapping

	@Entity
    public class Member {
        @Id @GeneratedValue(strategy = GenerationType.IDENTITY) // pk, identity 순
        private Long id;
        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;
		}
     
 	}

JpaMemberRepository

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();
	  } 
}

트랜젝션

서비스 계층에 @Transactional 추가

해당 클래스의 메서드를 실행할 때 트랜잭션을 시작하고, 메서드가 정상 종료되면 트랜잭션을 커밋한다. (런타임 예외가 발생하면 롤백)

JPA를 통한 모든 데이터 변경은 트랜잭션 안에서 실행해야 한다.

스프링 설정 변경할 것들

@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 MemberRepository memberRepository() {
    	return new MemoryMemberRepository();
        return new JdbcMemberRepository(dataSource);
        return new JdbcTemplateMemberRepository(dataSource);
        return new JpaMemberRepository(em);
    }

}