QJitterHandle.cc

Go to the documentation of this file.

#include "QJitterHandle.hh"
#include "QJitter.hh" 
#include "QDianaDb.hh"
 
using namespace Diana;
 
QError QJitterHandle::FillFromDB()
{
    QError err = QERR_SUCCESS; 
 
    QJitter jitter;
    jitter.Clear();
 
    std::string bareOwner, extraLabel;
    GetLabel().GetBareOwnerAndExtraLabel(bareOwner,extraLabel);    
    if (extraLabel=="") extraLabel="None";
  
    int refCh;
    double jitt;
    double jittErr;
 
    QDianaDb *db = QDianaDb::Get();
    
    std::stringstream squery;
  
    // query reference channel  
 
    squery<<"select ref_channel from jitters where jitter_algo = '" <<bareOwner
          << "' and jitter_version = '"<<GetVersion()
          << "' and jitter_extralabel= '"<<extraLabel
          << "' and channel = "<<GetChannel()
          << " and data_set = "<<GetDataset();
    
    try {
      refCh = db->DoQueryInt(squery.str());
    }
    
    catch(const QError& cerr) {
      if(cerr!=QERR_SUCCESS) {
        err = cerr;
        return err;
      } 
    }
    
    squery.str("");
 
    // query jitter  
    
    squery<<"select jitter from jitters where jitter_algo = '" <<bareOwner
          << "' and jitter_version = '"<<GetVersion()
          << "' and jitter_extralabel= '"<<extraLabel
          << "' and channel = "<<GetChannel()
          << " and data_set = "<<GetDataset();
  
    try {
      jitt = db->DoQueryDouble(squery.str());
    }
    
    catch(const QError& cerr) {
      if(cerr!=QERR_SUCCESS) {
        err = cerr;
        return err;
      } 
    }
    
    squery.str("");
 
    // query jitter error  
    
    squery<<"select err_jitter from jitters where jitter_algo = '" <<bareOwner
        << "' and jitter_version = '"<<GetVersion()
        << "' and jitter_extralabel= '"<<extraLabel
        << "' and channel = "<<GetChannel()
        << " and data_set = "<<GetDataset();
  
    try {
      jittErr = db->DoQueryDouble(squery.str());
    }
  
    catch(const QError& cerr) {
      if(cerr!=QERR_SUCCESS) {
        err = cerr;
        return err;
      } 
    }
    
    jitter.fRefChannel = refCh;
    jitter.fJitter = jitt;
    jitter.fJitterError = jittErr;
 
    Set(jitter);
 
    // fill fCalibLabel from table xxx_jitter_algo where xxx is the name of the jitter module (now JitterByCoincidence)
    
      std::string calib_algo, calib_version, calib_extralabel;
 
      QDb::QDbTable table;
      
      squery.str("");
      
      squery<<"select calib_algo, calib_version, calib_extralabel from "<<bareOwner<<"_jitter_algo"
            <<" where jitter_version= '"<<GetVersion()
            <<"' and jitter_extralabel= '"<<extraLabel <<"'";
      
      try {
        table = db->DoQuery(squery.str());
      }
  
      catch(const QError& cerr) {
        err = cerr;
        return err;
      }
      
      try {
        if(table["calib_algo"].size() == 1) {    
          calib_algo = table["calib_algo"].begin()->GetString(); 
          calib_version = table["calib_version"].begin()->GetString(); 
          calib_extralabel = table["calib_extralabel"].begin()->GetString(); 
        }  else {
          err = QERR_DB_NULL_RESULT;
          std::string errMsg("The primary key was not found in DB; Check you input.\nFill the object with default values.\nQuery: ");
          errMsg +=squery.str();
          err.SetDescription(__FILE__, __LINE__, errMsg);
          return err;
        }
      }
      catch(const QError& cerr) {
        if(cerr!=QERR_SUCCESS) {
          err = cerr;
          return err;
        }
      }
      
      fCalibLabel = calib_algo + "_" + calib_extralabel;
      if(calib_extralabel=="None") fCalibLabel = calib_algo;
      fCalibVersion = calib_version;
      
      return err;
}
 
QError QJitterHandle::StoreOnDB() const
{
  QError err = QERR_SUCCESS;
  
  const QJitter& jitter = Get();
  
  std::string bareOwner, extraLabel;
  GetLabel().GetBareOwnerAndExtraLabel(bareOwner,extraLabel);    
  if (extraLabel=="") extraLabel="None";
  
  std::string calib_algo, calib_version, calib_extralabel;
  calib_version = GetCalibVersion();
  QGlobalLabel calib_label = GetCalibLabel();
  
  if (calib_label.GetStringLabel()!=Q_STRING_DEFAULT) {
    calib_label.GetBareOwnerAndExtraLabel(calib_algo,calib_extralabel);    
  }
  if (calib_extralabel=="") calib_extralabel = "None";
  if(calib_algo.empty() && fCalibLabel.find_first_of("@") == std::string::npos) calib_algo = fCalibLabel; 
  
  std::stringstream squery;
  
  // query insert into xxx_jitter_algo where xxx is the name of the jitter module (now JitterByCoincidence)
  
  // first check if the table is already filled 
  squery<<"select calib_algo from "<<bareOwner<<"_jitter_algo"
        << " where jitter_version = '"<<GetVersion()
        << "' and jitter_extralabel= '"<<extraLabel<<"'";
  
  try {
    QDianaDb *db = QDianaDb::Get();
    std::string ca = db->DoQueryString(squery.str());
  }
  
    catch(const QError& cerr) {
      if(cerr!=QERR_SUCCESS) {
 
        squery.str("");
 
        squery<<"INSERT into "<<bareOwner<<"_jitter_algo (jitter_version, jitter_extralabel, calib_algo, calib_version, calib_extralabel) values "
              <<"('"
              << GetVersion()<<"','"
              << extraLabel<<"','"
              << calib_algo<<"','"
              << calib_version<<"','"
              << calib_extralabel<<"')";
        
        try {
          QDianaDb *db = QDianaDb::Get();
          db->DoExec(squery.str());
        }
        
        catch(const QError& cerr) {
          if(cerr!=QERR_SUCCESS) {
            err = cerr;
            return err;
          } 
        }
      }
    }
 
    // query insert into jitters
    
    QVdt::QVdt_vector fields,values;
    fields.push_back((std::string)"jitter_algo");
    fields.push_back((std::string)"jitter_version");
    fields.push_back((std::string)"jitter_extralabel");
    fields.push_back((std::string)"channel");
    fields.push_back((std::string)"data_set");
    fields.push_back((std::string)"ref_channel");
    fields.push_back((std::string)"jitter");
    fields.push_back((std::string)"err_jitter");
    values.push_back("'"+bareOwner+"'");
    values.push_back("'"+GetVersion()+"'");
    values.push_back("'"+extraLabel+"'");
    values.push_back(GetChannel());
    values.push_back(GetDataset());
    values.push_back(jitter.fRefChannel);
    values.push_back(jitter.fJitter);
    values.push_back(jitter.fJitterError);
 
  try {
        QDianaDb *db = QDianaDb::Get();
        db->Insert("jitters",fields,values);
  }
  catch(const QError& cerr) {
      if(cerr!=QERR_SUCCESS) {
          err = cerr;
          return err;
      } 
  }
 
    return err;
}