MonRunDat Class Reference

#include <MonRunDat.h>

Inheritance diagram for MonRunDat:

Public Member Functions
MonRunOutcomeDef	getMonRunOutcomeDef () const
int	getNumEvents () const
std::string	getRootfileName () const
std::string	getTable () override
int	getTaskList () const
int	getTaskOutcome () const
	MonRunDat ()
void	setMonRunOutcomeDef (const MonRunOutcomeDef &outcomeDef)
void	setNumEvents (int num)
void	setRootfileName (std::string name)
void	setTaskList (int list)
void	setTaskOutcome (int outcome)
	~MonRunDat () override
Public Member Functions inherited from IDataItem
	IDataItem ()
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 Member Functions
void	fetchData (std::map< EcalLogicID, MonRunDat > *fillMap, MonRunIOV *iov) noexcept(false)
void	prepareWrite () noexcept(false) override
void	writeDB (const EcalLogicID *ecid, const MonRunDat *item, MonRunIOV *iov) noexcept(false)

Private Attributes
int	m_numEvents
MonRunOutcomeDef	m_outcomeDef
std::string	m_rootfileName
int	m_taskList
int	m_taskOutcome

Friends
class	EcalCondDBInterface

Additional Inherited Members
Static Public Attributes inherited from IDBObject
static int const	ECALDB_NROWS =1024
Protected Member Functions inherited from IDataItem
void	checkPrepare () noexcept(false)
void	createReadStatement () noexcept(false)
void	setPrefetchRowCount (int ncount) noexcept(false)
void	terminateReadStatement () noexcept(false)
void	terminateWriteStatement () noexcept(false)
Protected Member Functions inherited from IDBObject
void	checkConnection () const noexcept(false)
Protected Attributes inherited from IDataItem
oracle::occi::Statement *	m_readStmt
oracle::occi::Statement *	m_writeStmt
Protected Attributes inherited from IDBObject
oracle::occi::Connection *	m_conn
oracle::occi::Environment *	m_env

Detailed Description

Definition at line 12 of file MonRunDat.h.

Constructor & Destructor Documentation

MonRunDat::MonRunDat

(

)

Definition at line 12 of file MonRunDat.cc.

{
  m_env = nullptr;
  m_conn = nullptr;
  m_writeStmt = nullptr;
  m_readStmt = nullptr;

  m_numEvents = 0;
  m_outcomeDef = MonRunOutcomeDef();
  m_rootfileName = "";
  m_taskList = 0;
  m_taskOutcome = 0;
}

MonRunDat::~MonRunDat ( )

override

Definition at line 28 of file MonRunDat.cc.

{
}

Member Function Documentation

void MonRunDat::fetchData ( std::map< EcalLogicID, MonRunDat > *  fillMap, MonRunIOV *  iov  )

privatenoexcept

Definition at line 86 of file MonRunDat.cc.

