[SPRING]스프링 입문 - 코드로 배우는 스프링 부트, 웹 MVC, DB 접근 기술 섹션6 (스프링 DB 접근 기술)

💡H2 데이터베이스 설치

> https://www.h2database.com/html/download-archive.html

Archive Downloads

여기에 가서 1.4.200버전을 설치해준다. 
 

create a new database를 해준 다음, 

database를 생성해준다.
 

아이콘을 더블클릭하여, 맞게 적어준 후 연결을 누르면 

데이터베이스가 연결된다.

💻 H2 테이블 생성 및 실행

member 테이블을 생성한다.

drop table if exists member CASCADE;
create table member
(
 id bigint generated by default as identity,
 name varchar(255),
 primary key (id)
);

 

SELECT * FROM MEMBER

select 명령어로 member테이블을 조회할 수 있다.

조회한 화면

INSERT INTO MEMBER(NAME) VALUES('Spring')

insert 명령어로 member 테이블에 값을 추가하면, 

데이터가 추가된 것을 확인할 수 있다.
 

💡순수 JDBC

직접 memory가 아닌 DB에 데이터를 저장하여 넣고 빼는 방법 (옛날에 하던 방식)
 

💻 순수 Jdbc 환경설정 

dependencies {
	implementation 'org.springframework.boot:spring-boot-starter-thymeleaf'
	implementation 'org.springframework.boot:spring-boot-starter-web'
	testImplementation 'org.springframework.boot:spring-boot-starter-test'
	implementation 'org.springframework.boot:spring-boot-starter-jdbc'
	runtimeOnly 'com.h2database:h2'
}

build.gradle에 dependencies에 jdbc, h2 데이터베이스 관련 라이브러리 추가해준다.
 

spring.datasource.url=jdbc:h2:~/jpamember
spring.datasource.driver-class-name=org.h2.Driver

application.properties에 스프링 부트 데이터베이스 연결 설정 추가
 

💻 Jdbc 리포지토리 생성

repository에 JdbcMemberRepository라는 새로운 class를 생성해준 다음,

