Qt/C++ 多线程执行mysql插入数据

在Qt/C++中，利用QThread或多线程库处理MySQL插入操作是一种常见的优化手段，因为数据库I/O通常较慢，可以避免阻塞主线程。以下是基本步骤：

1. **包含必要的头文件**：

   #include <QtWidgets>
   #include <QtSql/QSqlDatabase>
   #include <QtSql/QSqlQuery>

2. **创建一个单独的线程**：

   class DBThread : public QThread {
       QSqlDatabase db;
       QSqlQuery query;
       // 构造函数和析构函数
   };

   // 创建DBThread实例并启动
   DBThread *dbThread = new DBThread();
   dbThread->start();

3. **在DBThread中连接数据库**：

   void DBThread::run() {
       db = QSqlDatabase::addDatabase("QMYSQL");
       db.setHostName("localhost"); // 数据库地址
       db.setDatabaseName("your_database"); // 数据库名
       db.setUserName("username"); // 用户名
       db.setPassword("password"); // 密码

       if (!db.open()) {
           qDebug() << "Failed to open database";
           return;
       }

       // 执行插入操作
       QSqlQuery insertQuery("INSERT INTO table_name (column1, column2) VALUES (:value1, :value2)");
       insertQuery.bindValue(":value1", value1);
       insertQuery.bindValue(":value2", value2);
       if (!insertQuery.exec()) {
           qDebug() << "Insert failed: " << insertQuery.lastError().text();
       } else {
           qDebug() << "Insert successful";
       }
   }

4. **确保查询线程安全**：
- 使用`QSqlDatabase::transaction()`开始事务。
- `commit()`或`rollback()`事务。

5. **关闭连接**：

   ~DBThread() {
       if (db.isOpen()) {
           db.close();
       }
   }