querythreadcommand.h

Go to the documentation of this file.

#ifndef QUERYTHREADCOMMAND_H
#define QUERYTHREADCOMMAND_H

#include <QQueue>
#include <QSqlQuery>
#include <QObject>
#include <QSharedPointer>

#define QT_SHAREDPOINTER_TRACK_POINTERS

class QueryThreadCommand {
public:
    inline QueryThreadCommand() : m_sender(0), m_transmitter(new QObject()) {}
    inline QueryThreadCommand(const QObject *sender) : m_sender(sender), m_transmitter(new QObject()) {}
    inline QueryThreadCommand(const QObject *sender, const QString &query) :
            m_sender(sender), m_transmitter(new QObject())
    {
        enqueueQuery(query);
    }
    inline QueryThreadCommand(const QObject *sender, const QQueue<QString> &queryQueue) :
            m_sender(sender), m_transmitter(new QObject())
    {
        m_queryQueue.append(queryQueue);
    }
    inline QueryThreadCommand(const QueryThreadCommand &original) :
            m_sender(original.m_sender), m_result(original.m_result), m_transmitter(original.m_transmitter)
    {
        m_queryQueue  = original.m_queryQueue;
    }

    bool operator==(const QueryThreadCommand &other) const ;
    void enqueueQuery(const QString &query);
    QString dequeueQuery();
    bool isValid() const;
    bool isEmpty() const;
    QObject *transmitter();

    void setResult(const QSharedPointer<QSqlQuery> &result);
    QSqlQuery *result() const;
    const QObject *sender() const;

private:
    const QObject *m_sender;
    QSharedPointer<QSqlQuery> m_result;
    QQueue<QString> m_queryQueue;
    QSharedPointer<QObject> m_transmitter;
};

#endif // QUERYTHREADCOMMAND_H