Initial scaffolding and work on db unit testing

Author: mlambert125

01-creating-databases/.idea/01-creating-databases.iml

@@ -0,0 +1,38 @@
+target/
+!.mvn/wrapper/maven-wrapper.jar
+!**/src/main/**/target/
+!**/src/test/**/target/
+
+### IntelliJ IDEA ###
+.idea/modules.xml
+.idea/jarRepositories.xml
+.idea/compiler.xml
+.idea/libraries/
+*.iws
+*.iml
+*.ipr
+
+### Eclipse ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+build/
+!**/src/main/**/build/
+!**/src/test/**/build/
+
+### VS Code ###
+.vscode/
+
+### Mac OS ###
+.DS_Store

01-creating-databases/.idea/misc.xml

@@ -0,0 +1,41 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>org.example</groupId>
+    <artifactId>creating-databases</artifactId>
+    <version>1.0-SNAPSHOT</version>
+
+    <properties>
+        <maven.compiler.source>23</maven.compiler.source>
+        <maven.compiler.target>23</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+    <dependencies>
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter</artifactId>
+            <version>RELEASE</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>ch.vorburger.mariaDB4j</groupId>
+            <artifactId>mariaDB4j</artifactId>
+            <version>3.1.0</version>
+        </dependency>
+        <dependency>
+            <groupId>org.mariadb.jdbc</groupId>
+            <artifactId>mariadb-java-client</artifactId>
+            <version>3.4.1</version>
+        </dependency>
+        <dependency>
+            <groupId>org.mybatis</groupId>
+            <artifactId>mybatis</artifactId>
+            <version>3.5.6</version>
+        </dependency>
+
+    </dependencies>
+
+</project>

01-creating-databases/.idea/modules.xml

@@ -0,0 +1,40 @@
+drop table if exists users;
+create table users (
+    id integer primary key auto_increment,
+    username varchar(255) not null,
+    password varchar(255) not null
+);
+
+drop table if exists topics;
+create table topics (
+    id integer primary key auto_increment,
+    subject varchar(255) not null,
+    body text not null,
+    author_id integer not null,
+    foreign key(author_id) references users(id)
+);
+
+drop table if exists comments;
+create table comments (
+    id integer primary key auto_increment,
+    body text not null,
+    author_id integer not null,
+    topic_id integer not null,
+    foreign key(topic_id) references topics(id),
+    foreign key(author_id) references users(id)
+);
+
+insert into users (username, password) values ('bob', 'password');
+insert into users (username, password) values ('alice', 'password');
+insert into users (username, password) values ('charlie', 'password');
+
+insert into topics (subject, body, author_id) values ('First topic', 'This is the first topic', 1);
+insert into topics (subject, body, author_id) values ('Second topic', 'This is the second topic', 2);
+insert into topics (subject, body, author_id) values ('Third topic', 'This is the third topic', 3);
+
+insert into comments (body, author_id, topic_id) values ('This is the first comment', 1, 1);
+insert into comments (body, author_id, topic_id) values ('This is the second comment', 2, 1);
+insert into comments (body, author_id, topic_id) values ('This is the third comment', 1, 2);
+insert into comments (body, author_id, topic_id) values ('This is the fourth comment', 2, 2);
+insert into comments (body, author_id, topic_id) values ('This is the fifth comment', 1, 3);
+insert into comments (body, author_id, topic_id) values ('This is the sixth comment', 2, 3);

01-creating-databases/.idea/vcs.xml

