JDBC 활용해 API 개발하기2 - CRUD 개발

이전에 유저 정보를 List에 저장했다면, 이번에는 DB에 저장하도록 코드를 바꿀 것이다.

 

먼저 User 테이블을 생성한다.

create table user(
   id bigint auto_increment,
   name varchar(25),
   age int,
   primary key(id)
);

 

 

jdbcTemplate을 활용해 MySQL로 SQL을 보낼 수 있다. UserController에서 jdbcTemplate을 선언하자.

final 변수를 만들고 생성자를 만들면,  스프링이 자동으로 jdbcTemplate을 주입해준다.

private final JdbcTemplate jdbcTemplate;

public UserController(JdbcTemplate jdbcTemplate){
	this.jdbcTemplate = jdbcTemplate;
}

 

 

기존 유저 API 수정

유저 생성 API 수정

@PostMapping("/user")
public void saveUser(@RequestBody UserCreateRequest request){
	String sql = "insert into user(name, age) values (?,?)";
    jdbcTemplate.update(sql, request.getName(), request.getAge());
}

 

jdbcTemplate.update는 INSERT, UPDATE, DELETE 쿼리에서 사용 가능하다.

첫 번째 파라미터로 sql을 넣고, ?에 대입할 값을 차례로 넣어준다.

 

 

 

유저 조회 API 수정

@GetMapping("/user")
public List<UserResponse> getUsers(){
    String sql = "SELECT * FROM user";
    
    return jdbcTemplate.query(sql, new RowMapper<UserResponse>(){
    	@Override
        public UserResponse mapRow(ResultSet rs, int rowNum) throws SQLException {
            long id = rs.getLong("id");
            String name = rs.getString("name");
            int age = rs.getInt("age");
            
            return new UserResponse(id, name, age);
        }
    }
}

.query(sql, RowMapper 클래스)는 SELECT 쿼리를 날려준다.

ResultSet 객체에 결과가 담겨 있고, getType("필드명")을 사용해 값을 가져올 수 있다.

마지막으로, DB에서 조회해 온 유저 정보를 UserResponse로 변환한다.

 

 

위의 코드는 람다를 사용하여 간결화할 수 있다.

@GetMapping("/user")
public List<UserResponse> getUsers(){
    String sql = "SELECT * FROM user";
    return jdbcTemplate.query(sql, (rs, rowNum) -> {
    	long id = rs.getLong("id");
        String name = rs.getString("name");
        int age = rs.getInt("age");
        return new UserResponse(id, name, age);
    });
   }

 

 

DB에 유저 정보를 저장하도록 API들을 수정하였다.

이어서 유저 업데이트와 삭제 API도 추가로 개발해보자

 

 

유저 API 추가 개발

유저 업데이트 API 개발

HTTP Method	PUT
HTTP Path	/user
HTTP Body	{"id" : Long, "name" : String}

 

DTO를 생성하자

@Getter
public class UserUpdateRequest {
    private Long id;
    private String name;
}

 

UserController 안에 updateUser() 를 작성한다.

@PutMapping("/user")
public void updateUser(@RequestBody UserUpdateRequest request){
    String updateSql = "UPDATE user SET name = ? WHERE id = ?";
    jdbcTemplate.update(updateSql, request.getName(), request.getId());
}

 

 

업데이트할 유저가 없다면, 예외를 던지는 코드를 추가하자

String readSql = "SELECT * FROM user WHERE id = ?";
boolean isUserNotExist = jdbcTemplate.query(readSql, (rs, rowNum) -> 0, request.getId()).isEmpty();
if (isUserNotExist) {
	throw new IllegalArgumentException();
}

[1] id를 기준으로 유저 존재 유무를 확인하는 select문을 작성한다.

[2] SELECT 쿼리를 날려 DB에 데이터가 있는지 확인한다.

     유저 데이터가 없으면 비어있는 List가 반환된다. 이 경우 isEmpty()로 참을 반환한다.

     

 

 

유저 삭제 API 개발

HTTP Method	Delete
HTTP Path	/user
HTTP Query	name

쿼리 파라미터가 1개이므로, DTO를 따로 생성하지 않고 @RequestParam을 사용했다.

 

@DeleteMapping("/user")
public void deleteUser(@RequestParam String name){
    String readSql = "SELECT * FROM user WHERE name = ?";
    boolean isUserNotExist = jdbcTemplate.query(readSql, (rs, rowNum) -> 0, name).isEmpty();
    if (isUserNotExist){
    	throw new IllegalArgumentException();
    }
    
    String deleteSql = "DELETE FROM user WHERE name = ?";
    jdbcTemplate.update(Sql, name);
}

이번에도 예외 처리를 해주는데, id가 아닌 name을 기준으로 readSql 쿼리를 날린다.

 

 

 

현재는 Controller에서 많은 기능을 수행한다.

다음 글에서 작성한 코드들을 삼단 분리시킬 것이다.

JDBC를 활용해 API 개발하기3 - 역할 분리

 

 

 

---

참고

https://www.inflearn.com/course/%EC%9E%90%EB%B0%94-%EC%8A%A4%ED%94%84%EB%A7%81%EB%B6%80%ED%8A%B8-%EC%84%9C%EB%B2%84%EA%B0%9C%EB%B0%9C-%EC%98%AC%EC%9D%B8%EC%9B%90/dashboard

자바와 스프링 부트로 생애 최초 서버 만들기, 누구나 쉽게 개발부터 배포까지! [서버 개발 올인