RunIOV Class Reference

#include <RunIOV.h>

Inheritance diagram for RunIOV:

Public Member Functions
int	fetchID () noexcept(false) override
int	fetchIDByRunAndTag () noexcept(false)
Tm	getDBInsertionTime ()
int	getID ()
Tm	getRunEnd () const
run_t	getRunNumber () const
Tm	getRunStart () const
RunTag	getRunTag () const
bool	operator!= (const RunIOV &r) const
bool	operator== (const RunIOV &r) const
	RunIOV ()
void	setByID (int id) noexcept(false) override
void	setDBInsertionTime (const Tm &dbtime)
void	setID (int id)
void	setRunEnd (const Tm &end)
void	setRunNumber (run_t run)
void	setRunStart (const Tm &start)
void	setRunTag (const RunTag &tag)
	~RunIOV () 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	setByRecentData (std::string dataTable, RunTag *tag, run_t run=(unsigned int) -1) noexcept(false)
void	setByRecentData (std::string dataTable, std::string location, run_t run) noexcept(false)
void	setByRun (RunTag *tag, run_t run) noexcept(false)
void	setByRun (std::string location, run_t run) noexcept(false)
void	setByTime (std::string location, const Tm &t) noexcept(false)
int	updateEndTimeDB () noexcept(false)
int	updateStartTimeDB () noexcept(false)
int	writeDB () noexcept(false)

Private Attributes
Tm	m_dbtime
Tm	m_runEnd
run_t	m_runNum
Tm	m_runStart
RunTag	m_runTag

Friends
class	EcalCondDBInterface

Additional Inherited Members
Static Public Attributes inherited from IDBObject
static int const	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 13 of file RunIOV.h.

Constructor & Destructor Documentation

RunIOV()

RunIOV::RunIOV

(

)

Definition at line 12 of file RunIOV.cc.

               {
  m_conn = nullptr;
  m_ID = 0;
  m_runNum = 0;
  m_runStart = Tm();
  m_runEnd = Tm();
}

~RunIOV()

RunIOV::~RunIOV ( )

override

Definition at line 20 of file RunIOV.cc.

{}

Member Function Documentation

fetchID()

int RunIOV::fetchID ( )

overridevirtualnoexcept

Implements IUniqueDBObject.

Definition at line 60 of file RunIOV.cc.

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

                                    {
  // Return from memory if available
  if (m_ID) {
    return m_ID;
  }

  this->checkConnection();

  m_runTag.setConnection(m_env, m_conn);
  int tagID = m_runTag.fetchID();
  if (!tagID) {
    return 0;
  }

  DateHandler dh(m_env, m_conn);

  if (m_runEnd.isNull()) {
    m_runEnd = dh.getPlusInfTm();
  }

  try {
    Statement* stmt = m_conn->createStatement();
    stmt->setSQL(
        "SELECT iov_id FROM run_iov "
        "WHERE tag_id = :tag_id AND "
        "run_num = :run_num AND "
        "run_start = :run_start  ");
    stmt->setInt(1, tagID);
    stmt->setInt(2, m_runNum);
    stmt->setDate(3, dh.tmToDate(m_runStart));

    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("RunIOV::fetchID:  " + e.getMessage()));
  }

  return m_ID;
}

fetchIDByRunAndTag()

int RunIOV::fetchIDByRunAndTag ( )

noexcept

Definition at line 229 of file RunIOV.cc.

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

                                               {
  // Return from memory if available
  if (m_ID) {
    return m_ID;
  }

  this->checkConnection();

  m_runTag.setConnection(m_env, m_conn);
  int tagID = m_runTag.fetchID();
  if (!tagID) {
    return 0;
  }

  DateHandler dh(m_env, m_conn);

  if (m_runEnd.isNull()) {
    m_runEnd = dh.getPlusInfTm();
  }

  try {
    Statement* stmt = m_conn->createStatement();
    stmt->setSQL(
        "SELECT iov_id FROM run_iov "
        "WHERE tag_id = :tag_id AND "
        "run_num = :run_num ");
    stmt->setInt(1, tagID);
    stmt->setInt(2, m_runNum);

    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("RunIOV::fetchID:  " + e.getMessage()));
  }

  return m_ID;
}

getDBInsertionTime()

Tm RunIOV::getDBInsertionTime ( )

inline

Definition at line 32 of file RunIOV.h.

References m_dbtime.

{ return m_dbtime; }

getID()

int RunIOV::getID ( )

inline

Definition at line 35 of file RunIOV.h.

References IUniqueDBObject::m_ID.

