#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 const int	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.

25 {}

Member Function Documentation

◆ fetchData()

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

privatenoexcept

Definition at line 78 of file MonRunDat.cc.

                                                                                               {
   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()));
   }
 }

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

◆ getMonRunOutcomeDef()

MonRunOutcomeDef MonRunDat::getMonRunOutcomeDef ( ) const

inline

Definition at line 25 of file MonRunDat.h.

25 { return m_outcomeDef; }

References m_outcomeDef.

◆ getNumEvents()

int MonRunDat::getNumEvents ( ) const

inline

Definition at line 22 of file MonRunDat.h.

22 { return m_numEvents; }

References m_numEvents.

◆ getRootfileName()

std::string MonRunDat::getRootfileName ( ) const

inline

Definition at line 28 of file MonRunDat.h.

28 { return m_rootfileName; }

References m_rootfileName.

◆ getTable()

std::string MonRunDat::getTable ( )

inlineoverridevirtual

Implements IDataItem.

Definition at line 19 of file MonRunDat.h.

19 { return "MON_RUN_DAT"; }

◆ getTaskList()

int MonRunDat::getTaskList ( ) const

inline

Definition at line 31 of file MonRunDat.h.

31 { return m_taskList; }

References m_taskList.

◆ getTaskOutcome()

int MonRunDat::getTaskOutcome ( ) const

inline

Definition at line 34 of file MonRunDat.h.

34 { return m_taskOutcome; }

References m_taskOutcome.

◆ prepareWrite()

void MonRunDat::prepareWrite ( )

overrideprivatevirtualnoexcept

Implements IDataItem.

Definition at line 27 of file MonRunDat.cc.

                                              {
   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()));
   }
 }

References MillePedeFileConverter_cfg::e.

◆ setMonRunOutcomeDef()

void MonRunDat::setMonRunOutcomeDef ( const MonRunOutcomeDef & outcomeDef )

inline

Definition at line 24 of file MonRunDat.h.

24 { m_outcomeDef = outcomeDef; }

References m_outcomeDef.

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

◆ setNumEvents()

void MonRunDat::setNumEvents ( int num )

inline

Definition at line 21 of file MonRunDat.h.

21 { m_numEvents = num; }

References m_numEvents, and EgammaValidation_cff::num.

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

◆ setRootfileName()

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

inline

Definition at line 27 of file MonRunDat.h.

27 { m_rootfileName = name; }

References m_rootfileName, and Skims_PA_cff::name.

Referenced by fetchData().

◆ setTaskList()

void MonRunDat::setTaskList ( int list )

inline

Definition at line 30 of file MonRunDat.h.

30 { m_taskList = list; }

References list(), and m_taskList.

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

◆ setTaskOutcome()

void MonRunDat::setTaskOutcome ( int outcome )

inline

Definition at line 33 of file MonRunDat.h.

33 { m_taskOutcome = outcome; }

References m_taskOutcome.

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

◆ writeDB()

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

privatenoexcept

Definition at line 42 of file MonRunDat.cc.

                                                                                                       {
   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()));
   }
 }

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

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().

Public Member Functions

Private Member Functions

Private Attributes

Friends

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ MonRunDat()

◆ ~MonRunDat()

Member Function Documentation

◆ fetchData()

◆ getMonRunOutcomeDef()

◆ getNumEvents()

◆ getRootfileName()

◆ getTable()

◆ getTaskList()

◆ getTaskOutcome()

◆ prepareWrite()

◆ setMonRunOutcomeDef()

◆ setNumEvents()

◆ setRootfileName()

◆ setTaskList()

◆ setTaskOutcome()

◆ writeDB()

Friends And Related Function Documentation

◆ EcalCondDBInterface

Member Data Documentation

◆ m_numEvents

◆ m_outcomeDef

◆ m_rootfileName

◆ m_taskList

◆ m_taskOutcome