Added mysql unit test example.

build.gradle

@@ -11,6 +11,9 @@ repositories {
 
 dependencies {
  testImplementation 'junit:junit:[4.13.2,)'
+ testImplementation 'org.zapodot:embedded-db-junit:[2.0.2,)'
+ testImplementation 'org.slf4j:slf4j-api:[1.7.32,)'
+ testImplementation 'org.slf4j:slf4j-simple:[1.7.32,)'
 }
 
 group = 'com.github.javadev'

pom-central.xml

@@ -130,5 +130,23 @@
  <version>[4.13.2,)</version>
  <scope>test</scope>
  </dependency>
+ <dependency>
+ <groupId>org.zapodot</groupId>
+ <artifactId>embedded-db-junit</artifactId>
+ <version>[2.0.2,)</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.slf4j</groupId>
+ <artifactId>slf4j-api</artifactId>
+ <version>[1.7.32,)</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.slf4j</groupId>
+ <artifactId>slf4j-simple</artifactId>
+ <version>[1.7.32,)</version>
+ <scope>test</scope>
+ </dependency>
  </dependencies>
 </project>

pom-central11.xml

@@ -123,5 +123,23 @@
  <version>[4.13.2,)</version>
  <scope>test</scope>
  </dependency>
+ <dependency>
+ <groupId>org.zapodot</groupId>
+ <artifactId>embedded-db-junit</artifactId>
+ <version>[2.0.2,)</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.slf4j</groupId>
+ <artifactId>slf4j-api</artifactId>
+ <version>[1.7.32,)</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.slf4j</groupId>
+ <artifactId>slf4j-simple</artifactId>
+ <version>[1.7.32,)</version>
+ <scope>test</scope>
+ </dependency>
  </dependencies>
 </project>

pom-central17.xml

@@ -123,5 +123,23 @@
  <version>[4.13.2,)</version>
  <scope>test</scope>
  </dependency>
+ <dependency>
+ <groupId>org.zapodot</groupId>
+ <artifactId>embedded-db-junit</artifactId>
+ <version>[2.0.2,)</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.slf4j</groupId>
+ <artifactId>slf4j-api</artifactId>
+ <version>[1.7.32,)</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.slf4j</groupId>
+ <artifactId>slf4j-simple</artifactId>
+ <version>[1.7.32,)</version>
+ <scope>test</scope>
+ </dependency>
  </dependencies>
 </project>

pom.xml

@@ -162,5 +162,23 @@
  <version>[4.13.2,)</version>
  <scope>test</scope>
  </dependency>
+ <dependency>
+ <groupId>org.zapodot</groupId>
+ <artifactId>embedded-db-junit</artifactId>
+ <version>[2.0.2,)</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.slf4j</groupId>
+ <artifactId>slf4j-api</artifactId>
+ <version>[1.7.32,)</version>
+ <scope>test</scope>
+ </dependency>
+ <dependency>
+ <groupId>org.slf4j</groupId>
+ <artifactId>slf4j-simple</artifactId>
+ <version>[1.7.32,)</version>
+ <scope>test</scope>
+ </dependency>
  </dependencies>
 </project>

src/main/java/g0101_0200/s0175_combine_two_tables/script.sql

@@ -1,5 +1,3 @@
 # Write your MySQL query statement below
-select distinct num as ConsecutiveNums from
-(select num, lag(num,1) over() as l1, lag(num,2) over() as l2
-from Logs) con_thr
-where num = l1 and num = l2
+SELECT FirstName, LastName, City, State
+FROM Person LEFT JOIN Address USING (PersonId)

src/test/java/g0101_0200/s0175_combine_two_tables/MysqlTest.java

@@ -0,0 +1,68 @@
+package g0101_0200.s0175_combine_two_tables;
+
+import static org.hamcrest.CoreMatchers.equalTo;
+import static org.hamcrest.MatcherAssert.assertThat;
+
+import java.io.BufferedReader;
+import java.io.FileNotFoundException;
+import java.io.FileReader;
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.util.stream.Collectors;
+import org.junit.Rule;
+import org.junit.Test;
+import org.zapodot.junit.db.EmbeddedDatabaseRule;
+import org.zapodot.junit.db.common.CompatibilityMode;
+
+public class MysqlTest {
+ @Rule
+ public final EmbeddedDatabaseRule embeddedDatabaseRule =
+ EmbeddedDatabaseRule.builder()
+ .withMode(CompatibilityMode.MySQL)
+ .withInitialSql(
+ "CREATE TABLE Person(personId INTEGER PRIMARY KEY, lastName VARCHAR(512)"
+ + ", firstName VARCHAR(512)); "
+ + "INSERT INTO Person(personId, lastName, firstName) "
+ + "VALUES (1, 'Wang', 'Allen'); "
+ + "INSERT INTO Person(personId, lastName, firstName) "
+ + "VALUES (2, 'Alice', 'Bob'); "
+ + "CREATE TABLE Address(addressId INTEGER PRIMARY KEY, personId INTEGER"
+ + ", city VARCHAR(512), state VARCHAR(512)); "
+ + "INSERT INTO Address(addressId, personId, city, state) "
+ + "VALUES (1, 2, 'New York City', 'New York'); "
+ + "INSERT INTO Address(addressId, personId, city, state) "
+ + "VALUES (2, 3, 'Leetcode', 'California'); ")
+ .build();
+
+ @Test
+ public void testScript() throws SQLException, FileNotFoundException {
+ try (final Connection connection =
+ DriverManager.getConnection(embeddedDatabaseRule.getConnectionJdbcUrl())) {
+ try (final Statement statement = connection.createStatement();
+ final ResultSet resultSet =
+ statement.executeQuery(
+ new BufferedReader(
+ new FileReader(
+ "src/main/java/g0101_0200/"
+ + "s0175_combine_two_tables/script.sql"))
+ .lines()
+ .collect(Collectors.joining("\n"))
+ .replaceAll("#.*?\\r?\\n", ""))) {
+ assertThat(resultSet.next(), equalTo(true));
+ assertThat(resultSet.getNString(1), equalTo("Allen"));
+ assertThat(resultSet.getNString(2), equalTo("Wang"));
+ assertThat(resultSet.getNString(3), equalTo(null));
+ assertThat(resultSet.getNString(4), equalTo(null));
+ assertThat(resultSet.next(), equalTo(true));
+ assertThat(resultSet.getNString(1), equalTo("Bob"));
+ assertThat(resultSet.getNString(2), equalTo("Alice"));
+ assertThat(resultSet.getNString(3), equalTo("New York City"));
+ assertThat(resultSet.getNString(4), equalTo("New York"));
+ assertThat(resultSet.next(), equalTo(false));
+ }
+ }
+ }
+}