TableManager.h

Go to the documentation of this file.

#ifndef CARMA_DBMS_TABLEMANAGER_H
#define CARMA_DBMS_TABLEMANAGER_H

#include "carma/dbms/DBConnection.h"
//#include "carma/util/Trace.h"
#include <vector>

namespace carma {
namespace dbms {


class TableManager {


public:
  struct Partition {
      std::string name;
      unsigned minFreeSpace;
  };

  TableManager(const bool& persistentConnection=true, DBConfigurator 
               *dbconf = NULL);

  virtual ~TableManager();
                     
  void loadConfigurationInformation();

  virtual int createMonitorDataTable(
                       const carma::dbms::MonitorAverageType& averageType,
                       const carma::dbms::MonitorAggregateType& aggType,
                       const unsigned& requiredSpace, 
                       std::string& tableName, const std::string& tag);



  void updateMonitorIndexTable(const std::string& tableName,
                               const MonitorAverageType& averageType);


protected:
  bool persistentConnection_;
  bool useProductionDB_;
  std::string rdbms_;
  carma::dbms::DBConnection *dbc_;
  std::map<int,Partition> partitions_;
  DBConfigurator *dbconf_;

  static int minimumFrameRetentionFrames_;
  static int minimumCorrelRetentionFrames_;
  static int minimumMinuteRetentionFrames_;

  //carma::util::Trace *trace_;

  void openDBConnectionIfNecessary();

  void closeDBConnectionIfNecessary();

  void closeDBConnection();

  virtual int getAvailablePartition(const int& requiredSpace, 
                                    const bool& connectionIsOpen);

  std::map<int, Partition> getEmptyPartitions(const bool& connectionIsOpen);

  unsigned getFreeMB(const std::string& partition) const;

  unsigned getTotalMB(const std::string& partition) const;


  void dropTable(const std::string& tableName) const;


}; 

class TableManagerException : public carma::util::ErrorException {
public:
    TableManagerException (const char* msg, const char* fileName = __FILE__, 
                           const int lineNum = __LINE__) 
        : carma::util::ErrorException (msg, fileName, lineNum) {};

    TableManagerException (const std::string msg, 
                           const char* fileName = __FILE__, 
                           const int lineNum = __LINE__) 
        : carma::util::ErrorException (msg.c_str(), fileName, lineNum) {};

};




}}
#endif