mythdbcon.h

Go to the documentation of this file.

#ifndef MYTHDBCON_H_
#define MYTHDBCON_H_

#include <qsqldatabase.h>
#include <qmutex.h>
#include <qsemaphore.h> 
#include <qstring.h>
#include <qptrlist.h>

#include <iostream>
using namespace std;

#include "mythcontext.h"

class MPUBLIC MSqlDatabase
{
  friend class MDBManager;
  friend class MSqlQuery;
  public:
    MSqlDatabase(const QString &name);
   ~MSqlDatabase(void);

  private:
    bool isOpen(void);
    bool OpenDatabase(void);
    bool KickDatabase(void);
    QSqlDatabase *db(void) { return m_db; }

  private:
    QString m_name;
    QSqlDatabase *m_db;
    QDateTime m_lastDBKick;
};

class MDBManager
{
  friend class MSqlQuery;
  public:
    MDBManager(void);
    ~MDBManager(void);

    void CloseDatabases(void);

  protected:
    MSqlDatabase *popConnection(void);
    void pushConnection(MSqlDatabase *db);

    MSqlDatabase *getSchedCon(void);
    MSqlDatabase *getDDCon(void);

  private:
    QPtrList<MSqlDatabase> m_pool;
    QMutex m_lock;
    QSemaphore *m_sem;
    int m_connID;

    MSqlDatabase *m_schedCon;
    MSqlDatabase *m_DDCon;
};

typedef struct _MSqlQueryInfo
{
    MSqlDatabase *db;
    QSqlDatabase *qsqldb;
    bool returnConnection;
} MSqlQueryInfo;

typedef QMap<QString, QVariant> MSqlBindings;

MPUBLIC void MSqlAddMoreBindings(MSqlBindings &output, MSqlBindings &addfrom);

MPUBLIC void MSqlEscapeAsAQuery(QString &query, MSqlBindings &bindings);

class MPUBLIC MSqlQuery : public QSqlQuery
{
  public:
    MSqlQuery(const MSqlQueryInfo &qi);
    ~MSqlQuery();

    bool isConnected(void) { return m_isConnected; }

    bool exec(void) { return QSqlQuery::exec(); }

    bool exec(const QString &query);

    bool prepare(const QString &query);

    void bindValues(MSqlBindings &bindings);

    QVariant lastInsertId();

    static bool testDBConnection();

    static MSqlQueryInfo InitCon();

    static MSqlQueryInfo SchedCon();

    static MSqlQueryInfo DDCon();

  private:
    MSqlDatabase *m_db;
    bool m_isConnected;
    bool m_returnConnection;
};

#endif    

---