|  | 
|  | 1 | +package g3601_3700.s3611_find_overbooked_employees; | 
|  | 2 | + | 
|  | 3 | +import static org.hamcrest.CoreMatchers.equalTo; | 
|  | 4 | +import static org.hamcrest.MatcherAssert.assertThat; | 
|  | 5 | + | 
|  | 6 | +import java.io.BufferedReader; | 
|  | 7 | +import java.io.FileNotFoundException; | 
|  | 8 | +import java.io.FileReader; | 
|  | 9 | +import java.sql.Connection; | 
|  | 10 | +import java.sql.ResultSet; | 
|  | 11 | +import java.sql.SQLException; | 
|  | 12 | +import java.sql.Statement; | 
|  | 13 | +import java.util.stream.Collectors; | 
|  | 14 | +import javax.sql.DataSource; | 
|  | 15 | +import org.junit.jupiter.api.Test; | 
|  | 16 | +import org.zapodot.junit.db.annotations.EmbeddedDatabase; | 
|  | 17 | +import org.zapodot.junit.db.annotations.EmbeddedDatabaseTest; | 
|  | 18 | +import org.zapodot.junit.db.common.CompatibilityMode; | 
|  | 19 | + | 
|  | 20 | +@EmbeddedDatabaseTest( | 
|  | 21 | +        compatibilityMode = CompatibilityMode.MySQL, | 
|  | 22 | +        initialSqls = | 
|  | 23 | +                "CREATE TABLE employees (" | 
|  | 24 | +                        + "    employee_id INTEGER," | 
|  | 25 | +                        + "    employee_name VARCHAR(50)," | 
|  | 26 | +                        + "    department VARCHAR(50)" | 
|  | 27 | +                        + ");" | 
|  | 28 | +                        + "INSERT INTO employees (employee_id, employee_name, department) VALUES" | 
|  | 29 | +                        + "    (1, 'Alice Johnson', 'Engineering')," | 
|  | 30 | +                        + "    (2, 'Bob Smith', 'Marketing')," | 
|  | 31 | +                        + "    (3, 'Carol Davis', 'Sales')," | 
|  | 32 | +                        + "    (4, 'David Wilson', 'Engineering')," | 
|  | 33 | +                        + "    (5, 'Emma Brown', 'HR');" | 
|  | 34 | +                        + "CREATE TABLE meetings (" | 
|  | 35 | +                        + "    meeting_id INTEGER," | 
|  | 36 | +                        + "    employee_id INTEGER," | 
|  | 37 | +                        + "    meeting_date DATE," | 
|  | 38 | +                        + "    meeting_type VARCHAR(20)," | 
|  | 39 | +                        + "    duration_hours DECIMAL(4,1)" | 
|  | 40 | +                        + ");" | 
|  | 41 | +                        + "INSERT INTO meetings (meeting_id, employee_id, " | 
|  | 42 | +                        + "meeting_date, meeting_type, duration_hours) VALUES" | 
|  | 43 | +                        + "    (1, 1, '2023-06-05', 'Team', 8.0)," | 
|  | 44 | +                        + "    (2, 1, '2023-06-06', 'Client', 6.0)," | 
|  | 45 | +                        + "    (3, 1, '2023-06-07', 'Training', 7.0)," | 
|  | 46 | +                        + "    (4, 1, '2023-06-12', 'Team', 12.0)," | 
|  | 47 | +                        + "    (5, 1, '2023-06-13', 'Client', 9.0)," | 
|  | 48 | +                        + "    (6, 2, '2023-06-05', 'Team', 15.0)," | 
|  | 49 | +                        + "    (7, 2, '2023-06-06', 'Client', 8.0)," | 
|  | 50 | +                        + "    (8, 2, '2023-06-12', 'Training', 10.0)," | 
|  | 51 | +                        + "    (9, 3, '2023-06-05', 'Team', 4.0)," | 
|  | 52 | +                        + "    (10, 3, '2023-06-06', 'Client', 3.0)," | 
|  | 53 | +                        + "    (11, 4, '2023-06-05', 'Team', 25.0)," | 
|  | 54 | +                        + "    (12, 4, '2023-06-19', 'Client', 22.0)," | 
|  | 55 | +                        + "    (13, 5, '2023-06-05', 'Training', 2.0);") | 
|  | 56 | +class MysqlTest { | 
|  | 57 | +    @Test | 
|  | 58 | +    void testScript(@EmbeddedDatabase DataSource dataSource) | 
|  | 59 | +            throws SQLException, FileNotFoundException { | 
|  | 60 | +        try (final Connection connection = dataSource.getConnection()) { | 
|  | 61 | +            try (final Statement statement = connection.createStatement(); | 
|  | 62 | +                    final ResultSet resultSet = | 
|  | 63 | +                            statement.executeQuery( | 
|  | 64 | +                                    new BufferedReader( | 
|  | 65 | +                                                    new FileReader( | 
|  | 66 | +                                                            "src/main/java/g3601_3700/" | 
|  | 67 | +                                                                    + "s3611_find_overbooked_employees/" | 
|  | 68 | +                                                                    + "script.sql")) | 
|  | 69 | +                                            .lines() | 
|  | 70 | +                                            .collect(Collectors.joining("\n")) | 
|  | 71 | +                                            .replaceAll("#.*?\\r?\\n", "") | 
|  | 72 | +                                            .replace("WEEKOFYEAR", "ISO_WEEK"))) { | 
|  | 73 | +                assertThat(resultSet.next(), equalTo(true)); | 
|  | 74 | +                assertThat(resultSet.getNString(1), equalTo("1")); | 
|  | 75 | +                assertThat(resultSet.getNString(2), equalTo("Alice Johnson")); | 
|  | 76 | +                assertThat(resultSet.getNString(3), equalTo("Engineering")); | 
|  | 77 | +                assertThat(resultSet.getNString(4), equalTo("2")); | 
|  | 78 | +                assertThat(resultSet.next(), equalTo(true)); | 
|  | 79 | +                assertThat(resultSet.getNString(1), equalTo("4")); | 
|  | 80 | +                assertThat(resultSet.getNString(2), equalTo("David Wilson")); | 
|  | 81 | +                assertThat(resultSet.getNString(3), equalTo("Engineering")); | 
|  | 82 | +                assertThat(resultSet.getNString(4), equalTo("2")); | 
|  | 83 | +                assertThat(resultSet.next(), equalTo(false)); | 
|  | 84 | +            } | 
|  | 85 | +        } | 
|  | 86 | +    } | 
|  | 87 | +} | 
0 commit comments