QwDBInterface.h

Go to the documentation of this file.

/*
 * QwDBInterface.h
 *
 *  Created on: Dec 14, 2010
 *      Author: jhlee
 */

#ifndef QWDBINTERFACE_H_
#define QWDBINTERFACE_H_

// System headers
#include <iostream>
#include <iomanip>
#include <cstring>
#include <vector>
#include <map>

// ROOT headers
#include "Rtypes.h"
#include "TString.h"

// Qweak headers
#include "QwLog.h"
//#include "QwParityDB.h"

// Forward declarations
class QwParityDB;

// QwDBInterface  GetDBEntry(TString subname);

// I extend a DB interface for QwIntegrationPMT to all subsystem,
// because the table structure are the same in the lumi_data table,
// the md_data table, and the beam table of MySQL database.
// Now every device-specified action will be done in
// the FillDB(QwParityDB *db, TString datatype) of QwBeamLine,
// QwMainCerenkovDetector, and QwLumi class.

class QwDBInterface {
 public:
  enum EQwDBIDataTableType{kQwDBI_OtherTable, kQwDBI_BeamTable, 
         kQwDBI_MDTable, kQwDBI_LumiTable};
 private:
  static std::map<TString, TString> fPrefix;

  UInt_t fAnalysisId;
  UInt_t fDeviceId;
  UInt_t fSubblock;
  UInt_t fN;
  Double_t fValue;
  Double_t fError;
  Char_t fMeasurementTypeId[4];

  TString fDeviceName;

 private:
  template <class T>
  T TypedDBClone();

 public:
  static TString DetermineMeasurementTypeID(TString type, TString suffix = "",
              Bool_t forcediffs = kFALSE);

 public:

    QwDBInterface()
    : fAnalysisId(0),fDeviceId(0),fSubblock(0),fN(0),fValue(0.0),fError(0.0) {
      std::strcpy(fMeasurementTypeId, "");fDeviceName ="";
    }
    virtual ~QwDBInterface() { }

    void SetAnalysisID(UInt_t id) {fAnalysisId = id;};
    void SetDetectorName(TString &in) {fDeviceName = in;};
    void SetDeviceID(UInt_t id) {fDeviceId = id;};
    void SetMonitorID(QwParityDB *db);
    void SetMainDetectorID(QwParityDB *db);
    void SetLumiDetectorID(QwParityDB *db);
    EQwDBIDataTableType SetDetectorID(QwParityDB *db);
    void SetMeasurementTypeID(const TString& in) {
      std::strncpy(fMeasurementTypeId, in.Data(), 3);
      fMeasurementTypeId[3] = '\0';
    };
    void SetMeasurementTypeID(const char* in) {
      std::strncpy(fMeasurementTypeId, in, 3);
      fMeasurementTypeId[3] = '\0';
    };
    void SetSubblock(UInt_t in) {fSubblock = in;};
    void SetN(UInt_t in)        {fN = in;};
    void SetValue(Double_t in)  {fValue = in;};
    void SetError(Double_t in)  {fError = in;};

    TString GetDeviceName() {return fDeviceName;};

    void Reset() {
      fAnalysisId = 0;
      fDeviceId = 0;
      fSubblock = 0;
      fN = 0;
      fValue = 0.0;
      fError = 0.0;
      std::strcpy(fMeasurementTypeId,"");
      fDeviceName = "";
    };

    template <class T> inline
    void AddThisEntryToList(std::vector<T> &list);


    void PrintStatus(Bool_t print_flag) {
      if(print_flag) {
        QwMessage << std::setw(12)
                  << " AnalysisID " << fAnalysisId
                  << " Device :"    << std::setw(30) << fDeviceName
                  << ":" << std::setw(4) << fDeviceId
                  << " Subblock "   << fSubblock
                  << " n "          << fN
                  << " Type "       << fMeasurementTypeId
                  << " [ave, err] "
                  << " [" << std::setw(14) << fValue
                  << ","  << std::setw(14) << fError
                  << "]"
                  << QwLog::endl;
      }
    }
};

