feat: Implementación de MovieRepository con JDBC en Java

Author: luiscacuango2

pom.xml

@@ -33,6 +33,16 @@
             <version>5.12.2</version>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-jdbc</artifactId>
+            <version>6.2.11</version>
+        </dependency>
+        <dependency>
+            <groupId>com.h2database</groupId>
+            <artifactId>h2</artifactId>
+            <version>2.4.240</version>
+        </dependency>
 
     </dependencies>
 

src/main/java/com/luigi/javatest/movies/data/MovieRepositoryJdbc.java

@@ -0,0 +1,39 @@
+package com.luigi.javatest.movies.data;
+
+import com.luigi.javatest.movies.model.Gender;
+import com.luigi.javatest.movies.model.Movie;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.core.RowMapper;
+
+import java.util.Collection;
+
+public class MovieRepositoryJdbc implements MovieRepository {
+
+    private JdbcTemplate jdbcTemplate;
+
+    public MovieRepositoryJdbc(JdbcTemplate jdbcTemplate) {
+        this.jdbcTemplate = jdbcTemplate;
+    }
+
+    @Override
+    public Movie findById(long id) {
+        return null;
+    }
+
+    @Override
+    public Collection<Movie> findAll() {
+
+        return jdbcTemplate.query("select * from movies", movieMapper);
+    }
+
+    @Override
+    public void saveOrUpdate(Movie movie) {
+
+    }
+
+    private static RowMapper<Movie> movieMapper = (rs, rowNum) -> new Movie(
+            rs.getInt("id"),
+            rs.getString("name"),
+            rs.getInt("minutes"),
+            Gender.valueOf(rs.getString("gender")));
+}

src/main/resources/sql-scripts/test-data.sql

@@ -0,0 +1,11 @@
+CREATE TABLE IF NOT EXISTS movies (
+    id INT AUTO_INCREMENT PRIMARY KEY,
+    name VARCHAR(50) NOT NULL,
+    minutes INT NOT NULL,
+    gender VARCHAR(50) NOT NULL
+    );
+
+INSERT INTO movies (name, minutes, gender) VALUES
+    ('Dark Knight', 152, 'ACTION'),
+    ('Memento', 113, 'THRILLER'),
+    ('Matrix', 136, 'ACTION')

src/test/java/com/luigi/javatest/movies/data/MovieRepositoryIntegrationTest.java

@@ -0,0 +1,58 @@
+package com.luigi.javatest.movies.data;
+
+import com.luigi.javatest.movies.model.Movie;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.springframework.core.io.ClassPathResource;
+import org.springframework.jdbc.core.JdbcTemplate;
+import org.springframework.jdbc.datasource.DriverManagerDataSource;
+import org.springframework.jdbc.datasource.init.ResourceDatabasePopulator;
+import org.springframework.jdbc.datasource.init.ScriptUtils;
+import javax.sql.DataSource;
+import java.sql.SQLException;
+import java.util.Arrays;
+import java.util.Collection;
+import java.util.List;
+import java.util.stream.Collectors;
+
+import static com.luigi.javatest.movies.service.MovieServiceShould.getMoviesIds;
+import static org.junit.jupiter.api.Assertions.*;
+
+public class MovieRepositoryIntegrationTest {
+    private MovieRepositoryJdbc movieRepository;
+    private DriverManagerDataSource dataSource;
+
+    @BeforeEach
+    void setUp() {
+        // 1. Configurar la conexión a la base de datos H2 en memoria
+        dataSource = new DriverManagerDataSource();
+        dataSource.setDriverClassName("org.h2.Driver");
+        // Añadimos DB_CLOSE_DELAY=-1 para que la tabla no desaparezca
+        dataSource.setUrl("jdbc:h2:mem:test;MODE=MYSQL;DB_CLOSE_DELAY=-1");
+        dataSource.setUsername("sa");
+        dataSource.setPassword("sa");
+
+        // 2. Cargamos el script
+            ResourceDatabasePopulator populator = new ResourceDatabasePopulator();
+            populator.addScript(new ClassPathResource("sql-scripts/test-data.sql"));
+
+        // 3. Ejecutamos el populator sobre el datasource
+        populator.execute(dataSource);
+
+        // 4. Inicializar el repositorio
+        movieRepository = new MovieRepositoryJdbc(new JdbcTemplate(dataSource));
+    }
+
+    @Test
+    public void load_all_movies() throws SQLException {
+        // Ejecutar
+        Collection<Movie> movies = movieRepository.findAll();
+
+        // Validar (Usamos una pequeña utilidad local para obtener IDs)
+        List<Integer> moviesIds = movies.stream().map(Movie::getId).collect(Collectors.toList());
+
+        assertEquals(Arrays.asList(1, 2, 3), moviesIds);
+    }
+
+
+}

src/test/java/com/luigi/javatest/movies/service/MovieServiceShould.java

@@ -57,7 +57,7 @@ public void return_movies_by_length() {
         assertEquals(Arrays.asList(2, 3, 4, 5, 6), getMoviesIds(movies));
     }
 
-    private static List<Integer> getMoviesIds(Collection<Movie> movies) {
+    public static List<Integer> getMoviesIds(Collection<Movie> movies) {
         return movies.stream()
                 .map(Movie::getId)
                 .collect(Collectors.toList());