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

순수 Jdbc와 동일한 환경설정을 하면 된다.

스프링 JdbcTemplate과 MyBatis 같은 라이브러리는 JDBC API에서 본 반복 코드를 대부분 제거해준다.

하지만 SQL은 직접 작성해야 한다.

RowMapper란?

RowMapper는 SQL 결과의 각 행을 Java 객체로 변환하는 "매핑 도구"

private RowMapper<Member> memberRowMapper(){
    return (rs, rowNum) -> {
        Member member = new Member();
        member.setId(rs.getLong("id"));      // DB 컬럼 "id" → 객체 필드
        member.setName(rs.getString("name")); // DB 컬럼 "name" → 객체 필드
        return member;
    };
}

 

• ResultSet rs: SQL 결과에서 한 줄(row)을 가져온 것
• rowNum: 현재 row의 인덱스
• 이 람다 함수는 Member 객체를 생성해서, DB 컬럼값을 setId, setName을 통해 채운 뒤 반환

SimpleJdbcInsert 란?

 

• SimpleJdbcInsert: Spring이 제공하는 편리한 insert 도우미 클래스
• JdbcTemplate을 기반으로 작동하므로, JdbcTemplate 객체를 생성자에 넣어준다.

 

@Override
public Member save(Member member) throws SQLException {
    //SimpleJdbcInsert 사용하면 Insert문을 적을 필요 없음
    SimpleJdbcInsert jdbcInsert = new SimpleJdbcInsert(jdbcTemplate);
    // 삽입할 테이블명을 지정 (member)
    // DB가 자동 생성해주는 PK 컬럼 이름을 지정 (id) → insert 이후 id 값을 자동으로 받아온다
    jdbcInsert.withTableName("member").usingGeneratedKeyColumns("id");

    // 삽입할 컬럼과 값 지정
    // 여기서는 name 컬럼만 테이블에 존재한다고 가정하고 "name" 값을 세팅
    Map<String, Object> parameters = new HashMap<>();
    parameters.put("name", member.getName());

    // INSERT 실행
    // 실행 후 자동 생성된 PK (id) 값을 Number 타입으로 반환
    Number key = jdbcInsert.executeAndReturnKey(new MapSqlParameterSource(parameters));
    // 반환된 id 값을 member 객체에 저장
    member.setId(key.longValue());
    return member;
}

 

스프링 JdbcTemplate 회원 리포지토리

package hello.hello_spring.repository;

import hello.hello_spring.domain.Member;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
import org.springframework.jdbc.core.simple.SimpleJdbcInsert;

import javax.sql.DataSource;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Optional;

public class JdbcTemplateMemberRepository implements MemberRepository{

    private final JdbcTemplate jdbcTemplate;

    public JdbcTemplateMemberRepository(DataSource dataSource) {
        jdbcTemplate = new JdbcTemplate(dataSource);
    }


    @Override
    public Member save(Member member) throws SQLException {
        //SimpleJdbcInsert 사용하면 Insert문을 적을 필요 없음
        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> findMyId(Long id) throws SQLException {
        // 왜 템플릿이냐 -> 디자인 패턴 템플릿을 사용해서 줄였기 때문
        List<Member> result= jdbcTemplate.query("select * from member where id=?", memberRowMapper());
        return result.stream().findAny();
    }

    @Override
    public Optional<Member> findMyName(String name) throws SQLException {
        List<Member> result= jdbcTemplate.query("select * from member where name=?", memberRowMapper());
        return result.stream().findAny();
    }

    @Override
    public List<Member> findAll() throws SQLException {
        return jdbcTemplate.query("select * from member", memberRowMapper());
    }

    private RowMapper<Member> memberRowMapper(){
        return (rs, rowNum) -> {
            Member member = new Member();
            member.setId(rs.getLong("id"));
            member.setName(rs.getString("name"));
            return member;
        };
    }
}

JdbcTemplate을 사용하도록 스프링 설정 변경

package hello.hello_spring;

import hello.hello_spring.repository.JdbcMemberRepository;
import hello.hello_spring.repository.JdbcTemplateMemberRepository;
import hello.hello_spring.repository.MemberRepository;
import hello.hello_spring.repository.MemoryMemberRepository;
import hello.hello_spring.service.MemberService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.sql.DataSource;

@Configuration
public class SpringConfig {

    private DataSource dataSource;

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

    @Bean
    public MemberService memberService(){
        return new MemberService(memberRepository());
    }

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