При написании многопоточных приложений на Qt многие сталкивались с тем, что реализация QtSql строго однопоточная. Что хуже, в ней нет ни единого метода для фонового выполнения запроса. А если запрос большой или просто долгий, выполнение его в основном потоке намертво подвесит интерфейс.
Что нервирует ещё больше, нигде нет хоть сколько-нибудь жизнеспособной реализации такой, казалось бы, нужной вещи. Максимум, который можно найти — пул соединений, работающий вполне синхронно. Что ж, время течёт, всё меняется.
tl;dr
Worker.h:
#include <QVariant> #include <QThread> #include <QSqlDatabase> typedef QVector< QVariant > VariantVector; typedef QVector< VariantVector > VariantVector2; class Worker : public QObject { Q_OBJECT public: Worker(); virtual ~Worker(); bool init(); bool isInitiated(); static int queryNum(); static int exec(Worker * w, QString query, QStringList bindNames = QStringList(), VariantVector bindList = VariantVector()); private slots: void slotExec(int num, QString query, QStringList bindNames, VariantVector bindList); signals: void signalExec(int, VariantVector2); void queryError(int, const QSqlError &); protected: QThread * th; QSqlDatabase db; }; Worker.cpp:
#include <QSqlRecord> #include <QSqlQuery> #include <QSqlError> #include <QTimer> QString GenConnectionName(){ static int num = 0; return QString("DBConnection%1").arg(num++); } Worker::Worker(): QObject(){ th = new QThread(this); qRegisterMetaType<VariantVector>("VariantVector"); qRegisterMetaType<VariantVector2>("VariantVector2"); } Worker::~Worker() { th->terminate(); db.close(); th->deleteLater(); } bool Worker::init() { if (db.isOpen()) return true; if (!th->isRunning()) { th->start(QThread::LowPriority); moveToThread(th); } if (!db.isOpen()) { db = QSqlDatabase::addDatabase("QPSQL",connection); db.setHostName("localhost"); db.setPort(5432); db.setUserName("username"); db.setDatabaseName("postgres"); QTimer timer; timer.start(10000); forever { if (db.isOpen()) break; if (db.open()) break; if (!timer.remainingTime()) break; if (db.lastError().databaseText().contains("ВАЖНО: система баз данных запускается") == 0) continue; } } if (!db.isOpen()) return false; return true; } bool Worker::isInitiated() { return th->isRunning() && db.isOpen(); } int Worker::queryNum() { static int i = 0; return i++; } int Worker::exec(Worker * w, QString q, QStringList s, VariantVector v) { int i = queryNum(); QMetaObject::invokeMethod(w, "slotExec", Qt::QueuedConnection, Q_ARG(int,i), Q_ARG(QString,q), Q_ARG(QStringList,s), Q_ARG(VariantVector,v)); return i; } void Worker::slotExec(int num, QString query, QStringList bindNames, VariantVector bindList) { QSqlQuery q(db); q.prepare(query); for (int i = 0; i < bindNames.size(); ++i) q.bindValue(bindNames[i],bindList[i]); q.exec(); if (q.lastError().isValid()) emit queryError(q.lastError()); VariantVector2 vv; QSqlRecord r = q.record(); int rn = r.count(); vv.push_back(VariantVector()); for (int i = 0; i < rn; ++i) vv[0].push_back(r.fieldName(i)); while(q.next()) { static int j = -1; ++j; vv.push_back(VariantVector()); for (int i = 0; i < rn; ++i) vv[j].push_back(q.value(i)); } emit signalExec(num,vv); } Example.cpp:
class MainView { // ... int id; Worker w; public slots: void onTest(int mid, VariantVector2 ret) { qDebug() << mid; if (id != mid) return; foreach (VariantVector r, ret) foreach (QVariant v, r) qDebug() << v; } public: void run() { connect(&w,SIGNAL(signalExec(int,VariantVector2)),this,SLOT(onTest(int,VariantVector2))); QStringList names; VariantVector params; names << ":myid"; params.push_back(3); if (w.init()); id = Worker::exec(&w,"select * from Table where not ID = :myid;",names,params); qDebug() << "Finished!"; } };
Finished! QVariant(QString, "id") QVariant(QString, "code") QVariant(QString, "prefasfk_id") QVariant(QString, "creationdate") QVariant(QString, "lasteditdate") QVariant(int, 1) QVariant(int, 10) QVariant(QString, "") QVariant(QDateTime, QDateTime(2015-12-18 17:05:43.877 RTZ 5 (зима) Qt::TimeSpec(LocalTime))) QVariant(QDateTime, QDateTime(2015-12-18 17:05:43.877 RTZ 5 (зима) Qt::TimeSpec(LocalTime))) QVariant(int, 2) QVariant(int, 20) QVariant(QString, "") QVariant(QDateTime, QDateTime(2015-12-18 17:05:45.729 RTZ 5 (зима) Qt::TimeSpec(LocalTime))) QVariant(QDateTime, QDateTime(2015-12-18 17:05:45.729 RTZ 5 (зима) Qt::TimeSpec(LocalTime))) QVariant(int, 4) QVariant(int, 40) QVariant(QString, "") QVariant(QDateTime, QDateTime(2015-12-18 17:05:49.152 RTZ 5 (зима) Qt::TimeSpec(LocalTime))) QVariant(QDateTime, QDateTime(2015-12-18 17:05:49.152 RTZ 5 (зима) Qt::TimeSpec(LocalTime)))
Чтобы вынести соединение в отдельный поток, воспользуемся старой доброй связкой QThread+QObject.
Но не будем об этом.
Worker.h:
#include <QVariant> #include <QThread> #include <QSqlDatabase> class Worker : public QObject { Q_OBJECT public: Worker(); virtual ~Worker(); bool init(); bool isInitiated(); static int queryNum(); protected: QThread * th; QSqlDatabase db; }; Worker.cpp:
#include <QSqlRecord> #include <QSqlQuery> #include <QSqlError> #include <QTimer> QString GenConnectionName(){ static int num = 0; return QString("DBConnection%1").arg(num++); } Worker::Worker(): QObject(){ th = new QThread(this); } Worker::~Worker() { th->terminate(); db.close(); th->deleteLater(); } bool Worker::init() { if (db.isOpen()) return true; if (!th->isRunning()) { th->start(QThread::LowPriority); moveToThread(th); } if (!db.isOpen()) { db = QSqlDatabase::addDatabase("QPSQL",connection); db.setHostName("localhost"); db.setPort(5432); db.setUserName("username"); db.setDatabaseName("postgres"); QTimer timer; timer.start(10000); forever { if (db.isOpen()) break; if (db.open()) break; if (!timer.remainingTime()) break; if (db.lastError().databaseText().contains("ВАЖНО: система баз данных запускается") == 0) continue; } } if (!db.isOpen()) return false; return true; } bool Worker::isInitiated() { return th->isRunning() && db.isOpen(); } int Worker::queryNum() { static int i = 0; return i++; }
Поток с собственным соединением создан, но запросы всё равно будут выполняться синхронно. Чтобы побороть эту проблему, воспользуемся старыми добрыми сигналами-слотами. Как известно, при передаче между потоками они преобразуются в сообщения и ставятся в очередь. Однако, есть одна проблема. [Боромир.gif] Нельзя просто взять, и добавить вызов слота. Если вызывать метод класса как обычно, Qt заблокирует оба потока, и вызывающий, и вызываемый, пока они не окажутся способны выполнить метод. Чтобы именно добавить вызов слота, нужно воспользоваться методом QMetaObject::invokeMethod. Заметьте, я оставил метод Worker::exec статическим именно из тех же блокирующих побуждений.
//Worker.h class Worker : public QObject { //... public: static int exec(Worker * w, QString query, QStringList bindNames = QStringList(), VariantVector bindList = VariantVector()); private slots: void slotExec(int num, QString query, QStringList bindNames, VariantVector bindList); signals: void signalExec(int, VariantVector2); void queryError(int, const QSqlError &); //... }; //Worker.cpp int Worker::exec(Worker * w, QString q, QStringList s, VariantVector v) { int i = queryNum(); QMetaObject::invokeMethod(w, "slotExec", Qt::QueuedConnection, Q_ARG(int,i), Q_ARG(QString,q), Q_ARG(QStringList,s), Q_ARG(VariantVector,v)); return i; } void Worker::slotExec(int num, QString query, QStringList bindNames, VariantVector bindList) { QSqlQuery q(db); q.prepare(query); for (int i = 0; i < bindNames.size(); ++i) q.bindValue(bindNames[i],bindList[i]); q.exec(); if (q.lastError().isValid()) emit queryError(q.lastError()); VariantVector2 vv; QSqlRecord r = q.record(); int rn = r.count(); vv.push_back(VariantVector()); for (int i = 0; i < rn; ++i) vv[0].push_back(r.fieldName(i)); while(q.next()) { static int j = -1; ++j; vv.push_back(VariantVector()); for (int i = 0; i < rn; ++i) vv[j].push_back(q.value(i)); } emit signalExec(num,vv); } Почти готово. Однако, если сейчас запустить исходники, метапроцесор откажется передавать данные, сославшись на неизвестный тип параметров. И в чём-то он прав. Ну что ж, давайте познакомим наши х героев.
//Worker.h typedef QVector< QVariant > VariantVector; typedef QVector< VariantVector > VariantVector2; //Worker.cpp Worker::Worker(): QObject(){ th = new QThread(this); qRegisterMetaType<VariantVector>("VariantVector"); qRegisterMetaType<VariantVector2>("VariantVector2"); } Теперь всё, осталось только создать слоты, соединить и вызвать. Учтите, в данной реализации первой строкой передаются названия столбцов таблицы.
class MainView { // ... int id; Worker w; public slots: void onTest(int mid, VariantVector2 ret) { qDebug() << mid; if (id != mid) return; foreach (VariantVector r, ret) foreach (QVariant v, r) qDebug() << v; } public: void run() { connect(&w,SIGNAL(signalExec(int,VariantVector2)),this,SLOT(onTest(int,VariantVector2))); QStringList names; VariantVector params; names << ":myid"; params.push_back(3); if (w.init()); id = Worker::exec(&w,"select * from Table where not ID = :myid;",names,params); qDebug() << "Finished!"; } };
Finished! QVariant(QString, "id") QVariant(QString, "code") QVariant(QString, "prefasfk_id") QVariant(QString, "creationdate") QVariant(QString, "lasteditdate") QVariant(int, 1) QVariant(int, 10) QVariant(QString, "") QVariant(QDateTime, QDateTime(2015-12-18 17:05:43.877 RTZ 5 (зима) Qt::TimeSpec(LocalTime))) QVariant(QDateTime, QDateTime(2015-12-18 17:05:43.877 RTZ 5 (зима) Qt::TimeSpec(LocalTime))) QVariant(int, 2) QVariant(int, 20) QVariant(QString, "") QVariant(QDateTime, QDateTime(2015-12-18 17:05:45.729 RTZ 5 (зима) Qt::TimeSpec(LocalTime))) QVariant(QDateTime, QDateTime(2015-12-18 17:05:45.729 RTZ 5 (зима) Qt::TimeSpec(LocalTime))) QVariant(int, 4) QVariant(int, 40) QVariant(QString, "") QVariant(QDateTime, QDateTime(2015-12-18 17:05:49.152 RTZ 5 (зима) Qt::TimeSpec(LocalTime))) QVariant(QDateTime, QDateTime(2015-12-18 17:05:49.152 RTZ 5 (зима) Qt::TimeSpec(LocalTime))) Вот и всё. Желающие могут добавить построчную передачу данных или, к примеру, удобный пул. Самые отчаяные могут даже добавить синхронные запросы без этих ваших сигналов и слотов.
ссылка на оригинал статьи http://habrahabr.ru/post/273647/
Добавить комментарий