双向数据库迁移工具：轻松实现 MySQL 与 SQLite 数据互导

项目概述与作用

在这里插入图片描述

该项目的核心是实现 MySQL 和 SQLite 两种数据库之间的数据迁移工具。它能够轻松地将 MySQL 数据库中的数据导出为 SQLite 数据库文件，反过来也可以将 SQLite 数据库中的数据上传到 MySQL 数据库中。这个双向迁移工具非常适用于：

数据库备份与恢复：
- 可以将 MySQL 数据库的数据备份为 SQLite 文件，作为数据的冗余副本；同样可以将 SQLite 数据恢复回 MySQL 数据库。
数据库迁移与转换：
- 支持跨平台的数据库迁移。如果开发环境和生产环境使用不同的数据库（如 SQLite 用于开发，MySQL 用于生产），可以使用该工具将开发环境的数据迁移到生产环境，反之亦然。
开发与测试场景：
- SQLite 是轻量级的数据库，适合本地开发和测试使用。通过该工具，开发者可以将 MySQL 的生产数据迁移到本地 SQLite 数据库进行测试，而无需连接生产数据库。
性能优化和分析：
- 某些场景下，开发者可能希望将 MySQL 中的一部分数据导出为 SQLite 进行本地离线分析。SQLite 数据库文件可以非常方便地进行传输和分析操作。

在这里插入图片描述

项目特点与亮点

1. 双向迁移功能

支持 MySQL 到 SQLite 的数据迁移，也支持从 SQLite 到 MySQL 的数据回迁。这使得项目具有双向迁移的灵活性，用户可以轻松在两种数据库间来回转换数据。

2. 图形用户界面（GUI）

使用 Qt 框架构建的图形用户界面（如图片所示）简洁直观，用户无需掌握复杂的数据库命令行工具即可进行数据库迁移操作。通过点击按钮完成数据库连接、选择表进行迁移或清理操作，操作简单且高效。

3. 日志系统实时反馈

项目中集成了实时的日志反馈系统，不同操作的结果会在右侧窗口中以不同颜色的文本形式显示，帮助用户直观地了解当前的操作是否成功，以及哪些表已经成功迁移或清理。

4. 批量处理能力

用户不仅可以选择单个表进行迁移，还可以一次性迁移多个表或者整个数据库中的所有表。这对于处理大型数据库时非常高效，减少了重复操作。

5. 灵活的数据清理功能

在从 SQLite 上传数据到 MySQL 前，用户可以选择清理 MySQL 中的现有数据表，确保数据在上传时不会冲突或者重复。通过一键清空 MySQL 表，保证数据的完整性和一致性。

在这里插入图片描述

项目代码详细解析

接下来，我们结合代码讲解每个模块的实现，帮助理解其内在逻辑。

1. 界面设计模块：GUI 部分

整个图形用户界面 (GUI) 是基于 Qt 框架开发的。界面清晰地划分了 “MySQL 数据库下载” 和 “MySQL 数据库上传” 两个功能区，用户可以在界面中输入 MySQL 的连接参数、选择需要迁移的表，并执行数据迁移或清理等操作。

设计界面关键代码：

MainWindow::MainWindow(QWidget *parent) :
    QMainWindow(parent),
    ui(new Ui::MainWindow),
    manager(new DatabaseManager())  // 数据库管理类实例
{
    ui->setupUi(this);  // 初始化界面
    QString qss, mpall;
    loadQss(":/qss/psblack.css", qss, mpall);  // 加载 QSS 样式表，设置界面风格
    setPalette(QPalette(mpall));  // 应用调色板
    setStyleSheet(qss);  // 应用样式表

    setWindowTitle(tc("Mysql/SQlite数据库迁移工具 1327666247@qq.com"));  // 设置窗口标题
}

通过加载样式表，使得整个界面风格统一，采用黑色背景和黄色字体，清晰地展示操作过程中的日志和反馈信息。

功能布局：将界面分为两个选项卡，“MySQL 数据库下载”和“MySQL 数据库上传”用于控制不同方向的数据迁移操作。
用户输入：用户在 GUI 界面输入 MySQL 的连接信息，如 IP 地址、用户名、密码等。然后通过按钮连接到 MySQL。

操作流程：

用户点击按钮后，触发相应的槽函数，进行数据库连接、数据迁移等操作。操作结果会显示在右侧的日志窗口中。

2. 日志系统模块：ColorfulTextEdit 类

ColorfulTextEdit 类用于实现带颜色的日志显示功能，它继承自 QTextEdit，并扩展了根据日志级别显示不同颜色的功能。日志系统是用户体验的关键之一，可以让用户及时获知当前操作的状态（成功、失败、警告等）。

ColorfulTextEdit 类代码：

ColorfulTextEdit::ColorfulTextEdit(QWidget *parent) : QTextEdit(parent) {
    // 初始化颜色映射
    colorMap[0] = Qt::red;    // 错误信息显示为红色
    colorMap[1] = Qt::yellow; // 警告信息显示为黄色
    colorMap[2] = Qt::green;  // 成功信息显示为绿色
    colorMap[3] = Qt::white;  // 普通信息显示为白色

    setStyleSheet("QWidget { background-color: rgb(0, 0, 0); font: 10pt '楷体'; }");  // 设置背景为黑色，字体为楷体
}

void ColorfulTextEdit::appendTextWithLevel(const QString &text, int level) {
    // 根据日志级别设置颜色
    QColor color = colorMap.value(level, Qt::black);  // 默认颜色为黑色
    QTextCharFormat fmt;
    fmt.setForeground(color);  // 设置前景色

    // 获取当前光标，移动到文本末尾
    QTextCursor cursor = this->textCursor();
    cursor.movePosition(QTextCursor::End);
    cursor.insertText(text + "\n", fmt);  // 插入日志信息并换行
    this->setTextCursor(cursor);
}

