sqlbase.h

#ifndef SQLBASE_H
#define SQLBASE_H
 
#include <platformu_global.h>
#include <QDateTime>
#include <QTime>
#include <QHash>
#include <QList>
#include <QMap>
#include <QObject>
#include <QObject>
#include <QPair>
#include <QSqlDatabase>
#include <QSqlError>
#include <QSqlQuery>
#include <QSqlRecord>
#include <QSqlTableModel>
#include <QSqlTableModel>
#include <QString>
#include <QVariant>
#include <QVariantList>
#include <QtCore>
 
#include <publication.h>
#include <subscription.h>
 
#include <vremthread.h>
#include "platformu_global.h"
 
#define DATABASEDEVICE "SQLBase"
 
 
class PLATFORMUSHARED_EXPORT SQLBase  : public QObject
{
    Q_OBJECT
 
public:
 
#define  MAX_RETRY_OPENDB 3
 
typedef enum dbtype{ postgres = 0, mysql = 1, sqlite = 2 } DBType;
 
 struct SqlRow
     {
          QString tagname;
          QString tablename;
     };
 
     typedef QList<SqlRow> QSqlRowList;
 
     struct VremMYSqlRecord
     {
         QDateTime timeOf;
         QVariantList data;
     };
 
     typedef QList<VremMYSqlRecord> QDataLoggerRecord;
 
 
 
protected :
 
     PublicationRegistration *cloud;
     QString databaseIP, databasePort, databaseName, databaseUser, databasePasswd;
     QSqlDatabase db;
     QSqlTableModel *sub_model, *key_model;
     DRWLock<short> retry;
     QMutex classLock;
 
     virtual void ReloadTables(void)  = 0;
     QSqlTableModel *newDbTable(QString tableName);
public:
     SQLBase (QObject *parent = 0);
     SQLBase (QString DatabaseIP, QString DatabasePort, QString DatabaseName, QString DatabaseUser,
      QString DatabasePasswd,  QObject *parent = 0);
 
     virtual ~SQLBase( );
 
     bool open();
     QString OpenDatabase(QString DatabaseIP, QString DatabasePort, QString DatabaseName, QString DatabaseUser, QString DatabasePasswd);
     void ScratchDataTable(QString DataTable);
 
     bool isOpen(void);
 
     QSqlDatabase &getDB(void);
 
     QList<SqlRow> getAllRows(void);
     qint64 GetCurrentGMT(void);
     qint64 GetGMTFromLocal( QDateTime time);
     bool AddData( Subscription *sub);
     bool AddData( Subscription *sub, QString dataTable);
     bool AddDataBySub(QString subName,  VremVArray va);
 
     QSqlTableModel *getSubMap(void );
 
     static QDateTime EarliestPossibleDate( void);
 
     virtual  bool ClearAllData( QString dataTable) = 0;
 
     virtual QString OpenDatabase(void)  = 0;
 
     virtual void ScratchSql(void) = 0;
     virtual void ScratchSubscriber(QString subscriber) = 0;
 
     virtual QString TrendThis(QString subscription) = 0;
 
     virtual QString getSubFromTable( QString table) = 0;
     virtual QString getTableFromSub( QString sub) = 0;
     virtual QDataLoggerRecord GetDataRecordsFromTrendTable(QString table, QDateTime fromLocalTime, QDateTime toLocalTime) = 0;
     virtual VremMYSqlRecord GetLastDataRecordsFromTrendTable(QString table, QDateTime fromLocalTime, QDateTime toLocalTime) = 0;
     virtual VremMYSqlRecord GetLastDataRecordsFromTrendTable(QString table, QDateTime toLocalTime) = 0;
     virtual VremMYSqlRecord GetLastDataRecordsFromTrendTable(QString table) = 0;
     virtual bool DeleteDataRecordsFromTrendTable(QString table, QDateTime beforeLocalTime) = 0;
     virtual bool AddData( QString dataTable, const VremVArray &instance1) = 0;
     virtual bool ChangeProperties(QString subscriber, VremVArray propertys) = 0;
     virtual VremVArray GetProperties( QString subscription) = 0;
 
     void AddDataBySubscriptionName( QString &name, VremVArray &data);
     virtual DBType  getDBType()  = 0;
 
     QHash<QString,QString> getAllTracking( void);
 
 
signals:
     void SignalValuesAdded( QString Table, QDateTime time);
 
public slots:
     void SlotAddDataBySubscriptionName( QString name, VremVArray data)
     {
         AddDataBySubscriptionName(  name, data);
     }
 
};
 
#endif // SQLBASE_H