Driven(query) 구현

build.gradle.kts

@@ -65,6 +65,7 @@ dependencies {
     annotationProcessor("jakarta.persistence:jakarta.persistence-api")
     annotationProcessor("jakarta.annotation:jakarta.annotation-api")
 
+
     // lombok test
     testCompileOnly("org.projectlombok:lombok")
     testAnnotationProcessor("org.projectlombok:lombok")
@@ -77,8 +78,6 @@ dependencies {
     testImplementation("io.kotest:kotest-runner-junit5:5.9.1")
     testImplementation("io.mockk:mockk:1.13.12")
     testImplementation(kotlin("script-runtime"))
-    testCompileOnly("org.projectlombok:lombok") // 테스트 의존성 추가
-    testAnnotationProcessor("org.projectlombok:lombok") // 테스트 의존성 추가
     testImplementation("io.kotest.extensions:kotest-extensions-spring:1.1.3")
 }
 

src/main/java/me/nettee/board/adapter/driven/mapper/BoardEntityMapper.java

@@ -0,0 +1,22 @@
+package me.nettee.board.adapter.driven.mapper;
+
+import me.nettee.board.adapter.driven.persistence.entity.BoardEntity;
+import me.nettee.board.application.domain.Board;
+import org.mapstruct.Mapper;
+
+import java.util.Optional;
+import me.nettee.board.application.model.BoardReadDetailModel;
+import me.nettee.board.application.model.BoardReadSummaryModel;
+
+// Entity <-> Domain 매핑 클래스
+@Mapper(componentModel = "spring")
+public interface BoardEntityMapper {
+    Board toDomain(BoardEntity boardEntity);
+    BoardReadDetailModel toBoardReadDetailModel(BoardEntity boardEntity);
+    BoardReadSummaryModel toBoardReadSummaryModel(BoardEntity boardEntity);
+    BoardEntity toEntity(Board board);
+
+    default Optional<BoardReadDetailModel> toOptionalBoardReadDetailModel(BoardEntity boardEntity) {
+        return Optional.ofNullable(toBoardReadDetailModel(boardEntity));
+    }
+}

src/main/java/me/nettee/board/adapter/driven/persistence/BoardJpaRepository.java

@@ -0,0 +1,15 @@
+package me.nettee.board.adapter.driven.persistence;
+
+import me.nettee.board.adapter.driven.persistence.entity.BoardEntity;
+import me.nettee.board.application.domain.type.BoardStatus;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.PageRequest;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+import java.util.Set;
+
+public interface BoardJpaRepository extends JpaRepository<BoardEntity, Long> {
+    Page<BoardEntity> findByStatusIn(Set<BoardStatus> statuses, Pageable pageable);
+    Page<BoardEntity> findByStatus(BoardStatus status, PageRequest pageRequest);
+}

src/main/java/me/nettee/board/adapter/driven/persistence/BoardQueryAdapter.java

@@ -0,0 +1,109 @@
+package me.nettee.board.adapter.driven.persistence;
+
+import me.nettee.board.adapter.driven.mapper.BoardEntityMapper;
+import me.nettee.board.adapter.driven.persistence.entity.BoardEntity;
+import me.nettee.board.adapter.driven.persistence.entity.QBoardEntity;
+import me.nettee.board.application.domain.Board;
+import me.nettee.board.application.domain.type.BoardStatus;
+import me.nettee.board.application.port.BoardQueryPort;
+import org.springframework.data.domain.Page;
+import org.springframework.data.domain.Pageable;
+import org.springframework.data.jpa.repository.support.QuerydslRepositorySupport;
+import org.springframework.data.support.PageableExecutionUtils;
+import org.springframework.stereotype.Repository;
+import me.nettee.board.application.model.BoardReadDetailModel;
+import me.nettee.board.application.model.BoardReadSummaryModel;
+
+import java.util.Optional;
+
+
+@Repository
+public class BoardQueryAdapter extends QuerydslRepositorySupport implements BoardQueryPort {
+    private final BoardEntityMapper boardEntityMapper;
+    QBoardEntity boardEntity = QBoardEntity.boardEntity;
+
+    public BoardQueryAdapter(BoardEntityMapper boardEntityMapper) {
+        super(BoardEntity.class);
+        this.boardEntityMapper = boardEntityMapper;
+    }
+
+    @Override
+    public Optional<BoardReadDetailModel> findById(Long id) {
+        return boardEntityMapper.toOptionalBoardReadDetailModel(
+                getQuerydsl().createQuery()
+                        .select(boardEntity)
+                        .from(boardEntity)
+                        .where(
+                                boardEntity.id.eq(id)
+                        ).fetchOne()
+        );
+    }
+
+    @Override
+    public Page<BoardReadDetailModel> findAll(Pageable pageable) {
+        // 기본 쿼리 생성
+        var query = getQuerydsl().createQuery()
+                .select(boardEntity)
+                .from(boardEntity)
+                .where();
+
+        // pageable 정렬 조건 적용
+        pageable.getSort().forEach(order -> {
+            if (order.isAscending()) {
+                query.orderBy(boardEntity.createdAt.asc()); // createdAt 필드를 기준으로 오름차순 정렬
+            } else {
+                query.orderBy(boardEntity.createdAt.desc()); // createdAt 필드를 기준으로 내림차순 정렬
+            }
+        });
+
+        var result = query
+                .offset(pageable.getOffset()) // 현재 페이지의 오프셋 설정
+                .limit(pageable.getPageSize()) // 페이지 크기 설정
+                .fetch(); // 쿼리 실행
+
+        var totalCount  = getQuerydsl().createQuery()
+                .select(boardEntity.count())
+                .from(boardEntity)
+                .where();
+
+        return PageableExecutionUtils.getPage(
+                result.stream().map(boardEntityMapper::toBoardReadDetailModel).toList(),
+                pageable,
+                totalCount::fetchOne
+        );
+    }
+
+    @Override
+    public Page<BoardReadSummaryModel> findByStatusesList(Pageable pageable, java.util.Set<me.nettee.board.application.domain.type.BoardStatus> statuses) {
+        // 기본 쿼리 생성
+        var query = getQuerydsl().createQuery()
+                .select(boardEntity)
+                .from(boardEntity)
+                .where(boardEntity.status.in(statuses));
+
+        // pageable 정렬 조건 적용
+        pageable.getSort().forEach(order -> {
+            if (order.isAscending()) {
+                query.orderBy(boardEntity.createdAt.asc()); // createdAt 필드를 기준으로 오름차순 정렬
+            } else {
+                query.orderBy(boardEntity.createdAt.desc()); // createdAt 필드를 기준으로 내림차순 정렬
+            }
+        });
+
+        var result = query
+                .offset(pageable.getOffset()) // 현재 페이지의 오프셋 설정
+                .limit(pageable.getPageSize()) // 페이지 크기 설정
+                .fetch(); // 쿼리 실행
+
+        var totalCount  = getQuerydsl().createQuery()
+                .select(boardEntity.count())
+                .from(boardEntity)
+                .where(boardEntity.status.in(statuses));
+
+        return PageableExecutionUtils.getPage(
+                result.stream().map(boardEntityMapper::toBoardReadSummaryModel).toList(),
+                pageable,
+                totalCount::fetchOne
+        );
+    }
+}

src/main/java/me/nettee/board/adapter/driven/persistence/entity/BoardEntity.java

@@ -0,0 +1,43 @@
+package me.nettee.board.adapter.driven.persistence.entity;
+
+import jakarta.persistence.*;
+import lombok.*;
+import me.nettee.board.application.domain.type.BoardStatus;
+import org.hibernate.annotations.DynamicUpdate;
+
+import java.time.Instant;
+
+@Getter
+@Builder(toBuilder = true)
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@AllArgsConstructor
+@DynamicUpdate
+@Entity(name = "board")
+public class BoardEntity {
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    @Column(name = "id", nullable = false)
+    private Long id;
+
+    @Column(name = "title", length = 20, nullable = false)
+    private String title;
+
+    @Column(name = "content", length = 300, nullable = false)
+    private String content;
+
+    @Enumerated(EnumType.STRING)
+    @Column(name = "status")
+    private BoardStatus status;
+
+    @Column(name = "created_at")
+    private Instant createdAt;
+
+    @Column(name = "updated_at")
+    private Instant updatedAt;
+
+    // 삭제
+    public void softDelete() {
+        this.updatedAt = Instant.now();
+        this.status = BoardStatus.REMOVED;
+    }
+}

src/main/java/me/nettee/board/application/domain/Board.java

@@ -26,8 +26,6 @@ public class Board {
 
     private Instant updatedAt;
 
-    private Instant deletedAt;
-
     @Builder(
         builderClassName = "updateBoardBuilder",
         builderMethodName = "prepareUpdate",

src/main/java/me/nettee/board/application/exception/BoardCommandErrorCode.java

@@ -0,0 +1,42 @@
+package me.nettee.board.application.exception;
+
+import me.nettee.common.exeption.ErrorCode;
+import org.springframework.http.HttpStatus;
+
+public enum BoardCommandErrorCode implements ErrorCode {
+    // ⬇️ 인증 쪽 에러코드 제공받아 쓸 것이냐
+    // UNAUTHORIZED("로그인이 필요한 기능입니다.", HttpStatus.UNAUTHORIZED),
+    // ⬇️ 조회 쪽 에러코드 제공받아 쓸 것이냐, 아니면 Master DB 핸들 시 사용할 용도로 여기 따로 둘 거냐.
+    BOARD_NOT_FOUND("게시물을 찾을 수 없습니다.", HttpStatus.NOT_FOUND),
+    BOARD_GONE("더 이상 존재하지 않는 게시물입니다.", HttpStatus.GONE),
+    BOARD_FORBIDDEN("권한이 없습니다.", HttpStatus.FORBIDDEN),
+    DEFAULT("게시물 조작 오류", HttpStatus.INTERNAL_SERVER_ERROR);
+
+    private final String message;
+    private final HttpStatus status;
+
+    BoardCommandErrorCode(String message, HttpStatus status) {
+        this.message = message;
+        this.status = status;
+    }
+
+    @Override
+    public String defaultMessage() {
+        return message;
+    }
+
+    @Override
+    public HttpStatus defaultHttpStatus() {
+        return status;
+    }
+
+    @Override
+    public BoardCommandException defaultException() {
+        return new BoardCommandException(this);
+    }
+
+    @Override
+    public BoardCommandException defaultException(Throwable cause) {
+        return new BoardCommandException(this, cause);
+    }
+}

src/main/java/me/nettee/board/application/exception/BoardCommandException.java

@@ -0,0 +1,17 @@
+package me.nettee.board.application.exception;
+
+import me.nettee.common.exeption.CustomException;
+import me.nettee.common.exeption.ErrorCode;
+
+public class BoardCommandException extends CustomException {
+    // (intellij) Ctrl + O
+    // (eclipse or sts) Alt Shift S => generate constructors
+
+    public BoardCommandException(ErrorCode errorCode) {
+        super(errorCode);
+    }
+
+    public BoardCommandException(ErrorCode errorCode, Throwable cause) {
+        super(errorCode, cause);
+    }
+}

src/main/java/me/nettee/board/application/exception/BoardQueryErrorCode.java

@@ -0,0 +1,42 @@
+package me.nettee.board.application.exception;
+
+import me.nettee.common.exeption.ErrorCode;
+import org.springframework.http.HttpStatus;
+
+public enum BoardQueryErrorCode implements ErrorCode {
+    // ⬇️ 인증 쪽 에러코드 제공받아 쓸 것이냐
+    // UNAUTHORIZED("로그인이 필요한 기능입니다.", HttpStatus.UNAUTHORIZED),
+    // ⬇️ 조회 쪽 에러코드 제공받아 쓸 것이냐, 아니면 Master DB 핸들 시 사용할 용도로 여기 따로 둘 거냐.
+    BOARD_NOT_FOUND("게시물을 찾을 수 없습니다.", HttpStatus.NOT_FOUND),
+    BOARD_GONE("더 이상 존재하지 않는 게시물입니다.", HttpStatus.GONE),
+    BOARD_FORBIDDEN("권한이 없습니다.", HttpStatus.FORBIDDEN),
+    DEFAULT("게시물 조작 오류", HttpStatus.INTERNAL_SERVER_ERROR);
+
+    private final String message;
+    private final HttpStatus status;
+
+    BoardQueryErrorCode(String message, HttpStatus status) {
+        this.message = message;
+        this.status = status;
+    }
+
+    @Override
+    public String defaultMessage() {
+        return message;
+    }
+
+    @Override
+    public HttpStatus defaultHttpStatus() {
+        return status;
+    }
+
+    @Override
+    public BoardCommandException defaultException() {
+        return new BoardCommandException(this);
+    }
+
+    @Override
+    public BoardCommandException defaultException(Throwable cause) {
+        return new BoardCommandException(this, cause);
+    }
+}

src/main/java/me/nettee/board/application/exception/BoardQueryException.java

@@ -0,0 +1,14 @@
+package me.nettee.board.application.exception;
+
+import me.nettee.common.exeption.CustomException;
+import me.nettee.common.exeption.ErrorCode;
+
+public class BoardQueryException extends CustomException {
+    public BoardQueryException(ErrorCode errorCode) {
+        super(errorCode);
+    }
+
+    public BoardQueryException(ErrorCode errorCode, Throwable cause) {
+        super(errorCode, cause);
+    }
+}

src/main/java/me/nettee/board/application/port/BoardQueryPort.java

@@ -1,5 +1,6 @@
 package me.nettee.board.application.port;
 
+
 import java.util.Optional;
 import java.util.Set;
 import me.nettee.board.application.domain.type.BoardStatus;
@@ -11,7 +12,7 @@
 public interface BoardQueryPort {
 
     Optional<BoardReadDetailModel> findById(Long id);
-
+    Page<BoardReadDetailModel> findAll(Pageable pageable);
     Page<BoardReadSummaryModel> findByStatusesList(Pageable pageable, Set<BoardStatus> statuses);
 
 }

src/main/java/me/nettee/common/exeption/CustomException.java

@@ -0,0 +1,20 @@
+package me.nettee.common.exeption;
+
+public class CustomException extends RuntimeException {
+    protected ErrorCode errorCode;
+
+    public CustomException(ErrorCode errorCode) {
+        // ErrorCode의 기본 메시지를 RuntimeException에 전달하여 예외 메시지를 설정
+        super(errorCode.defaultMessage());
+        this.errorCode = errorCode;
+    }
+
+    public CustomException(ErrorCode errorCode, Throwable cause) {
+        super(errorCode.defaultMessage(), cause);
+        this.errorCode = errorCode;
+    }
+
+    public ErrorCode getErrorCode() {
+        return errorCode;
+    }
+}

src/main/java/me/nettee/common/exeption/ErrorCode.java

@@ -0,0 +1,11 @@
+package me.nettee.common.exeption;
+
+import org.springframework.http.HttpStatus;
+
+public interface ErrorCode {
+    String name(); // enum default method
+    String defaultMessage();
+    HttpStatus defaultHttpStatus();
+    RuntimeException defaultException();
+    RuntimeException defaultException(Throwable cause);
+}