//
//  Template definitions for the QwDBInterface class.
//
//

template <class T>
inline void QwDBInterface::AddThisEntryToList(std::vector<T> &list)
{
  Bool_t okay = kTRUE;
  if (fAnalysisId == 0) {
    QwError << "QwDBInterface::AddDBEntryToList:  Analysis ID invalid; entry dropped"
            << QwLog::endl;
    okay = kFALSE;
  }
  if (fDeviceId == 0) {
    QwError << "QwDBInterface::AddDBEntryToList:  Device ID invalid; entry dropped"
            << QwLog::endl;
    okay = kFALSE;
  }
  if (okay) {
    T row = TypedDBClone<T>();
    if (row.analysis_id == 0){
      QwError << "QwDBInterface::AddDBEntryToList:  Unknown list type; entry dropped"
              << QwLog::endl;
      okay = kFALSE;
    } else {
      list.push_back(row);
    }
  }
  if (okay == kFALSE) {
    PrintStatus(kTRUE);
  };
}






class QwErrDBInterface {

 private:

  UInt_t fAnalysisId;
  UInt_t fDeviceId;
  UInt_t fErrorCodeId;
  UInt_t fN;

  TString fDeviceName;

  template <class T>
  T TypedDBClone();


 public:

    QwErrDBInterface()
    : fAnalysisId(0),fDeviceId(0),fErrorCodeId(0),fN(0) {
      fDeviceName ="";
    }
    virtual ~QwErrDBInterface() { }

    void SetAnalysisID(UInt_t id) {fAnalysisId = id;};
    void SetDeviceName(TString &in) {fDeviceName = in;};
    void SetDeviceID(UInt_t id) {fDeviceId = id;};

    void SetMonitorID(QwParityDB *db);
    void SetMainDetectorID(QwParityDB *db);
    void SetLumiDetectorID(QwParityDB *db);

    void SetErrorCodeId(UInt_t in) {fErrorCodeId = in;};
    void SetN(UInt_t in)        {fN = in;};

    TString GetDeviceName() {return fDeviceName;};

    void Reset() {
      fAnalysisId = 0;
      fDeviceId = 0;
      fErrorCodeId = 0;
      fN = 0;
      fDeviceName = "";
    };

    template <class T> inline
    void AddThisEntryToList(std::vector<T> &list);


    void PrintStatus(Bool_t print_flag) {
      if(print_flag) {
        QwMessage << std::setw(12)
                  << " AnalysisID " << fAnalysisId
                  << " Device :"    << std::setw(30) << fDeviceName
                  << ":" << std::setw(4) << fDeviceId
                  << " ErrorCode "   << fErrorCodeId
                  << " n "          << fN
                  << QwLog::endl;
      }
    }
};

template <class T>
inline void QwErrDBInterface::AddThisEntryToList(std::vector<T> &list)
{
  Bool_t okay = kTRUE;
  if (fAnalysisId == 0) {
    QwError << "QwErrDBInterface::AddDBEntryToList:  Analysis ID invalid; entry dropped"
            << QwLog::endl;
    okay = kFALSE;
  }
  if (fDeviceId == 0) {
    QwError << "QwErrDBInterface::AddDBEntryToList:  Device ID invalid; entry dropped"
            << QwLog::endl;
    okay = kFALSE;
  }
  if (okay) {
    T row = TypedDBClone<T>();
    if (row.analysis_id == 0){
      QwError << "QwErrDBInterface::AddDBEntryToList:  Unknown list type; entry dropped"
              << QwLog::endl;
      okay = kFALSE;
    } else {
      list.push_back(row);
    }
  }
  if (okay == kFALSE) {
    PrintStatus(kTRUE);
  };
}

#endif /* QWDBINTERFACE_H_ */