@@ -0,0 +1,140 @@
+
+import ch.vorburger.mariadb4j.DB;
+import ch.vorburger.mariadb4j.DBConfigurationBuilder;
+import org.apache.ibatis.jdbc.ScriptRunner;
+import org.junit.jupiter.api.AfterAll;
+import org.junit.jupiter.api.BeforeAll;
+import org.junit.jupiter.api.Test;
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.ResultSet;
+import java.sql.Statement;
+
+public class TestCreateScript {
+    private static DB db;
+    private static Connection connection;
+
+    @BeforeAll
+    public static void setup() throws Exception {
+        DBConfigurationBuilder configBuilder = DBConfigurationBuilder.newBuilder();
+        configBuilder.setPort(0);
+        db = DB.newEmbeddedDB(configBuilder.build());
+        db.start();
+
+        connection = DriverManager.getConnection(
+            "jdbc:mariadb://localhost:" + db.getConfiguration().getPort() + "/test",
+            "root",
+            ""
+        );
+
+        java.io.Reader reader = new java.io.InputStreamReader(
+            TestCreateScript.class.getResource("/create-database.sql").openStream()
+        );
+
+        ScriptRunner sr = new ScriptRunner(connection);
+        sr.setStopOnError(true);
+        sr.runScript(reader);
+    }
+
+    @AfterAll
+    public static void tearDown() throws Exception {
+        connection.close();
+        db.stop();
+    }
+
+    @Test
+    public void checkUserColumns() throws Exception {
+        String[] columns = {"id", "username", "password" };
+        String[] types = {"int(11)", "varchar(255)", "varchar(255)"};
+        String[] keys = {"PRI", "", ""};
+        String[] extra = {"auto_increment", "", ""};
+
+        try (Statement statement = connection.createStatement()) {
+            ResultSet resultSet = statement.executeQuery("SHOW COLUMNS FROM users");
+            while (resultSet.next()) {
+                String column = resultSet.getString("Field");
+                boolean found = false;
+                for (int i = 0; i < columns.length; i++) {
+                    String c = columns[i];
+                    if (column.equals(c)) {
+                        if (!resultSet.getString("Type").equals(types[i])) {
+                            throw new Exception("Column " + column + " has wrong type - Expected: " + types[i] + " Found: " + resultSet.getString("Type"));
+                        }
+                        if (!resultSet.getString("Key").equals(keys[i])) {
+                            throw new Exception("Column " + column + " has wrong key type - Expected: " + keys[i] + " Found: " + resultSet.getString("Key"));
+                        }
+                        columns[i] = null;
+                        found = true;
+                        break;
+                    }
+                }
+                if (!found) {
+                    throw new Exception("Column " + column + " not expected");
+                }
+            }
+
+            for (String c : columns) {
+                if (c != null) {
+                    throw new Exception("Column " + c + " not found");
+                }
+            }
+        }
+    }
+
+    @Test
+    public void topicUserForeignKeyShouldExist() throws Exception {
+        String query = """
+                SELECT *
+                FROM information_schema.KEY_COLUMN_USAGE
+                WHERE TABLE_NAME = 'topics'
+                    AND COLUMN_NAME = 'author_id'
+                    AND REFERENCED_TABLE_NAME = 'users'
+                    AND REFERENCED_COLUMN_NAME = 'id'
+                """;
+
+        try (Statement statement = connection.createStatement()) {
+            ResultSet resultSet = statement.executeQuery(query);
+            if (!resultSet.next()) {
+                throw new Exception("Foreign key constraint not found");
+            }
+        }
+    }
+
+    @Test
+    public void commentUserForeignKeyShouldExist() throws Exception {
+        String query = """
+                SELECT *
+                FROM information_schema.KEY_COLUMN_USAGE
+                WHERE TABLE_NAME = 'comments'
+                    AND COLUMN_NAME = 'author_id'
+                    AND REFERENCED_TABLE_NAME = 'users'
+                    AND REFERENCED_COLUMN_NAME = 'id'
+                """;
+
+        try (Statement statement = connection.createStatement()) {
+            ResultSet resultSet = statement.executeQuery(query);
+            if (!resultSet.next()) {
+                throw new Exception("Foreign key constraint not found");
+            }
+        }
+    }
+
+    @Test
+    public void commentTopicForeignKeyShouldExist() throws Exception {
+        String query = """
+                SELECT *
+                FROM information_schema.KEY_COLUMN_USAGE
+                WHERE TABLE_NAME = 'comments'
+                    AND COLUMN_NAME = 'topic_id'
+                    AND REFERENCED_TABLE_NAME = 'topics'
+                    AND REFERENCED_COLUMN_NAME = 'id'
+                """;
+
+        try (Statement statement = connection.createStatement()) {
+            ResultSet resultSet = statement.executeQuery(query);
+            if (!resultSet.next()) {
+                throw new Exception("Foreign key constraint not found");
+            }
+        }
+    }
+}