Add film director

README.md

@@ -15,7 +15,8 @@
 - Хранение данных в базе H2 (файловый режим — данные переживают перезапуск),
   доступ через `JdbcTemplate` и `RowMapper`.
 - Справочники жанров и рейтингов MPA в базе, эндпоинты `/genres` и `/mpa`.
-- У фильма есть рейтинг и список жанров; жанры в ответе — без дублей, по порядку id.
+- У фильма есть рейтинг и список жанров; жанры в ответе — без дублей, по порядку id. 
+- У фильмов можно указывать режиссёров и получать список фильмов выбранного режиссёра с сортировкой по году выпуска или количеству лайков.
 - Односторонняя дружба: добавление/удаление друзей, список друзей, общие друзья.
 - Лайки фильмам: добавление/удаление, топ-N фильмов по количеству лайков.
 - Отзывы к фильмам: положительные и негативные, с рейтингом полезности по лайкам и дизлайкам.
@@ -71,6 +72,10 @@
 - `DELETE /films/{id}` — удалить фильм; связанные с ним записи удаляются каскадно.
 - `PUT /films/{id}/like/{userId}` — поставить лайк фильму.
 - `DELETE /films/{id}/like/{userId}` — убрать лайк.
+- `GET /films/popular?count={count}` — топ-N фильмов по лайкам (по умолчанию 10).
+- `GET /films/director/{directorId}` — получить список фильмов режиссёра.
+- `GET /films/director/{directorId}?sortBy=likes` — получить список фильмов режиссёра, отсортированный по лайкам.
+- `GET /films/director/{directorId}?sortBy=year` — получить список фильмов режиссёра, отсортированный по году выпуска.
 - `GET /films/popular?count={count}&genreId={genreId}&year={year}` — топ-N фильмов по лайкам
   (по умолчанию 10); жанр и год — необязательные фильтры.
 - `GET /films/common?userId={userId}&friendId={friendId}` — общие фильмы двух пользователей,
@@ -107,6 +112,13 @@
 - `GET /mpa` — получить список всех рейтингов.
 - `GET /mpa/{id}` — получить рейтинг по ID.
 
