#include <MonRunIOV.h>

Inheritance diagram for MonRunIOV:

Public Member Functions
int	fetchID () noexcept(false) override

int	getID ()

MonRunTag	getMonRunTag () const

RunIOV	getRunIOV ()

Tm	getSubRunEnd () const

run_t	getSubRunNumber () const

Tm	getSubRunStart () const

	MonRunIOV ()

bool	operator!= (const MonRunIOV &m) const

bool	operator== (const MonRunIOV &m) const

void	setByID (int id) noexcept(false) override

void	setID (int id)

void	setMonRunTag (const MonRunTag &tag)

void	setRunIOV (const RunIOV &iov)

void	setSubRunEnd (const Tm &end)

void	setSubRunNumber (subrun_t subrun)

void	setSubRunStart (const Tm &start)

	~MonRunIOV () 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 Member Functions
void	fetchParentIDs (int monRunTagID, int runIOVID) noexcept(false)

void	setByRun (MonRunTag montag, RunIOV runiov, subrun_t subrun) noexcept(false)

int	writeDB () noexcept(false)

Private Attributes
MonRunTag	m_monRunTag

RunIOV	m_runIOV

Tm	m_subRunEnd

subrun_t	m_subRunNum

Tm	m_subRunStart

Friends
class	EcalCondDBInterface

Additional Inherited Members
Static Public Attributes inherited from IDBObject
static const int	ECALDB_NROWS = 1024

Protected Member Functions inherited from IDBObject
void	checkConnection () const noexcept(false)

Protected Attributes inherited from IUniqueDBObject
int	m_ID

Protected Attributes inherited from IDBObject
oracle::occi::Connection *	m_conn

oracle::occi::Environment *	m_env

Detailed Description

Definition at line 14 of file MonRunIOV.h.

Constructor & Destructor Documentation

◆ MonRunIOV()

MonRunIOV::MonRunIOV ( )

Definition at line 13 of file MonRunIOV.cc.

                      {
   m_conn = nullptr;
   m_ID = 0;
   m_monRunTag = MonRunTag();
   m_runIOV = RunIOV();
   m_subRunNum = 0;
   m_subRunStart = Tm();
   m_subRunEnd = Tm();
 }

◆ ~MonRunIOV()

MonRunIOV::~MonRunIOV ( )

override

Definition at line 23 of file MonRunIOV.cc.

23 {}

Member Function Documentation

◆ fetchID()

int MonRunIOV::fetchID ( )

overridevirtualnoexcept

Implements IUniqueDBObject.

Definition at line 72 of file MonRunIOV.cc.

                                        {
   // Return from memory if available
   if (m_ID) {
     return m_ID;
   }
  
   this->checkConnection();
  
   // fetch the parent IDs
   int monRunTagID, runIOVID;
   this->fetchParentIDs(&monRunTagID, &runIOVID);
  
   if (!monRunTagID || !runIOVID) {
     return 0;
   }
  
   DateHandler dh(m_env, m_conn);
  
   if (m_subRunEnd.isNull()) {
     m_subRunEnd = dh.getPlusInfTm();
   }
  
   try {
     Statement* stmt = m_conn->createStatement();
     stmt->setSQL(
         "SELECT iov_id FROM mon_run_iov "
         "WHERE tag_id = :1 AND "
         "run_iov_id   = :2 AND "
         "subrun_num   = :3 AND "
         "subrun_start = :4 AND "
         "subrun_end   = :5");
     stmt->setInt(1, monRunTagID);
     stmt->setInt(2, runIOVID);
     stmt->setInt(3, m_subRunNum);
     stmt->setDate(4, dh.tmToDate(m_subRunStart));
     stmt->setDate(5, dh.tmToDate(m_subRunEnd));
  
     ResultSet* rset = stmt->executeQuery();
  
     if (rset->next()) {
       m_ID = rset->getInt(1);
     } else {
       m_ID = 0;
     }
     m_conn->terminateStatement(stmt);
   } catch (SQLException& e) {
     throw(std::runtime_error("MonRunIOV::fetchID:  " + e.getMessage()));
   }
  
   return m_ID;
 }

References cuy::dh, and MillePedeFileConverter_cfg::e.

◆ fetchParentIDs()

void MonRunIOV::fetchParentIDs	(	int *	monRunTagID,
		int *	runIOVID
	)

