Merge pull request #8 from DokPlay/add-database

sprint-12 add database schema docs

Author: DokPlay

.gitignore

@@ -7,7 +7,11 @@
 /.settings/
 /out/
 *.log
+db/*.mv.db
+db/*.trace.db
 
 # OS
 .DS_Store
 Thumbs.db
+
+*.patch

pom.xml

@@ -8,7 +8,7 @@
   <artifactId>filmorate</artifactId>
   <version>1.0.0</version>
   <name>Filmorate</name>
-  <description>Filmorate Sprint 1</description>
+  <description>Filmorate Sprint 12</description> <!-- SPRINT 12: обновили описание под текущий спринт -->
 
   <parent>
     <groupId>org.springframework.boot</groupId>
@@ -37,6 +37,19 @@
       <artifactId>spring-boot-starter-validation</artifactId>
     </dependency>
 
+    <!-- SPRINT 12: JDBC и подключение к базе данных -->
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-starter-jdbc</artifactId>
+    </dependency>
+
+    <!-- SPRINT 12: встроенная БД H2, в рантайме хранит данные в файле ./db/filmorate -->
+    <dependency>
+      <groupId>com.h2database</groupId>
+      <artifactId>h2</artifactId>
+      <scope>runtime</scope>
+    </dependency>
+
     <!-- Lombok -->
     <dependency>
       <groupId>org.projectlombok</groupId>
@@ -52,7 +65,7 @@
       <version>3.7.2</version>
     </dependency>
 
-    <!-- Tests -->
+    <!-- SPRINT 12: тестирование, в том числе @JdbcTest с in-memory H2 -->
     <dependency>
       <groupId>org.springframework.boot</groupId>
       <artifactId>spring-boot-starter-test</artifactId>

src/main/java/ru/yandex/practicum/filmorate/controller/GenreController.java

@@ -0,0 +1,33 @@
+package ru.yandex.practicum.filmorate.controller;
+
+import java.util.List;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import ru.yandex.practicum.filmorate.model.Genre;
+import ru.yandex.practicum.filmorate.service.GenreService;
+
+/** REST controller for film genres. */
+@Slf4j
+@RestController
+@RequestMapping("/genres")
+@RequiredArgsConstructor
+public class GenreController {
+
+  private final GenreService genreService;
+
+  @GetMapping
+  public List<Genre> findAll() {
+    log.debug("GET /genres — list");
+    return genreService.findAll();
+  }
+
+  @GetMapping("/{id}")
+  public Genre getById(@PathVariable final int id) {
+    log.info("GET /genres/{} — fetch", id);
+    return genreService.getById(id);
+  }
+}

src/main/java/ru/yandex/practicum/filmorate/controller/MpaController.java

@@ -0,0 +1,33 @@
+package ru.yandex.practicum.filmorate.controller;
+
+import java.util.List;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import ru.yandex.practicum.filmorate.model.Mpa;
+import ru.yandex.practicum.filmorate.service.MpaService;
+
+/** REST controller for MPA ratings. */
+@Slf4j
+@RestController
+@RequestMapping("/mpa")
+@RequiredArgsConstructor
+public class MpaController {
+
+  private final MpaService mpaService;
+
+  @GetMapping
+  public List<Mpa> findAll() {
+    log.debug("GET /mpa — list");
+    return mpaService.findAll();
+  }
+
+  @GetMapping("/{id}")
+  public Mpa getById(@PathVariable final int id) {
+    log.info("GET /mpa/{} — fetch", id);
+    return mpaService.getById(id);
+  }
+}

src/main/java/ru/yandex/practicum/filmorate/model/Film.java

@@ -7,6 +7,7 @@
 import jakarta.validation.constraints.Size;
 import java.time.LocalDate;
 import java.util.HashSet;
+import java.util.LinkedHashSet;
 import java.util.Set;
 import lombok.Data;
 import lombok.NoArgsConstructor;
@@ -43,6 +44,15 @@ public class Film {
   @Positive(message = "Продолжительность должна быть положительным числом.")
   private Integer duration;
 
+  @NotNull(message = "Рейтинг обязателен.")
+  private Mpa mpa;
+
+  private Set<Genre> genres = new LinkedHashSet<>();
+
   // SPRINT 11: лайки от пользователей (уникальные id)
   private final Set<Long> likes = new HashSet<>();
+
+  public void setGenres(Set<Genre> genres) {
+    this.genres = genres == null ? new LinkedHashSet<>() : new LinkedHashSet<>(genres);
+  }
 }

src/main/java/ru/yandex/practicum/filmorate/model/Genre.java

@@ -0,0 +1,16 @@
+package ru.yandex.practicum.filmorate.model;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/** Genre of a film. */
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class Genre {
+
+  private Integer id;
+
+  private String name;
+}

src/main/java/ru/yandex/practicum/filmorate/model/Mpa.java

@@ -0,0 +1,16 @@
+package ru.yandex.practicum.filmorate.model;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/** Motion Picture Association rating. */
+@Data
+@NoArgsConstructor
+@AllArgsConstructor
+public class Mpa {
+
+  private Integer id;
+
+  private String name;
+}

src/main/java/ru/yandex/practicum/filmorate/service/FilmService.java

@@ -1,7 +1,13 @@
 package ru.yandex.practicum.filmorate.service;
 
 import java.time.LocalDate;
