querythread.h

Go to the documentation of this file.

#ifndef QUERYTHREAD_H
#define QUERYTHREAD_H

#include "querythreadcommand.h"

struct QueryThreadConnSpecs {
    QString driver;
    QString dbName;
    QString host;
    QString user;
    QString passwd;
    int port;
};

#include <QMutex>
#include <QQueue>

class QueryQueue {
public:
    void enqueue(const QueryThreadCommand &cmd);
    QueryThreadCommand dequeue();
    bool contains(const QueryThreadCommand &cmd) const;

private:
    void filter(const QueryThreadCommand &cmd);

private:
    QMutex mutex;
    QQueue<QueryThreadCommand> queue;
};

extern QSqlDatabase createConnection(const QueryThreadConnSpecs &specs, const char *connName);
extern void connectToDatabase(QSqlDatabase db);

#include <QObject>

class QueryWorker : public QObject {
    Q_OBJECT
public:
    QueryWorker(QueryThreadConnSpecs &specs, QueryQueue *queryQueue, QObject* parent = 0);
    ~QueryWorker();
    QueryThreadCommand currentCmd();

public slots:
    void slotExecute(QueryQueue *queue);

private:
    void setCurrentCmd(QueryThreadCommand &cmd);
    void releaseCurrentCmd();

signals:
    void querying(bool); 
    void signal_result(QueryThreadCommand result);

private:
    QObject *m_requester;
    QueryQueue *m_queryQueue;
    QueryThreadCommand m_currentCmd;
    QMutex m_currentCmdMutex;
};

#include <QThread>
#include <QVariant> // Q_DECLARE_METATYPE veronderstelt deze header file
#include "libpq-fe.h"
Q_DECLARE_METATYPE(PGconn*);

class QueryThread : public QThread {
    Q_OBJECT
public:
    QueryThread(QueryThreadConnSpecs &specs, QueryQueue *queue, QObject *parent = 0);
    ~QueryThread();

    void waitToStart();
    QueryThreadCommand currentCmd();

public slots:
    bool cancelQuery();
    void slot_queryQueue_changed(QueryQueue *queue);

signals:
    void querying(bool);
    void signal_result(QueryThreadCommand result);
    void fwdToWorker(QueryQueue *queue);

protected:
    void run();

private:
    QueryWorker* worker;
    QueryThreadConnSpecs specs;
    QueryQueue *m_queryQueue;
};

#endif // QUERYTHREAD_H