diff --git a/README.md b/README.md index 4155f68510..3b494f2986 100644 --- a/README.md +++ b/README.md @@ -62,3 +62,16 @@ - 도메인 모델은 TDD로 구현 - Service 클래스는 단위 테스트가 없어도 된다 + +### 3단계 - 수강신청(DB 적용) + +#### 프로그래밍 요구사항 + +1. [x] 이미지 생성 기능 +2. [x] 이미지 조회 기능 +3. [x] 이미지 수정 기능 +4. [x] 이미지 삭제 기능 +5. [x] 강의 생성 기능 +6. [x] 강의 조회 기능 +7. [x] 강의 수정 기능 +8. [x] 강의 삭제 기능 diff --git a/src/main/java/nextstep/courses/domain/Image.java b/src/main/java/nextstep/courses/domain/Image.java index 52ac6dd079..9793d4ca16 100644 --- a/src/main/java/nextstep/courses/domain/Image.java +++ b/src/main/java/nextstep/courses/domain/Image.java @@ -9,11 +9,12 @@ public class Image { private static final int MINIMUM_HEIGHT = 200; private static final Set ALLOWED_TYPES = Set.of("gif", "jpg", "jpeg", "png", "svg"); - private final String fileName; - private final int fileSize; - private final String fileType; - private final int width; - private final int height; + private Long id; + private String fileName; + private int fileSize; + private String fileType; + private int width; + private int height; public Image(String fileName, int fileSize, String fileType, int width, int height) { validateSize(fileSize); @@ -31,7 +32,6 @@ private void validateFileType(String fileType) { if (!ALLOWED_TYPES.contains(fileType.toLowerCase())) { throw new IllegalArgumentException("허용되지 않는 파일 형식입니다."); } - } private void validateSize(int fileSize) { @@ -49,4 +49,36 @@ private void validateFileStandard(int width, int height) { } } + public Long getId() { + return id; + } + + public String getFileName() { + return fileName; + } + + public int getFileSize() { + return fileSize; + } + + public String getFileType() { + return fileType; + } + + public int getWidth() { + return width; + } + + public int getHeight() { + return height; + } + + public void setId(long id) { + this.id = id; + } + + public void setFileName(String fileName) { + this.fileName = fileName; + } + } diff --git a/src/main/java/nextstep/courses/domain/ImageRepository.java b/src/main/java/nextstep/courses/domain/ImageRepository.java new file mode 100644 index 0000000000..bae9224d1f --- /dev/null +++ b/src/main/java/nextstep/courses/domain/ImageRepository.java @@ -0,0 +1,11 @@ +package nextstep.courses.domain; + +public interface ImageRepository { + int save(Image image); + + Image findById(Long id); + + int update(Image image); + + int deleteById(Long id); +} diff --git a/src/main/java/nextstep/courses/domain/Session.java b/src/main/java/nextstep/courses/domain/Session.java deleted file mode 100644 index 1a5da0a713..0000000000 --- a/src/main/java/nextstep/courses/domain/Session.java +++ /dev/null @@ -1,83 +0,0 @@ -package nextstep.courses.domain; - -import nextstep.courses.constants.SessionStatus; - -import java.time.LocalDate; - -public abstract class Session { - protected String title; - protected LocalDate startDate; - protected LocalDate endDate; - protected Image sessionImage; - protected int enrollCount; - protected SessionStatus status; - - public Session(String title, LocalDate startDate, LocalDate endDate, Image sessionImage, SessionStatus status) { - validateDate(startDate, endDate); - this.title = title; - this.startDate = startDate; - this.endDate = endDate; - this.sessionImage = sessionImage; - this.status = status; - this.enrollCount = 0; - } - - protected void validateDate(LocalDate startDate, LocalDate endDate) { - if (startDate.isAfter(endDate)) { - throw new IllegalArgumentException("시작일은 종료일 이전이어야 합니다."); - } - } - - public void startEnrollment() { - this.status = SessionStatus.OPEN; - } - - public void closeEnrollment() { - this.status = SessionStatus.CLOSED; - } - - public abstract void enroll(int payment); - - public int getEnrolledCount() { - return enrollCount; - } -} - -class FreeSession extends Session { - public FreeSession(String title, LocalDate startDate, LocalDate endDate, Image sessionImage) { - super(title, startDate, endDate, sessionImage, SessionStatus.READY); - } - - @Override - public void enroll(int payment) { - if (status != SessionStatus.OPEN) { - throw new IllegalStateException("수강 신청은 모집중인 상태에서만 가능합니다."); - } - enrollCount++; - } -} - -class PaidSession extends Session { - private int maxEnrollment; - private int sessionFee; - - public PaidSession(String title, LocalDate startDate, LocalDate endDate, Image sessionImage, int maxEnrollment, int sessionFee) { - super(title, startDate, endDate, sessionImage, SessionStatus.READY); - this.maxEnrollment = maxEnrollment; - this.sessionFee = sessionFee; - } - - @Override - public void enroll(int payment) { - if (status != SessionStatus.OPEN) { - throw new IllegalStateException("수강 신청은 모집중인 상태에서만 가능합니다."); - } - if (enrollCount >= maxEnrollment) { - throw new IllegalStateException("수강 인원이 초과되었습니다."); - } - if (payment != sessionFee) { - throw new IllegalArgumentException("결제 금액이 수강료와 일치하지 않습니다."); - } - enrollCount++; - } -} diff --git a/src/main/java/nextstep/courses/domain/SessionRepository.java b/src/main/java/nextstep/courses/domain/SessionRepository.java new file mode 100644 index 0000000000..ff4659f8b9 --- /dev/null +++ b/src/main/java/nextstep/courses/domain/SessionRepository.java @@ -0,0 +1,13 @@ +package nextstep.courses.domain; + +import nextstep.courses.domain.session.Session; + +public interface SessionRepository { + int save(Session session); + + Session findById(Long id); + + int update(Session session); + + int deleteById(Long id); +} diff --git a/src/main/java/nextstep/courses/domain/session/FreeSession.java b/src/main/java/nextstep/courses/domain/session/FreeSession.java new file mode 100644 index 0000000000..b44ea0808a --- /dev/null +++ b/src/main/java/nextstep/courses/domain/session/FreeSession.java @@ -0,0 +1,20 @@ +package nextstep.courses.domain.session; + +import nextstep.courses.constants.SessionStatus; +import nextstep.courses.domain.Image; + +import java.time.LocalDate; + +public class FreeSession extends Session { + public FreeSession(Long courseId, String title, LocalDate startDate, LocalDate endDate, Image sessionImage) { + super(courseId, title, startDate, endDate, sessionImage, SessionStatus.READY); + } + + @Override + public void enroll(int payment) { + if (status != SessionStatus.OPEN) { + throw new IllegalStateException("수강 신청은 모집중인 상태에서만 가능합니다."); + } + enrollCount++; + } +} diff --git a/src/main/java/nextstep/courses/domain/session/PaidSession.java b/src/main/java/nextstep/courses/domain/session/PaidSession.java new file mode 100644 index 0000000000..a2bb657de3 --- /dev/null +++ b/src/main/java/nextstep/courses/domain/session/PaidSession.java @@ -0,0 +1,43 @@ +package nextstep.courses.domain.session; + +import nextstep.courses.constants.SessionStatus; +import nextstep.courses.domain.Image; + +import java.time.LocalDate; + +public class PaidSession extends Session { + private int maxEnrollment; + private int sessionFee; + + public abstract class Session { + protected Long courseId; + + public Session(Long courseId, String title, LocalDate startDate, LocalDate endDate, Image sessionImage, SessionStatus status) { + this.courseId = courseId; + } + } + + public PaidSession(Long courseId, String title, LocalDate startDate, LocalDate endDate, Image sessionImage, int maxEnrollment, int sessionFee) { + super(courseId, title, startDate, endDate, sessionImage, SessionStatus.READY); + this.maxEnrollment = maxEnrollment; + this.sessionFee = sessionFee; + } + + @Override + public void enroll(int payment) { + if (status != SessionStatus.OPEN) { + throw new IllegalStateException("수강 신청은 모집중인 상태에서만 가능합니다."); + } + if (enrollCount >= maxEnrollment) { + throw new IllegalStateException("수강 인원이 초과되었습니다."); + } + if (payment != sessionFee) { + throw new IllegalArgumentException("결제 금액이 수강료와 일치하지 않습니다."); + } + enrollCount++; + } + + public int getSessionFee() { + return sessionFee; + } +} diff --git a/src/main/java/nextstep/courses/domain/session/Session.java b/src/main/java/nextstep/courses/domain/session/Session.java new file mode 100644 index 0000000000..869c00cf41 --- /dev/null +++ b/src/main/java/nextstep/courses/domain/session/Session.java @@ -0,0 +1,93 @@ +package nextstep.courses.domain.session; + +import nextstep.courses.constants.SessionStatus; +import nextstep.courses.domain.Image; + +import java.time.LocalDate; +import java.time.temporal.ChronoUnit; + +public abstract class Session { + protected Long id; + protected Long courseId; + protected String title; + protected LocalDate startDate; + protected LocalDate endDate; + protected Image sessionImage; + protected int enrollCount; + protected SessionStatus status; + + public Session(Long courseId, String title, LocalDate startDate, LocalDate endDate, Image sessionImage, SessionStatus status) { + validateDate(startDate, endDate); + this.courseId = courseId; + this.title = title; + this.startDate = startDate; + this.endDate = endDate; + this.sessionImage = sessionImage; + this.status = status; + this.enrollCount = 0; + } + + public Session(String title, LocalDate startDate, LocalDate endDate, Image sessionImage, SessionStatus status) { + this(null, title, startDate, endDate, sessionImage, status); + } + + private void validateDate(LocalDate startDate, LocalDate endDate) { + if (startDate.isAfter(endDate)) { + throw new IllegalArgumentException("시작일은 종료일 이전이어야 합니다."); + } + } + + public void startEnrollment() { + this.status = SessionStatus.OPEN; + } + + public void closeEnrollment() { + this.status = SessionStatus.CLOSED; + } + + public abstract void enroll(int payment); + + public int getEnrolledCount() { + return enrollCount; + } + + public Long getId() { + return id; + } + + public Long getCourseId() { + return courseId; + } + + public String getTitle() { + return title; + } + + public void setTitle(String title) { + this.title = title; + } + + public long getDuration() { + return ChronoUnit.DAYS.between(startDate, endDate); + } + + public LocalDate getStartTime() { + return this.startDate; + } + + public LocalDate getEndTime() { + return this.endDate; + } + + public void setId(long id) { + this.id = id; + } + + public Image getSessionImage() { + return sessionImage; + } + + public void setSessionImage(Image sessionImage) { + this.sessionImage = sessionImage; + } +} diff --git a/src/main/java/nextstep/courses/infrastructure/JdbcImageRepository.java b/src/main/java/nextstep/courses/infrastructure/JdbcImageRepository.java new file mode 100644 index 0000000000..e7aeb43878 --- /dev/null +++ b/src/main/java/nextstep/courses/infrastructure/JdbcImageRepository.java @@ -0,0 +1,77 @@ +package nextstep.courses.infrastructure; + +import nextstep.courses.domain.Image; +import nextstep.courses.domain.ImageRepository; +import org.springframework.jdbc.core.JdbcOperations; +import org.springframework.jdbc.core.RowMapper; +import org.springframework.jdbc.support.GeneratedKeyHolder; +import org.springframework.jdbc.support.KeyHolder; +import org.springframework.stereotype.Repository; + +import java.sql.PreparedStatement; +import java.util.List; + +@Repository("imageRepository") +public class JdbcImageRepository implements ImageRepository { + private final JdbcOperations jdbcTemplate; + + public JdbcImageRepository(JdbcOperations jdbcTemplate) { + this.jdbcTemplate = jdbcTemplate; + } + + @Override + public int save(Image image) { + String sql = "INSERT INTO image (file_name, file_size, file_type, width, height) VALUES (?, ?, ?, ?, ?)"; + KeyHolder keyHolder = new GeneratedKeyHolder(); + + int result = jdbcTemplate.update(connection -> { + PreparedStatement ps = connection.prepareStatement(sql, new String[]{"id"}); + ps.setString(1, image.getFileName()); + ps.setInt(2, image.getFileSize()); + ps.setString(3, image.getFileType()); + ps.setInt(4, image.getWidth()); + ps.setInt(5, image.getHeight()); + return ps; + }, keyHolder); + + if (keyHolder.getKey() != null) { + image.setId(keyHolder.getKey().longValue()); + } + return result; + } + + @Override + public Image findById(Long id) { + String sql = "SELECT id, file_name, file_size, file_type, width, height FROM image WHERE id = ?"; + RowMapper rowMapper = (rs, rowNum) -> { + Image image = new Image( + rs.getString("file_name"), + rs.getInt("file_size"), + rs.getString("file_type"), + rs.getInt("width"), + rs.getInt("height") + ); + return image; + }; + List images = jdbcTemplate.query(sql, rowMapper, id); + return images.isEmpty() ? null : images.get(0); + } + + @Override + public int update(Image image) { + String sql = "update image set file_name = ?, file_size = ?, file_type = ?, width = ?, height = ? where id = ?"; + return jdbcTemplate.update(sql, + image.getFileName(), + image.getFileSize(), + image.getFileType(), + image.getWidth(), + image.getHeight(), + image.getId()); + } + + @Override + public int deleteById(Long id) { + String sql = "delete from image where id = ?"; + return jdbcTemplate.update(sql, id); + } +} diff --git a/src/main/java/nextstep/courses/infrastructure/JdbcSessionRepository.java b/src/main/java/nextstep/courses/infrastructure/JdbcSessionRepository.java new file mode 100644 index 0000000000..125aee8044 --- /dev/null +++ b/src/main/java/nextstep/courses/infrastructure/JdbcSessionRepository.java @@ -0,0 +1,97 @@ +package nextstep.courses.infrastructure; + +import nextstep.courses.domain.SessionRepository; +import nextstep.courses.domain.session.FreeSession; +import nextstep.courses.domain.session.PaidSession; +import nextstep.courses.domain.session.Session; +import org.springframework.jdbc.core.JdbcTemplate; +import org.springframework.jdbc.core.RowMapper; +import org.springframework.jdbc.support.GeneratedKeyHolder; +import org.springframework.jdbc.support.KeyHolder; + +import java.sql.PreparedStatement; +import java.sql.ResultSet; +import java.sql.SQLException; +import java.time.LocalDate; +import java.util.List; + +public class JdbcSessionRepository implements SessionRepository { + + private final JdbcTemplate jdbcTemplate; + + public JdbcSessionRepository(JdbcTemplate jdbcTemplate) { + this.jdbcTemplate = jdbcTemplate; + } + + @Override + public int save(Session session) { + String sql = "INSERT INTO session (course_id, type, duration, start_time, end_time, price, title) VALUES (?, ?, ?, ?, ?, ?, ?)"; + KeyHolder keyHolder = new GeneratedKeyHolder(); + + int result = jdbcTemplate.update(connection -> { + PreparedStatement ps = connection.prepareStatement(sql, new String[]{"id"}); + ps.setLong(1, session.getCourseId()); + ps.setString(2, session instanceof PaidSession ? "PAID" : "FREE"); + ps.setInt(3, (int) session.getDuration()); + ps.setObject(4, session.getStartTime()); + ps.setObject(5, session.getEndTime()); + ps.setInt(6, session instanceof PaidSession ? ((PaidSession) session).getSessionFee() : 0); + ps.setString(7, session.getTitle()); + return ps; + }, keyHolder); + + if (keyHolder.getKey() != null) { + session.setId(keyHolder.getKey().longValue()); + } + return result; + } + + @Override + public Session findById(Long id) { + String sql = "SELECT id, course_id, type, duration, start_time, end_time, price, title FROM session WHERE id = ?"; + RowMapper rowMapper = new SessionRowMapper(); + List sessions = jdbcTemplate.query(sql, rowMapper, id); + return sessions.isEmpty() ? null : sessions.get(0); + } + + @Override + public int update(Session session) { + String sql = "UPDATE session SET course_id = ?, title = ?, type = ?, duration = ?, start_time = ?, end_time = ?, price = ? WHERE id = ?"; + return jdbcTemplate.update(sql, + session.getCourseId(), + session.getTitle(), + session instanceof PaidSession ? "PAID" : "FREE", + session.getDuration(), + session.getStartTime(), + session.getEndTime(), + session instanceof PaidSession ? ((PaidSession) session).getSessionFee() : 0, + session.getId() + ); + } + + @Override + public int deleteById(Long id) { + String sql = "DELETE FROM session WHERE id = ?"; + return jdbcTemplate.update(sql, id); + } + + private static class SessionRowMapper implements RowMapper { + @Override + public Session mapRow(ResultSet rs, int rowNum) throws SQLException { + String type = rs.getString("type"); + Long id = rs.getLong("id"); + Long courseId = rs.getLong("course_id"); + String title = rs.getString("title"); + LocalDate startDate = rs.getObject("start_time", LocalDate.class); + LocalDate endDate = rs.getObject("end_time", LocalDate.class); + int duration = rs.getInt("duration"); + int price = rs.getInt("price"); + + if ("PAID".equalsIgnoreCase(type)) { + int maxEnrollment = 30; + return new PaidSession(courseId, title, startDate, endDate, null, maxEnrollment, price); + } + return new FreeSession(courseId, title, startDate, endDate, null); + } + } +} diff --git a/src/main/resources/schema.sql b/src/main/resources/schema.sql index 8d5a988c8b..b9a691db25 100644 --- a/src/main/resources/schema.sql +++ b/src/main/resources/schema.sql @@ -1,50 +1,80 @@ -create table course ( - id bigint generated by default as identity, - title varchar(255) not null, - creator_id bigint not null, - created_at timestamp not null, +create table course +( + id bigint generated by default as identity, + title varchar(255) not null, + creator_id bigint not null, + created_at timestamp not null, updated_at timestamp, primary key (id) ); -create table ns_user ( - id bigint generated by default as identity, - user_id varchar(20) not null, - password varchar(20) not null, - name varchar(20) not null, - email varchar(50), - created_at timestamp not null, - updated_at timestamp, +create table session +( + id bigint generated by default as identity, + course_id bigint not null, + type varchar(50) not null, + duration int, + start_time timestamp not null, + end_time timestamp, + price int, + title varchar(255), + primary key (id) +); + +create table image +( + id bigint generated by default as identity, + session_id int, + file_name varchar(255) not null, + file_size int not null, + file_type varchar(50) not null, + width int not null, + height int not null, primary key (id) ); -create table question ( - id bigint generated by default as identity, - created_at timestamp not null, +create table ns_user +( + id bigint generated by default as identity, + user_id varchar(20) not null, + password varchar(20) not null, + name varchar(20) not null, + email varchar(50), + created_at timestamp not null, updated_at timestamp, - contents clob, - deleted boolean not null, - title varchar(100) not null, - writer_id bigint, primary key (id) ); -create table answer ( - id bigint generated by default as identity, - created_at timestamp not null, +create table question +( + id bigint generated by default as identity, + created_at timestamp not null, updated_at timestamp, - contents clob, - deleted boolean not null, + contents clob, + deleted boolean not null, + title varchar(100) not null, + writer_id bigint, + primary key (id) +); + +create table answer +( + id bigint generated by default as identity, + created_at timestamp not null, + updated_at timestamp, + contents clob, + deleted boolean not null, question_id bigint, - writer_id bigint, + writer_id bigint, primary key (id) ); -create table delete_history ( - id bigint not null, - content_id bigint, - content_type varchar(255), - created_date timestamp, +create table delete_history +( + id bigint not null, + content_id bigint, + content_type varchar(255), + created_date timestamp, deleted_by_id bigint, primary key (id) ); diff --git a/src/test/java/nextstep/courses/domain/SessionTest.java b/src/test/java/nextstep/courses/domain/SessionTest.java index 3045c92f10..fd0e54696e 100644 --- a/src/test/java/nextstep/courses/domain/SessionTest.java +++ b/src/test/java/nextstep/courses/domain/SessionTest.java @@ -1,6 +1,7 @@ package nextstep.courses.domain; -import nextstep.courses.constants.SessionStatus; +import nextstep.courses.domain.session.FreeSession; +import nextstep.courses.domain.session.PaidSession; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.DisplayName; import org.junit.jupiter.api.Test; @@ -16,26 +17,25 @@ class SessionTest { private Image image; private FreeSession freeSession; private PaidSession paidSession; + private final LocalDate today = LocalDate.now(); @BeforeEach void setUp() { this.image = new Image("강의이미지", 1, "jpg", 300, 200); - this.freeSession = new FreeSession("무료 강의", LocalDate.now(), LocalDate.now().plusDays(10), image); - this.paidSession = new PaidSession("유료 강의", LocalDate.now(), LocalDate.now().plusDays(10), image, 10, 100000); - + this.freeSession = new FreeSession(1L, "무료 강의", today, today.plusDays(10), image); + this.paidSession = new PaidSession(1L, "유료 강의", today, today.plusDays(10), image, 10, 100000); this.freeSession.startEnrollment(); this.paidSession.startEnrollment(); - } @Test @DisplayName("강의 생성 가능한지 확인") void createSession() { - FreeSession session = new FreeSession("무료 강의", LocalDate.now(), LocalDate.now().plusDays(10), image); + FreeSession session = new FreeSession(1L, "무료 강의", today, today.plusDays(10), image); assertThat(session) .extracting("title", "startDate", "endDate", "sessionImage") - .containsExactly("무료 강의", LocalDate.now(), LocalDate.now().plusDays(10), image); + .containsExactly("무료 강의", today, today.plusDays(10), image); } @Test @@ -70,7 +70,7 @@ void overMaxEnrollmentThrowsException() { @Test @DisplayName("모집 중이 아닌 강의 수강 신청 시 예외 발생") void enrollReadySessionThrowsException() { - FreeSession readySession = new FreeSession("무료 강의", LocalDate.now(), LocalDate.now().plusDays(10), image); + FreeSession readySession = new FreeSession(1L, "무료 강의", today, today.plusDays(10), image); assertThatThrownBy(() -> readySession.enroll(0)).isInstanceOf(IllegalStateException.class); } } diff --git a/src/test/java/nextstep/courses/infrastructure/ImageRepositoryTest.java b/src/test/java/nextstep/courses/infrastructure/ImageRepositoryTest.java new file mode 100644 index 0000000000..c4b04075dd --- /dev/null +++ b/src/test/java/nextstep/courses/infrastructure/ImageRepositoryTest.java @@ -0,0 +1,73 @@ +package nextstep.courses.infrastructure; + +import nextstep.courses.domain.Image; +import nextstep.courses.domain.ImageRepository; +import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.DisplayName; +import org.junit.jupiter.api.Test; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.boot.test.autoconfigure.jdbc.JdbcTest; +import org.springframework.jdbc.core.JdbcTemplate; + +import static org.assertj.core.api.Assertions.assertThat; + +@JdbcTest +public class ImageRepositoryTest { + + private static final Logger LOGGER = LoggerFactory.getLogger(ImageRepositoryTest.class); + + @Autowired + private JdbcTemplate jdbcTemplate; + + private ImageRepository imageRepository; + + @BeforeEach + void setUp() { + jdbcTemplate.execute("DELETE FROM image"); + imageRepository = new JdbcImageRepository(jdbcTemplate); + } + + @Test + @DisplayName("이미지 생성 / 조회") + void saveAndFindById() { + Image image = new Image("강의_이미지", 1, "jpg", 300, 200); + + imageRepository.save(image); + Image savedImage = imageRepository.findById(image.getId()); + + assertThat(savedImage.getFileName()).isEqualTo(image.getFileName()); + LOGGER.debug("Saved Image: {}", savedImage); + } + + @Test + @DisplayName("이미지 변경") + void update() { + Image image = new Image("강의_이미지", 1, "jpg", 300, 200); + imageRepository.save(image); + + image.setFileName("강의_이미지_수정"); + int count = imageRepository.update(image); + assertThat(count).isEqualTo(1); + + Image updatedImage = imageRepository.findById(image.getId()); + assertThat(updatedImage.getFileName()).isEqualTo("강의_이미지_수정"); + LOGGER.debug("Updated Image: {}", updatedImage); + } + + @Test + @DisplayName("이미지 삭제") + void deleteById() { + Image image = new Image("강의_이미지", 1, "jpg", 300, 200); + imageRepository.save(image); + + int count = imageRepository.deleteById(image.getId()); + assertThat(count).isEqualTo(1); + + Image deletedImage = imageRepository.findById(image.getId()); + assertThat(deletedImage).isNull(); + LOGGER.debug("Deleted Image: {}", deletedImage); + } + +} diff --git a/src/test/java/nextstep/courses/infrastructure/SessionRepositoryTest.java b/src/test/java/nextstep/courses/infrastructure/SessionRepositoryTest.java new file mode 100644 index 0000000000..0b7237f757 --- /dev/null +++ b/src/test/java/nextstep/courses/infrastructure/SessionRepositoryTest.java @@ -0,0 +1,94 @@ +package nextstep.courses.infrastructure; + +import nextstep.courses.domain.Image; +import nextstep.courses.domain.SessionRepository; +import nextstep.courses.domain.session.FreeSession; +import nextstep.courses.domain.session.PaidSession; +import nextstep.courses.domain.session.Session; +import org.junit.jupiter.api.BeforeEach; +import org.junit.jupiter.api.DisplayName; +import org.junit.jupiter.api.Test; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.boot.test.autoconfigure.jdbc.JdbcTest; +import org.springframework.jdbc.core.JdbcTemplate; + +import java.time.LocalDate; + +import static org.assertj.core.api.Assertions.assertThat; + +@JdbcTest +public class SessionRepositoryTest { + + private static final Logger LOGGER = LoggerFactory.getLogger(SessionRepositoryTest.class); + + @Autowired + private JdbcTemplate jdbcTemplate; + + private SessionRepository sessionRepository; + private Image image; + + @BeforeEach + void setUp() { + this.image = new Image("강의이미지", 1, "jpg", 300, 200); + jdbcTemplate.execute("DELETE FROM session"); + sessionRepository = new JdbcSessionRepository(jdbcTemplate); + } + + @Test + @DisplayName("유료 강의 생성 / 조회") + void saveAndFindPaidSessionById() { + Session paidSession = new PaidSession(1L, "유료 강의", LocalDate.of(2024, 1, 1), LocalDate.of(2024, 12, 31), image, 30, 50000); + + sessionRepository.save(paidSession); + Session savedSession = sessionRepository.findById(paidSession.getId()); + + assertThat(savedSession).isInstanceOf(PaidSession.class); + assertThat(paidSession.getTitle()).isEqualTo(savedSession.getTitle()); + LOGGER.debug("Saved Paid Session: {}", savedSession); + } + + @Test + @DisplayName("무료 강의 생성 / 조회") + void saveAndFindFreeSessionById() { + Session freeSession = new FreeSession(1L, "무료 강의", LocalDate.of(2024, 1, 1), LocalDate.of(2024, 12, 31), image); + + sessionRepository.save(freeSession); + Session savedSession = sessionRepository.findById(freeSession.getId()); + + assertThat(savedSession).isInstanceOf(FreeSession.class); + assertThat(savedSession.getTitle()).isEqualTo(freeSession.getTitle()); + LOGGER.debug("Saved Free Session: {}", savedSession); + } + + @Test + @DisplayName("강의 정보 변경") + void updateSession() { + Session paidSession = new PaidSession(1L, "유료 강의", LocalDate.of(2024, 1, 1), LocalDate.of(2024, 12, 31), image, 30, 50000); + sessionRepository.save(paidSession); + + paidSession.setTitle("유료 강의 (수정)"); + int count = sessionRepository.update(paidSession); + assertThat(count).isEqualTo(1); + + Session updatedSession = sessionRepository.findById(paidSession.getId()); + assertThat(updatedSession).isInstanceOf(PaidSession.class); + assertThat(updatedSession.getTitle()).isEqualTo("유료 강의 (수정)"); + LOGGER.debug("Updated Session: {}", updatedSession); + } + + @Test + @DisplayName("강의 삭제") + void deleteSessionById() { + Session freeSession = new FreeSession(1L, "무료 강의", LocalDate.of(2024, 1, 1), LocalDate.of(2024, 12, 31), image); + sessionRepository.save(freeSession); + + int count = sessionRepository.deleteById(freeSession.getId()); + assertThat(count).isEqualTo(1); + + Session deletedSession = sessionRepository.findById(freeSession.getId()); + assertThat(deletedSession).isNull(); + LOGGER.debug("Deleted Session: {}", deletedSession); + } +}