privatenoexcept

Definition at line 217 of file MonRunIOV.cc.

                                                                               {
   // get the MonRunTag
   m_monRunTag.setConnection(m_env, m_conn);
   *monRunTagID = m_monRunTag.fetchID();
  
   // get the RunIOV
   m_runIOV.setConnection(m_env, m_conn);
   *runIOVID = m_runIOV.fetchID();
  
   if (!*runIOVID) {
     throw(std::runtime_error("MonRunIOV:  Given RunIOV does not exist in DB"));
   }
 }

◆ getID()

int MonRunIOV::getID ( )

inline

Definition at line 22 of file MonRunIOV.h.

22 { return m_ID; };

References IUniqueDBObject::m_ID.

◆ getMonRunTag()

MonRunTag MonRunIOV::getMonRunTag ( ) const

Definition at line 34 of file MonRunIOV.cc.

34 { return m_monRunTag; }

◆ getRunIOV()

RunIOV MonRunIOV::getRunIOV ( )

Definition at line 43 of file MonRunIOV.cc.

43 { return m_runIOV; }

◆ getSubRunEnd()

Tm MonRunIOV::getSubRunEnd ( ) const

Definition at line 70 of file MonRunIOV.cc.

70 { return m_subRunEnd; }

◆ getSubRunNumber()

run_t MonRunIOV::getSubRunNumber ( ) const

Definition at line 52 of file MonRunIOV.cc.

52 { return m_subRunNum; }

◆ getSubRunStart()

Tm MonRunIOV::getSubRunStart ( ) const

Definition at line 61 of file MonRunIOV.cc.

61 { return m_subRunStart; }

◆ operator!=()

bool MonRunIOV::operator!= ( const MonRunIOV & m ) const

inline

Definition at line 46 of file MonRunIOV.h.

46 { return !(*this == m); }

References visualization-live-secondInstance_cfg::m.

◆ operator==()

bool MonRunIOV::operator== ( const MonRunIOV & m ) const

inline

Definition at line 41 of file MonRunIOV.h.

                                                    {
     return (m_monRunTag == m.m_monRunTag && m_runIOV == m.m_runIOV && m_subRunNum == m.m_subRunNum &&
             m_subRunStart == m.m_subRunStart && m_subRunEnd == m.m_subRunEnd);
   }

References visualization-live-secondInstance_cfg::m, m_monRunTag, m_runIOV, m_subRunEnd, m_subRunNum, and m_subRunStart.

◆ setByID()

void MonRunIOV::setByID ( int id )

overridevirtualnoexcept

Implements IUniqueDBObject.

Definition at line 124 of file MonRunIOV.cc.

                                               {
   this->checkConnection();
  
   DateHandler dh(m_env, m_conn);
  
   try {
     Statement* stmt = m_conn->createStatement();
  
     stmt->setSQL("SELECT tag_id, run_iov_id, subrun_num, subrun_start, subrun_end FROM mon_run_iov WHERE iov_id = :1");
     stmt->setInt(1, id);
  
     ResultSet* rset = stmt->executeQuery();
     if (rset->next()) {
       int monRunTagID = rset->getInt(1);
       int runIOVID = rset->getInt(2);
       m_subRunNum = rset->getInt(3);
       Date startDate = rset->getDate(4);
       Date endDate = rset->getDate(5);
  
       m_subRunStart = dh.dateToTm(startDate);
       m_subRunEnd = dh.dateToTm(endDate);
  
       m_monRunTag.setConnection(m_env, m_conn);
       m_monRunTag.setByID(monRunTagID);
  
       m_runIOV.setConnection(m_env, m_conn);
       m_runIOV.setByID(runIOVID);
  
       m_ID = id;
     } else {
       throw(std::runtime_error("MonRunIOV::setByID:  Given tag_id is not in the database"));
     }
  
     m_conn->terminateStatement(stmt);
   } catch (SQLException& e) {
     throw(std::runtime_error("MonRunIOV::setByID:  " + e.getMessage()));
   }
 }

References cuy::dh, MillePedeFileConverter_cfg::e, and triggerObjects_cff::id.

◆ setByRun()

void MonRunIOV::setByRun	(	MonRunTag *	montag,
		RunIOV *	runiov,
		subrun_t	subrun
	)

