src/main/java/org/opensearch/data/example/service/MovieIndexingService.java - development - cherepakhin/SpringBoot-OpenSearch-FullTextSearch

src/main/java/org/opensearch/data/example/service/MovieIndexingService.java

38 строк1 KB

Ляшенко Евгений Иванович

Add OpenSearch Dashboards

14 фев 2025, 01:28

14 фев 2025, 01:284b7c644

package org.opensearch.data.example.service;

import org.opensearch.data.example.entity.Movie;
import org.opensearch.data.example.model.MovieDoc;
import org.opensearch.data.example.repository.MovieElasticsearchRepository;
import org.opensearch.data.example.repository.MovieRepository;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import java.util.List;

@Service
public class MovieIndexingService {

    private final MovieRepository movieRepository;

    private final MovieElasticsearchRepository movieElasticsearchRepository;

    public MovieIndexingService(MovieRepository movieRepository, MovieElasticsearchRepository movieElasticsearchRepository) {
        this.movieRepository = movieRepository;
        this.movieElasticsearchRepository = movieElasticsearchRepository;
    }

    @Transactional(readOnly = true)
    public void reindexAllMovies() {
        List<Movie> movies = movieRepository.findAll();

        movieElasticsearchRepository.saveAll(
                movies.stream().map(
                        movie -> new MovieDoc(
                                movie.getId(),
                                movie.getMovie(),
                                movie.getOverview()
                        )
                ).toList()
        );
    }
}