+import java.util.Collections;
+import java.util.Comparator;
+import java.util.HashSet;
+import java.util.LinkedHashSet;
 import java.util.List;
+import java.util.Objects;
+import java.util.Set;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
@@ -10,6 +16,7 @@
 // import ru.yandex.practicum.filmorate.exception.NotFoundException;
 import ru.yandex.practicum.filmorate.exception.ValidationException;
 import ru.yandex.practicum.filmorate.model.Film;
+import ru.yandex.practicum.filmorate.model.Genre;
 import ru.yandex.practicum.filmorate.storage.film.FilmStorage;
 import ru.yandex.practicum.filmorate.storage.user.UserStorage;
 
@@ -41,6 +48,7 @@ public class FilmService {
 
   // CHANGE: вынесена константа самой ранней корректной даты
   private static final LocalDate EARLIEST_DATE = LocalDate.of(1895, 12, 28);
+  private static final int DEFAULT_POPULAR_LIMIT = FilmStorage.DEFAULT_POPULAR_LIMIT;
 
   // SPRINT 11: внедряем зависимости от интерфейсов хранилищ
   private final FilmStorage filmStore;
@@ -64,6 +72,7 @@ public Film getById(final long id) {
 
   public Film create(final Film film) {
     validateBusinessRules(film);
+    normalizeGenres(film);
     // SPRINT 11: генерация id и сохранение — в storage
     final Film saved = filmStore.create(film);
     // CHANGE: безопасный лог
@@ -76,6 +85,7 @@ public Film update(final Film film) {
       throw new ValidationException("id обязателен для обновления фильма.");
     }
     validateBusinessRules(film);
+    normalizeGenres(film);
     // SPRINT 11: обновление — через storage
     final Film saved = filmStore.update(film);
     // CHANGE
@@ -119,11 +129,9 @@ public void removeLike(final long filmId, final long userId) {
   }
 
   public List<Film> getPopular(int count) {
-    if (count <= 0) {
-      count = 10; // SPRINT 11: дефолт, если параметр не задан/некорректен
-    }
+    final int effectiveLimit = count <= 0 ? DEFAULT_POPULAR_LIMIT : count; // SPRINT 11: дефолт, если параметр не задан/некорректен
     // SPRINT 11 FIX: сортировку и лимит выполняет хранилище (для будущей БД)
-    return filmStore.findMostPopular(count);
+    return filmStore.findMostPopular(effectiveLimit);
   }
 
   // ----------- валидация -----------
@@ -133,5 +141,32 @@ private void validateBusinessRules(final Film film) {
     if (film.getReleaseDate() != null && film.getReleaseDate().isBefore(EARLIEST_DATE)) {
       throw new ValidationException("Дата релиза не может быть раньше " + EARLIEST_DATE + ".");
     }
+    if (film.getMpa() == null || film.getMpa().getId() == null) {
+      throw new ValidationException("Рейтинг MPA обязателен.");
+    }
+    if (film.getMpa().getId() <= 0) {
+      throw new ValidationException("Некорректный идентификатор рейтинга.");
+    }
+  }
+
+  private void normalizeGenres(final Film film) {
+    if (film.getGenres() == null || film.getGenres().isEmpty()) {
+      film.setGenres(Collections.emptySet());
+      return;
+    }
+    final Set<Genre> genres = film.getGenres();
+    final int expectedSize = Math.max(genres.size(), 1);
+    final Set<Integer> seen = new HashSet<>(expectedSize);
+    final Set<Genre> normalized = new LinkedHashSet<>(expectedSize);
+    genres.stream()
+        .filter(Objects::nonNull)
+        .filter(genre -> genre.getId() != null && genre.getId() > 0)
+        .sorted(Comparator.comparingInt(Genre::getId))
+        .forEach(genre -> {
+          if (seen.add(genre.getId())) {
+            normalized.add(new Genre(genre.getId(), genre.getName()));
+          }
+        });
+    film.setGenres(normalized);
   }
 }

src/main/java/ru/yandex/practicum/filmorate/service/GenreService.java

@@ -0,0 +1,23 @@
+package ru.yandex.practicum.filmorate.service;
+
+import java.util.List;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import ru.yandex.practicum.filmorate.model.Genre;
+import ru.yandex.practicum.filmorate.storage.genre.GenreStorage;
+
+/** Service facade for working with genres. */
+@Service
+@RequiredArgsConstructor
+public class GenreService {
+
+  private final GenreStorage genreStorage;
+
+  public List<Genre> findAll() {
+    return genreStorage.findAll();
+  }
+
+  public Genre getById(int id) {
+    return genreStorage.getById(id);
+  }
+}

src/main/java/ru/yandex/practicum/filmorate/service/MpaService.java

@@ -0,0 +1,23 @@
+package ru.yandex.practicum.filmorate.service;
+
+import java.util.List;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+import ru.yandex.practicum.filmorate.model.Mpa;
+import ru.yandex.practicum.filmorate.storage.mpa.MpaStorage;
+
+/** Service facade for MPA ratings. */
+@Service
+@RequiredArgsConstructor
+public class MpaService {
+
+  private final MpaStorage mpaStorage;
+
+  public List<Mpa> findAll() {
+    return mpaStorage.findAll();
+  }
+
+  public Mpa getById(int id) {
+    return mpaStorage.getById(id);
+  }
+}