박자스동터차 경주 2단계

build.gradle

@@ -1,20 +1,23 @@
 plugins {
-	id 'java'
-	id 'org.springframework.boot' version '2.7.9'
-	id 'io.spring.dependency-management' version '1.0.15.RELEASE'
+    id 'java'
+    id 'org.springframework.boot' version '2.7.9'
+    id 'io.spring.dependency-management' version '1.0.15.RELEASE'
 }
 
 sourceCompatibility = '11'
 
 repositories {
-	mavenCentral()
+    mavenCentral()
 }
 
 dependencies {
-	implementation 'org.springframework.boot:spring-boot-starter-web'
-	testImplementation 'org.springframework.boot:spring-boot-starter-test'
+    implementation 'org.springframework.boot:spring-boot-starter-web'
+    implementation 'org.springframework.boot:spring-boot-starter-jdbc'
+    runtimeOnly 'com.h2database:h2'
+    testImplementation 'io.rest-assured:rest-assured:4.4.0'
+    testImplementation 'org.springframework.boot:spring-boot-starter-test'
 }
 
 tasks.named('test') {
-	useJUnitPlatform()
+    useJUnitPlatform()
 }

src/main/java/racingcar/RacingCarConsoleApplication.java

@@ -0,0 +1,61 @@
+package racingcar;
+
+import java.util.Comparator;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+import java.util.stream.Collectors;
+import racingcar.controller.RacingConsoleController;
+import racingcar.dao.CarDao;
+import racingcar.dao.RacingGameDao;
+import racingcar.dao.entity.CarEntity;
+import racingcar.dao.entity.RacingGameEntity;
+import racingcar.service.RacingGameService;
+
+public class RacingCarConsoleApplication {
+    public static void main(String[] args) {
+        RacingGameService racingGameService = new RacingGameService(new InnerCarDao(), new InnerRacingGameDao());
+        RacingConsoleController racingConsoleController = new RacingConsoleController(racingGameService);
+        racingConsoleController.run();
+    }
+
+    static class InnerCarDao implements CarDao {
+        private final Map<Long, CarEntity> database = new HashMap<>();
+        private Long key = 1L;
+
+        @Override
+        public void saveAll(List<CarEntity> racingCars) {
+            for (CarEntity racingCar : racingCars) {
+                database.put(key, racingCar);
+                key++;
+            }
+        }
+
+        @Override
+        public List<CarEntity> findByRacingGameId(Long id) {
+            return database.values().stream()
+                    .filter(carEntity -> Objects.equals(carEntity.getGameId(), id))
+                    .collect(Collectors.toList());
+        }
+    }
+
+    static class InnerRacingGameDao implements RacingGameDao {
+        private final Map<Long, RacingGameEntity> database = new HashMap<>();
+        private Long id = 1L;
+
+        @Override
+        public Long save(RacingGameEntity racingGameEntity) {
+            database.put(id, racingGameEntity);
+            id++;
+            return id - 1;
+        }
+
+        @Override
+        public List<RacingGameEntity> findAllByCreatedTimeAsc() {
+            return database.values()
+                    .stream().sorted(Comparator.comparing(RacingGameEntity::getCreatedTime))
+                    .collect(Collectors.toList());
+        }
+    }
+}

src/main/java/racingcar/controller/ControllerAdvice.java

@@ -0,0 +1,19 @@
+package racingcar.controller;
+
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.RestControllerAdvice;
+
+@RestControllerAdvice
+public class ControllerAdvice {
+
+    @ExceptionHandler
+    public ResponseEntity<String> handleValidationExceptions(RuntimeException e) {
+        return ResponseEntity.internalServerError().body(e.getMessage());
+    }
+
+    @ExceptionHandler
+    public ResponseEntity<String> handleValidationExceptions(IllegalArgumentException e) {
+        return ResponseEntity.badRequest().body(e.getMessage());
+    }
+}

src/main/java/racingcar/controller/RacingConsoleController.java