Referenced by LMFSeqDat::fetchByRunIOV(), LMFSeqDat::fetchIdSql(), LMFSeqDat::fetchParentIDs(), and LMFSeqDat::writeDBSql().

{ return m_ID; };

getRunEnd()

Tm RunIOV::getRunEnd

(

)

const

Definition at line 49 of file RunIOV.cc.

Referenced by EcalCondDBWriter::dqmEndJob(), and EcalTPGDBApp::printIOV().

{ return m_runEnd; }

getRunNumber()

run_t RunIOV::getRunNumber

(

)

const

Definition at line 31 of file RunIOV.cc.

Referenced by popcon::EcalADCToGeVHandler::getNewObjects(), popcon::EcalDCSHandler::getNewObjects(), EcalTPGDBApp::printIOV(), and EcalErrorMask::readDB().

{ return m_runNum; }

getRunStart()

Tm RunIOV::getRunStart

(

)

const

Definition at line 40 of file RunIOV.cc.

Referenced by EcalCondDBWriter::dqmEndJob(), and EcalTPGDBApp::printIOV().

{ return m_runStart; }

getRunTag()

RunTag RunIOV::getRunTag

(

)

const

Definition at line 58 of file RunIOV.cc.

Referenced by EcalCondDBWriter::dqmEndJob(), EcalCondDBReader::EcalCondDBReader(), EcalTPGDBApp::printIOV(), and EcalPedOffset::writeDb().

{ return m_runTag; }

operator!=()

bool RunIOV::operator!= ( const RunIOV &  r ) const

inline

Definition at line 46 of file RunIOV.h.

References alignCSCRings::r.

{ return !(*this == r); }

operator==()

bool RunIOV::operator== ( const RunIOV &  r ) const

inline

Definition at line 42 of file RunIOV.h.

References m_runEnd, m_runNum, m_runStart, m_runTag, and alignCSCRings::r.

                                                {
    return (m_runNum == r.m_runNum && m_runStart == r.m_runStart && m_runEnd == r.m_runEnd && m_runTag == r.m_runTag);
  }

setByID()

void RunIOV::setByID ( int  id )

overridevirtualnoexcept

Implements IUniqueDBObject.

Definition at line 106 of file RunIOV.cc.

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

Referenced by LMFCorrCoefDat::fetchLastInsertedRun(), LMFSeqDat::fetchParentIDs(), and LMFSeqDat::getParameters().

                                           {
  this->checkConnection();

  DateHandler dh(m_env, m_conn);

  try {
    Statement* stmt = m_conn->createStatement();

    stmt->setSQL("SELECT tag_id, run_num, run_start, run_end FROM run_iov WHERE iov_id = :1");
    stmt->setInt(1, id);

    ResultSet* rset = stmt->executeQuery();
    if (rset->next()) {
      int tagID = rset->getInt(1);
      m_runNum = rset->getInt(2);
      Date startDate = rset->getDate(3);
      Date endDate = rset->getDate(4);

      m_runStart = dh.dateToTm(startDate);
      m_runEnd = dh.dateToTm(endDate);

      m_runTag.setConnection(m_env, m_conn);
      m_runTag.setByID(tagID);
      m_ID = id;
    } else {
      throw(std::runtime_error("RunIOV::setByID:  Given tag_id is not in the database"));
    }

    m_conn->terminateStatement(stmt);
  } catch (SQLException& e) {
    throw(std::runtime_error("RunIOV::setByID:  " + e.getMessage()));
  }
}

setByRecentData() [1/2]

void RunIOV::setByRecentData ( std::string  dataTable, RunTag *  tag, run_t  run = (unsigned int)-1  )

privatenoexcept

Definition at line 429 of file RunIOV.cc.

References cuy::dh, MillePedeFileConverter_cfg::e, writedatasetfile::run, and makeGlobalPositionRcd_cfg::tag.

                                                                                        {
  this->checkConnection();

  tag->setConnection(m_env, m_conn);
  int tagID = tag->fetchID();
  if (!tagID) {
    throw(std::runtime_error("RunIOV::setByRecentData:  Given tag is not in the database"));
  }

  DateHandler dh(m_env, m_conn);

  try {
    Statement* stmt = m_conn->createStatement();

    stmt->setSQL(
        "SELECT * FROM (SELECT riov.iov_id, riov.run_num, riov.run_start, riov.run_end "
        "FROM run_iov riov "
        "JOIN " +
        dataTable +
        " dat on dat.iov_id = riov.iov_id "
        "WHERE tag_id = :1 AND riov.run_num <= :run ORDER BY riov.run_num DESC) WHERE rownum = 1");

    stmt->setInt(1, tagID);
    stmt->setInt(2, run);

    ResultSet* rset = stmt->executeQuery();
    if (rset->next()) {
      m_runTag = *tag;

      m_ID = rset->getInt(1);
      m_runNum = rset->getInt(2);
      Date startDate = rset->getDate(3);
      Date endDate = rset->getDate(4);

      m_runStart = dh.dateToTm(startDate);
      m_runEnd = dh.dateToTm(endDate);
    } else {
      throw(std::runtime_error("RunIOV::setByRecentData:  No data exists for given tag and run"));
    }

    m_conn->terminateStatement(stmt);
  } catch (SQLException& e) {
    throw(std::runtime_error("RunIOV::setByRecentData:  " + e.getMessage()));
  }
}

