[Spring 체스 - 3단계] 다니(이다은) 미션 제출합니다.

docs/README.md

@@ -4,32 +4,54 @@
 - Spring Framework를 활용하여 애플리케이션을 구동한다.
 - Spark를 대체하여 Spring MVC를 활용하여 요청을 받고 응답을 한다.
 - Spring JDBC를 활용하여 DB 접근하던 기존 로직을 대체한다.
+<br/>
 
 ## step1 프로그래밍 요구사항
 - 스프링 애플리케이션으로 체스가 실행 가능 해야한다.
 - @Controller나 @RestController를 활용하여 요청을 받아야 한다.
 - Spring JDBC에서 제공하는 JdbcTemplate를 이용하여 Connection을 직접 만들어 주는 로직을 대체한다.
 - JdbcTemplate는 매번 새로 생성하지 않고 빈 주입을 받아서 사용한다.
+<br/>
+
+## step2 요구사항
+- 체스 게임을 진행할 수 있는 방을 만들어서 동시에 여러 게임이 가능하도록 하기
+<br/>
+
+## step2 프로그래밍 요구사항
+### 체스방 만들기
+- localhost:8080 요청 시 노출되는 페이지에 체스방을 만들 수 있는 버튼이 있다.
+- 체스방 만들기 버튼을 누르면 새로운 체스판이 초기화된다.
+- 체스방에는 고유 식별값이 부여된다. (이 고유 식별값은 체스방 주소에서 사용됨)
+### 체스방 목록 조회하기
+- localhost:8080 요청 시 체스방 목록을 조회할 수 있다.
+- 체스방 목록에는 체스방 제목이 표시된다.
+### 체스방 참여하기
+- localhost:8080 요청 시 체스방 목록에서 체스방을 클릭하면 체스 게임을 이어서 진행할 수 있다.
+<br/>
 
 ## DB DDL
 ```sql
 -- -----------------------------------------------------
--- Table `mydb`.`piece`
+-- Table `mychess`.`room`
 -- -----------------------------------------------------
-CREATE TABLE IF NOT EXISTS `mydb`.`piece` (
-`id` BIGINT NOT NULL AUTO_INCREMENT,
-`piece_name` VARCHAR(45) NOT NULL,
-`piece_position` VARCHAR(45) NOT NULL,
-PRIMARY KEY (`id`))
-ENGINE = InnoDB;
+CREATE TABLE IF NOT EXISTS `mychess`.`room` (
+    `room_id` BIGINT NOT NULL AUTO_INCREMENT,
+    `room_name` VARCHAR(45) NOT NULL,
+    `current_turn` VARCHAR(45) NOT NULL,
+    PRIMARY KEY (`room_id`)
+    ) CHARSET = utf8, ENGINE = InnoDB;
 
 
 -- -----------------------------------------------------
--- Table `mydb`.`turn`
+-- Table `mychess`.`piece`
 -- -----------------------------------------------------
-CREATE TABLE IF NOT EXISTS `mydb`.`turn` (
-`id` BIGINT NOT NULL AUTO_INCREMENT,
-`current_turn` VARCHAR(45) NOT NULL,
-PRIMARY KEY (`id`))
-ENGINE = InnoDB;
+CREATE TABLE IF NOT EXISTS `mychess`.`piece` (
+    `id` BIGINT NOT NULL AUTO_INCREMENT,
+    `piece_name` VARCHAR(45) NOT NULL,
+    `piece_position` VARCHAR(45) NOT NULL,
+    `room_id` BIGINT NOT NULL,
+    PRIMARY KEY (`id`),
+    FOREIGN KEY (`room_id`)
+    REFERENCES room(`room_id`)
+    ) CHARSET = utf8, ENGINE = InnoDB;
 ```

src/main/java/chess/controller/ChessApiController.java

@@ -1,15 +1,14 @@
 package chess.controller;
 