@@ -0,0 +1,27 @@
+package racingcar.controller;
+
+import racingcar.dto.RacingGameRequest;
+import racingcar.dto.RacingGameResponse;
+import racingcar.service.RacingGameService;
+import racingcar.view.InputView;
+import racingcar.view.OutputView;
+
+public class RacingConsoleController {
+
+    private final RacingGameService racingGameService;
+
+    public RacingConsoleController(RacingGameService racingGameService) {
+        this.racingGameService = racingGameService;
+    }
+
+    public void run() {
+        String names = InputView.inputNames();
+        int count = InputView.inputTryCount();
+        RacingGameRequest racingGameRequest = new RacingGameRequest(names, count);
+
+        RacingGameResponse racingGameResponse = racingGameService.play(racingGameRequest);
+
+        OutputView.printRacing(racingGameResponse.getRacingCars());
+        OutputView.printWinners(racingGameResponse.getWinners());
+    }
+}

src/main/java/racingcar/controller/RacingGameController.java

@@ -0,0 +1,32 @@
+package racingcar.controller;
+
+import java.util.List;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RestController;
+import racingcar.dto.RacingGameRequest;
+import racingcar.dto.RacingGameResponse;
+import racingcar.service.RacingGameService;
+
+@RestController
+public class RacingGameController {
+    private final RacingGameService racingGameService;
+
+    public RacingGameController(RacingGameService racingGameService) {
+        this.racingGameService = racingGameService;
+    }
+
+    @PostMapping("/plays")
+    public ResponseEntity<RacingGameResponse> play(@RequestBody RacingGameRequest racingGameRequest) {
+        RacingGameResponse response = racingGameService.play(racingGameRequest);
+        return ResponseEntity.ok(response);
+    }
+
+    @GetMapping("/plays")
+    public ResponseEntity<List<RacingGameResponse>> playHistory() {
+        List<RacingGameResponse> history = racingGameService.findHistory();
+        return ResponseEntity.ok(history);
+    }
+}

src/main/java/racingcar/dao/CarDao.java

@@ -0,0 +1,11 @@
+package racingcar.dao;
+
+import java.util.List;
+import racingcar.dao.entity.CarEntity;
+
+public interface CarDao {
+
+    void saveAll(List<CarEntity> racingCars);
+
+    List<CarEntity> findByRacingGameId(Long id);
+}

src/main/java/racingcar/dao/CarJdbcDao.java

@@ -0,0 +1,50 @@
+package racingcar.dao;
+
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+import java.util.List;
+import org.springframework.jdbc.core.BatchPreparedStatementSetter;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.stereotype.Component;
+import racingcar.dao.entity.CarEntity;
+
+@Component
+public class CarJdbcDao implements CarDao {
+
+    private final JdbcTemplate jdbcTemplate;
+
+    public CarJdbcDao(JdbcTemplate jdbcTemplate) {
+        this.jdbcTemplate = jdbcTemplate;
+    }
+
+    @Override
+    public void saveAll(List<CarEntity> racingCars) {
+        String sql = "INSERT INTO CAR (name, position, is_win, racing_game_id) VALUES (?, ?, ?, ?)";
+        jdbcTemplate.batchUpdate(sql, new BatchPreparedStatementSetter() {
+            @Override
+            public void setValues(PreparedStatement ps, int i) throws SQLException {
+                CarEntity carEntity = racingCars.get(i);
+                ps.setString(1, carEntity.getName());
+                ps.setInt(2, carEntity.getPosition());
+                ps.setBoolean(3, carEntity.isWin());
+                ps.setLong(4, carEntity.getGameId());
+            }
+
+            @Override
+            public int getBatchSize() {
+                return racingCars.size();
+            }
+        });
+    }
+
+    @Override
+    public List<CarEntity> findByRacingGameId(Long racingGameId) {
+        return jdbcTemplate.query("SELECT * FROM car WHERE racing_game_id = " + racingGameId,
+                (resultSet, rowNum) -> new CarEntity(
+                        resultSet.getString("name"),
+                        resultSet.getInt("position"),
+                        resultSet.getBoolean("is_win"),
+                        racingGameId
+                ));
+    }
+}