setByRecentData() [2/2]

void RunIOV::setByRecentData ( std::string  dataTable, std::string  location, run_t  run  )

privatenoexcept

Definition at line 475 of file RunIOV.cc.

References cuy::dh, MillePedeFileConverter_cfg::e, EcalCondDBWriter_cfi::location, and writedatasetfile::run.

                                                                                               {
  this->checkConnection();

  DateHandler dh(m_env, m_conn);

  try {
    Statement* stmt = m_conn->createStatement();

    stmt->setSQL(
        "SELECT * FROM (SELECT riov.iov_id, riov.run_num, riov.run_start, riov.run_end "
        "FROM run_iov riov "
        "JOIN " +
        dataTable +
        " dat on dat.iov_id = riov.iov_id "
        "JOIN run_tag rtag ON riov.tag_id = rtag.tag_id "
        "JOIN location_def loc ON rtag.location_id = loc.def_id "
        "WHERE loc.location = :1 AND riov.run_num <= :2 ORDER BY riov.run_num DESC ) WHERE rownum = 1");

    stmt->setString(1, location);
    stmt->setInt(2, run);

    ResultSet* rset = stmt->executeQuery();

    if (rset->next()) {
      int id = rset->getInt(1);
      this->setByID(id);
    } else {
      throw(std::runtime_error("RunIOV::setByRecentData(datatable, loc, run):  Given run is not in the database"));
    }

    m_conn->terminateStatement(stmt);
  } catch (SQLException& e) {
    throw(std::runtime_error("RunIOV::setByRecentData:  " + e.getMessage()));
  }
}

setByRun() [1/2]

void RunIOV::setByRun ( RunTag *  tag, run_t  run  )

privatenoexcept

Definition at line 314 of file RunIOV.cc.

References cuy::dh, MillePedeFileConverter_cfg::e, writedatasetfile::run, and makeGlobalPositionRcd_cfg::tag.

Referenced by EcalCondDBInterface::fetchRunIOV().

                                                            {
  this->checkConnection();

  tag->setConnection(m_env, m_conn);
  int tagID = tag->fetchID();
  if (!tagID) {
    throw(std::runtime_error("RunIOV::setByRun:  Given tag is not in the database"));
  }

  DateHandler dh(m_env, m_conn);

  try {
    Statement* stmt = m_conn->createStatement();

    stmt->setSQL("SELECT iov_id, run_start, run_end FROM run_iov WHERE tag_id = :1 AND run_num = :2");
    stmt->setInt(1, tagID);
    stmt->setInt(2, run);

    ResultSet* rset = stmt->executeQuery();
    if (rset->next()) {
      m_runTag = *tag;
      m_runNum = run;

      m_ID = rset->getInt(1);
      Date startDate = rset->getDate(2);
      Date endDate = rset->getDate(3);

      m_runStart = dh.dateToTm(startDate);
      m_runEnd = dh.dateToTm(endDate);
    } else {
      throw(std::runtime_error("RunIOV::setByRun:  Given run is not in the database"));
    }

    m_conn->terminateStatement(stmt);
  } catch (SQLException& e) {
    throw(std::runtime_error("RunIOV::setByRun:  " + e.getMessage()));
  }
}

setByRun() [2/2]

void RunIOV::setByRun ( std::string  location, run_t  run  )

privatenoexcept

Definition at line 393 of file RunIOV.cc.