+import chess.dto.ChessBoardDto;
 import chess.dto.request.MoveRequestDto;
 import chess.dto.request.TurnChangeRequestDto;
 import chess.dto.response.MoveResponseDto;
 import chess.service.ChessService;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.MediaType;
 import org.springframework.http.ResponseEntity;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 
 @RestController
 public class ChessApiController {
@@ -19,13 +18,23 @@ public ChessApiController(final ChessService chessService) {
         this.chessService = chessService;
     }
 
+    @PostMapping("/room")
+    public Long start(@RequestBody final String req) {
+        return chessService.addRoom(req.split(":")[1].split("\"")[1]);
+    }
+
+    @GetMapping("/board/{roomId}")
+    public ChessBoardDto chess(@PathVariable final Long roomId) {
+        return chessService.chessBoardFromDB(roomId);
+    }
+
     @PostMapping(value = "/move", produces = MediaType.APPLICATION_JSON_VALUE)
-    public MoveResponseDto move(@RequestBody MoveRequestDto moveRequestDto) {
+    public MoveResponseDto move(@RequestBody final MoveRequestDto moveRequestDto) {
         return chessService.move(moveRequestDto);
     }
 
     @PostMapping(value = "/turn", produces = MediaType.APPLICATION_JSON_VALUE)
-    public ResponseEntity<Void> turn(@RequestBody TurnChangeRequestDto turnChangeRequestDto) {
+    public ResponseEntity<Void> turn(@RequestBody final TurnChangeRequestDto turnChangeRequestDto) {
         chessService.changeTurn(turnChangeRequestDto);
         return new ResponseEntity<>(HttpStatus.OK);
     }

src/main/java/chess/controller/ChessController.java

@@ -1,13 +1,14 @@
 package chess.controller;
 
-import chess.dto.ChessBoardDto;
-import chess.dto.StringChessBoardDto;
+import chess.dto.response.RoomResponseDto;
 import chess.dto.response.ScoreResponseDto;
 import chess.service.ChessService;
-import com.fasterxml.jackson.core.JsonProcessingException;
 import org.springframework.stereotype.Controller;
 import org.springframework.ui.Model;
 import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+
+import java.util.List;
 
 @Controller
 public class ChessController {
@@ -17,34 +18,18 @@ public ChessController(final ChessService chessService) {
         this.chessService = chessService;
     }
 
-    @GetMapping("/start")
-    public String start() {
-        chessService.makeRound();
-        return makeNewGame();
-    }
-
-    @GetMapping("/reset")
-    public String reset() {
-        chessService.resetRound();
-        return makeNewGame();
+    @GetMapping("/room-list")
+    public String roomList(final Model model) {
+        List<RoomResponseDto> rooms = chessService.rooms();
+        model.addAttribute("rooms", rooms);
+        return "room-list";
     }
 
-    @GetMapping("/chess")
-    public String chess(final Model model) throws JsonProcessingException {
-        ChessBoardDto chessBoard = chessService.chessBoardFromDB();
-        String jsonFormatChessBoard = chessService.jsonFormatChessBoard(chessBoard);
-        model.addAttribute("jsonFormatChessBoard", jsonFormatChessBoard);
-        String currentTurn = chessService.currentTurn();
-        model.addAttribute("currentTurn", currentTurn);
-        chessService.updateRound(chessBoard, currentTurn);
-
-        ScoreResponseDto scoreResponseDto = chessService.scoreResponseDto();
+    @GetMapping("/chess/{roomId}")
+    public String chess(@PathVariable final Long roomId, final Model model) {
+        ScoreResponseDto scoreResponseDto = chessService.scoreResponseDto(roomId);
+        model.addAttribute("roomId", roomId);
         model.addAttribute("score", scoreResponseDto);
         return "chess";
     }
-
-    private String makeNewGame() {
-        chessService.initialize();
-        return "redirect:/chess";
-    }
 }

src/main/java/chess/dao/PieceDao.java

@@ -1,75 +1,45 @@
 package chess.dao;
 
-import chess.dao.setting.DBConnection;
 import chess.dto.request.MoveRequestDto;
 import chess.dto.response.ChessResponseDto;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.jdbc.core.JdbcTemplate;
 import org.springframework.stereotype.Repository;
 
 import javax.sql.DataSource;
-import java.util.ArrayList;
 import java.util.List;
 
 @Repository
-public class PieceDao extends DBConnection {
-    @Autowired
+public class PieceDao {
     private final JdbcTemplate jdbcTemplate;
 
-    public PieceDao(DataSource dataSource) {
+    public PieceDao(final DataSource dataSource) {
         this.jdbcTemplate = new JdbcTemplate(dataSource);
     }
 
-    public void initializePieceStatus(final String pieceName, final String piecePosition) {
-        String query = "INSERT INTO piece (piece_name, piece_position) VALUE (?, ?)";
-        try {
-            jdbcTemplate.update(query, pieceName, piecePosition);
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
+    public void initializePieceStatus(final String pieceName, final String piecePosition, Long roomId) {
+        String query = "INSERT INTO piece (piece_name, piece_position, room_id) VALUE (?, ?, ?)";
+        jdbcTemplate.update(query, pieceName, piecePosition, roomId);
     }
 
-    public List<ChessResponseDto> showAllPieces() {
-        List<ChessResponseDto> pieces = new ArrayList<>();
-        String query = "SELECT * FROM piece";
-
-        try {
-            pieces = jdbcTemplate.query(
-                    query, (rs, rowNum) -> new ChessResponseDto(
-                            rs.getLong("id"),
-                            rs.getString("piece_name"),
-                            rs.getString("piece_position"))
-            );
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
+    public List<ChessResponseDto> showAllPieces(final Long roomId) {
+        List<ChessResponseDto> pieces;
+        String query = "SELECT * FROM piece WHERE room_id = ?";
+        pieces = jdbcTemplate.query(
+                query, (rs, rowNum) -> new ChessResponseDto(
+                        rs.getLong("id"),
+                        rs.getString("piece_name"),
+                        rs.getString("piece_position")), roomId
+        );
         return pieces;
     }
 
     public void movePiece(final MoveRequestDto moveRequestDto) {
         String query = "UPDATE piece SET piece_position=? WHERE piece_position=?";
-        try {
-            jdbcTemplate.update(query, moveRequestDto.getTarget(), moveRequestDto.getSource());
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
-    }
-
-    public void removeAllPieces() {
-        String query = "DELETE FROM piece";
-        try {
-            jdbcTemplate.update(query);
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
+        jdbcTemplate.update(query, moveRequestDto.getTarget(), moveRequestDto.getSource());
     }
 
     public void removePiece(final MoveRequestDto moveRequestDto) {
         String query = "DELETE FROM piece WHERE piece_position=?";
-        try {
-            jdbcTemplate.update(query, moveRequestDto.getTarget());
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
+        jdbcTemplate.update(query, moveRequestDto.getTarget());
     }
 }

src/main/java/chess/dao/RoomDao.java

@@ -0,0 +1,56 @@
+package chess.dao;
+
+import chess.dto.request.TurnChangeRequestDto;
+import chess.dto.response.RoomResponseDto;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.support.GeneratedKeyHolder;
+import org.springframework.jdbc.support.KeyHolder;
+import org.springframework.stereotype.Repository;
+
+import javax.sql.DataSource;
+import java.sql.PreparedStatement;
+import java.util.List;
+import java.util.Objects;
+
+@Repository
+public class RoomDao {
+    private final JdbcTemplate jdbcTemplate;
+
+    public RoomDao(final DataSource dataSource) {
+        this.jdbcTemplate = new JdbcTemplate(dataSource);
+    }
+
+    public Long addRoom(final String roomName) {
+        KeyHolder keyHolder = new GeneratedKeyHolder();
+        String query = "INSERT INTO room (room_name, current_turn) VALUES (?, ?)";
+        jdbcTemplate.update(connection -> {
+            PreparedStatement ps = connection.prepareStatement(query, new String[]{"room_id"});
+            ps.setString(1, roomName);
+            ps.setString(2, "white");
+            return ps;
+        }, keyHolder);
+        return Objects.requireNonNull(keyHolder.getKey()).longValue();
+    }
+
+    public List<RoomResponseDto> showAllRooms() {
+        List<RoomResponseDto> rooms;
+        String query = "SELECT * FROM room";
+        rooms = jdbcTemplate.query(
+                query, (rs, rowName) -> new RoomResponseDto(
+                        rs.getLong("room_id"),
+                        rs.getString("room_name"),
+                        rs.getString("current_turn"))
+        );
+        return rooms;
+    }
+
+    public String showCurrentTurn(final Long roomId) {
+        String query = "SELECT current_turn FROM room WHERE room_id=?";
+        return jdbcTemplate.queryForObject(query, String.class, roomId);
+    }
+
+    public void changeTurn(final TurnChangeRequestDto turnChangeRequestDto) {
+        String query = "UPDATE room SET current_turn=? WHERE room_id=?";
+        jdbcTemplate.update(query, turnChangeRequestDto.getNextTurn(), turnChangeRequestDto.getRoomId());
+    }
+}