privatenoexcept

Definition at line 231 of file MonRunIOV.cc.

                                                                                            {
   this->checkConnection();
  
   runiov->setConnection(m_env, m_conn);
   int runIOVID = runiov->fetchID();
  
   if (!runIOVID) {
     throw(std::runtime_error("MonRunIOV::setByRun:  Given RunIOV does not exist in DB"));
   }
  
   montag->setConnection(m_env, m_conn);
   int monTagID = montag->fetchID();
  
   if (!monTagID) {
     throw(std::runtime_error("MonRunIOV::setByRun:  Given MonRunTag does not exist in the DB"));
   }
  
   DateHandler dh(m_env, m_conn);
  
   try {
     Statement* stmt = m_conn->createStatement();
  
     stmt->setSQL(
         "SELECT iov_id, subrun_start, subrun_end FROM mon_run_iov "
         "WHERE tag_id = :1 AND run_iov_id = :2 AND subrun_num = :3");
     stmt->setInt(1, monTagID);
     stmt->setInt(2, runIOVID);
     stmt->setInt(3, subrun);
  
     ResultSet* rset = stmt->executeQuery();
     if (rset->next()) {
       m_monRunTag = *montag;
       m_runIOV = *runiov;
       m_subRunNum = subrun;
  
       m_ID = rset->getInt(1);
       Date startDate = rset->getDate(2);
       Date endDate = rset->getDate(3);
  
       m_subRunStart = dh.dateToTm(startDate);
       m_subRunEnd = dh.dateToTm(endDate);
     } else {
       throw(std::runtime_error("MonRunIOV::setByRun:  Given subrun is not in the database"));
     }
  
     m_conn->terminateStatement(stmt);
   } catch (SQLException& e) {
     throw(std::runtime_error("MonRunIOV::setByRun:  " + e.getMessage()));
   }
 }

References cuy::dh, and MillePedeFileConverter_cfg::e.

Referenced by EcalCondDBInterface::fetchMonRunIOV().

◆ setID()

void MonRunIOV::setID ( int id )

Definition at line 25 of file MonRunIOV.cc.

25 { m_ID = id; }

References triggerObjects_cff::id.

Referenced by MonRunList::fetchLastNRuns(), and MonRunList::fetchRuns().

◆ setMonRunTag()

void MonRunIOV::setMonRunTag ( const MonRunTag & tag )

Definition at line 27 of file MonRunIOV.cc.

                                                  {
   if (tag != m_monRunTag) {
     m_ID = 0;
     m_monRunTag = tag;
   }
 }

References makeGlobalPositionRcd_cfg::tag.

Referenced by EcalCondDBWriter::dqmEndJob(), MonRunList::fetchLastNRuns(), MonRunList::fetchRuns(), and EcalPedOffset::writeDb().

◆ setRunIOV()

void MonRunIOV::setRunIOV ( const RunIOV & iov )

Definition at line 36 of file MonRunIOV.cc.

                                            {
   if (iov != m_runIOV) {
     m_ID = 0;
     m_runIOV = iov;
   }
 }

Referenced by EcalCondDBWriter::dqmEndJob(), MonRunList::fetchLastNRuns(), MonRunList::fetchRuns(), and EcalPedOffset::writeDb().

◆ setSubRunEnd()

void MonRunIOV::setSubRunEnd ( const Tm & end )

Definition at line 63 of file MonRunIOV.cc.

                                           {
   if (end != m_subRunEnd) {
     m_ID = 0;
     m_subRunEnd = end;
   }
 }

References mps_fire::end.

Referenced by EcalCondDBWriter::dqmEndJob(), MonRunList::fetchLastNRuns(), and MonRunList::fetchRuns().

◆ setSubRunNumber()

void MonRunIOV::setSubRunNumber ( subrun_t subrun )

Definition at line 45 of file MonRunIOV.cc.

                                                {
   if (subrun != m_subRunNum) {
     m_ID = 0;
     m_subRunNum = subrun;
   }
 }

Referenced by EcalCondDBWriter::dqmEndJob(), MonRunList::fetchLastNRuns(), MonRunList::fetchRuns(), and EcalPedOffset::writeDb().

◆ setSubRunStart()

void MonRunIOV::setSubRunStart ( const Tm & start )

