MonRunList Class Reference

#include <MonRunList.h>

Inheritance diagram for MonRunList:

Public Member Functions
void	fetchLastNRuns (int max_run, int n_runs) noexcept(false)
void	fetchRuns () noexcept(false)
void	fetchRuns (int min_run, int max_run) noexcept(false)
MonRunTag	getMonRunTag () const
std::vector< MonRunIOV >	getRuns ()
RunTag	getRunTag () const
	MonRunList ()
void	setMonRunTag (const MonRunTag &tag)
void	setRunTag (const RunTag &tag)
	~MonRunList () override
Public Member Functions inherited from IDBObject
oracle::occi::Connection *	getConn () const
oracle::occi::Environment *	getEnv () const
void	setConnection (oracle::occi::Environment *env, oracle::occi::Connection *conn)
virtual	~IDBObject ()

Private Attributes
MonRunTag	m_monrunTag
RunTag	m_runTag
std::vector< MonRunIOV >	m_vec_monruniov

Friends
class	EcalCondDBInterface

Additional Inherited Members
Static Public Attributes inherited from IDBObject
static int const	ECALDB_NROWS =1024
Protected Member Functions inherited from IDBObject
void	checkConnection () const noexcept(false)
Protected Attributes inherited from IDBObject
oracle::occi::Connection *	m_conn
oracle::occi::Environment *	m_env

Detailed Description

Definition at line 16 of file MonRunList.h.

Constructor & Destructor Documentation

MonRunList::MonRunList

(

)

Definition at line 14 of file MonRunList.cc.

{
  m_conn = nullptr;
}

MonRunList::~MonRunList ( )

override

Definition at line 19 of file MonRunList.cc.

{
}

Member Function Documentation

void MonRunList::fetchLastNRuns ( int  max_run, int  n_runs  )

noexcept

Definition at line 259 of file MonRunList.cc.