References MillePedeFileConverter_cfg::e, AlCaHLTBitMon_ParallelJobs::p, MonRunOutcomeDef::setByID(), IDBObject::setConnection(), setMonRunOutcomeDef(), setNumEvents(), setRootfileName(), setTaskList(), setTaskOutcome(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by getTaskOutcome().

{
  this->checkConnection();
  fillMap->clear();

  iov->setConnection(m_env, m_conn);
  int iovID = iov->fetchID();
  if (!iovID) { 
    //  throw(std::runtime_error("MonRunDat::writeDB:  IOV not in DB")); 
    return;
  }

  try {

    m_readStmt->setSQL("SELECT cv.name, cv.logic_id, cv.id1, cv.id2, cv.id3, cv.maps_to, "
         "d.num_events, d.run_outcome_id, d.rootfile_name, d.task_list, d.task_outcome "
         "FROM channelview cv JOIN mon_run_dat d "
         "ON cv.logic_id = d.logic_id AND cv.name = cv.maps_to "
         "WHERE d.iov_id = :iov_id");
    m_readStmt->setInt(1, iovID);
    ResultSet* rset = m_readStmt->executeQuery();
    
    std::pair< EcalLogicID, MonRunDat > p;
    MonRunDat dat;
    MonRunOutcomeDef outcomeDef;
    outcomeDef.setConnection(m_env, m_conn);
    while(rset->next()) {
      p.first = EcalLogicID( getOraString(rset,1),     // name
                 rset->getInt(2),        // logic_id
                 rset->getInt(3),        // id1
                 rset->getInt(4),        // id2
                 rset->getInt(5),        // id3
                 getOraString(rset,6));    // maps_to

      dat.setNumEvents( rset->getInt(7) );
      outcomeDef.setByID( rset->getInt(8) );
      dat.setMonRunOutcomeDef( outcomeDef );
      dat.setRootfileName( getOraString(rset,9) );
      dat.setTaskList( rset->getInt(10) );
      dat.setTaskOutcome( rset->getInt(11) );

      p.second = dat;
      fillMap->insert(p);
    }
  } catch (SQLException &e) {
    throw(std::runtime_error(std::string("MonRunDat::fetchData():  ")+getOraMessage(&e)));
  }
}

MonRunOutcomeDef MonRunDat::getMonRunOutcomeDef ( ) const

inline

Definition at line 25 of file MonRunDat.h.

References m_outcomeDef.

{ return m_outcomeDef; }

int MonRunDat::getNumEvents ( ) const

inline

Definition at line 22 of file MonRunDat.h.

References m_numEvents.

{ return m_numEvents; }

std::string MonRunDat::getRootfileName ( ) const

inline

Definition at line 28 of file MonRunDat.h.

References m_rootfileName.

{ return m_rootfileName; }

std::string MonRunDat::getTable ( )

inlineoverridevirtual

Implements IDataItem.

Definition at line 19 of file MonRunDat.h.

{ return "MON_RUN_DAT"; }

int MonRunDat::getTaskList ( ) const

inline

Definition at line 31 of file MonRunDat.h.

References m_taskList.

{ return m_taskList; }

int MonRunDat::getTaskOutcome ( ) const

inline

Definition at line 34 of file MonRunDat.h.

References fetchData(), m_taskOutcome, noexcept, prepareWrite(), and writeDB().

{ return m_taskOutcome; }

void MonRunDat::prepareWrite ( )

overrideprivatevirtualnoexcept

Implements IDataItem.

Definition at line 34 of file MonRunDat.cc.

References MillePedeFileConverter_cfg::e, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by getTaskOutcome().

{
  this->checkConnection();

  try {
    m_writeStmt = m_conn->createStatement();
    m_writeStmt->setSQL("INSERT INTO mon_run_dat (iov_id, logic_id, "
            "num_events, run_outcome_id, rootfile_name, task_list, task_outcome) "
            "VALUES (:iov_id, :logic_id, "
            ":num_events, :run_outcome_id, :rootfile_name, :task_list, :task_outcome) ");
  } catch (SQLException &e) {
    throw(std::runtime_error(std::string("MonRunDat::prepareWrite():  ")+getOraMessage(&e)));
  }
}

void MonRunDat::setMonRunOutcomeDef ( const MonRunOutcomeDef &  outcomeDef )

inline

Definition at line 24 of file MonRunDat.h.

References m_outcomeDef.

Referenced by fetchData(), and ecaldqm::SummaryWriter::run().

{ m_outcomeDef = outcomeDef; }

void MonRunDat::setNumEvents ( int  num )

inline

Definition at line 21 of file MonRunDat.h.

References m_numEvents, and pileupDistInMC::num.

Referenced by fetchData(), and ecaldqm::SummaryWriter::run().

{ m_numEvents = num; }

void MonRunDat::setRootfileName ( std::string  name )

inline

Definition at line 27 of file MonRunDat.h.

References m_rootfileName, and dataset::name.

Referenced by fetchData().

{ m_rootfileName = name; }

void MonRunDat::setTaskList ( int  list )

inline

Definition at line 30 of file MonRunDat.h.

References list(), and m_taskList.

Referenced by fetchData(), and ecaldqm::SummaryWriter::run().

{ m_taskList = list; }

void MonRunDat::setTaskOutcome ( int  outcome )

inline

Definition at line 33 of file MonRunDat.h.

References m_taskOutcome.

Referenced by fetchData(), and ecaldqm::SummaryWriter::run().

{ m_taskOutcome = outcome; }

void MonRunDat::writeDB ( const EcalLogicID *  ecid, const MonRunDat *  item, MonRunIOV *  iov  )

privatenoexcept

Definition at line 52 of file MonRunDat.cc.

References MillePedeFileConverter_cfg::e, MonRunOutcomeDef::fetchID(), IDBObject::setConnection(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by getTaskOutcome().

{
  this->checkConnection();
  this->checkPrepare();

  int iovID = iov->fetchID();
  if (!iovID) { throw(std::runtime_error("MonRunDat::writeDB:  IOV not in DB")); }

  MonRunOutcomeDef monRunOutcomeDef = item->getMonRunOutcomeDef(); // XXX object copy every row!
  monRunOutcomeDef.setConnection(m_env, m_conn);
  int outcomeID = monRunOutcomeDef.fetchID();
  if (!outcomeID) { throw(std::runtime_error("MonRunDat::writeDB:  Outcome Definition not in DB")); }

  int logicID = ecid->getLogicID();
  if (!logicID) { throw(std::runtime_error("MonRunDat::writeDB:  Bad EcalLogicID")); }
  
  try {
    m_writeStmt->setInt(1, iovID);
    m_writeStmt->setInt(2, logicID);
    m_writeStmt->setInt(3, item->getNumEvents());
    m_writeStmt->setInt(4, outcomeID);
    m_writeStmt->setString(5, item->getRootfileName());
    m_writeStmt->setInt(6, item->getTaskList());
    m_writeStmt->setInt(7, item->getTaskOutcome());

    m_writeStmt->executeUpdate();
  } catch (SQLException &e) {
    throw(std::runtime_error(std::string("MonRunDat::writeDB():  ")+getOraMessage(&e)));
  }
}

Friends And Related Function Documentation

friend class EcalCondDBInterface

friend

Definition at line 14 of file MonRunDat.h.

Member Data Documentation

int MonRunDat::m_numEvents

private

Definition at line 47 of file MonRunDat.h.

Referenced by getNumEvents(), and setNumEvents().

MonRunOutcomeDef MonRunDat::m_outcomeDef

private

Definition at line 48 of file MonRunDat.h.

Referenced by getMonRunOutcomeDef(), and setMonRunOutcomeDef().

std::string MonRunDat::m_rootfileName

private

Definition at line 49 of file MonRunDat.h.

Referenced by getRootfileName(), and setRootfileName().

int MonRunDat::m_taskList

private

Definition at line 50 of file MonRunDat.h.

Referenced by getTaskList(), and setTaskList().

int MonRunDat::m_taskOutcome

private

Definition at line 51 of file MonRunDat.h.

Referenced by getTaskOutcome(), and setTaskOutcome().