QEnergyRangesHandle.cc

Go to the documentation of this file.

#include "QEnergyRangesHandle.hh"
#include "QDianaDb.hh"
 
using namespace Diana;
 
QError QEnergyRangesHandle::FillFromDB()
{
    QError err = QERR_SUCCESS; 
 
    QInterval er;
    er.Clear();
 
    std::string bareOwner, extraLabel;
    QGlobalLabel calibLabel = GetCalibLabel();
    calibLabel.GetBareOwnerAndExtraLabel(bareOwner,extraLabel);      
    if (extraLabel=="") extraLabel="None";
 
    QDianaDb *db = QDianaDb::Get();
  
    // query peak energy
    std::stringstream squery;
 
    // query peak range min
    squery<<"select energy_range_min from data_sets_analyses where calib_algo = '"<<bareOwner
      <<"' and calib_version= '"<<GetCalibVersion()
      <<"' and calib_extralabel= '"<<extraLabel
      <<"' and channel= "<< GetChannel()
      <<" and data_set= "<<GetDataset();
   
    try {
      er.SetMin ( db->DoQueryDouble(squery.str()));
    }
    
    catch(const QError& cerr) {
        if(cerr!=QERR_SUCCESS) {
            err = cerr;
            return err;   
        }
    }
 
    squery.str("");
 
    // query peak range max
    squery<<"select energy_range_max from data_sets_analyses where calib_algo = '"<<bareOwner
      <<"' and calib_version= '"<<GetCalibVersion()
      <<"' and calib_extralabel= '"<<extraLabel
      <<"' and channel= "<< GetChannel()
      <<" and data_set= "<<GetDataset();
   
    try {
      er.SetMax ( db->DoQueryDouble(squery.str()));
    }
    
    catch(const QError& cerr) {
      if(cerr!=QERR_SUCCESS) {
    err = cerr;
    return err;   
      }
    }
   
    Set(er);
 
    return err;
}
 
 
QError QEnergyRangesHandle::StoreOnDB() const
{
    QError err = QERR_SUCCESS;  
    const QInterval& epar = Get();
 
    
    std::string calib_algo, calib_version, calib_extralabel;
    calib_version = GetCalibVersion();
    QGlobalLabel calibLabel = GetCalibLabel();
    calibLabel.GetBareOwnerAndExtraLabel(calib_algo,calib_extralabel);
    if (calib_extralabel=="") calib_extralabel="None";
 
    std::stringstream squery;
 
    // first check if the table is already filled 
    squery<<"SELECT energy_range_min from data_sets_analyses "  
        << " where channel = "<< GetChannel()
        << " and data_set = "<< GetDataset()
        << " and calib_algo = '"<< calib_algo
        << "' and calib_version = '"<< calib_version
        << "' and calib_extralabel= '"<< calib_extralabel<<"'";
    try {
        QDianaDb *db = QDianaDb::Get();
        db->DoQueryDouble(squery.str());    
    }
 
 
    catch(const QError& cerr) {
        err = cerr;
        if(err == QERR_TYPE_CONVERSION) {
            // campo vuoto, faccio update;
            squery.str("");
            squery<<"UPDATE data_sets_analyses set "
                <<" energy_range_min = "<<epar.GetMin()
                <<", energy_range_max = "<<epar.GetMax()
                <<" where data_set="
                << GetDataset()<<" and channel="
                << GetChannel()<<" and calib_algo='"
                << calib_algo<<"' and calib_version='"
                << calib_version<<"' and calib_extralabel ='"
                << calib_extralabel<<"'";
 
            try {
                QDianaDb *db = QDianaDb::Get();
                db->DoExec(squery.str());
                err =QERR_SUCCESS;
                return err;
            }
 
            catch(const QError& cerror) {
                if(cerror!=QERR_SUCCESS) {
                    err = cerror;
                    return err;
                }
            }
        } else if(err != QERR_DB_NULL_RESULT) {
            return err;
 
        } 
    } 
 
    if(err == QERR_DB_NULL_RESULT || err == QERR_SUCCESS) {
        // riga inesistente o uguale 
        squery.str("");
 
        QVdt::QVdt_vector fields,values;
        fields.push_back((std::string)"data_set");           values.push_back(GetDataset());
        fields.push_back((std::string)"calib_algo");         values.push_back("'"+calib_algo+"'");
        fields.push_back((std::string)"calib_version");      values.push_back("'"+calib_version+"'");
        fields.push_back((std::string)"calib_extralabel");   values.push_back("'"+calib_extralabel+"'");
        fields.push_back((std::string)"channel");            values.push_back(GetChannel());
        fields.push_back((std::string)"energy_range_min");   values.push_back(epar.GetMin());
        fields.push_back((std::string)"energy_range_max");   values.push_back(epar.GetMax());
 
        try {
            QDianaDb *db = QDianaDb::Get();
            db->Insert("data_sets_analyses",fields,values);
        }
 
        catch(const QError& cerror) {
            if(cerror!=QERR_SUCCESS) {
                err = cerror;
                return err;
            }
        }
        err = QERR_SUCCESS;
    }
 
    return err;
}