求教,怎样用多线程怎样向MYSQL数据库中写入数据

1363386323

多线程怎样向MYSQL数据库中写入数据，弄了几天还没弄好，要疯了。再此向大侠们请教 ！！
真的很急，因为在最近在开发这个程序！
#include <QCoreApplication>
#include "thread.h"
#include <QVector>#include <QDebug>

int main(int argc, char *argv[])
{
    QCoreApplication a(argc, argv);
    QVector<Thread*> vector;    Thread *thread;
    //创建多个线程，并start
    for(int i=0;i<10;i++){
        thread=new Thread;
        vector.append(thread);
       thread->set(i);
        thread->start();
    }
    //等待所有线程执行完，然后删除线程
    foreach(thread,vector){
        thread->wait();
    }
   foreach(thread,vector){
        delete thread;
    }
    return a.exec();
}

-------------------------------------------------------------------------------------------------

#include "thread.h"

Thread::Thread(QObject *parent) :    QThread(parent)
{
}
void Thread::run()
{
    begin();
}

//为每个线程创建一个连接名
void Thread::set(int a)
{
    connectionName=QString::number(a);
}

void Thread::connectionDatabase(QString dbName)
{
    QSqlDatabasedb=QSqlDatabase::addDatabase("QMYSQL",connectionName);
    db.setHostName("localhost");
    db.setDatabaseName(dbName);
    db.setUserName("root");
    db.setPassword("");

    if(!db.open())
       qDebug()<<"db open fail";
}

void Thread::begin()
{
    QString dbName="learnsql";
    connectionDatabase(dbName);

    QSqlDatabase db=QSqlDatabase::database(connectionName);
    db.transaction();  //开启事物

    QSqlQuery query(db);

    //向表student中插入10000条数据
   for(int i=1;i<=10000;i++){
        query.exec("insert into student values(1)");
    }

    db.commit();       //提交事物}


备注：提 前已在MYSQL数据库中创建了learnsql数据库，和student表
编译执行时通过了，可却数据写不进去，不知道哪出了问题；
不管怎样，只要大侠们能告诉我怎样用多线程在MYSQL数据库中写入数据就行了

imlison

1363386323 发表于 2014-6-6 18:26
@imlison  帮帮我，怎样用多线程向MYSQL数据库中写入数据，前提是要用事物

抱歉，现在才看到这个帖子，因为最近都很少上论坛。
你这段代码写法是有问题的，某些情况下会导致程序崩溃。
原因：虽然Qt数据库很多方法是线程安全的，但是在加载数据库plugin上却不安全，会导致竞争从而崩溃。
解决：把数据库连接部分用线程同步相关方法保护起来。
下面的代码是在你的基础上修改而来。亲测可行。

Thread.h

1. #ifndef THREAD_H
   
2. #define THREAD_H
   
3. 
   
4. #include <QThread>
   
5. #include <QMutex>
   
6. 
   
7. class Thread : public QThread
   
8. {
   
9.     Q_OBJECT
   
10. public:
    
11.     explicit Thread(QObject *parent = 0);
    
12.     ~Thread();
    
13.     void set(int a);
    
14. 
    
15. protected:
    
16.     void run();
    
17. 
    
18. private:
    
19.     bool connectDatabase(QString dbName);
    
20.     bool begin();
    
21. 
    
22. private:
    
23.     QString connectionName;
    
24.     static QMutex mutex_log;
    
25.     static QMutex mutex_db;
    
26. 
    
27. signals:
    
28. 
    
29. public slots:
    
30. 
    
31. };
    
32. 
    
33. #endif // THREAD_H
    

复制代码

Thread.cpp

1. #include "Thread.h"
   
2. #include <QSqlDatabase>
   
3. #include <QSqlDriver>
   
4. #include <QSqlQuery>
   
5. #include <QSqlError>
   
6. #include <QMutexLocker>
   
7. #include <QDebug>
   
8. 
   
9. QMutex Thread::mutex_log;
   
10. QMutex Thread::mutex_db;
    
11. 
    
12. #define PRINT(msg) do\
    
13. {\
    
14.     QMutexLocker lock(&mutex_log);\
    
15.     qDebug() << __FILE__ << ":" << __LINE__ << " -> " << (msg);\
    
16. }while(0)
    
17. 
    
18. Thread::Thread(QObject *parent) :
    
19.     QThread(parent)
    
20. {
    
21. }
    
22. 
    
23. Thread::~Thread()
    
24. {
    
25. }
    
26. 
    
27. void Thread::set(int a)
    
28. {
    
29.     connectionName = QString::number(a);
    
30. }
    
31. 
    
32. bool Thread::connectDatabase(QString dbName)
    
33. {
    
34.     QMutexLocker lock(&mutex_db);
    
35.     QSqlDatabase db = QSqlDatabase::addDatabase("QMYSQL", connectionName);
    
36.     db.setHostName("127.0.0.1");
    
37.     db.setDatabaseName(dbName);
    
38.     db.setUserName("root");
    
39.     db.setPassword("");
    
40.     if(!db.open())
    
41.     {
    
42.         PRINT(QString("db open fail: %1").arg(db.lastError().text()));
    
43.         return false;
    
44.     }
    
45.     return true;
    
46. }
    
47. 
    
48. bool Thread::begin()
    
49. {
    
50.     QString dbName = "learnsql";
    
51.     connectDatabase(dbName);
    
52.     QSqlDatabase db = QSqlDatabase::database(connectionName);
    
53.     if( !db.isValid() )
    
54.     {
    
55.         return false;
    
56.     }
    
57.     db.transaction();
    
58.     PRINT(QString("进入事务"));
    
59.     QSqlQuery query(db);
    
60.     for(int i=0; i<10; ++i)
    
61.     {
    
62.         query.prepare("INSERT INTO student VALUES(:value)");
    
63.         query.bindValue(":value",i);
    
64.         if( !query.exec() )
    
65.         {
    
66.             PRINT(QString("query error: %1").arg(query.lastError().text()));
    
67.             continue;
    
68.         }
    
69.     }
    
70.     db.commit();
    
71.     PRINT(QString("退出事务"));
    
72.     return true;
    
73. }
    
74. 
    
75. void Thread::run()
    
76. {
    
77.     begin();
    
78. }

复制代码

main.cpp

1. #include <QCoreApplication>
   
2. #include "Thread.h"
   
3. #include <QVector>
   
4. 
   
5. #define THREAD_NUM 10
   
6. 
   
7. int main(int argc, char *argv[])
   
8. {
   
9.     QCoreApplication a(argc, argv);
   
10. 
    
11.     QVector<Thread *> threads;
    
12.     for(int i=0; i<THREAD_NUM; ++i)
    
13.     {
    
14.         Thread *thr = new Thread;
    
15.         thr->set(i);
    
16.         thr->start();
    
17.         threads.push_back(thr);
    
18.     }
    
19.     foreach (Thread *thr, threads) {
    
20.         thr->wait();
    
21.     }
    
22.     foreach (Thread *thr, threads) {
    
23.         delete thr;
    
24.     }
    
25.     threads.clear();
    
26. 
    
27.     qDebug("程序执行完毕");
    
28.     return a.exec();
    
29. }
    

复制代码

1363386323

@imlison  帮帮我，怎样用多线程向MYSQL数据库中写入数据，前提是要用事物