Database.h

Go to the documentation of this file.

#ifndef DATABASE_H
#define DATABASE_H

#include <QSqlDatabase>
class QueryThreadCommand;
class QueryThreadConnSpecs;

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

#include <QObject>
#include "querythread.h"
#include "progresswidget.h"

class Database : public QObject
{
    Q_OBJECT
public:
    static Database *instance();
    static QSqlDatabase staticCon();
    static QSqlQuery execStatic(const QString &query = QString());
    static QSqlRecord execStaticR(const QString &query);
    void execThreaded(const QString &query, const QObject *sender);
    void execThreaded(const QueryThreadCommand &cmd);
    static ProgressToolBar *progressToolBar();
    static bool execPending(const QObject *sender);
    static QSqlIndex lastInserted(const QString &tableName);

    static void listenForTableChange(const QString &tableName);
    static void notifyTableChange(const QString &tableName);

private:
    void threadSetup(const QString &driver, const QString &dbName, const QString &host,
                     const QString &user, const QString &passwd, int port);
    void cancelQuery(const QObject *sender);

public slots:
    void slot_queryThreadResult(QueryThreadCommand result);
    void pipe_queryResult(QSqlQuery*);

protected:
    Database();
    Database(const QString &driver, const QString &dbName, const QString &host,
             const QString &user, const QString &passwd, int port);
    ~Database();

protected slots:
    void onDriverNotification(const QString & name);

signals:
    void signal_queryQueue_changed(QueryQueue *queue);
    void tableChanged(const QString &tableName);

private:
    QueryQueue queryQueue;
    QueryThread *thread;
    ProgressToolBar *m_progressToolBar;
};

class SqlHelper
{
public:
    void setDependency(const QString &tableName);
    void setDependencies(const QStringList &tableNames);
    void setRowIdentifierField(const QString &fieldName);
    QString rowIdentifierField() const;

    void clearDependencies();
    const QStringList &dependencies() const;

protected:
    SqlHelper(){};
    virtual void onTableChange(const QString &tableName) = 0; // This function should be connected to on every table change

private:
    QStringList m_dependencies;
    QString m_rowIdentifierField;
};

#include <QSqlQueryModel>

class SqlQueryModel : public QSqlQueryModel, public SqlHelper
{
    Q_OBJECT
public:
    SqlQueryModel(QObject *parent = 0);

    bool contains(const QString &value, const int column = 0) const ;
    bool contains(const QMap<int, QString> &columnToStringMap) const ;

public slots:
    virtual void clear();

    void reQuery();

private slots:
    virtual void onTableChange(const QString &tableName);

private:
};

#include <QSqlRelationalTableModel>

class SqlTableModel : public QSqlRelationalTableModel, public SqlHelper
{
    Q_OBJECT
public:
    SqlTableModel(QObject *parent = 0, QSqlDatabase db = QSqlDatabase());
    virtual void queryChange();
    void setTable(const QString &table);

private slots:
    virtual void onTableChange(const QString &tableName);

signals:
    void queryChanged();
};

#include <QWidget>
class QTableView;

class DatabaseAuditLogView : public QWidget
{
    Q_OBJECT
public:
    DatabaseAuditLogView(QWidget *parent = 0);
    static const QString staticWindowTitle();

public slots:
    void pipe_queryResult(QSqlQuery* result);
    void updateModel();

private:
    const QString baseQuery;
    QTableView *logView;
};

#endif // DATABASE_H