Definition at line 54 of file MonRunIOV.cc.

                                               {
   if (start != m_subRunStart) {
     m_ID = 0;
     m_subRunStart = start;
   }
 }

References command_line::start.

Referenced by EcalCondDBWriter::dqmEndJob(), MonRunList::fetchLastNRuns(), MonRunList::fetchRuns(), and EcalPedOffset::writeDb().

◆ writeDB()

int MonRunIOV::writeDB ( )

privatenoexcept

Definition at line 163 of file MonRunIOV.cc.

                                        {
   this->checkConnection();
  
   // Check if this IOV has already been written
   if (this->fetchID()) {
     return m_ID;
   }
  
   // fetch Parent IDs
   int monRunTagID, runIOVID;
   this->fetchParentIDs(&monRunTagID, &runIOVID);
  
   if (!monRunTagID) {
     monRunTagID = m_monRunTag.writeDB();
   }
  
   // Validate the data, use infinity-till convention
   DateHandler dh(m_env, m_conn);
  
   if (m_subRunStart.isNull()) {
     throw(std::runtime_error("MonRunIOV::writeDB:  Must setSubRunStart before writing"));
   }
  
   if (m_subRunEnd.isNull()) {
     m_subRunEnd = dh.getPlusInfTm();
   }
  
   try {
     Statement* stmt = m_conn->createStatement();
  
     stmt->setSQL(
         "INSERT INTO mon_run_iov (iov_id, tag_id, run_iov_id, subrun_num, subrun_start, subrun_end) "
         "VALUES (mon_run_iov_sq.NextVal, :1, :2, :3, :4, :5)");
     stmt->setInt(1, monRunTagID);
     stmt->setInt(2, runIOVID);
     stmt->setInt(3, m_subRunNum);
     stmt->setDate(4, dh.tmToDate(m_subRunStart));
     stmt->setDate(5, dh.tmToDate(m_subRunEnd));
  
     stmt->executeUpdate();
  
     m_conn->terminateStatement(stmt);
   } catch (SQLException& e) {
     throw(std::runtime_error("MonRunIOV::writeDB:  " + e.getMessage()));
   }
  
   // Now get the ID
   if (!this->fetchID()) {
     throw(std::runtime_error("MonRunIOV::writeDB:  Failed to write"));
   }
  
   return m_ID;
 }

References cuy::dh, and MillePedeFileConverter_cfg::e.

Friends And Related Function Documentation

◆ EcalCondDBInterface

friend class EcalCondDBInterface

friend

Definition at line 16 of file MonRunIOV.h.

Member Data Documentation

◆ m_monRunTag

MonRunTag MonRunIOV::m_monRunTag

private

Definition at line 50 of file MonRunIOV.h.

Referenced by operator==().

◆ m_runIOV

RunIOV MonRunIOV::m_runIOV

private

Definition at line 51 of file MonRunIOV.h.

Referenced by operator==().

◆ m_subRunEnd

Tm MonRunIOV::m_subRunEnd

private

Definition at line 54 of file MonRunIOV.h.

Referenced by operator==().

◆ m_subRunNum

subrun_t MonRunIOV::m_subRunNum

private

Definition at line 52 of file MonRunIOV.h.

Referenced by operator==().

◆ m_subRunStart

Tm MonRunIOV::m_subRunStart

private

Definition at line 53 of file MonRunIOV.h.

Referenced by operator==().

Public Member Functions

Private Member Functions

Private Attributes

Friends

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ MonRunIOV()

◆ ~MonRunIOV()

Member Function Documentation

◆ fetchID()

◆ fetchParentIDs()

◆ getID()

◆ getMonRunTag()

◆ getRunIOV()

◆ getSubRunEnd()

◆ getSubRunNumber()

◆ getSubRunStart()

◆ operator!=()

◆ operator==()

◆ setByID()

◆ setByRun()

◆ setID()

◆ setMonRunTag()

◆ setRunIOV()

◆ setSubRunEnd()

◆ setSubRunNumber()

◆ setSubRunStart()

◆ writeDB()

Friends And Related Function Documentation

◆ EcalCondDBInterface

Member Data Documentation

◆ m_monRunTag

◆ m_runIOV

◆ m_subRunEnd

◆ m_subRunNum

◆ m_subRunStart