스프링(Spring) DB 접근 기술(순수 JDBC, 스프링 JdbcTemplate) - 1

순수 JDBC

build.gradle 스프링 부트 관련 라이브러리 추가

• Jdbc, h2

 

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

 

Repository 구현 형태

    public Member save(Member member) {
        String sql = "insert into member(name) values(?)";

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

        try {
            conn = getConnection();
            pstmt = conn.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS);
            pstmt.setString(1, member.getName());
            pstmt.executeUpdate();
            rs = pstmt.getGeneratedKeys();

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

 

Connection은 DB 트랜잭션과 관련한 이유로 동일한 것으로 유지해야 한다.

• Connection을 얻을 때, DataSourceUtils 로 커넥션을 얻으면 동일한 커넥션을 유지시켜준다.

DataSourceUtils.getConnection(dataSource)

• Connection을 해제할 때도 마찬가지로 DataSourceUtils를 사용한다.

DataSourceUtils.releaseConnection(conn, dataSource)

• dataSource를 통해서 직접 Connection을 얻으면 다른 Connection이 생성된다.

 

---

스프링 JdbcTemplate

build.gradle 스프링 부트 관련 라이브러리 추가

• Jdbc, h2

 

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

 

Repository 구현 형태

private final JdbcTemplate jdbcTemplate;

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


    @Override
    public Member save(Member member) {

        SimpleJdbcInsert jdbcInsert = new SimpleJdbcInsert(jdbcTemplate);
        jdbcInsert.withTableName("member").usingGeneratedKeyColumns("id"); // 테이블명, pk 넣어서 알아서 insert구문 만들어줌

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

    //콜백
    private RowMapper<Member> memberRowMapper() {
        return new RowMapper<Member>() {
            @Override
            public Member mapRow(ResultSet rs, int rowNum) throws SQLException {
                Member member = new Member();
                member.setId(rs.getLong("id"));
                member.setName(rs.getString("name"));
                return member;
            }
        };
    }

 

스프링 jdbcTemplate과 MyBatis 같은 라이브러리는 jdbc api에서 봤던 반복 코드를 대부분 제거해 준다. 하지만 SQL은 마찬가지로 직접 작성해야 한다.

• 기존 Jdbc(Connection, PreparedStatement, ResultSet 등)의 반복 코드가 사라지고 RowMapper가 등장하여 결과 값을 받아오는 것을 확인할 수 있다.

 

save 메소드의 SimpleJdbcInsert와 같은 객체를 이용해서 SQL 작성없이 데이터를 추가할 수도 있다.

• 테이블 명과 PK 값을 통해 INSERT문 생성