References gather_cfg::cout, DateHandler::dateToTm(), cuy::dh, MillePedeFileConverter_cfg::e, mps_fire::i, alignCSCRings::r, mathSSE::return(), MonRunIOV::setID(), RunIOV::setID(), MonRunIOV::setMonRunTag(), RunIOV::setRunEnd(), MonRunIOV::setRunIOV(), RunIOV::setRunNumber(), RunIOV::setRunStart(), RunIOV::setRunTag(), MonRunIOV::setSubRunEnd(), MonRunIOV::setSubRunNumber(), MonRunIOV::setSubRunStart(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by EcalCondDBInterface::fetchMonRunListLastNRuns().

{

  // fetch the last n_runs that come just before max_run (including max_run)

  this->checkConnection();


  m_runTag.setConnection(m_env, m_conn);
  int tagID = m_runTag.fetchID();
  cout <<"tag id="<< tagID << endl;
  if (!tagID) { 
    return ;
  }
  m_monrunTag.setConnection(m_env, m_conn);
  int montagID = m_monrunTag.fetchID();
  cout <<"mon tag id="<< montagID << endl;
  if (!montagID) { 
    return ;
  }

  int my_max_run=max_run+1;
  try {

    int nruns=n_runs;
    m_vec_monruniov.reserve(nruns);
    
    Statement* stmt = m_conn->createStatement();
    stmt->setSQL("select run_num, run_start, run_end, tag_id, run_iov_id, subrun_num, subrun_start, subrun_end, mon_iov_id from (SELECT run_iov.run_num, run_iov.run_start, run_iov.run_end, mon_run_iov.tag_id, mon_run_iov.run_iov_id, mon_run_iov.subrun_num, mon_run_iov.subrun_start, mon_run_iov.subrun_end, mon_run_iov.iov_id as mon_iov_id FROM run_iov, mon_run_iov "
         "WHERE mon_run_iov.run_iov_id=run_iov.iov_id and run_iov.tag_id = :tag_id "
         " and mon_run_iov.tag_id=:montag_id "
         " and run_iov.run_num< :max_run "
         " order by run_iov.run_num DESC ) where rownum< :n_runs order by run_num DESC " );
    stmt->setInt(1, tagID);
    stmt->setInt(2, montagID);
    stmt->setInt(3, my_max_run);
    stmt->setInt(4, n_runs);

    DateHandler dh(m_env, m_conn);
    Tm runStart;
    Tm runEnd;
    Tm lrunStart;
    Tm lrunEnd;
  
    ResultSet* rset = stmt->executeQuery();
    int i=0;
    while (i<nruns) {
      rset->next();
       int runNum = rset->getInt(1);
       Date startDate = rset->getDate(2);
       Date endDate = rset->getDate(3);
       // int ltag = rset->getInt(4);
       int lid=rset->getInt(5);
       int subrun=rset->getInt(6);
       Date monstartDate = rset->getDate(7);
       Date monendDate = rset->getDate(8);
       int liov_id=rset->getInt(9);
     
       runStart = dh.dateToTm( startDate );
       runEnd = dh.dateToTm( endDate );
       lrunStart = dh.dateToTm( monstartDate );
       lrunEnd = dh.dateToTm( monendDate );
       
       RunIOV r ;
       r.setRunNumber(runNum);
       r.setRunStart(runStart);
       r.setRunEnd(runEnd);
       r.setRunTag(m_runTag);
       r.setID(lid);
    
       MonRunIOV lr ;
       // da correggere qui
       lr.setRunIOV(r);
       lr.setSubRunNumber(subrun);
       lr.setSubRunStart(lrunStart);
       lr.setSubRunEnd(lrunEnd);
       lr.setMonRunTag(m_monrunTag);
       lr.setID(liov_id);
       m_vec_monruniov.push_back(lr);
      
      i++;
    }
   

    m_conn->terminateStatement(stmt);
  } catch (SQLException &e) {
    throw(std::runtime_error(std::string("MonRunList::fetchLastNRuns:  ")+getOraMessage(&e)));
  }


}

void MonRunList::fetchRuns ( )

noexcept

Definition at line 52 of file MonRunList.cc.

References gather_cfg::cout, DateHandler::dateToTm(), cuy::dh, MillePedeFileConverter_cfg::e, mps_fire::i, alignCSCRings::r, mathSSE::return(), MonRunIOV::setID(), RunIOV::setID(), MonRunIOV::setMonRunTag(), RunIOV::setRunEnd(), MonRunIOV::setRunIOV(), RunIOV::setRunNumber(), RunIOV::setRunStart(), RunIOV::setRunTag(), MonRunIOV::setSubRunEnd(), MonRunIOV::setSubRunNumber(), MonRunIOV::setSubRunStart(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by EcalCondDBInterface::fetchMonRunList().

{


  this->checkConnection();
  int nruns=0;

  m_runTag.setConnection(m_env, m_conn);
  int tagID = m_runTag.fetchID();
  cout <<"tag id="<< tagID << endl;
  if (!tagID) { 
    return ;
  }
  m_monrunTag.setConnection(m_env, m_conn);
  int montagID = m_monrunTag.fetchID();
  cout <<"mon tag id="<< montagID << endl;
  if (!montagID) { 
    return ;
  }

  try {
    Statement* stmt0 = m_conn->createStatement();
    stmt0->setSQL("SELECT count(mon_run_iov.iov_id) FROM mon_run_iov, run_iov "
         "WHERE mon_run_iov.run_iov_id= run_iov.iov_id and run_iov.tag_id = :tag_id and mon_run_iov.tag_id=:montag_id " );
    stmt0->setInt(1, tagID);
    stmt0->setInt(2, montagID);
  
    ResultSet* rset0 = stmt0->executeQuery();
    if (rset0->next()) {
      nruns = rset0->getInt(1);
    }
    m_conn->terminateStatement(stmt0);

    cout <<"nruns="<< nruns << endl;
    
    m_vec_monruniov.reserve(nruns);
    
    Statement* stmt = m_conn->createStatement();
    stmt->setSQL("SELECT run_iov.run_num, run_iov.run_start, run_iov.run_end, mon_run_iov.tag_id, mon_run_iov.run_iov_id, mon_run_iov.subrun_num, mon_run_iov.subrun_start, mon_run_iov.subrun_end, mon_run_iov.iov_id FROM run_iov, mon_run_iov "
         "WHERE mon_run_iov.run_iov_id=run_iov.iov_id and run_iov.tag_id = :tag_id  order by run_iov.run_num, mon_run_iov.subrun_num  ASC " );
    stmt->setInt(1, tagID);

    DateHandler dh(m_env, m_conn);
    Tm runStart;
    Tm runEnd;
    Tm lrunStart;
    Tm lrunEnd;
  
    ResultSet* rset = stmt->executeQuery();
    int i=0;
    while (i<nruns) {
      rset->next();
       int runNum = rset->getInt(1);
       Date startDate = rset->getDate(2);
       Date endDate = rset->getDate(3);
       //int ltag = rset->getInt(4);
       int lid=rset->getInt(5);
       int subrun=rset->getInt(6);
       Date monstartDate = rset->getDate(7);
       Date monendDate = rset->getDate(8);
       int liov_id=rset->getInt(9);
     
       runStart = dh.dateToTm( startDate );
       runEnd = dh.dateToTm( endDate );
       lrunStart = dh.dateToTm( monstartDate );
       lrunEnd = dh.dateToTm( monendDate );
       
       RunIOV r ;
       r.setRunNumber(runNum);
       r.setRunStart(runStart);
       r.setRunEnd(runEnd);
       r.setRunTag(m_runTag);
       r.setID(lid);
    
       MonRunIOV lr ;
       // da correggere qui
       lr.setRunIOV(r);
       lr.setSubRunNumber(subrun);
       lr.setSubRunStart(lrunStart);
       lr.setSubRunEnd(lrunEnd);
       lr.setMonRunTag(m_monrunTag);
       lr.setID(liov_id);
       m_vec_monruniov.push_back(lr);
      
      i++;
    }
   

    m_conn->terminateStatement(stmt);
  } catch (SQLException &e) {
    throw(std::runtime_error(std::string("RunIOV::fetchID:  ")+getOraMessage(&e)));
  }


}

void MonRunList::fetchRuns ( int  min_run, int  max_run  )

noexcept

Definition at line 149 of file MonRunList.cc.

References gather_cfg::cout, DateHandler::dateToTm(), cuy::dh, MillePedeFileConverter_cfg::e, mps_fire::i, alignCSCRings::r, mathSSE::return(), MonRunIOV::setID(), RunIOV::setID(), MonRunIOV::setMonRunTag(), RunIOV::setRunEnd(), MonRunIOV::setRunIOV(), RunIOV::setRunNumber(), RunIOV::setRunStart(), RunIOV::setRunTag(), MonRunIOV::setSubRunEnd(), MonRunIOV::setSubRunNumber(), MonRunIOV::setSubRunStart(), and AlCaHLTBitMon_QueryRunRegistry::string.

{


  this->checkConnection();
  int nruns=0;

  m_runTag.setConnection(m_env, m_conn);
  int tagID = m_runTag.fetchID();
  cout <<"tag id="<< tagID << endl;
  if (!tagID) { 
    return ;
  }
  m_monrunTag.setConnection(m_env, m_conn);
  int montagID = m_monrunTag.fetchID();
  cout <<"mon tag id="<< montagID << endl;
  if (!montagID) { 
    return ;
  }

  int my_min_run=min_run-1;
  int my_max_run=max_run+1;
  try {
    Statement* stmt0 = m_conn->createStatement();
    stmt0->setSQL("SELECT count(mon_run_iov.iov_id) FROM mon_run_iov, run_iov "
         "WHERE mon_run_iov.run_iov_id= run_iov.iov_id "
          "and run_iov.tag_id = :tag_id and mon_run_iov.tag_id=:montag_id "
          " and run_iov.run_num> :min_run and run_iov.run_num< :max_run "
          );
    stmt0->setInt(1, tagID);
    stmt0->setInt(2, montagID);
    stmt0->setInt(3, my_min_run);
    stmt0->setInt(4, my_max_run);
  
    ResultSet* rset0 = stmt0->executeQuery();
    if (rset0->next()) {
      nruns = rset0->getInt(1);
    }
    m_conn->terminateStatement(stmt0);

    cout <<"nruns="<< nruns << endl;
    
    m_vec_monruniov.reserve(nruns);
    
    Statement* stmt = m_conn->createStatement();
    stmt->setSQL("SELECT run_iov.run_num, run_iov.run_start, run_iov.run_end, mon_run_iov.tag_id, mon_run_iov.run_iov_id, mon_run_iov.subrun_num, mon_run_iov.subrun_start, mon_run_iov.subrun_end, mon_run_iov.iov_id FROM run_iov, mon_run_iov "
         "WHERE mon_run_iov.run_iov_id=run_iov.iov_id and run_iov.tag_id = :tag_id "
         " and mon_run_iov.tag_id=:montag_id "
         " and run_iov.run_num> :min_run and run_iov.run_num< :max_run "
         " order by run_iov.run_num, mon_run_iov.subrun_num ASC " );
    stmt->setInt(1, tagID);
    stmt->setInt(2, montagID);
    stmt->setInt(3, my_min_run);
    stmt->setInt(4, my_max_run);

    DateHandler dh(m_env, m_conn);
    Tm runStart;
    Tm runEnd;
    Tm lrunStart;
    Tm lrunEnd;
  
    ResultSet* rset = stmt->executeQuery();
    int i=0;
    while (i<nruns) {
      rset->next();
       int runNum = rset->getInt(1);
       Date startDate = rset->getDate(2);
       Date endDate = rset->getDate(3);
       // int ltag = rset->getInt(4);
       int lid=rset->getInt(5);
       int subrun=rset->getInt(6);
       Date monstartDate = rset->getDate(7);
       Date monendDate = rset->getDate(8);
       int liov_id=rset->getInt(9);
     
       runStart = dh.dateToTm( startDate );
       runEnd = dh.dateToTm( endDate );
       lrunStart = dh.dateToTm( monstartDate );
       lrunEnd = dh.dateToTm( monendDate );
       
       RunIOV r ;
       r.setRunNumber(runNum);
       r.setRunStart(runStart);
       r.setRunEnd(runEnd);
       r.setRunTag(m_runTag);
       r.setID(lid);
    
       MonRunIOV lr ;
       // da correggere qui
       lr.setRunIOV(r);
       lr.setSubRunNumber(subrun);
       lr.setSubRunStart(lrunStart);
       lr.setSubRunEnd(lrunEnd);
       lr.setMonRunTag(m_monrunTag);
       lr.setID(liov_id);
       m_vec_monruniov.push_back(lr);
      
      i++;
    }
   

    m_conn->terminateStatement(stmt);
  } catch (SQLException &e) {
    throw(std::runtime_error(std::string("RunIOV::fetchID:  ")+getOraMessage(&e)));
  }


}

MonRunTag MonRunList::getMonRunTag

(

)

const

Definition at line 41 of file MonRunList.cc.

{
  return m_monrunTag;
}

std::vector< MonRunIOV > MonRunList::getRuns

(

)

Definition at line 46 of file MonRunList.cc.

Referenced by EcalPedestalHistory::beginRun(), popcon::EcalChannelStatusHandler::getNewObjects(), popcon::EcalPedestalsHandler::getNewObjectsH2(), popcon::EcalPedestalsHandler::getNewObjectsP5(), and EcalTPGDBApp::readFromCondDB_Pedestals().

{
  return m_vec_monruniov;
}

RunTag MonRunList::getRunTag

(

)

const

Definition at line 37 of file MonRunList.cc.

{
  return m_runTag;
}

void MonRunList::setMonRunTag

(

const MonRunTag &

tag

)

Definition at line 29 of file MonRunList.cc.

References GlobalPosition_Frontier_DevDB_cff::tag.

Referenced by EcalPedestalHistory::beginRun(), EcalCondDBInterface::fetchMonRunList(), EcalCondDBInterface::fetchMonRunListLastNRuns(), popcon::EcalChannelStatusHandler::getNewObjects(), popcon::EcalPedestalsHandler::getNewObjectsH2(), popcon::EcalPedestalsHandler::getNewObjectsP5(), and EcalTPGDBApp::readFromCondDB_Pedestals().

{
  if (tag != m_monrunTag) {
    m_monrunTag = tag;
  }
}

void MonRunList::setRunTag

(

const RunTag &

tag

)

Definition at line 23 of file MonRunList.cc.

References GlobalPosition_Frontier_DevDB_cff::tag.

Referenced by EcalPedestalHistory::beginRun(), EcalCondDBInterface::fetchMonRunList(), EcalCondDBInterface::fetchMonRunListLastNRuns(), popcon::EcalChannelStatusHandler::getNewObjects(), popcon::EcalPedestalsHandler::getNewObjectsH2(), popcon::EcalPedestalsHandler::getNewObjectsP5(), and EcalTPGDBApp::readFromCondDB_Pedestals().

{
  if (tag != m_runTag) {
    m_runTag = tag;
  }
}

Friends And Related Function Documentation

friend class EcalCondDBInterface

friend

Definition at line 18 of file MonRunList.h.

Member Data Documentation

MonRunTag MonRunList::m_monrunTag

private

Definition at line 40 of file MonRunList.h.

RunTag MonRunList::m_runTag

private

Definition at line 39 of file MonRunList.h.

std::vector<MonRunIOV> MonRunList::m_vec_monruniov

private

Definition at line 38 of file MonRunList.h.