QCOFParametersHandle.cc

Go to the documentation of this file.

#include "QGlobalDataManager.hh"
#include "QCOFParametersHandle.hh"
#include "QObject.hh"
#include "QMessage.hh"
#include "QDianaDb.hh"
 
using namespace Diana;
 
QError QCOFParametersHandle::FillFromDB()
{
  QError err = QERR_NOT_IMPLEMENTED; // (yet)
  err.SetDescription("FillFromDB() not implemented for QCOFParametersHandle");
  return err;
}
 
QError QCOFParametersHandle::StoreOnDB() const
{
  QError err = QERR_SUCCESS; 
    
  std::string bareOwner, extraLabel;
  GetLabel().GetBareOwnerAndExtraLabel(bareOwner,extraLabel);    
  if (extraLabel=="") extraLabel="None";
  
  std::string ap_algo, ap_extralabel;
  QGlobalLabel ap_label = fAPLabel;
  if (ap_label.GetStringLabel()!=Q_STRING_DEFAULT) {
    ap_label.GetBareOwnerAndExtraLabel(ap_algo,ap_extralabel);    
  }
  if(ap_extralabel=="") ap_extralabel = "None";
 
  std::string nps_algo, nps_extralabel;
  QGlobalLabel nps_label = fNPSLabel;
  if (nps_label.GetStringLabel()!=Q_STRING_DEFAULT) {
    nps_label.GetBareOwnerAndExtraLabel(nps_algo,nps_extralabel);    
  }
  if(nps_extralabel=="") nps_extralabel = "None";
    
  // first FILL cof_amp_algo
 
  std::stringstream squery;
  QDb::QDbTable av,vv;
 
  // first check if the table is already filled 
  squery<<"select amp_version from " <<bareOwner<<"_amp_algo where amp_version='" << GetVersion() <<"' and amp_extralabel='"<< extraLabel<< "'";  
  
  try {
    QDianaDb *db = QDianaDb::Get();
    av = db->DoQuery(squery.str());
  }
  catch(const QError& cerr) {
    err = cerr;
    return err;
  }
 
  if(av.empty()) {
    
    squery.str("");
    
    squery<<"INSERT into "<<bareOwner<<"_amp_algo (amp_version, amp_extralabel) values " << "('" << GetVersion() << "','" << extraLabel << "')";
    
    try {
      QDianaDb *db = QDianaDb::Get();
      db->DoExec(squery.str());
    }
      
    catch(const QError& cerr) {
      if(cerr!=QERR_SUCCESS) {
        err = cerr;
        return err;
      }
    }
  }
 
  // FILL cof_amp_params
 
  squery.str("");
  
  // first check if the table is already filled 
  squery<<"select amp_version from " <<bareOwner<<"_amp_params where amp_version='" << GetVersion() <<"' and amp_extralabel='"<< extraLabel << "' and channel=" << GetChannel() << " and ap_algo='" << ap_algo << "' and ap_extralabel='" << ap_extralabel << "' and ap_validity_kind ='"<< fAPValidityKind << "' and nps_algo='" << nps_algo << "' and nps_extralabel='" << nps_extralabel << "' and nps_validity_kind ='"<< fNPSValidityKind << "'";
  
    try {
      QDianaDb *db = QDianaDb::Get();
      vv = db->DoQuery(squery.str());
    }
    catch(const QError& cerr) {
      err = cerr;
      return err;
    }
 
    if(vv.empty()) {
 
        QVdt::QVdt_vector fields,values;
        fields.push_back((std::string)"amp_version");        values.push_back("'"+GetVersion()+"'");
        fields.push_back((std::string)"amp_extralabel");     values.push_back("'"+extraLabel+"'");
        fields.push_back((std::string)"channel");            values.push_back(GetChannel());
        fields.push_back((std::string)"ap_algo");            values.push_back("'"+ap_algo+"'");
        fields.push_back((std::string)"ap_version");         values.push_back("'"+fAPVersion+"'");
        fields.push_back((std::string)"ap_extralabel");      values.push_back("'"+ap_extralabel+"'");
        fields.push_back((std::string)"ap_validity_kind");   values.push_back("'"+fAPValidityKind+"'");
        fields.push_back((std::string)"nps_algo");           values.push_back("'"+nps_algo+"'");
        fields.push_back((std::string)"nps_version");        values.push_back("'"+fNPSVersion+"'");
        fields.push_back((std::string)"nps_extralabel");     values.push_back("'"+nps_extralabel+"'");
        fields.push_back((std::string)"nps_validity_kind");  values.push_back("'"+fNPSValidityKind+"'");
 
        try {
            QDianaDb *db = QDianaDb::Get();
            db->Insert(bareOwner+"_amp_params",fields,values);
        }
 
        catch(const QError& cerr) {
            if(cerr!=QERR_SUCCESS) {
                err = cerr;
                return err;
            }
        }
    }
 
    return err;
}