[Step3] 데이터베이스를 교체한다.

.gitignore

@@ -34,3 +34,4 @@ out/
 
 ### VS Code ###
 .vscode/
+*.yml

README.md

@@ -57,19 +57,46 @@
 
 사용자 정보를 바탕으로 로그인 기능을 구현한다.
 
-1. 로그인 기능을 구현한다.
-- 세션을 이용해 구현한다.
-- 세션은 애플리케이션 내부에 저장/관리한다.
-   - 세션 유지 시간을 제한 한다.
-   - [선택] 최근 로그인 기록과 아이피를 식별할 수 있도록 한다.
-   
-2. 개인 정보 상세 조회 기능을 개발한다.
-- [선택] 이미지 업로드 기능을 구현한다.
+- [x] 로그인 기능을 구현한다.
+  - 세션을 이용해 구현한다.
+  - 세션은 애플리케이션 내부에 저장/관리한다.
+  - 세션 유지 시간을 제한 한다.
+  - [선택] 최근 로그인 기록과 아이피를 식별할 수 있도록 한다.
+
+- [x] 개인 정보 상세 조회 기능을 개발한다.
+
 
 <br>
 <br>
 
 ### 학습 목표
-- HTTP 특징에 대해 학습한다.
+
+1. HTTP 특징에 대해 학습한다.
    - 쿠키/세션에 대해 학습한다.
-   - 세션 관리 방법에 대해 학습한다.
+
+2. 세션 관리 방법에 대해 학습한다.
+
+<br>
+<br>
+<br>
+<br>
+<br>
+<br>
+
+## Step3. 데이터베이스를 교체한다.
+
+애플리케이션 내부에 저장하던 데이터를 외부 데이터베이스에 저장한다.
+
+1. 데이터베이스 종류는 자유롭게 선택 한다.
+    - RDB, Redis 등
+2. JDBC 템플릿을 구현한다.
+
+<br>
+<br>
+
+### 학습 목표
+
+1. 추상화에 대해 이해한다.
+2. 데이터베이스 통신 과정에 대해 이해한다.
+3. 각 데이터베이스의 특징에 대해 이해한다.
+4. 트랜잭션에 대해 학습한다.

app/README.md

@@ -0,0 +1,19 @@
+## ⛺️ Application 모듈
+
+Application 모듈.
+
+<br/><br/><br/>
+
+## 👪 패키지 간 의존관계
+
+Application 모듈은 Mvc, Jdbc 모듈에 의존합니다.
+
+| Application Module | Mvc Module | Jdbc Module | 
+|:------------------:|:----------:|:-----------:|
+|         -          |     O      |      O      |
+
+&nbsp;&nbsp; - Application: 애플리케이션 모듈 <br/>
+&nbsp;&nbsp; - Mvc: 스프링 Mvc 모듈 <br/>
+&nbsp;&nbsp; - Jdbc: 데이터베이스 접근 모듈 <br/>
+
+<br/>

app/build.gradle

