MonitorDataQueryManager.h

Go to the documentation of this file.

#ifndef CARMA_DBMS_MONITORDATAQUERYMANAGER_H
#define CARMA_DBMS_MONITORDATAQUERYMANAGER_H

#include <set>
#include <vector>
#include "carma/util/Time.h"
#include "carma/dbms/MonitorSystemAndDBMSRelationships.h"
#include "carma/dbms/ColumnNames.h"
#include "carma/dbms/MonitorPointSelector.h"

namespace carma {
namespace dbms {

    class DBConnection;
    class Filter;
    class OneComponentFilter;
    class MonitorPointFilter;
    //class MultiComponentFilter;
    //class Selector;
    class TimeRangeFilter;
    class TagIDFilter;
    class TagIDSetFilter;
    

class MonitorDataQueryManager {

public:
    /*
    MonitorDataQueryManager
        (const std::set<const carma::dbms::Selector*>& selectors,
         const carma::dbms::TimeRangeFilter * const trFilter,
         const carma::dbms::Filter * const otherFilter,
         const carma::dbms::DBConnection * const dbc);
    */
    MonitorDataQueryManager
        (const MPSelectorSet& selectors,
         const carma::dbms::TimeRangeFilter * const trFilter,
         const carma::dbms::DBConnection * const dbc);

    MonitorDataQueryManager
        (const MPSelectorSet& selectors,
         const carma::dbms::TimeRangeFilter * const trFilter,
         const std::set<const carma::dbms::MonitorPointFilter * >& mpfilters,
         const carma::dbms::DBConnection * const dbc);

    std::set<carma::dbms::MonitorAggregateType> getAggregateDataTypes() const;


    //bool shouldCheckArchive() const;

    ~MonitorDataQueryManager();

    static carma::util::frameType getBeginningOfProduction();

    std::map<carma::dbms::MonitorAggregateType, std::vector<std::string> > 
        getTablesToQuery() const;

    std::vector<std::string> getSetUpQueries() const { return setUpQueries_; }

    std::vector<std::string> getWideSetUpQueries() const { 
        return wideSetUpQueries_; 
    }

    std::map<int,std::string> getNarrowRSQueries() const {
        return narrowRSQueries_;
    }

    std::string getWideRSQuery() const { return wideRSQuery_; }

    std::map<int,carma::dbms::Table> execNarrowQueries();
    
    carma::dbms::Table execWideQuery();

    std::string mdqmGetColumnName(DBColumn column)const;
protected:
    const carma::dbms::DBConnection *dbc_;
    const carma::dbms::TimeRangeFilter *trFilter_;
    //const carma::dbms::Filter *otherFilter_;
    const std::set<const carma::dbms::MonitorPointFilter *> mpFilters_;
    MPSelectorSet selectors_;
    carma::dbms::MonitorAverageType avgType_;
    std::map<carma::dbms::MonitorAggregateType,std::string> tmpTableName_;


    std::map<carma::dbms::MonitorAggregateType, carma::dbms::Table> 
        tablesToQuery_;

    std::map<carma::dbms::MonitorAggregateType, 
        std::vector<const carma::dbms::MonitorPointSelector * > >
        aggType2MPSelectors_;

    std::map<carma::dbms::MonitorAggregateType, 
        std::vector<const carma::dbms::MonitorPointFilter * > >
        aggType2MPFilters_;

    std::map<unsigned, const carma::dbms::MonitorPointFilter * > tagID2MPFilter_;

    std::map<carma::dbms::MonitorAggregateType, std::string> 
        aggType2FilterClause_;


    std::set<MonitorAggregateType> aggTypes_;
    const static std::string TAGID_TO_DATATYPE;
    carma::dbms::Table tagIDToDataTypeID_;

    std::vector<std::string> setUpQueries_;
    bool haveRunSetUpQueries_;

    std::map<int,std::string> narrowRSQueries_;

    std::vector<std::string> wideSetUpQueries_;
    bool haveRunWideSetUpQueries_;

    std::vector<std::string> tablesToDropUponDestruction_;


    std::string wideRSQuery_;

    static int tCount_;

    std::string wideErrMsg_;

    void determineAggregateTableTypes_();

    /*
    void handleOneComponentFilter_
        (const carma::dbms::OneComponentFilter * const ocf);
    */
    //void handleTagIDFilter_(const carma::dbms::TagIDFilter * const tif);

    //void handleTagIDSetFilter_(const carma::dbms::TagIDSetFilter * const tisf);

    /*
    void handleMultiComponentFilter_ 
        (const carma::dbms::MultiComponentFilter * const tcf);
    */

    void determineTablesToQuery_();

    void cacheTagIDToDataType_();
    
    void createQueries_();
    
    void doSanityChecks_();

    void execSetUpQueries_() const;

    void execWideSetUpQueries_() const;

    void createSetUpQueries_();

    void createNarrowRSQueries_();

    void createWideRSQuery_();

    void createJoinSetUpQueries_
        (const std::vector
         < std::vector<const carma::dbms::MonitorPointSelector * > >& mpssVec);

    void init_();

    void constructFilterClauses_();
};
}}

#endif // CARMA_DBMS_MONITORDATAQUERYMANAGER_H