test: Add sqlite3 test (#2161)

CLose #1131

Signed-off-by: unknowIfGuestInDream <liang.tang.cx@gmail.com>

Author: unknowIfGuestInDream

core/pom.xml

@@ -455,6 +455,11 @@
             <artifactId>qrcodegen</artifactId>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>org.xerial</groupId>
+            <artifactId>sqlite-jdbc</artifactId>
+            <scope>test</scope>
+        </dependency>
     </dependencies>
 
     <build>

core/src/test/java/com/tlcsdm/core/database/Sqlite1Test.java

@@ -0,0 +1,91 @@
+/*
+ * Copyright (c) 2025 unknowIfGuestInDream.
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *     * Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ *     * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ *     * Neither the name of unknowIfGuestInDream, any associated website, nor the
+ * names of its contributors may be used to endorse or promote products
+ * derived from this software without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+ * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+ * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+ * DISCLAIMED. IN NO EVENT SHALL UNKNOWIFGUESTINDREAM BE LIABLE FOR ANY
+ * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+ * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+ * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+ * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+ * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+package com.tlcsdm.core.database;
+
+import cn.hutool.core.io.resource.ResourceUtil;
+import com.tlcsdm.core.database.sqlite.UserDao;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.BeforeAll;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+
+import java.io.File;
+import java.nio.file.Paths;
+import java.sql.SQLException;
+import java.util.List;
+
+/**
+ * @author unknowIfGuestInDream
+ */
+public class Sqlite1Test {
+
+    private static String dbParentPath;
+    private static String TEST_DB_URL;
+    private UserDao userDao;
+
+    @BeforeAll
+    static void init() {
+        dbParentPath = new File(ResourceUtil.getResource("database/init.sql").getPath()).getParent();
+        TEST_DB_URL = "jdbc:sqlite:" + Paths.get(dbParentPath).resolve("usersqlite.db");
+        System.out.println(TEST_DB_URL);
+    }
+
+    @BeforeEach
+    void setUp() throws SQLException {
+        userDao = new UserDao(TEST_DB_URL);
+        userDao.deleteAllUsers();
+    }
+
+    @Test
+    void testInsertAndGetUsers() throws SQLException {
+        // 插入测试数据
+        userDao.insertUser("Alice", "alice@example.com");
+        userDao.insertUser("Bob", "bob@example.com");
+
+        // 验证数据
+        List<String> names = userDao.getAllUserNames();
+        Assertions.assertEquals(2, names.size());
+        Assertions.assertTrue(names.contains("Alice"));
+        Assertions.assertTrue(names.contains("Bob"));
+    }
+
+    @Test
+    void testEmptyDatabase() throws SQLException {
+        List<String> names = userDao.getAllUserNames();
+        Assertions.assertTrue(names.isEmpty());
+    }
+
+    @Test
+    void testDuplicateEmail() {
+        // 测试唯一约束
+        Assertions.assertDoesNotThrow(() -> userDao.insertUser("Alice", "alice@example.com"));
+        SQLException exception = Assertions.assertThrows(SQLException.class,
+            () -> userDao.insertUser("Alice", "alice@example.com"));
+        Assertions.assertTrue(exception.getMessage().contains("UNIQUE constraint failed"));
+    }
+}

core/src/test/java/com/tlcsdm/core/database/Sqlite2Test.java

@@ -0,0 +1,89 @@
+/*
+ * Copyright (c) 2025 unknowIfGuestInDream.
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *     * Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ *     * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ *     * Neither the name of unknowIfGuestInDream, any associated website, nor the
+ * names of its contributors may be used to endorse or promote products
+ * derived from this software without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+ * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+ * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+ * DISCLAIMED. IN NO EVENT SHALL UNKNOWIFGUESTINDREAM BE LIABLE FOR ANY
+ * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+ * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+ * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+ * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+ * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+package com.tlcsdm.core.database;
+
+import com.tlcsdm.core.database.sqlite.UserDao;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.BeforeAll;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.io.TempDir;
+
+import java.nio.file.Path;
+import java.sql.SQLException;
+import java.util.List;
+
+/**
+ * @author unknowIfGuestInDream
+ */
+public class Sqlite2Test {
+    @TempDir
+    static Path tempDir;
+    private static String TEST_DB_URL;
+    private UserDao userDao;
+
+    @BeforeAll
+    static void init() {
+        TEST_DB_URL = "jdbc:sqlite:" + tempDir.resolve("test.db");
+        System.out.println(TEST_DB_URL);
+    }
+
+    @BeforeEach
+    void setUp() throws SQLException {
+        userDao = new UserDao(TEST_DB_URL);
+        userDao.deleteAllUsers();
+    }
+
+    @Test
+    void testInsertAndGetUsers() throws SQLException {
+        // 插入测试数据
+        userDao.insertUser("Alice", "alice@example.com");
+        userDao.insertUser("Bob", "bob@example.com");
+
+        // 验证数据
+        List<String> names = userDao.getAllUserNames();
+        Assertions.assertEquals(2, names.size());
+        Assertions.assertTrue(names.contains("Alice"));
+        Assertions.assertTrue(names.contains("Bob"));
+    }
+
+    @Test
+    void testEmptyDatabase() throws SQLException {
+        List<String> names = userDao.getAllUserNames();
+        Assertions.assertTrue(names.isEmpty());
+    }
+
+    @Test
+    void testDuplicateEmail() {
+        // 测试唯一约束
+        Assertions.assertDoesNotThrow(() -> userDao.insertUser("Alice", "alice@example.com"));
+        SQLException exception = Assertions.assertThrows(SQLException.class,
+            () -> userDao.insertUser("Alice", "alice@example.com"));
+        Assertions.assertTrue(exception.getMessage().contains("UNIQUE constraint failed"));
+    }
+}

core/src/test/java/com/tlcsdm/core/database/SqliteAccountTest.java

@@ -0,0 +1,90 @@
+/*
+ * Copyright (c) 2025 unknowIfGuestInDream.
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *     * Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ *     * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ *     * Neither the name of unknowIfGuestInDream, any associated website, nor the
+ * names of its contributors may be used to endorse or promote products
+ * derived from this software without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+ * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+ * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+ * DISCLAIMED. IN NO EVENT SHALL UNKNOWIFGUESTINDREAM BE LIABLE FOR ANY
+ * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+ * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+ * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+ * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+ * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+package com.tlcsdm.core.database;
+
+import cn.hutool.core.io.resource.ResourceUtil;
+import org.junit.jupiter.api.BeforeAll;
+import org.junit.jupiter.api.Test;
+
+import java.io.File;
+import java.nio.file.Paths;
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+
+/**
+ * @author unknowIfGuestInDream
+ */
+public class SqliteAccountTest {
+    /**
+     * 以嵌入式(本地)连接方式连接数据库
+     */
+    private static final String DRIVER_CLASS = "org.sqlite.JDBC";
+    private static final String USER = "root";
+    private static final String PASSWORD = "root";
+    private static String dbParentPath;
+    private static String TEST_DB_URL;
+
+    @BeforeAll
+    static void init() {
+        dbParentPath = new File(ResourceUtil.getResource("database/init.sql").getPath()).getParent();
+        TEST_DB_URL = "jdbc:sqlite:" + Paths.get(dbParentPath).resolve("sqliteDB.db");
+        System.out.println(TEST_DB_URL);
+    }
+
+    @Test
+    void testInsertAndGetUsers() throws ClassNotFoundException, SQLException {
+        //与数据库建立连接
+        Class.forName(DRIVER_CLASS);
+        Connection conn = DriverManager.getConnection(TEST_DB_URL, USER, PASSWORD);
+        Statement statement = conn.createStatement();
+
+        //删除表
+        statement.execute("DROP TABLE IF EXISTS USER_INF");
+        //创建表
+        statement.execute(
+            "CREATE TABLE USER_INF(id VARCHAR(50) PRIMARY KEY, name VARCHAR(50) NOT NULL, sex VARCHAR(50) NOT NULL)");
+
+        //插入数据
+        statement.executeUpdate("INSERT INTO USER_INF VALUES('1', '程咬金', '男') ");
+        statement.executeUpdate("INSERT INTO USER_INF VALUES('2', '孙尚香', '女') ");
+        statement.executeUpdate("INSERT INTO USER_INF VALUES('3', '猴子', '男') ");
+
+        //查询数据
+        ResultSet resultSet = statement.executeQuery("select * from USER_INF");
+        while (resultSet.next()) {
+            System.out.println(
+                resultSet.getInt("id") + ", " + resultSet.getString("name") + ", " + resultSet.getString("sex"));
+        }
+        //关闭连接
+        statement.close();
+        conn.close();
+    }
+}

core/src/test/java/com/tlcsdm/core/database/SqliteInitSQLTest.java

@@ -0,0 +1,100 @@
+/*
+ * Copyright (c) 2025 unknowIfGuestInDream.
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *     * Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ *     * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ *     * Neither the name of unknowIfGuestInDream, any associated website, nor the
+ * names of its contributors may be used to endorse or promote products
+ * derived from this software without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+ * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+ * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+ * DISCLAIMED. IN NO EVENT SHALL UNKNOWIFGUESTINDREAM BE LIABLE FOR ANY
+ * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+ * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+ * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+ * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+ * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+package com.tlcsdm.core.database;
+
+import cn.hutool.core.io.resource.ResourceUtil;
+import org.junit.jupiter.api.AfterAll;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.BeforeAll;
+import org.junit.jupiter.api.Test;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+
+/**
+ * 初始化脚本.
+ *
+ * @author unknowIfGuestInDream
+ */
+public class SqliteInitSQLTest {
+
+    private static Connection conn;
+
+    @BeforeAll
+    static void setup() throws Exception {
+        // 创建内存数据库连接
+        conn = DriverManager.getConnection("jdbc:sqlite::memory:");
+        // 执行初始化脚本
+        initializeInMemoryDatabase(conn);
+    }
+
+    @Test
+    void testUserCount() throws SQLException {
+        try (Statement stmt = conn.createStatement();
+             ResultSet rs = stmt.executeQuery("SELECT COUNT(*) FROM users")) {
+            rs.next();
+            Assertions.assertEquals(3, rs.getInt(1));
+        }
+    }
+
+    @AfterAll
+    static void cleanup() throws SQLException {
+        if (conn != null) {
+            conn.close();
+        }
+    }
+
+    private static void initializeInMemoryDatabase(Connection conn) throws SQLException, IOException {
+        try (InputStream is = ResourceUtil.getResource("database/init.sql").openStream();
+             BufferedReader reader = new BufferedReader(new InputStreamReader(is));
+             Statement stmt = conn.createStatement()) {
+
+            String line;
+            StringBuilder sb = new StringBuilder();
+            while ((line = reader.readLine()) != null) {
+                // 跳过注释和空行
+                if (!line.trim().startsWith("--") && !line.trim().isEmpty()) {
+                    sb.append(line);
+                    // 检查是否以分号结束（完整SQL语句）
+                    if (line.trim().endsWith(";")) {
+                        String sql = sb.toString();
+                        stmt.execute(sql);
+                        sb = new StringBuilder();
+                    }
+                }
+            }
+        }
+    }
+}