@@ -5,6 +5,10 @@ plugins {
 
 dependencies {
     implementation(project(":mvc"))
+    implementation(project(":jdbc"))
+
+    implementation("com.fasterxml.jackson.dataformat:jackson-dataformat-yaml:2.13.1")
+    runtimeOnly("com.mysql:mysql-connector-j:8.1.0")
 }
 
 tasks.named("test") {
@@ -68,3 +72,25 @@ sonarqube {
         property("sonar.coverage.jacoco.xmlReportPaths", "${buildDir}/jacoco/index.xml")
     }
 }
+
+task downloadYml {
+    doLast {
+        def url = new URL(System.getenv("YML_URL"))
+        def connection = url.openConnection()
+
+        def file = new File(projectDir, "./src/main/resources/application.yml")
+        if (!file.parentFile.exists()) {
+            file.parentFile.mkdirs()
+        }
+
+        connection.inputStream.withStream { inputStream ->
+            file.withOutputStream { outputStream ->
+                inputStream.transferTo(outputStream)
+            }
+        }
+    }
+}
+
+tasks.named("downloadYml") {
+    dependsOn downloadYml
+}

app/src/main/java/project/server/app/common/codeandmessage/failure/ErrorCodeAndMessages.java

@@ -7,7 +7,8 @@ public enum ErrorCodeAndMessages implements ErrorCodeAndMessage {
     INVALID_SESSION(HttpStatus.UN_AUTHORIZED, "세션이 만료되었습니다."),
     INVALID_PARAMETER(HttpStatus.BAD_REQUEST, "올바른 값을 입력해주세요."),
     PAGE_NOT_FOUND(HttpStatus.NOT_FOUND, "페이지를 찾을 수 없습니다."),
-    UN_AUTHORIZED(HttpStatus.UN_AUTHORIZED, "권한이 존재하지 않습니다.");
+    UN_AUTHORIZED(HttpStatus.UN_AUTHORIZED, "권한이 존재하지 않습니다."),
+    INVALID_DATA_ACCESS(HttpStatus.INTERNAL_SERVER_ERROR, "서버 내부 오류입니다.");
 
     private final HttpStatus httpStatus;
     private final String errorMessage;

app/src/main/java/project/server/app/common/configuration/ConfigMapLoader.java

@@ -0,0 +1,31 @@
+package project.server.app.common.configuration;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import static com.fasterxml.jackson.databind.PropertyNamingStrategies.KEBAB_CASE;
+import com.fasterxml.jackson.dataformat.yaml.YAMLFactory;
+import java.io.IOException;
+import java.io.InputStream;
+import project.server.jdbc.core.ConfigMap;
+
+public class ConfigMapLoader {
+
+    public ConfigMap getConfigMap() throws IOException {
+        return loadConfig("application.yml");
+    }
+
+    public ConfigMap loadConfig(String resourcePath) throws IOException {
+        InputStream inputStream = getInputStream(resourcePath);
+        if (inputStream == null) {
+            throw new IOException("Resource not found: " + resourcePath);
+        }
+
+        ObjectMapper mapper = new ObjectMapper(new YAMLFactory());
+        mapper.setPropertyNamingStrategy(KEBAB_CASE);
+        return mapper.readValue(inputStream, ConfigMap.class);
+    }
+
+    private InputStream getInputStream(String resourcePath) {
+        return ConfigMapLoader.class.getClassLoader()
+            .getResourceAsStream(resourcePath);
+    }
+}

app/src/main/java/project/server/app/common/configuration/DatabaseConfiguration.java

@@ -0,0 +1,35 @@
+package project.server.app.common.configuration;
+
+import java.io.IOException;
+import project.server.jdbc.core.ConfigMap;
+import project.server.jdbc.core.DriverManager;
+import project.server.jdbc.core.jdbc.JdbcTemplate;
+import project.server.jdbc.core.transaction.JdbcTransactionManager;
+import project.server.jdbc.core.transaction.PlatformTransactionManager;
+import project.server.mvc.springframework.annotation.Bean;
+import project.server.mvc.springframework.annotation.Configuration;
+
+@Configuration
+public class DatabaseConfiguration {
+
+    @Bean
+    public ConfigMapLoader configMapLoader() {
+        return new ConfigMapLoader();
+    }
+
+    @Bean
+    public DriverManager driverManager() throws IOException {
+        ConfigMap configMap = configMapLoader().getConfigMap();
+        return new DriverManager(configMap);
+    }
+
+    @Bean
+    public PlatformTransactionManager transactionManager() throws IOException {
+        return new JdbcTransactionManager(driverManager().getDataSource());
+    }
+
+    @Bean
+    public JdbcTemplate jdbcTemplate() throws IOException {
+        return new JdbcTemplate(driverManager().getDataSource());
+    }
+}

app/src/main/java/project/server/app/common/exception/BusinessException.java

@@ -1,6 +1,7 @@
 package project.server.app.common.exception;
 
 import project.server.app.common.codeandmessage.ErrorCodeAndMessage;
+import project.server.mvc.servlet.http.HttpStatus;
 
 public class BusinessException extends RuntimeException {
 
@@ -14,4 +15,14 @@ public BusinessException(ErrorCodeAndMessage errorCodeAndMessage) {
     public ErrorCodeAndMessage getCodeAndMessage() {
         return codeAndMessage;
     }
+
+    @Override
+    public String toString() {
+        HttpStatus status = codeAndMessage.getStatus();
+        return String.format(
+            "{\"code\":%d, \"message\":\"%s\"}",
+            status.getStatusCode(),
+            codeAndMessage.getErrorMessage()
+        );
+    }
 }

app/src/main/java/project/server/app/common/exception/InvalidParameterException.java

@@ -1,6 +1,7 @@
 package project.server.app.common.exception;
 
 import project.server.app.common.codeandmessage.failure.ErrorCodeAndMessages;
+import project.server.mvc.servlet.http.HttpStatus;
 
 public class InvalidParameterException extends RuntimeException {
 
@@ -19,4 +20,14 @@ public ErrorCodeAndMessages getErrorCodeAndMessages() {
     public Object getArgs() {
         return args;
     }
+
+    @Override
+    public String toString() {
+        HttpStatus status = errorCodeAndMessages.getStatus();
+        return String.format(
+            "{\"code\":%d, \"message\":\"%s\"}",
+            status.getStatusCode(),
+            errorCodeAndMessages.getErrorMessage()
+        );
+    }
 }

app/src/main/java/project/server/app/common/exception/UnAuthorizedException.java

@@ -2,9 +2,9 @@
 
 import static project.server.app.common.codeandmessage.failure.ErrorCodeAndMessages.UN_AUTHORIZED;
 
-public class UnAuthorizedException extends RuntimeException {
+public class UnAuthorizedException extends BusinessException {
 
     public UnAuthorizedException() {
-        super(UN_AUTHORIZED.getErrorMessage());
+        super(UN_AUTHORIZED);
     }
 }

app/src/main/java/project/server/app/common/utils/JdbcConfiguration.java

@@ -0,0 +1,7 @@
+package project.server.app.common.utils;
+
+import project.server.mvc.springframework.annotation.Configuration;
+
+@Configuration
+public class JdbcConfiguration {
+}

app/src/main/java/project/server/app/core/domain/user/User.java

@@ -60,22 +60,27 @@ public String getPassword() {
         return password.value();
     }
 
-    public Deleted getDeleted() {
-        return deleted;
+    public LocalDateTime getCreatedAt() {
+        return createdAt;
     }
 
-    public boolean isNew() {
-        return this.id == null;
+    public LocalDateTime getLastModifiedAt() {
+        return lastModifiedAt;
     }
 
-    public void registerId(Long id) {
-        this.id = id;
+    public Deleted getDeleted() {
+        return deleted;
     }
 
     public boolean isAlreadyDeleted() {
         return this.deleted.equals(Deleted.TRUE);
     }
 
+    public void delete(LocalDateTime lastModifiedAt) {
+        this.lastModifiedAt = lastModifiedAt;
+        this.deleted = Deleted.TRUE;
+    }
+
     @Override
     public boolean equals(Object object) {
         if (this == object) {
@@ -87,11 +92,6 @@ public boolean equals(Object object) {
         return getId().equals(user.getId());
     }
 
-    public void delete(LocalDateTime lastModifiedAt) {
-        this.lastModifiedAt = lastModifiedAt;
-        this.deleted = Deleted.TRUE;
-    }
-
     @Override
     public int hashCode() {
         return Objects.hash(getId());

app/src/main/java/project/server/app/core/domain/user/UserRepository.java

@@ -4,15 +4,17 @@
 import java.util.Optional;
 
 public interface UserRepository {
-    User save(User user);
+    Long save(User user);
 
     Optional<User> findById(Long userId);
 
     void clear();
 
-    boolean existByName(String username);
-
-    List<User> findAll();
+    boolean existsByName(String username);
 
     Optional<User> findByUsernameAndPassword(String username, String password);
+
+    void delete(User user);
+
+    List<User> findAll();
 }

app/src/main/java/project/server/app/core/web/user/application/UserSaveUseCase.java

@@ -1,7 +1,5 @@
 package project.server.app.core.web.user.application;
 
-import project.server.app.core.domain.user.User;
-
 public interface UserSaveUseCase {
-    User save(User user);
+    Long save(String username, String password);
 }

app/src/main/java/project/server/app/core/web/user/application/service/UserLoginService.java

@@ -39,12 +39,16 @@ public Session login(
 
     @Override
     public Session findSessionById(Long userId) {
-        Session findSession = sessionManager.findByUserId(userId)
-            .orElseThrow(UnAuthorizedException::new);
+        try {
+            Session findSession = sessionManager.findByUserId(userId)
+                .orElseThrow(UnAuthorizedException::new);
 
-        if (!findSession.isValid(now())) {
-            throw new SessionExpiredException();
+            if (!findSession.isValid(now())) {
+                throw new SessionExpiredException();
+            }
+            return findSession;
+        } catch (UnAuthorizedException | SessionExpiredException exception) {
+            return null;
         }
-        return findSession;
     }
 }