[JdbcTemplate] RowMapper에 대해

jdbctemplate에서 select는 query()와 queryForObject() 라는 메소드를 사용합니다.

• query() 는 쿼리문 실행을 통해 결과 row가 하나일 경우 사용합니다.
• queryForObject() 는 쿼리문 실행을 통해 결과 row가 하나 이상일 때 사용합니다.

query(), queryForObject() 메소드는 기본적으로 파라미터로 아래 세 가지를 받습니다.

1. sql : 수행할 SQL 쿼리문 

2. newRowMapper() : RowMapper<Type> 객체를 넣어줍니다. 

3. new Object[]{} : SQL 쿼리문의 물음표 값에 세팅할 값 

 

3번의 경우 제너릭 타입에 Type과 맞는 익명 클래스 로직 방식으로 작성해줍니다.

RowMapper<T> Interface

@FunctionalInterface
public interface RowMapper<T> {

   /**
    * Implementations must implement this method to map each row of data
    * in the ResultSet. This method should not call {@code next()} on
    * the ResultSet; it is only supposed to map values of the current row.
    * @param rs the ResultSet to map (pre-initialized for the current row)
    * @param rowNum the number of the current row
    * @return the result object for the current row (may be {@code null})
    * @throws SQLException if an SQLException is encountered getting
    * column values (that is, there's no need to catch SQLException)
    */
   @Nullable
   T mapRow(ResultSet rs, int rowNum) throws SQLException;

}

• mapRow() 메소드는 SQL 실행 결과로 구한 ResultSet에서 한 행의 데이터를 읽어와 자바 객체로 변환하는 매퍼 기능을 구현합니다.
• RowMapper 인터페이스를 구현한 클래스를 작성할 수도 있지만, 임의 클래스나 람다식으로 RowMapper의 객체를 생성해서 query() 메소드에 전달하는 경우가 많습니다.

익명 클래스로 구현하기 

@Override
public Optional<Item> findById(Long id) 
{
    String sql = "select id, item_name, price, quantity from item where id=?";
    try
    {
        Item item = template.queryForObject(sql,
                new RowMapper<Item>() {
                    @Override
                    public Item mapRow(ResultSet rs, int rowNum) throws SQLException {
                        Item item = new Item();
                        item.setId(rs.getLong("id"));
                        item.setItemName(rs.getString("item_name"));
                        item.setPrice(rs.getInt("price"));
                        item.setQuantity(rs.getInt("quantity"));
                        return item;
                    }
                }, id);
        return Optional.of(item);
    }catch(EmptyResultDataAccessException e)
    {
        return Optional.empty();
    }
}

• findById() 메소드는 jdbcTemplate의 query() 메소드를 이용해서 쿼리를 실행합니다.
• 이 쿼리는 인덱스 파라미터(?)를 포함하고 있습니다. 인덱스 파라미터 물음표가 여러개인 경우 만약 이 query() 메소드의 세 번째 파라미터인 가변인자가 값이 여러개인 경우, 각 값을 콤마로 구분하면 됩니다. ( id, price, .. ) 
• mapRow 메소드는 ResultSet으로부터 데이터를 읽어와 Item 객체를 생성해서 리턴하도록 구현했습니다.

 

람다식으로 구현

@Override
public Optional<Item> findById(Long id) {
    String sql = "select id, item_name, price, quantity from item where id=?";
    try
    {
        Item item = template.queryForObject(sql, itemRowMapper(), id);
        return Optional.of(item);
    }catch(EmptyResultDataAccessException e)
    {
        return Optional.empty();
    }
}

private RowMapper<Item> itemRowMapper() {
    return ( (rs, rowNum) -> {
        Item item = new Item();
        item.setId(rs.getLong("id"));
        item.setItemName(rs.getString("item_name"));
        item.setPrice(rs.getInt("price"));
        item.setQuantity(rs.getInt("quantity"));
        return item;
    });
}

• 마찬가지로 Item객체를 만들고 rs(ResultSet)으로부터 데이터를 읽어와 setter 주입하여 객체를 리턴하도록 구현했습니다.

queryForObject() Logic  

1. sql과 가변인자(?)로 받은 값을 통해 SQL 쿼리를 생성 후 실행하여 쿼리 실행 결과 ResultSet에 저장.

2. itemRowMapper에서 ResultSet을 통해 생성된 객체(Item) 리턴.

(+ query()의 경우에는 ResultSet에 row가 여러 개인 경우 List<T> 로 리턴) 

 

 

<참고자료>

RowMapper (Spring Framework 6.0.7 API)

 

RowMapper에 대해!