src/main/java/racingcar/dao/RacingGameDao.java

@@ -0,0 +1,11 @@
+package racingcar.dao;
+
+import java.util.List;
+import racingcar.dao.entity.RacingGameEntity;
+
+public interface RacingGameDao {
+
+    Long save(RacingGameEntity racingGameEntity);
+
+    List<RacingGameEntity> findAllByCreatedTimeAsc();
+}

src/main/java/racingcar/dao/RacingGameJdbcDao.java

@@ -0,0 +1,46 @@
+package racingcar.dao;
+
+import java.sql.PreparedStatement;
+import java.sql.Timestamp;
+import java.util.List;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.support.GeneratedKeyHolder;
+import org.springframework.jdbc.support.KeyHolder;
+import org.springframework.stereotype.Component;
+import racingcar.dao.entity.RacingGameEntity;
+
+@Component
+public class RacingGameJdbcDao implements RacingGameDao {
+
+    private final JdbcTemplate jdbcTemplate;
+
+    public RacingGameJdbcDao(JdbcTemplate jdbcTemplate) {
+        this.jdbcTemplate = jdbcTemplate;
+    }
+
+    @Override
+    public Long save(RacingGameEntity racingGameEntity) {
+        String sql = "INSERT INTO racing_game (trial_count, created_at) VALUES (?,?)";
+
+        KeyHolder keyHolder = new GeneratedKeyHolder();
+        jdbcTemplate.update(con -> {
+            PreparedStatement preparedStatement = con.prepareStatement(sql, new String[]{"id"});
+            preparedStatement.setInt(1, racingGameEntity.getTrialCount());
+            preparedStatement.setTimestamp(2, Timestamp.valueOf(racingGameEntity.getCreatedTime()));
+            return preparedStatement;
+        }, keyHolder);
+
+        return keyHolder.getKey().longValue();
+    }
+
+    @Override
+    public List<RacingGameEntity> findAllByCreatedTimeAsc() {
+        return jdbcTemplate.query(
+                "SELECT * FROM racing_game ORDER BY created_at DESC ",
+                (resultSet, rowNum) -> new RacingGameEntity(
+                        resultSet.getLong("id"),
+                        resultSet.getInt("trial_count"),
+                        resultSet.getTimestamp("created_at").toLocalDateTime()
+                ));
+    }
+}

src/main/java/racingcar/dao/entity/CarEntity.java

@@ -0,0 +1,32 @@
+package racingcar.dao.entity;
+
+public class CarEntity {
+
+    private final String name;
+    private final int position;
+    private final boolean isWin;
+    private final Long gameId;
+
+    public CarEntity(String name, int position, boolean isWin, Long gameId) {
+        this.name = name;
+        this.position = position;
+        this.isWin = isWin;
+        this.gameId = gameId;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public int getPosition() {
+        return position;
+    }
+
+    public boolean isWin() {
+        return isWin;
+    }
+
+    public Long getGameId() {
+        return gameId;
+    }
+}

src/main/java/racingcar/dao/entity/RacingGameEntity.java

@@ -0,0 +1,32 @@
+package racingcar.dao.entity;
+
+import java.time.LocalDateTime;
+
+public class RacingGameEntity {
+
+    private final Long id;
+    private final int trialCount;
+    private final LocalDateTime createdTime;
+
+    public RacingGameEntity(Long id, int trialCount, LocalDateTime createdTime) {
+        this.id = id;
+        this.trialCount = trialCount;
+        this.createdTime = createdTime;
+    }
+
+    public RacingGameEntity(int trialCount) {
+        this(null, trialCount, LocalDateTime.now());
+    }
+
+    public int getTrialCount() {
+        return trialCount;
+    }
+
+    public Long getId() {
+        return id;
+    }
+
+    public LocalDateTime getCreatedTime() {
+        return createdTime;
+    }
+}