feat: Tests de JDBC: Búsqueda e Inserción de Películas por ID

Author: luiscacuango2

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

@@ -17,7 +17,7 @@ public MovieRepositoryJdbc(JdbcTemplate jdbcTemplate) {
 
     @Override
     public Movie findById(long id) {
-        return null;
+        return jdbcTemplate.queryForObject("select * from movies where id = ?", movieMapper, id);
     }
 
     @Override
@@ -28,12 +28,18 @@ public Collection<Movie> findAll() {
 
     @Override
     public void saveOrUpdate(Movie movie) {
-
+        if (movie.getId() == null) {
+            jdbcTemplate.update("insert into movies (name, minutes, gender) values (?, ?, ?)",
+                    movie.getName(), movie.getMinutes(), movie.getGender().toString());
+        }
     }
 
-    private static RowMapper<Movie> movieMapper = (rs, rowNum) -> new Movie(
-            rs.getInt("id"),
-            rs.getString("name"),
-            rs.getInt("minutes"),
-            Gender.valueOf(rs.getString("gender")));
+    private static RowMapper<Movie> movieMapper = (rs, rowNum) ->
+            new Movie(
+                    rs.getInt("id"),
+                    rs.getString("name"),
+                    rs.getInt("minutes"),
+                    // Convertir String a Enum
+                    Gender.valueOf(rs.getString("gender"))
+            );
 }

src/main/java/com/luigi/javatest/movies/model/Movie.java

@@ -1,5 +1,7 @@
 package com.luigi.javatest.movies.model;
 
+import java.util.Objects;
+
 public class Movie {
     private Integer id;
     private String name;
@@ -32,4 +34,19 @@ public int getMinutes() {
     public Gender getGender() {
         return gender;
     }
+
+    @Override
+    public boolean equals(Object o) {
+        if (o == null || getClass() != o.getClass()) return false;
+        Movie movie = (Movie) o;
+        return minutes == movie.minutes &&
+                Objects.equals(id, movie.id) &&
+                Objects.equals(name, movie.name) &&
+                gender == movie.gender;
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(id, name, minutes, gender);
+    }
 }

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

@@ -5,6 +5,8 @@ CREATE TABLE IF NOT EXISTS movies (
     gender VARCHAR(50) NOT NULL
     );
 
+TRUNCATE TABLE movies;
+
 INSERT INTO movies (name, minutes, gender) VALUES
     ('Dark Knight', 152, 'ACTION'),
     ('Memento', 113, 'THRILLER'),

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

@@ -1,26 +1,25 @@
 package com.luigi.javatest.movies.data;
 
+import com.luigi.javatest.movies.model.Gender;
 import com.luigi.javatest.movies.model.Movie;
+import org.junit.jupiter.api.AfterAll;
 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.sql.Statement;
 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;
+    private static DriverManagerDataSource dataSource;
 
     @BeforeEach
     void setUp() {
@@ -33,8 +32,8 @@ void setUp() {
         dataSource.setPassword("sa");
 
         // 2. Cargamos el script
-            ResourceDatabasePopulator populator = new ResourceDatabasePopulator();
-            populator.addScript(new ClassPathResource("sql-scripts/test-data.sql"));
+        ResourceDatabasePopulator populator = new ResourceDatabasePopulator();
+        populator.addScript(new ClassPathResource("sql-scripts/test-data.sql"));
 
         // 3. Ejecutamos el populator sobre el datasource
         populator.execute(dataSource);
@@ -54,5 +53,36 @@ public void load_all_movies() throws SQLException {
         assertEquals(Arrays.asList(1, 2, 3), moviesIds);
     }
 
+    @Test
+    public void load_movie_by_id() {
+        // Ejecutar
+        Movie movie = movieRepository.findById(2);
+
+        // Validar
+        assertEquals(2, movie.getId());
+        assertEquals("Memento", movie.getName());
+    }
+
+    @Test
+    public void insert_a_movie() {
+        // Preparar
+        Movie movie = new Movie(null, "Super 8", 112, Gender.THRILLER);
+
+        // Ejecutar
+        movieRepository.saveOrUpdate(movie);
 
+        // Validar
+        Movie movieFromDb = movieRepository.findById(4);
+        assertEquals(4, movieFromDb.getId());
+        assertEquals("Super 8", movieFromDb.getName());
+    }
+
+    @AfterAll
+    public static void tearDown() throws Exception { // Añadido 'static'
+        if (dataSource != null) {
+            try (Statement s = dataSource.getConnection().createStatement()) {
+                s.execute("DROP ALL OBJECTS DELETE FILES");
+            }
+        }
+    }
 }