package hello.hellospring.repository;
import hello.hellospring.domain.Member;
import org.springframework.jdbc.datasource.DataSourceUtils;
import javax.sql.DataSource;
import java.sql.*;
import java.util.ArrayList;
import java.util.List;
import java.util.Optional;
public class JdbcMemberRepository implements MemberRepository {
    private final DataSource dataSource;
    public JdbcMemberRepository(DataSource dataSource) {
        this.dataSource = dataSource;
    }
    @Override
    public Member save(Member member) {
        String sql = "insert into member(name) values(?)";

        Connection conn = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null; //결과를 받음

        try {
            conn = getConnection();//connection 가지고 옴
            pstmt = conn.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS);

            pstmt.setString(1, member.getName()); //1->?랑 매칭됨

            pstmt.executeUpdate();//실제 쿼리 날라감
            rs = pstmt.getGeneratedKeys(); //1번이면 1번 반환, 2번이면 2번 반환

            if (rs.next()) {
                member.setId(rs.getLong(1));
            } else {
                throw new SQLException("id 조회 실패");
            }
            return member;
        } catch (Exception e) {
            throw new IllegalStateException(e);
        } finally {
            close(conn, pstmt, rs);
        }
    }
    @Override
    public Optional<Member> findById(Long id) {
        String sql = "select * from member where id = ?";

        Connection conn = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;

        try {
            conn = getConnection();
            pstmt = conn.prepareStatement(sql);
            pstmt.setLong(1, id);

            rs = pstmt.executeQuery();

            if(rs.next()) {
                Member member = new Member();
                member.setId(rs.getLong("id"));
                member.setName(rs.getString("name"));
                return Optional.of(member);
            } else {
                return Optional.empty();
            }
        } catch (Exception e) {
            throw new IllegalStateException(e);
        } finally {
            close(conn, pstmt, rs);
        }
    }
    @Override
    public List<Member> findAll() {
        String sql = "select * from member";
        Connection conn = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        try {
            conn = getConnection();
            pstmt = conn.prepareStatement(sql);
            rs = pstmt.executeQuery();
            List<Member> members = new ArrayList<>();
            while(rs.next()) {
                Member member = new Member();
                member.setId(rs.getLong("id"));
                member.setName(rs.getString("name"));
                members.add(member);
            }
            return members;
        } catch (Exception e) {
            throw new IllegalStateException(e);
        } finally {
            close(conn, pstmt, rs);
        }
    }
    @Override
    public Optional<Member> findByName(String name) {
        String sql = "select * from member where name = ?";
        Connection conn = null;
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        try {
            conn = getConnection();
            pstmt = conn.prepareStatement(sql);
            pstmt.setString(1, name);
            rs = pstmt.executeQuery();
            if(rs.next()) {
                Member member = new Member();
                member.setId(rs.getLong("id"));
                member.setName(rs.getString("name"));
                return Optional.of(member);
            }
            return Optional.empty();
        } catch (Exception e) {
            throw new IllegalStateException(e);
        } finally {
            close(conn, pstmt, rs);
        }
    }
    private Connection getConnection() {
        return DataSourceUtils.getConnection(dataSource);
    }
    private void close(Connection conn, PreparedStatement pstmt, ResultSet rs)
    {
        try {
            if (rs != null) {
                rs.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        try {
            if (pstmt != null) {
                pstmt.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
        try {
            if (conn != null) {
                close(conn);
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }
    }
    private void close(Connection conn) throws SQLException {
        DataSourceUtils.releaseConnection(conn, dataSource);
    }
}

위 코드를 작성해준다.
 

💻 Spring 설정 변경

package spring.study1;

...

@Configuration
public class SpringConfig {

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

	...

    @Bean
    public MemberRepository memberRepository() {
        // return new MemoryMemberRepository();
        return new JdbcMemberRepository(dataSource);
    }
}

이렇게 코드를 작성해준 후에 localhost:8080/members 에 들어가면 H2 DB에서 추가한 데이터들의 목록이 보인다.

추가적으로 새롭게 회원을 등록해주면 ex)123

DB에도 새롭게 추가된 것도 볼 수 있다.
 

💻 원리 설명

MemberService는 MemberRepository를 의존하고, MemberRepository 구현체에는 Memroy와 Jdbc가 있다.
 

스프링 컨테이너에서 설정을 바꿔서, 기존의 MemoryMemberRepository를 spring bean에서 제외시키고 JdbcMemberRepository를 새로운 spring bean으로 등록해준다.
 

 

💡스프링 통합 테스트

스프링 컨테이너와 DB까지 연결한 통합테스트를 실시한다.
 

💻 회원 서비스 통합 테스트

MemberServiceTest의 내용을 복붙하여 새로운 MemberServiceIntegrationTest를 만들어준다.

package hello.hellospring.service;

import hello.hellospring.domain.Member;
import hello.hellospring.repository.MemberRepository;
import hello.hellospring.repository.MemoryMemberRepository;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.transaction.annotation.Transactional;

import static org.assertj.core.api.Assertions.assertThat;
import static org.junit.jupiter.api.Assertions.assertThrows;

@SpringBootTest
@Transactional //test가 끝나면 rollback을 해줘서 데이터가 다 지워짐 (testcase에 붙었을 때만, 그냥 MemberService일 때는 x)
class MemberServiceIntegrationTest {

    //MemberService memberService = new MemberService(); // member service

    @Autowired MemberService memberService;
    @Autowired MemberRepository memberRepository;



    @Test
    void 회원가입() {
        //given
        Member member = new Member();
        member.setName("spring");

        //when
        Long saveId = memberService.join(member);

        //then
        Member findMember = memberService.findOne(saveId).get();
        //memberRepository에서 가져와서 비교해야되니까 간단한 findOne으로 객체 가져옴
        // 회원가입한 member의 id가 저장소에 있으면, 해당 member 객체를 findMember로
        assertThat(member.getName()).isEqualTo(findMember.getName());
    }

    @Test
    public void 중복_회원_예외() {
        //given
        Member member1 = new Member();
        member1.setName("spring");

        Member member2 = new Member();
        member2.setName("spring");

        //when
        memberService.join(member1);
//        try{
//            memberService.join(member2); //validate에서 걸려서 예외가 터짐
//            fail();
//        } catch (IllegalStateException e){
//            assertThat(e.getMessage()).isEqualTo("이미 존재하는 회원입니다.");
//        }
        //try catch문은 번거로움

        IllegalStateException e = assertThrows(IllegalStateException.class, () -> memberService.join(member2));

        assertThat(e.getMessage()).isEqualTo("이미 존재하는 회원입니다.");
        //then
        
    }

}

 

DELETE FROM MEMBER

DB에 있는 내용을 모두 지워준다.
 

💻 스프링 통합 테스트 설명

@Transactional 애노테이션을 사용하면, 테스트 실행 시 트랜잭션이 자동으로 관리된다. 테스트가 시작되기 전에 트랜잭션이 시작되고, 테스트가 끝나면 모든 데이터 변경사항은 자동으로 롤백된다.
이는 테스트 중에 데이터베이스에 데이터를 삽입하더라도, 테스트 종료 후에 이러한 변경사항이 실제 데이터베이스에 반영되지 않는다는 것을 의미한다. 결과적으로, 각 테스트 실행 후에 데이터베이스를 수동으로 정리할 필요가 없어진다.
반면에, @Transactional 애노테이션이 없는 경우, 테스트 중에 데이터베이스에 적용된 모든 변경사항이 실제로 반영된다. 이는 테스트를 반복적으로 실행할 때 데이터베이스에 중복된 데이터가 쌓이는 문제를 야기할 수 있으며, 이는 매번 테스트를 실행하기 전에 데이터베이스를 수동으로 정리해야 하는 번거로움을 초래한다.
결론적으로, @Transactional 애노테이션은 테스트 중 데이터베이스의 일관성을 유지하고, 테스트 후 정리 작업을 줄여주는 중요한 역할을 한다.