References cuy::dh, MillePedeFileConverter_cfg::e, EcalCondDBWriter_cfi::location, and writedatasetfile::run.

                                                                   {
  this->checkConnection();

  DateHandler dh(m_env, m_conn);

  try {
    Statement* stmt = m_conn->createStatement();

    stmt->setSQL(
        "SELECT iov_id FROM run_iov riov "
        "JOIN run_tag rtag ON riov.tag_id = rtag.tag_id "
        "JOIN location_def loc ON rtag.location_id = loc.def_id "
        "WHERE loc.location = :1 AND riov.run_num = :2 "
        "AND rtag.gen_tag != 'INVALID'");
    stmt->setString(1, location);
    stmt->setInt(2, run);

    ResultSet* rset = stmt->executeQuery();
    if (rset->next()) {
      int id = rset->getInt(1);
      this->setByID(id);
    } else {
      throw(std::runtime_error("RunIOV::setByRun(loc, run):  Given run is not in the database"));
    }

    // Check for uniqueness of run
    if (rset->next()) {
      throw(std::runtime_error("RunIOV::setByRun(loc, run):  Run is nonunique for given location."));
    }

    m_conn->terminateStatement(stmt);
  } catch (SQLException& e) {
    throw(std::runtime_error("RunIOV::setByRun(loc, run):  " + e.getMessage()));
  }
}

setByTime()

void RunIOV::setByTime ( std::string  location, const Tm &  t  )

privatenoexcept

Definition at line 353 of file RunIOV.cc.

References cuy::dh, MillePedeFileConverter_cfg::e, EcalCondDBWriter_cfi::location, and submitPVValidationJobs::t.

Referenced by EcalCondDBInterface::fetchRunIOV().

                                                                      {
  this->checkConnection();

  DateHandler dh(m_env, m_conn);

  try {
    Statement* stmt = m_conn->createStatement();

    stmt->setSQL(
        "SELECT iov_id FROM (SELECT iov_id FROM run_iov riov "
        "JOIN run_tag rtag ON riov.tag_id = rtag.tag_id "
        "JOIN location_def loc ON rtag.location_id = loc.def_id "
        "WHERE loc.location = :1 AND "
        "run_start <= to_date(:2, 'YYYY-MM-DD HH24:MI:SS') AND "
        "run_end >= to_date(:3, 'YYYY-MM-DD HH24:MI:SS') "
        "AND rtag.gen_tag != 'INVALID' ORDER BY iov_id DESC) "
        "where ROWNUM <=1");
    stmt->setString(1, location);
    stmt->setString(2, t.str());
    stmt->setString(3, t.str());

    ResultSet* rset = stmt->executeQuery();
    if (rset->next()) {
      int id = rset->getInt(1);
      this->setByID(id);
    } else {
      throw(std::runtime_error("RunIOV::setByTime(loc, run):  Given run is not in the database"));
    }

    // Check for uniqueness of run
    if (rset->next()) {
      throw(std::runtime_error("RunIOV::setByTime(loc, run):  Run is nonunique for given location."));
    }

    m_conn->terminateStatement(stmt);
  } catch (SQLException& e) {
    throw(std::runtime_error("RunIOV::setByTime(loc, run):  " + e.getMessage()));
  }
}

setDBInsertionTime()

void RunIOV::setDBInsertionTime ( const Tm &  dbtime )

inline

Definition at line 31 of file RunIOV.h.

References m_dbtime.

{ m_dbtime = dbtime; }

setID()

void RunIOV::setID

(

int

id

)

Definition at line 29 of file RunIOV.cc.

References triggerObjects_cff::id.

{ m_ID = id; }

setRunEnd()

void RunIOV::setRunEnd

(

const Tm &

end

)

Definition at line 42 of file RunIOV.cc.

References mps_fire::end.

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

setRunNumber()

void RunIOV::setRunNumber

(

run_t

run

)

Definition at line 22 of file RunIOV.cc.

References writedatasetfile::run.

Referenced by EcalCondDBWriter::dqmEndJob().

                                   {
  if (run != m_runNum) {
    m_ID = 0;
    m_runNum = run;
  }
}

setRunStart()

void RunIOV::setRunStart

(

const Tm &

start

)

Definition at line 33 of file RunIOV.cc.

References command_line::start.

Referenced by EcalCondDBWriter::dqmEndJob().

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

setRunTag()

void RunIOV::setRunTag

(

const RunTag &

tag

)

Definition at line 51 of file RunIOV.cc.

References makeGlobalPositionRcd_cfg::tag.

Referenced by EcalCondDBWriter::dqmEndJob().

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

updateEndTimeDB()

int RunIOV::updateEndTimeDB ( )

privatenoexcept

