#include <MonRunDat.h>

Inheritance diagram for MonRunDat:

Public Member Functions
MonRunOutcomeDef	getMonRunOutcomeDef () const

int	getNumEvents () const

std::string	getRootfileName () const

std::string	getTable ()

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

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) throw (std::runtime_error)

void	prepareWrite () throw (std::runtime_error)

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

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 () throw (std::runtime_error)

void	createReadStatement () throw (std::runtime_error)

void	setPrefetchRowCount (int ncount) throw (std::runtime_error)

void	terminateReadStatement () throw (std::runtime_error)

void	terminateWriteStatement () throw (std::runtime_error)

Protected Member Functions inherited from IDBObject
void	checkConnection () const throw (std::runtime_error)

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.

References NULL.

 {
   m_env = NULL;
   m_conn = NULL;
   m_writeStmt = NULL;
   m_readStmt = NULL;
 
   m_numEvents = 0;
   m_outcomeDef = MonRunOutcomeDef();
   m_rootfileName = "";
   m_taskList = 0;
   m_taskOutcome = 0;
 }

MonRunDat::~MonRunDat ( )

Definition at line 28 of file MonRunDat.cc.

29 {

30 }

Member Function Documentation

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

private

Definition at line 86 of file MonRunDat.cc.

References dat, alignCSCRings::e, o2o::iov, 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()));
   }
 }

MonRunOutcomeDef MonRunDat::getMonRunOutcomeDef ( ) const

inline

Definition at line 25 of file MonRunDat.h.

References m_outcomeDef.

25 { return m_outcomeDef; }

MonRunDat::m_outcomeDef

MonRunOutcomeDef m_outcomeDef

Definition: MonRunDat.h:48

int MonRunDat::getNumEvents ( ) const

inline

Definition at line 22 of file MonRunDat.h.

References m_numEvents.

22 { return m_numEvents; }

MonRunDat::m_numEvents

int m_numEvents

Definition: MonRunDat.h:47

std::string MonRunDat::getRootfileName ( ) const

inline

Definition at line 28 of file MonRunDat.h.

References m_rootfileName.

28 { return m_rootfileName; }

MonRunDat::m_rootfileName

std::string m_rootfileName

Definition: MonRunDat.h:49

std::string MonRunDat::getTable ( )

inlinevirtual

Implements IDataItem.

Definition at line 19 of file MonRunDat.h.

19 { return "MON_RUN_DAT"; }

int MonRunDat::getTaskList ( ) const

inline

Definition at line 31 of file MonRunDat.h.

References m_taskList.

31 { return m_taskList; }

MonRunDat::m_taskList

int m_taskList

Definition: MonRunDat.h:50

int MonRunDat::getTaskOutcome ( ) const

inline

Definition at line 34 of file MonRunDat.h.

References m_taskOutcome.

34 { return m_taskOutcome; }

MonRunDat::m_taskOutcome

int m_taskOutcome

Definition: MonRunDat.h:51

void MonRunDat::prepareWrite	(		)
throw	(	std::runtime_error
	)

privatevirtual

Implements IDataItem.

Definition at line 34 of file MonRunDat.cc.

References alignCSCRings::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()));
   }
 }

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

24 { m_outcomeDef = outcomeDef; }

MonRunDat::m_outcomeDef

MonRunOutcomeDef m_outcomeDef

Definition: MonRunDat.h:48

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

21 { m_numEvents = num; }

pileupDistInMC.num

tuple num

Definition: pileupDistInMC.py:64

MonRunDat::m_numEvents

int m_numEvents

Definition: MonRunDat.h:47

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

inline

Definition at line 27 of file MonRunDat.h.

References m_rootfileName, and mergeVDriftHistosByStation::name.

Referenced by fetchData().

27 { m_rootfileName = name; }

mergeVDriftHistosByStation.name

string name

Definition: mergeVDriftHistosByStation.py:77

MonRunDat::m_rootfileName

std::string m_rootfileName

Definition: MonRunDat.h:49

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

30 { m_taskList = list; }

MonRunDat::m_taskList

int m_taskList

Definition: MonRunDat.h:50

list

How EventSelector::AcceptEvent() decides whether to accept an event for output otherwise it is excluding the probing of A single or multiple positive and the trigger will pass if any such matching triggers are PASS or EXCEPTION[A criterion thatmatches no triggers at all is detected and causes a throw.] A single negative with an expectation of appropriate bit checking in the decision and the trigger will pass if any such matching triggers are FAIL or EXCEPTION A wildcarded negative criterion that matches more than one trigger in the trigger list("!*","!HLTx*"if it matches 2 triggers or more) will accept the event if all the matching triggers are FAIL.It will reject the event if any of the triggers are PASS or EXCEPTION(this matches the behavior of"!*"before the partial wildcard feature was incorporated).Triggers which are in the READY state are completely ignored.(READY should never be returned since the trigger paths have been run

void MonRunDat::setTaskOutcome ( int outcome )

inline

Definition at line 33 of file MonRunDat.h.

References m_taskOutcome.

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

33 { m_taskOutcome = outcome; }

MonRunDat::m_taskOutcome

int m_taskOutcome

Definition: MonRunDat.h:51

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

private

Definition at line 52 of file MonRunDat.cc.

References alignCSCRings::e, MonRunOutcomeDef::fetchID(), o2o::iov, 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()));
   }
 }