[SqliteWAL]: 重构示例并优化SQLite配置

- 文件重命名: 将`databasetest`和`databaseutils`统一重命名为`sqlitetest`和`sqliteutils`，保持命名一致性
- 文档更新: 替换README中WAL模式说明为官方文档链接，明确工程实践方案
- 功能增强:
  - 增加`readLastRecord()`方法支持读取最后插入的记录
  - 添加`local_time`字段存储本地格式化时间戳
- SQL优化:
  - 增加WAL模式下的PRAGMA优化配置（内存映射/自动清理/缓存设置）
  - 添加SQLite版本及编译选项的运行时日志输出
  - 实现数据库连接关闭时的主动优化操作（ANALYZE/VACUUM）
- 线程安全:
  - 明确写入操作使用QMutex串行化避免SQLITE_BUSY错误
  - 读取操作无需加锁保证并发性能
- 示例扩展:
  - 增加测试手机品牌数量（9个品牌）
  - 每个写入线程增加读取最后记录操作
- 健壮性提升:
  - 数据库连接移除时增加资源清理
  - 首次运行时删除旧测试数据库
  - 增强错误日志输出

Author: RealChuan

README.md

@@ -150,19 +150,12 @@
 
 ## [SqliteWAL](SqliteWAL/)——Sqlite WAL 模式下多线程并发写入数据库程序
 