Definition at line 188 of file RunIOV.cc.

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

                                            {
  this->checkConnection();

  // Check if this IOV has already been written
  if (!this->fetchID()) {
    this->writeDB();
  }

  m_runTag.setConnection(m_env, m_conn);
  //  int tagID = m_runTag.writeDB();

  // Validate the data, use infinity-till convention
  DateHandler dh(m_env, m_conn);

  // we only update the run end here
  if (m_runEnd.isNull()) {
    m_runEnd = dh.getPlusInfTm();
  }

  try {
    Statement* stmt = m_conn->createStatement();

    stmt->setSQL("UPDATE run_iov set run_end=:1 where iov_id=:2 ");
    stmt->setDate(1, dh.tmToDate(m_runEnd));
    stmt->setInt(2, m_ID);

    stmt->executeUpdate();

    m_conn->terminateStatement(stmt);
  } catch (SQLException& e) {
    throw(std::runtime_error("RunIOV::writeDB:  " + e.getMessage()));
  }

  // Now get the ID
  if (!this->fetchID()) {
    throw(std::runtime_error("RunIOV::writeDB:  Failed to write"));
  }

  return m_ID;
}

updateStartTimeDB()

int RunIOV::updateStartTimeDB ( )

privatenoexcept

Definition at line 273 of file RunIOV.cc.

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

                                              {
  this->checkConnection();

  // Check if this IOV has already been written
  if (!this->fetchIDByRunAndTag()) {
    this->writeDB();
  }

  //  m_runTag.setConnection(m_env, m_conn);
  // int tagID = m_runTag.writeDB();

  // Validate the data, use infinity-till convention
  DateHandler dh(m_env, m_conn);

  // we only update the run start here
  if (m_runEnd.isNull()) {
    m_runEnd = dh.getPlusInfTm();
  }

  try {
    Statement* stmt = m_conn->createStatement();

    stmt->setSQL("UPDATE run_iov set run_start=:1 where iov_id=:2 ");
    stmt->setDate(1, dh.tmToDate(m_runStart));
    stmt->setInt(2, m_ID);

    stmt->executeUpdate();

    m_conn->terminateStatement(stmt);
  } catch (SQLException& e) {
    throw(std::runtime_error("RunIOV::writeDB:  " + e.getMessage()));
  }

  // Now get the ID
  if (!this->fetchID()) {
    throw(std::runtime_error("RunIOV::writeDB:  Failed to write"));
  }

  return m_ID;
}

writeDB()

int RunIOV::writeDB ( )

privatenoexcept

Definition at line 140 of file RunIOV.cc.

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

                                    {
  this->checkConnection();

  // Check if this IOV has already been written
  if (this->fetchID()) {
    return m_ID;
  }

  m_runTag.setConnection(m_env, m_conn);
  int tagID = m_runTag.writeDB();

  // Validate the data, use infinity-till convention
  DateHandler dh(m_env, m_conn);

  if (m_runStart.isNull()) {
    throw(std::runtime_error("RunIOV::writeDB:  Must setRunStart before writing"));
  }

  if (m_runEnd.isNull()) {
    m_runEnd = dh.getPlusInfTm();
  }

  try {
    Statement* stmt = m_conn->createStatement();

    stmt->setSQL(
        "INSERT INTO run_iov (iov_id, tag_id, run_num, run_start, run_end) "
        "VALUES (run_iov_sq.NextVal, :1, :2, :3, :4)");
    stmt->setInt(1, tagID);
    stmt->setInt(2, m_runNum);
    stmt->setDate(3, dh.tmToDate(m_runStart));
    stmt->setDate(4, dh.tmToDate(m_runEnd));

    stmt->executeUpdate();

    m_conn->terminateStatement(stmt);
  } catch (SQLException& e) {
    throw(std::runtime_error("RunIOV::writeDB:  " + e.getMessage()));
  }

  // Now get the ID
  if (!this->fetchID()) {
    throw(std::runtime_error("RunIOV::writeDB:  Failed to write"));
  }

  return m_ID;
}

Friends And Related Function Documentation

EcalCondDBInterface

friend class EcalCondDBInterface

friend

Definition at line 15 of file RunIOV.h.

Member Data Documentation

m_dbtime

Tm RunIOV::m_dbtime

private

Definition at line 54 of file RunIOV.h.

Referenced by getDBInsertionTime(), and setDBInsertionTime().

m_runEnd

Tm RunIOV::m_runEnd

private

Definition at line 52 of file RunIOV.h.

Referenced by operator==().

m_runNum

run_t RunIOV::m_runNum

private

Definition at line 50 of file RunIOV.h.

Referenced by operator==().

m_runStart

Tm RunIOV::m_runStart

private

Definition at line 51 of file RunIOV.h.

Referenced by operator==().

m_runTag

RunTag RunIOV::m_runTag

private

Definition at line 53 of file RunIOV.h.

Referenced by operator==().