+## Режиссёры (`/directors`)
+- `GET /directors` — получить список всех режиссёров.
+- `GET /directors/{id}` — получить режиссёра по ID.
+- `POST /directors` — создать нового режиссёра.
+- `PUT /directors` — обновить данные режиссёра.
+- `DELETE /directors/{id}` — удалить режиссёра.
+
 ## Схема базы данных
 
 ```mermaid
@@ -118,6 +130,8 @@ erDiagram
     users ||--o{ film_likes : "user_id"
     users ||--o{ friendship : "user_id"
     users ||--o{ friendship : "friend_id"
+    films ||--o{film_director : "film_id"
+    directors ||--o{film_director : "director_id"
     users ||--o{ reviews : "user_id"
     films ||--o{ reviews : "film_id"
     reviews ||--o{ review_likes : "review_id"
@@ -158,6 +172,14 @@ erDiagram
         BIGINT user_id PK, FK
         BIGINT friend_id PK, FK
     }
+    directors {
+        BIGINT id PK
+        VARCHAR name
+    }
+    film_director {
+        BIGINT film_id  PK, FK
+        BIGINT director_id PK, FK
+    }
     reviews {
         BIGINT id PK
         VARCHAR content
@@ -181,6 +203,8 @@ erDiagram
 | `film_genres` | связь «фильм — жанр», многие ко многим |
 | `film_likes` | лайки: какой пользователь лайкнул какой фильм |
 | `friendship` | дружба: одна строка — `user_id` добавил в друзья `friend_id`; подтверждённая (взаимная) дружба — две встречные строки |
+| `directors` | режиссёры |
+| `film_director` | связь "фильм — режиссёр", многие ко многим |
 | `reviews` | отзывы пользователей к фильмам; рейтинг полезности не хранится, а считается по `review_likes` |
 | `review_likes` | оценки отзывов: одна строка — один пользователь, лайк или дизлайк |
 

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

@@ -0,0 +1,53 @@
+package ru.yandex.practicum.filmorate.controller;
+
+import jakarta.validation.Valid;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+import ru.yandex.practicum.filmorate.model.Director;
+import ru.yandex.practicum.filmorate.service.DirectorService;
+import java.util.List;
+
+@Slf4j
+@RestController
+@RequestMapping("/directors")
+public class DirectorController {
+
+    private final DirectorService directorService;
+
+    @Autowired
+    public DirectorController(DirectorService directorService) {
+        this.directorService = directorService;
+    }
+
+    @GetMapping
+    public List<Director> getDirectors() {
+        log.info("GET /directors");
+        return directorService.getAllDirectors();
+    }
+
+    @GetMapping("/{id}")
+    public Director getDirectorById(@PathVariable Long id) {
+        log.info("GET /directors/{}", id);
+        return directorService.getDirectorById(id);
+    }
+
+    @PostMapping
+    public Director createDirector(@Valid @RequestBody Director director) {
+        log.info("POST /directors, body:{}", director);
+        return directorService.addDirector(director);
+    }
+
+    @PutMapping
+    public Director updateDirector(@Valid @RequestBody Director director) {
+        log.info("PUT /directors, body:{}", director);
+        return directorService.updateDirector(director);
+    }
+
+    @DeleteMapping("/{id}")
+    public void deleteDirector(@PathVariable Long id) {
+        log.info("DELETE /directors/{}", id);
+        directorService.deleteDirector(id);
+    }
+
+}

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

@@ -77,4 +77,11 @@ public Collection<Film> getCommon(@RequestParam long userId, @RequestParam long
         log.info("GET /films/common?userId={}&friendId={}", userId, friendId);
         return filmService.getCommon(userId, friendId);
     }
+
+    @GetMapping("/director/{directorId}")
+    public Collection<Film> getFilmsByDirector(@PathVariable long directorId,
+                                    @RequestParam (defaultValue = "likes") String sortBy) {
+        log.info("GET /films/director/{}?sortBy={}", directorId, sortBy);
+        return filmService.findByDirectorSorted(directorId, sortBy);
+    }
 }

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

@@ -0,0 +1,12 @@
+package ru.yandex.practicum.filmorate.model;
+
+import jakarta.validation.constraints.NotBlank;
+import lombok.Data;
+
+@Data
+public class Director {
+    private Long id;
+
+    @NotBlank(message = "Имя режиссера не может быть пустым")
+    private String name;
+}

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

@@ -38,11 +38,14 @@ public class Film {
     @JsonIgnore
     private Set<Long> likes = new HashSet<>();
 
+    private Set<Director> directors = new LinkedHashSet<>();
+
     public void addLike(Long userId) {
         likes.add(userId);
     }
 
     public boolean removeLike(Long userId) {
         return likes.remove(userId);
     }
+
 }

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

@@ -0,0 +1,39 @@
+package ru.yandex.practicum.filmorate.service;
+
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.stereotype.Service;
+import ru.yandex.practicum.filmorate.exception.NotFoundException;
+import ru.yandex.practicum.filmorate.model.Director;
+import ru.yandex.practicum.filmorate.storage.director.DirectorStorage;
+
+@Service
+public class DirectorService {
+
+    private final DirectorStorage directorStorage;
+
+    public DirectorService(@Qualifier("directorDbStorage") DirectorStorage directorStorage) {
+        this.directorStorage = directorStorage;
+    }
+
+    public Director addDirector(Director director) {
+        return directorStorage.addDirector(director);
+    }
+
+    public Director updateDirector(Director director) {
+        return directorStorage.updateDirector(director);
+    }
+
+    public void deleteDirector(long id) {
+        directorStorage.removeDirector(id);
+    }
+
+    public Director getDirectorById(long id) {
+        return directorStorage.findDirectorById(id)
+                .orElseThrow(() -> new NotFoundException("Режиссер с id " + id + " не найден"));
+    }
+
+    public java.util.List<Director> getAllDirectors() {
+        return directorStorage.findAllDirectors();
+    }
+
+}

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

@@ -6,6 +6,7 @@
 import org.springframework.stereotype.Service;
 import ru.yandex.practicum.filmorate.exception.NotFoundException;
 import ru.yandex.practicum.filmorate.exception.ValidationException;
+import ru.yandex.practicum.filmorate.model.Director;
 import ru.yandex.practicum.filmorate.model.Film;
 import ru.yandex.practicum.filmorate.model.Genre;
 import ru.yandex.practicum.filmorate.storage.film.FilmStorage;
@@ -30,16 +31,19 @@ public class FilmService {
     // Нужны для проверки рейтинга и жанра из запроса
     private final MpaService mpaService;
     private final GenreService genreService;
+    private final DirectorService directorService;
 
     @Autowired
     public FilmService(@Qualifier("filmDbStorage") FilmStorage filmStorage,
                        @Qualifier("userDbStorage") UserStorage userStorage,
                        MpaService mpaService,
-                       GenreService genreService) {
+                       GenreService genreService,
+                       DirectorService directorService) {
         this.filmStorage = filmStorage;
         this.userStorage = userStorage;
         this.mpaService = mpaService;
         this.genreService = genreService;
+        this.directorService = directorService;
     }
 
     // Получение фильма по id с проверкой существования
@@ -134,16 +138,35 @@ private void validateMpaAndGenres(Film film) {
         }
     }
 
+    private void validateDirectors(Film film) {
+
+        if (film.getDirectors() == null || film.getDirectors().isEmpty()) {
+            return;
+        }
+
+        Set<Long> knownIds = new HashSet<>();
+        for (Director director : directorService.getAllDirectors()) {
+            knownIds.add(director.getId());
+        }
+        for (Director director : film.getDirectors()) {
+            if (!knownIds.contains(director.getId())) {
+                throw new NotFoundException("Режиссёр с id=" + director.getId() + " не найден");
+            }
+        }
+    }
+
     public Film add(Film film) {
         validateReleaseDate(film);
         validateMpaAndGenres(film);
+        validateDirectors(film);
         return filmStorage.add(film);
     }
 
     public Film update(Film film) {
         getFilmOrThrow(film.getId()); // проверка существования — иначе 404
         validateReleaseDate(film);
         validateMpaAndGenres(film);
+        validateDirectors(film);
         return filmStorage.update(film);
     }
 
@@ -160,4 +183,9 @@ public Collection<Film> findAll() {
     public Film findById(long id) {
         return getFilmOrThrow(id);
     }
+
+    public Collection<Film> findByDirectorSorted(long directorId, String sortBy) {
+        directorService.getDirectorById(directorId); // проверка существования режиссёра — иначе 404
+        return filmStorage.findFilmByDirector(directorId, sortBy);
+    }
 }

src/main/java/ru/yandex/practicum/filmorate/storage/director/DirectorDbStorage.java

@@ -0,0 +1,78 @@
+package ru.yandex.practicum.filmorate.storage.director;
+
+import java.util.Optional;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.support.GeneratedKeyHolder;
+import org.springframework.jdbc.support.KeyHolder;
+import org.springframework.stereotype.Repository;
+import ru.yandex.practicum.filmorate.exception.NotFoundException;
+import ru.yandex.practicum.filmorate.model.Director;
+import ru.yandex.practicum.filmorate.storage.mapper.DirectorRowMapper;
+import java.util.List;
+
+@Repository
+public class DirectorDbStorage implements DirectorStorage {
+
+    private final JdbcTemplate jdbcTemplate;
+    private final DirectorRowMapper directorRowMapper;
+
+    private static final String INSERT_QUERY = "INSERT INTO directors (name) VALUES (?)";
+    private static final String UPDATE_QUERY = "UPDATE directors SET name = ? WHERE id = ?";
+    private static final String DELETE_QUERY = "DELETE FROM directors WHERE id = ?";
+    private static final String SELECT_BY_ID_QUERY = "SELECT * FROM directors WHERE id = ?";
+    private static final String SELECT_ALL_QUERY = "SELECT * FROM directors ORDER BY id";
+
+    @Autowired
+    public DirectorDbStorage(JdbcTemplate jdbcTemplate, DirectorRowMapper directorRowMapper) {
+        this.jdbcTemplate = jdbcTemplate;
+        this.directorRowMapper = directorRowMapper;
+    }
+
+    @Override
+    public Director addDirector(Director director) {
+        KeyHolder keyHolder = new GeneratedKeyHolder();
+        jdbcTemplate.update(connection -> {
+            var ps = connection.prepareStatement(INSERT_QUERY, new String[]{"id"});
+            ps.setString(1, director.getName());
+            return ps;
+        }, keyHolder);
+        director.setId(keyHolder.getKey().longValue());
+        return director;
+    }
+
+    @Override
+    public Director updateDirector(Director director) {
+        int updatedRows = jdbcTemplate.update(
+                UPDATE_QUERY,
+                director.getName(),
+                director.getId()
+        );
+
+        if (updatedRows == 0) {
+            throw new NotFoundException(
+                    "Режиссёр с id=" + director.getId() + " не найден"
+            );
+        }
+        return director;
+    }
+
+    @Override
+    public void removeDirector(long id) {
+        Director director = findDirectorById(id)
+                .orElseThrow(() -> new NotFoundException("Режиссёр с id " + id + " не найден"));
+        jdbcTemplate.update(DELETE_QUERY, id);
+    }
+
+    @Override
+    public Optional<Director> findDirectorById(long id) {
+        Optional<Director> director = jdbcTemplate.query(SELECT_BY_ID_QUERY, directorRowMapper, id).stream().findFirst();
+        return director;
+    }
+
+    @Override
+    public List<Director> findAllDirectors() {
+        List<Director> directors = jdbcTemplate.query(SELECT_ALL_QUERY, directorRowMapper);
+        return directors;
+    }
+}

src/main/java/ru/yandex/practicum/filmorate/storage/director/DirectorStorage.java

@@ -0,0 +1,18 @@
+package ru.yandex.practicum.filmorate.storage.director;
+
+import ru.yandex.practicum.filmorate.model.Director;
+import java.util.List;
+import java.util.Optional;
+
+public interface DirectorStorage {
+
+    Director addDirector(Director director);
+
+    Director updateDirector(Director director);
+
+    void removeDirector(long id);
+
+    Optional<Director> findDirectorById(long id);
+
+    List<Director> findAllDirectors();
+}