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::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::~MonRunDat ( )

override

Definition at line 25 of file MonRunDat.cc.

{}

Member Function Documentation

fetchData()

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

privatenoexcept

Definition at line 78 of file MonRunDat.cc.

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

                                                                                              {
  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(rset->getString(1),   // name
                            rset->getInt(2),      // logic_id
                            rset->getInt(3),      // id1
                            rset->getInt(4),      // id2
                            rset->getInt(5),      // id3
                            rset->getString(6));  // maps_to

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

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

getMonRunOutcomeDef()

MonRunOutcomeDef MonRunDat::getMonRunOutcomeDef ( ) const

inline

Definition at line 25 of file MonRunDat.h.

References m_outcomeDef.

{ return m_outcomeDef; }

getNumEvents()

int MonRunDat::getNumEvents ( ) const

inline

Definition at line 22 of file MonRunDat.h.

References m_numEvents.

{ return m_numEvents; }

getRootfileName()

std::string MonRunDat::getRootfileName ( ) const

inline

Definition at line 28 of file MonRunDat.h.

References m_rootfileName.

{ return m_rootfileName; }

getTable()

std::string MonRunDat::getTable ( )

inlineoverridevirtual

Implements IDataItem.

Definition at line 19 of file MonRunDat.h.

{ return "MON_RUN_DAT"; }

getTaskList()

int MonRunDat::getTaskList ( ) const

inline

Definition at line 31 of file MonRunDat.h.

References m_taskList.

{ return m_taskList; }

getTaskOutcome()

int MonRunDat::getTaskOutcome ( ) const

inline

Definition at line 34 of file MonRunDat.h.

References m_taskOutcome.

{ return m_taskOutcome; }

prepareWrite()

void MonRunDat::prepareWrite ( )

overrideprivatevirtualnoexcept

Implements IDataItem.

Definition at line 27 of file MonRunDat.cc.

References MillePedeFileConverter_cfg::e.

                                             {
  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("MonRunDat::prepareWrite():  " + e.getMessage()));
  }
}

setMonRunOutcomeDef()

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; }

setNumEvents()

void MonRunDat::setNumEvents ( int  num )

inline

Definition at line 21 of file MonRunDat.h.

References m_numEvents, and EgammaValidation_cff::num.

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

{ m_numEvents = num; }

setRootfileName()

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

inline

Definition at line 27 of file MonRunDat.h.

References m_rootfileName, and Skims_PA_cff::name.

Referenced by fetchData().

{ m_rootfileName = name; }

setTaskList()

void MonRunDat::setTaskList ( int  list )

inline

Definition at line 30 of file MonRunDat.h.

References m_taskList.

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

{ m_taskList = list; }

setTaskOutcome()

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; }

writeDB()

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

privatenoexcept

Definition at line 42 of file MonRunDat.cc.

References MillePedeFileConverter_cfg::e, MonRunOutcomeDef::fetchID(), B2GTnPMonitor_cfi::item, and IDBObject::setConnection().

                                                                                                      {
  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("MonRunDat::writeDB():  " + e.getMessage()));
  }
}

Friends And Related Function Documentation

EcalCondDBInterface

friend class EcalCondDBInterface

friend

Definition at line 14 of file MonRunDat.h.

Member Data Documentation

m_numEvents

int MonRunDat::m_numEvents

private

Definition at line 44 of file MonRunDat.h.

Referenced by getNumEvents(), and setNumEvents().

m_outcomeDef

MonRunOutcomeDef MonRunDat::m_outcomeDef

private

Definition at line 45 of file MonRunDat.h.

Referenced by getMonRunOutcomeDef(), and setMonRunOutcomeDef().

m_rootfileName

std::string MonRunDat::m_rootfileName

private

Definition at line 46 of file MonRunDat.h.

Referenced by getRootfileName(), and setRootfileName().

m_taskList

int MonRunDat::m_taskList

private

Definition at line 47 of file MonRunDat.h.

Referenced by getTaskList(), and setTaskList().

m_taskOutcome

int MonRunDat::m_taskOutcome

private

Definition at line 48 of file MonRunDat.h.

Referenced by getTaskOutcome(), and setTaskOutcome().