颜色映射表：不同的日志级别对应不同的颜色。比如，level=0 表示错误信息，显示为红色，level=2 表示成功信息，显示为绿色。
文本插入：每次调用 appendTextWithLevel() 方法，都会将日志文本插入到文本框的末尾，按级别自动换行并显示相应颜色。

特点：

实时的日志反馈使用户能够及时掌握操作进度。
通过颜色区分日志类型，直观反映成功与错误信息。

3. 数据库管理模块：DatabaseManager 类

DatabaseManager 类是该项目的核心功能模块，它封装了与 MySQL 和 SQLite 的交互逻辑，负责管理数据库连接、数据查询和迁移等操作。

连接数据库的功能：

连接 MySQL 数据库：

bool DatabaseManager::connectToMySQL(const QString &host, const QString &user, const QString &password, const QString &databaseName) {
    mysqlDb.setHostName(host);          // 设置主机名
    mysqlDb.setUserName(user);          // 设置用户名
    mysqlDb.setPassword(password);      // 设置密码
    mysqlDb.setDatabaseName(databaseName);  // 设置数据库名
    return mysqlDb.open();  // 打开连接
}

通过传递 MySQL 数据库的连接参数（主机、用户名、密码、数据库名）来创建数据库连接。成功后即可操作 MySQL。

连接 SQLite 数据库：

bool DatabaseManager::connectToSQLite(const QString &databaseName) {
    sqliteDb.setDatabaseName(databaseName);  // 设置 SQLite 文件路径
    return sqliteDb.open();  // 打开 SQLite 数据库连接
}

特点：

该类封装了数据库操作，使得数据库连接、查询、迁移等操作抽象化。这样主界面和数据库操作分离，降低了代码耦合度。

4. 主逻辑控制模块：MainWindow 类

MainWindow 类负责界面和业务逻辑的绑定。每个操作按钮的点击会触发相应的槽函数，调用 DatabaseManager 中的方法完成具体的数据库操作。

连接 MySQL 按钮的槽函数：

void MainWindow::on_btn_connected_Down_clicked() {
    // 连接到 MySQL 数据库
    if (!manager->connectToMySQL(ui->mysqlHost_down->text(),
                                 ui->mysqlUser_down->text(),
                                 ui->mysqlPassword_down->text(),
                                 ui->mysqlDatabaseName_down->

text())) {
        writeRunTimeMsgs(tc("MySql数据库链接失败"), 0);  // 连接失败，显示红色日志
        return;
    }

    // 连接成功，获取表名列表并显示在下拉框中
    QStringList names = manager->getMySQLTableNames();
    ui->com_sqlTabNames->clear();
    ui->com_sqlTabNames->addItems(names);  // 将表名添加到 UI 下拉框
    writeRunTimeMsgs(tc("数据库链接成功,当前数据库有【%1】个表").arg(names.size()), 1);  // 显示黄色日志
}

特点：

MainWindow 类集中处理所有用户交互，将操作按钮与数据库操作逻辑绑定。它通过按钮触发各类数据库操作，并通过日志系统将结果反馈给用户。

5. MySQL 到 SQLite 的迁移逻辑

核心迁移功能是将 MySQL 数据库中的数据导出到 SQLite 数据库文件中。DatabaseManager::transferDataToSQLite() 实现了这个功能。

MySQL 到 SQLite 的迁移逻辑：

bool DatabaseManager::transferDataToSQLite(const QString &tableName) {
    // 获取 MySQL 表结构并在 SQLite 中创建表
    QString createSQL = getCreateTableSQL(tableName);
    executeSQLiteQuery(createSQL);  // 执行 SQLite 的建表语句

    // 从 MySQL 读取表数据
    QSqlQuery readQuery = getMySQLQuery("SELECT * FROM " + tableName);

    // 准备在 SQLite 中插入数据
    QSqlQuery writeQuery(sqliteDb);
    QString insertSQL = "INSERT INTO " + tableName + " (";
    // 构建插入 SQL 语句
    // ...

    // 遍历 MySQL 数据并插入 SQLite
    while (readQuery.next()) {
        // 将 MySQL 中的每一行数据插入 SQLite
        // ...
    }

    return true;  // 如果迁移成功，返回 true
}

流程：首先在 SQLite 中创建与 MySQL 表结构相同的表，然后从 MySQL 中逐行读取数据，并插入到 SQLite 中。
特点：通过 QSqlQuery 执行查询和插入操作，确保数据按原始结构和内容迁移。

6. SQLite 到 MySQL 的回迁逻辑

数据回迁功能将 SQLite 数据上传回 MySQL 数据库，用于数据恢复等场景。

SQLite 到 MySQL 回迁代码：

bool DatabaseManager::uploadDataToMySQL(const QString &tableName) {
    if (!openSQlite()) {
        qWarning() << "Failed to open SQLite database.";
        return false;
    }

    // 检查 SQLite 表是否存在
    QSqlQuery checkQuery(sqliteDb);
    // ...

    // 读取 SQLite 中的数据
    QSqlQuery readQuery = getSQLiteQuery("SELECT * FROM " + tableName);
    QSqlQuery writeQuery(mysqlDb);

    // 逐行读取 SQLite 数据并插入 MySQL
    while (readQuery.next()) {
        for (int i = 0; i < numFields; ++i) {
            QVariant value = readQuery.value(i);
            writeQuery.bindValue(i, value);  // 绑定数据到 MySQL 插入语句
        }
        writeQuery.exec();  // 执行插入操作
    }

    return true;  // 数据上传成功
}