QThread + QtSql: Асинхронные запросы

// *.H
class Worker : public QObject {
    Q_OBJECT
public:
    Worker();
    virtual ~Worker();
    bool init();
    bool isInitiated();
protected:
    QThread * th;
    QSqlDatabase db;
};
 
 
// *.CPP
QString GenConnectionName() {
    static int num = 0;
    return QString("DBConnection%1").arg(num++);
}
Worker::Worker(): QObject() {
    th = new QThread();
}
Worker::~Worker() {
    db.close();
    th->quit();
    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",GenConnectionName());
        db.setHostName("localhost");
        db.setPort(5432);
        db.setUserName("postgres");
        db.setDatabaseName("postgres");
        QTimer timer;
        timer.start(10000);
        forever {
            if (db.isOpen()) break;
            if (db.open()) break;
            if (!timer.remainingTime()) break;
    }    }
    if (!db.isOpen()) return false;
    return true;
}
 
bool Worker::isInitiated() {
    return th->isRunning() && db.isOpen();
}

// *.H
typedef QVector< QVariant > VariantVector;
typedef QVector< VariantVector > VariantVector2;
 
class Worker : public QObject {
    int queryNum() { static int i = 0; return i++; } // Эта штука может сбоить без мутексов
   
    // ...
    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 sqlError(int, QSqlError)
//...
};
 
// *.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 sqlError(num,q.lastError());
    VariantVector2 vv;
    while(q.next()) {
         static int j = -1; ++j;
         vv.push_back(VariantVector());
         for (int i = 0; q.value(i).isValid(); ++i)
             vv[j].push_back(q.value(i));
    }
    emit signalExec(num,vv);
}

Worker::Worker(): QObject() {
    th = new QThread();
    qRegisterMetaType<VariantVector>("VariantVector");
    qRegisterMetaType<VariantVector2>("VariantVector2");
}

// public slots:
void onReturnQuery(int i, VariantVector2 v) {
    if (id != i)
    return;
    foreach(auto i, v);
         qDebug() << i[0] << i[1];
}
 
void call() {
    Worker w;
    w.init();
    connect(&w,SIGNAL(signalExec(int,VariantVector2)),SLOT(onReturnQuery(int,VariantVector2)));
    id = Worker::exec("select 1,2 from 1;");
}