Qt/C++ 开源项目：双向数据库迁移工具，实现 MySQL 与 SQLite 数据互导

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"));  // 设置窗口标题
}

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);
}

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();  // 打开连接
}

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);  // 显示黄色日志
}

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
}

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;  // 数据上传成功
}