-1. 每个线程拥有独立的数据库连接（不同的连接名称），线程退出需要主动移除数据库连接，不然会产生大量的数据库连接；
-2. 在多线程下，依旧使用QMutex保证线程安全，在读的时候，可以考虑不使用QMutex，并发读应该没什么影响（对于写的时候，可以考虑使用QMutex）;
-
-### WAL模式的优点
-
-1. 提高了并发性：WAL模式允许多个读取器和一个写入器同时访问数据库，可以提高并发性能；
-2. 崩溃恢复：WAL模式在发生崩溃时确保数据库保持一致，通过在提交事务之前将所有更改刷新到日志文件来实现；
+[Write-Ahead Logging (WAL) 官方文档](https://sqlite.org/wal.html)
 
-### WAL模式的注意事项
-
-1. WAL模式仅适用于SQLite 3.35.5+版本；
-2. 增加了磁盘使用量：与回滚模式相比，WAL模式需要更多的磁盘空间，因为它在提交更改之前将所有更改都写入日志文件；
-3. 读取性能较慢：读取操作不会被写入操作阻塞，如果同时进行读取和写入操作，可能导致数据不一致。
+1. 每个线程拥有独立的数据库连接（不同的连接名称），线程退出需要主动移除数据库连接，不然会产生大量的数据库连接；
+2. 最佳工程实践，并不是最佳性能：
+   1. 写入操作使用`QMutex`，使写入操作串行化，避免[SQLITE_BUSY](https://sqlite.org/rescode.html#busy)错误；
+   2. 读取操作不需要加锁;
 
 ## [TableViewModel](TableViewModel/)——表格视图
 

SqliteWAL/CMakeLists.txt

@@ -1,5 +1,5 @@
-set(PROJECT_SOURCES databasetest.cc databasetest.hpp databaseutils.cc
-                    databaseutils.hpp main.cc)
+set(PROJECT_SOURCES sqlitetest.cc sqlitetest.hpp sqliteutils.cc sqliteutils.hpp
+                    main.cc)
 
 qt_add_executable(SqliteWAL MANUAL_FINALIZATION ${PROJECT_SOURCES})
 target_link_libraries(SqliteWAL PRIVATE Qt::Core Qt::Sql)

SqliteWAL/SqliteWAL.pro

@@ -5,13 +5,13 @@ QT += core sql
 CONFIG += cmdline
 
 SOURCES += \
-        databasetest.cc \
-        databaseutils.cc \
-        main.cc
+        main.cc \
+        sqlitetest.cc \
+        sqliteutils.cc
 
 HEADERS += \
-    databasetest.hpp \
-    databaseutils.hpp
+    sqlitetest.hpp \
+    sqliteutils.hpp
 
 # Default rules for deployment.
 qnx: target.path = /tmp/$${TARGET}/bin

SqliteWAL/databasetest.cc

@@ -1,4 +1,4 @@
-#include "databasetest.hpp"
+#include "sqlitetest.hpp"
 
 #include <QCoreApplication>
 #include <QSqlDatabase>
@@ -7,9 +7,10 @@
 
 void insertThread(const QString &brand)
 {
-    DataBaseTest test;
+    SqliteTest test;
     for (int i = 0; i < 1000; i++) {
         test.insert(brand, i);
+        test.readLastRecord();
     }
 }
 
@@ -22,7 +23,16 @@ int main(int argc, char *argv[])
         return -1;
     }
 
-    const QStringList brands{"Apple", "Samsung", "Xiaomi", "Huawei", "Oppo", "Vivo", "Realme"};
+    const QStringList brands{"Apple",
+                             "Samsung",
+                             "Xiaomi",
+                             "Redmi",
+                             "Oppo",
+                             "Vivo",
+                             "Realme",
+                             "IQOO",
+                             "OnePlus",
+                             "Pixel"};
     std::vector<std::thread> threads;
     for (const auto &brand : std::as_const(brands)) {
         threads.emplace_back(insertThread, brand);

SqliteWAL/databasetest.hpp

@@ -0,0 +1,128 @@
+#include "sqlitetest.hpp"
+#include "sqliteutils.hpp"
+
+#include <QDir>
+#include <QMutex>
+#include <QSqlError>
+#include <QSqlQuery>
+#include <QThread>
+
+#include <mutex>
+
+class SqliteTest::SqliteTestPrivate
+{
+public:
+    explicit SqliteTestPrivate(SqliteTest *q)
+        : q_ptr(q)
+    {
+        dataBaseConnection.dataBasePath = QString("%1/%2").arg(QDir::tempPath()).arg("test.db");
+
+        static std::once_flag onceFlag;
+        std::call_once(onceFlag, [this]() { QFile::remove(this->dataBaseConnection.dataBasePath); });
+
+        dataBaseConnection.connectionName = getDatabaseConnectionName();
+
+        createTable();
+
+        qInfo() << "DataBaseTestPrivate connectionName: " << dataBaseConnection.connectionName
+                << QThread::currentThread();
+    }
+
+    ~SqliteTestPrivate()
+    {
+        QMutexLocker locker(&mutex);
+        removeDatabase(dataBaseConnection);
+    }
+
+    bool createTable()
+    {
+        const auto createTable
+            = QString(
+                  "CREATE TABLE [%1]("
+                  " [id] INTEGER NOT NULL ON CONFLICT REPLACE UNIQUE ON CONFLICT "
+                  "REPLACE COLLATE BINARY, "
+                  " [brand] TEXT, "
+                  " [num] TEXT, "
+                  " [create_time] TIMESTAMP DEFAULT CURRENT_TIMESTAMP, "
+                  " [local_time] TEXT DEFAULT (strftime('%Y-%m-%d %H:%M:%f', 'now', 'localtime')), "
+                  " PRIMARY KEY([id] COLLATE [BINARY] ASC) ON CONFLICT REPLACE)")
+                  .arg(tableName);
+
+        QMutexLocker locker(&mutex);
+        auto db = getDatabase(dataBaseConnection);
+        CHECK_DATABASE_VALIDITY(db)
+
+        if (db.tables().contains(tableName)) {
+            return true;
+        }
+
+        QSqlQuery query(db);
+        if (!query.exec(createTable)) {
+            qWarning() << query.lastError().text();
+            return false;
+        }
+        return true;
+    }
+
+    SqliteTest *q_ptr;
+
+    SqliteConnection dataBaseConnection;
+    const QString tableName = "phone";
+
+    static QMutex mutex;
+};
+
+QMutex SqliteTest::SqliteTestPrivate::mutex;
+
+SqliteTest::SqliteTest(QObject *parent)
+    : QObject{parent}
+    , d_ptr(new SqliteTestPrivate(this))
+{}
+
+SqliteTest::~SqliteTest() {}
+
+bool SqliteTest::insert(const QString &brand, int num)
+{
+    auto db = getDatabase(d_ptr->dataBaseConnection);
+    CHECK_DATABASE_VALIDITY(db)
+    QSqlQuery query(db);
+    query.prepare(
+        QString("INSERT INTO %1 (brand, num) VALUES (:brand, :num)").arg(d_ptr->tableName));
+    query.bindValue(":brand", brand);
+    query.bindValue(":num", num);
+
+    QMutexLocker locker(&d_ptr->mutex);
+    if (!query.exec()) {
+        qCritical() << query.lastError().text();
+        return false;
+    }
+    qInfo() << "Last inserted id:" << query.lastInsertId().toInt();
+    return true;
+}
+
+bool SqliteTest::readLastRecord()
+{
+    auto db = getDatabase(d_ptr->dataBaseConnection);
+    CHECK_DATABASE_VALIDITY(db)
+
+    QSqlQuery query(db);
+    if (!query.exec(QString("SELECT id, brand, num, create_time, local_time "
+                            "FROM %1 ORDER BY id DESC LIMIT 1")
+                        .arg(d_ptr->tableName))) {
+        qCritical() << query.lastError().text();
+        return false;
+    }
+    if (!query.next()) {
+        qWarning() << "No records found.";
+        return false;
+    }
+    auto text = QString(
+                    "Last Record - ID: %1, Brand: %2\t, Num: %3\t, Created At: %4, Local Time: %5")
+                    .arg(QString::number(query.value("id").toInt()),
+                         query.value("brand").toString(),
+                         QString::number(query.value("num").toInt()),
+                         query.value("create_time").toString(),
+                         query.value("local_time").toString());
+    qDebug().noquote() << text;
+    return true;
+}

SqliteWAL/databaseutils.cc

@@ -0,0 +1,18 @@
+#pragma once
+
+#include <QObject>
+
+class SqliteTest : public QObject
+{
+    Q_OBJECT
+public:
+    explicit SqliteTest(QObject *parent = nullptr);
+    ~SqliteTest();
+
+    bool insert(const QString &brand, int num);
+    bool readLastRecord();
+
+private:
+    class SqliteTestPrivate;
+    QScopedPointer<SqliteTestPrivate> d_ptr;
+};