RunList Class Reference

#include <RunList.h>

Inheritance diagram for RunList:

Public Member Functions
void	fetchGlobalRunsByLocation (int min_run, int max_run, const LocationDef &locDef) throw (std::runtime_error)
void	fetchLastNRuns (int max_run, int n_runs) throw (std::runtime_error)
void	fetchNonEmptyGlobalRuns () throw (std::runtime_error)
void	fetchNonEmptyGlobalRuns (int min_run, int max_run) throw (std::runtime_error)
void	fetchNonEmptyRuns () throw (std::runtime_error)
void	fetchNonEmptyRuns (int min_run, int max_run) throw (std::runtime_error)
void	fetchRuns () throw (std::runtime_error)
void	fetchRuns (int min_run, int max_run) throw (std::runtime_error)
void	fetchRuns (int min_run, int max_run, bool withTriggers, bool withGlobalTriggers) throw (std::runtime_error)
void	fetchRunsByLocation (int min_run, int max_run, const LocationDef &locDef) throw (std::runtime_error)
std::vector< RunIOV >	getRuns ()
RunTag	getRunTag () const
	RunList ()
void	setRunTag (const RunTag &tag)
	~RunList ()
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 Attributes
RunTag	m_runTag
std::vector< RunIOV >	m_vec_runiov

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 throw (std::runtime_error)
Protected Attributes inherited from IDBObject
oracle::occi::Connection *	m_conn
oracle::occi::Environment *	m_env

Detailed Description

Definition at line 16 of file RunList.h.

Constructor & Destructor Documentation

RunList::RunList

(

)

Definition at line 13 of file RunList.cc.

References NULL.

{
  m_conn = NULL;
}

RunList::~RunList

(

)

Definition at line 18 of file RunList.cc.

{
}

Member Function Documentation

void RunList::fetchGlobalRunsByLocation	(	int	min_run,
		int	max_run,
		const LocationDef &	locDef
	)
throw	(	std::runtime_error
	)

Definition at line 354 of file RunList.cc.

References getBeamSpotDB::atag, gather_cfg::cout, DateHandler::dateToTm(), cuy::dh, alignCSCRings::e, i, alignCSCRings::r, RunIOV::setDBInsertionTime(), RunTag::setGeneralTag(), RunIOV::setID(), RunTag::setLocationDef(), RunIOV::setRunEnd(), RunIOV::setRunNumber(), RunIOV::setRunStart(), RunIOV::setRunTag(), RunTypeDef::setRunType(), and RunTag::setRunTypeDef().

Referenced by EcalCondDBInterface::fetchGlobalRunListByLocation().

{

  this->checkConnection();
  int nruns=0;

  int my_min_run=min_run-1;
  int my_max_run=max_run+1;
  try {
    Statement* stmt0 = m_conn->createStatement();
    stmt0->setSQL("SELECT count(iov_id) FROM run_iov r , run_tag t, location_def l "
                 " WHERE r.tag_id=t.tag_id and t.LOCATION_ID=l.def_id AND l.LOCATION= :1 " 
          "  and t.gen_tag='GLOBAL' "
          "  and r.run_num> :2 and r.run_num< :3 ");
    stmt0->setString(1,locDef.getLocation() );
    stmt0->setInt(2, my_min_run);
    stmt0->setInt(3, my_max_run);
  
    ResultSet* rset0 = stmt0->executeQuery();
    if (rset0->next()) {
      nruns = rset0->getInt(1);
    }
    m_conn->terminateStatement(stmt0);

    cout <<"number of runs="<< nruns << endl;
    
    m_vec_runiov.reserve(nruns);
    
    Statement* stmt = m_conn->createStatement();
    stmt->setSQL("SELECT  r.iov_id, r.tag_id, r.run_num, r.run_start, r.run_end, r.DB_TIMESTAMP , "
                 " t.gen_tag, rt.RUN_TYPE "
         " FROM run_iov r , run_tag t, location_def l, run_type_def rt "
         " WHERE r.tag_id=t.tag_id and t.LOCATION_ID=l.def_id and t.run_type_id=rt.DEF_ID "
         " AND l.LOCATION= :1 "
         " and t.gen_tag='GLOBAL' "
         " and r.run_num> :2 and r.run_num< :3 "
         " order by run_num " );
    stmt->setString(1,locDef.getLocation() );
    stmt->setInt(2, my_min_run);
    stmt->setInt(3, my_max_run);

    DateHandler dh(m_env, m_conn);
    Tm runStart;
    Tm runEnd;
    Tm dbtime;
  
    ResultSet* rset = stmt->executeQuery();
    int i=0;
    while (i<nruns) {
      rset->next();
      int iovID = rset->getInt(1);
      //       int tagID = rset->getInt(2);
       int runNum = rset->getInt(3);
       Date startDate = rset->getDate(4);
       Date endDate = rset->getDate(5);
       Date dbDate = rset->getDate(6);
     
       runStart = dh.dateToTm( startDate );
       runEnd = dh.dateToTm( endDate );
       dbtime = dh.dateToTm( dbDate );
       
       RunTag atag;
       atag.setLocationDef(locDef);
       atag.setGeneralTag(rset->getString(7));
       RunTypeDef rundef;
       rundef.setRunType(rset->getString(8));
       atag.setRunTypeDef(rundef);

       RunIOV r ;
       r.setRunNumber(runNum);
       r.setRunStart(runStart);
       r.setRunEnd(runEnd);
       r.setDBInsertionTime(dbtime);
       r.setRunTag(atag);
       r.setID(iovID);
       m_vec_runiov.push_back(r);
      
      i++;
    }
   

    m_conn->terminateStatement(stmt);

  } catch (SQLException &e) {
    throw(std::runtime_error("RunList::fetchRunsByLocation:  "+e.getMessage()));
  }


}

void RunList::fetchLastNRuns	(	int	max_run,
		int	n_runs
	)
throw	(	std::runtime_error
	)

Definition at line 191 of file RunList.cc.

References gather_cfg::cout, DateHandler::dateToTm(), cuy::dh, alignCSCRings::e, i, alignCSCRings::r, mathSSE::return(), RunIOV::setDBInsertionTime(), RunIOV::setID(), RunIOV::setRunEnd(), RunIOV::setRunNumber(), RunIOV::setRunStart(), and RunIOV::setRunTag().

Referenced by EcalCondDBInterface::fetchRunListLastNRuns().

{

  // fetch the last n_runs that come just before max_run (including max_run)

  this->checkConnection();


  m_runTag.setConnection(m_env, m_conn);
  int tagID = m_runTag.fetchID();
  cout <<"tag id="<< tagID << endl;
  if (!tagID) { 
    return ;
  }

  int my_max_run=max_run+1;
  try {

    int nruns=n_runs+1;
    m_vec_runiov.reserve(nruns);
    
    Statement* stmt = m_conn->createStatement();
    stmt->setSQL("select iov_id, tag_id, run_num, run_start, run_end, DB_TIMESTAMP from "
         " (SELECT * from RUN_IOV "
         " WHERE tag_id = :tag_id "
         " and run_num< :max_run "
         " order by run_num DESC ) where rownum< :n_runs ORDER BY run_num ASC " );
    stmt->setInt(1, tagID);
    stmt->setInt(2, my_max_run);
    stmt->setInt(3, nruns);

    DateHandler dh(m_env, m_conn);
    Tm runStart;
    Tm runEnd;
    Tm dbtime;
  
    ResultSet* rset = stmt->executeQuery();
    int i=0;
    while (i<n_runs) {
      rset->next();
      int iovID = rset->getInt(1);
      // int tagID = rset->getInt(2);
       int runNum = rset->getInt(3);
       Date startDate = rset->getDate(4);
       Date endDate = rset->getDate(5);
       Date dbDate = rset->getDate(6);
     
       runStart = dh.dateToTm( startDate );
       runEnd = dh.dateToTm( endDate );
       dbtime = dh.dateToTm( dbDate );
       
       RunIOV r ;
       r.setRunNumber(runNum);
       r.setRunStart(runStart);
       r.setRunEnd(runEnd);
       r.setDBInsertionTime(dbtime);
       r.setRunTag(m_runTag);
       r.setID(iovID);
       m_vec_runiov.push_back(r);
      
      i++;
    }

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


}

void RunList::fetchNonEmptyGlobalRuns	(		)
throw	(	std::runtime_error
	)

Definition at line 46 of file RunList.cc.

Referenced by EcalCondDBInterface::fetchNonEmptyGlobalRunList().

{
  fetchRuns(-1, -1, false, true); 
}

void RunList::fetchNonEmptyGlobalRuns	(	int	min_run,
		int	max_run
	)
throw	(	std::runtime_error
	)

Definition at line 58 of file RunList.cc.

{
  fetchRuns(min_run, max_run, false, true); 
}

void RunList::fetchNonEmptyRuns	(		)
throw	(	std::runtime_error
	)

Definition at line 40 of file RunList.cc.

Referenced by EcalCondDBInterface::fetchNonEmptyRunList().

{
  fetchRuns(-1, -1, true, false); 
}

void RunList::fetchNonEmptyRuns	(	int	min_run,
		int	max_run
	)
throw	(	std::runtime_error
	)

Definition at line 52 of file RunList.cc.

{
  fetchRuns(min_run, max_run, true, false); 
}

void RunList::fetchRuns	(		)
throw	(	std::runtime_error
	)

Definition at line 64 of file RunList.cc.

Referenced by EcalCondDBInterface::fetchRunList().

{
  fetchRuns(-1, -1);
}

void RunList::fetchRuns	(	int	min_run,
		int	max_run
	)
throw	(	std::runtime_error
	)

Definition at line 70 of file RunList.cc.

{
  fetchRuns(min_run, max_run, false, false);
}

void RunList::fetchRuns	(	int	min_run,
		int	max_run,
		bool	withTriggers,
		bool	withGlobalTriggers
	)
throw	(	std::runtime_error
	)

Definition at line 76 of file RunList.cc.

References gather_cfg::cout, DateHandler::dateToTm(), cuy::dh, alignCSCRings::e, i, alignCSCRings::r, mathSSE::return(), RunIOV::setDBInsertionTime(), RunIOV::setID(), RunIOV::setRunEnd(), RunIOV::setRunNumber(), RunIOV::setRunStart(), and RunIOV::setRunTag().

{

  /*
    withTriggers and withGlobalTriggers selects those non empty runs.
    Possible combinations are

    withTriggers withGlobalTriggers select
    ------------ ------------------ ------------------------------
    false        false              all
    false        true               only runs with global triggers
    true         false              only runs with any trigger
    true         true               only runs with global triggers
   */
  this->checkConnection();
  int nruns=0;

  m_runTag.setConnection(m_env, m_conn);
  int tagID = m_runTag.fetchID();
  cout <<"tag id="<< tagID << endl;
  if (!tagID) { 
    return ;
  }

  int my_min_run=min_run-1;
  int my_max_run=max_run+1;
  try {
    Statement* stmt0 = m_conn->createStatement();
    string sql =  "SELECT count(iov_id) FROM run_iov "
      "WHERE tag_id = :tag_id ";
    if (min_run > 0) {
      // don't need to specify empty/non empty here. This is needed
      // just to allocate the memory for the vector
      sql += " and run_iov.run_num> :min_run and run_iov.run_num< :max_run ";
    }
    stmt0->setSQL(sql);
    stmt0->setInt(1, tagID);
    if (min_run > 0) {
      stmt0->setInt(2, my_min_run);
      stmt0->setInt(3, my_max_run);
    }
    
    ResultSet* rset0 = stmt0->executeQuery();
    if (rset0->next()) {
      nruns = rset0->getInt(1);
    }
    m_conn->terminateStatement(stmt0);

    cout <<"number of runs="<< nruns << endl;
    m_vec_runiov.reserve(nruns);
    
    Statement* stmt = m_conn->createStatement();
    sql = "SELECT DISTINCT i.iov_id, tag_id, run_num, run_start, run_end, " 
      "db_timestamp FROM run_iov i ";
    if ((withTriggers) || (withGlobalTriggers)) {
      sql += "join cms_ecal_cond.run_dat d on d.iov_id = i.iov_id " 
    "left join CMS_RUNINFO.RUNSESSION_PARAMETER G on " 
    "(i.run_num = G.RUNNUMBER and G.NAME = 'CMS.TRG:NumTriggers') "; 
    }
    sql +=  "WHERE tag_id = :tag_id ";
    if (min_run > 0) {
      sql += "and i.run_num> :min_run and i.run_num< :max_run ";
    }
    if (withGlobalTriggers) {
      sql += "and G.STRING_VALUE != '0' "; 
    } else if (withTriggers) {
      sql += "and (G.STRING_VALUE != '0' or num_events > 0) ";
    }
    sql += " order by run_num ";
    stmt->setSQL(sql);
    stmt->setInt(1, tagID);
    if (min_run > 0) {
      stmt->setInt(2, my_min_run);
      stmt->setInt(3, my_max_run);
    }

    DateHandler dh(m_env, m_conn);
    Tm runStart;
    Tm runEnd;
    Tm dbtime;
  
    ResultSet* rset = stmt->executeQuery();
    int i=0;
    while ((i<nruns) && (rset->next()))  {
      int iovID = rset->getInt(1);
      // int tagID = rset->getInt(2);
      int runNum = rset->getInt(3);
      Date startDate = rset->getDate(4);
      Date endDate = rset->getDate(5);
      Date dbDate = rset->getDate(6);
     
      runStart = dh.dateToTm( startDate );
      runEnd = dh.dateToTm( endDate );
      dbtime = dh.dateToTm( dbDate );
       
      RunIOV r ;
      r.setRunNumber(runNum);
      r.setRunStart(runStart);
      r.setRunEnd(runEnd);
      r.setDBInsertionTime(dbtime);
      r.setRunTag(m_runTag);
      r.setID(iovID);
      m_vec_runiov.push_back(r);
      
      i++;
    }
    m_vec_runiov.resize(i);
    m_conn->terminateStatement(stmt);
  } catch (SQLException &e) {
    throw(std::runtime_error("RunList::fetchRuns:  "+e.getMessage()));
  }
}

void RunList::fetchRunsByLocation	(	int	min_run,
		int	max_run,
		const LocationDef &	locDef
	)
throw	(	std::runtime_error
	)

Definition at line 265 of file RunList.cc.

References getBeamSpotDB::atag, gather_cfg::cout, DateHandler::dateToTm(), cuy::dh, alignCSCRings::e, i, alignCSCRings::r, RunIOV::setDBInsertionTime(), RunTag::setGeneralTag(), RunIOV::setID(), RunTag::setLocationDef(), RunIOV::setRunEnd(), RunIOV::setRunNumber(), RunIOV::setRunStart(), RunIOV::setRunTag(), RunTypeDef::setRunType(), and RunTag::setRunTypeDef().

Referenced by EcalCondDBInterface::fetchRunListByLocation().

{

  this->checkConnection();
  int nruns=0;

  int my_min_run=min_run-1;
  int my_max_run=max_run+1;
  try {
    Statement* stmt0 = m_conn->createStatement();
    stmt0->setSQL("SELECT count(iov_id) FROM run_iov r , run_tag t, location_def l "
                 " WHERE r.tag_id=t.tag_id and t.LOCATION_ID=l.def_id AND l.LOCATION= :1 " 
          "  and r.run_num> :2 and r.run_num< :3 ");
    stmt0->setString(1,locDef.getLocation() );
    stmt0->setInt(2, my_min_run);
    stmt0->setInt(3, my_max_run);
  
    ResultSet* rset0 = stmt0->executeQuery();
    if (rset0->next()) {
      nruns = rset0->getInt(1);
    }
    m_conn->terminateStatement(stmt0);

    cout <<"number of runs="<< nruns << endl;
    
    m_vec_runiov.reserve(nruns);
    
    Statement* stmt = m_conn->createStatement();
    stmt->setSQL("SELECT  r.iov_id, r.tag_id, r.run_num, r.run_start, r.run_end, r.DB_TIMESTAMP , "
                 " t.gen_tag, rt.RUN_TYPE "
         " FROM run_iov r , run_tag t, location_def l, run_type_def rt "
         " WHERE r.tag_id=t.tag_id and t.LOCATION_ID=l.def_id and t.run_type_id=rt.DEF_ID "
         " AND l.LOCATION= :1 "
         " and r.run_num> :2 and r.run_num< :3 "
         " order by run_num " );
    stmt->setString(1,locDef.getLocation() );
    stmt->setInt(2, my_min_run);
    stmt->setInt(3, my_max_run);

    DateHandler dh(m_env, m_conn);
    Tm runStart;
    Tm runEnd;
    Tm dbtime;
  
    ResultSet* rset = stmt->executeQuery();
    int i=0;
    while (i<nruns) {
      rset->next();
      int iovID = rset->getInt(1);
      //       int tagID = rset->getInt(2);
       int runNum = rset->getInt(3);
       Date startDate = rset->getDate(4);
       Date endDate = rset->getDate(5);
       Date dbDate = rset->getDate(6);
     
       runStart = dh.dateToTm( startDate );
       runEnd = dh.dateToTm( endDate );
       dbtime = dh.dateToTm( dbDate );
       
       RunTag atag;
       atag.setLocationDef(locDef);
       atag.setGeneralTag(rset->getString(7));
       RunTypeDef rundef;
       rundef.setRunType(rset->getString(8));
       atag.setRunTypeDef(rundef);

       RunIOV r ;
       r.setRunNumber(runNum);
       r.setRunStart(runStart);
       r.setRunEnd(runEnd);
       r.setDBInsertionTime(dbtime);
       r.setRunTag(atag);
       r.setID(iovID);
       m_vec_runiov.push_back(r);
      
      i++;
    }
   

    m_conn->terminateStatement(stmt);

  } catch (SQLException &e) {
    throw(std::runtime_error("RunList::fetchRunsByLocation:  "+e.getMessage()));
  }


}

std::vector< RunIOV > RunList::getRuns

(

)

Definition at line 35 of file RunList.cc.

Referenced by popcon::EcalSRPHandler::getNewObjects(), popcon::EcalDAQHandler::getNewObjects(), popcon::EcalTPGBadTTHandler::getNewObjects(), popcon::EcalTPGWeightIdMapHandler::getNewObjects(), popcon::EcalTPGLinConstHandler::getNewObjects(), popcon::EcalTPGPhysicsConstHandler::getNewObjects(), popcon::EcalTPGBadStripHandler::getNewObjects(), popcon::EcalTPGLutIdMapHandler::getNewObjects(), popcon::EcalTPGFineGrainEBIdMapHandler::getNewObjects(), popcon::EcalTPGBadXTHandler::getNewObjects(), popcon::EcalTPGFineGrainTowerEEHandler::getNewObjects(), popcon::EcalTPGFineGrainEBGroupHandler::getNewObjects(), popcon::EcalTPGWeightGroupHandler::getNewObjects(), popcon::EcalTPGFineGrainStripEEHandler::getNewObjects(), popcon::EcalTPGSlidingWindowHandler::getNewObjects(), popcon::EcalTPGPedestalsHandler::getNewObjects(), popcon::EcalTPGSpikeThresholdHandler::getNewObjects(), and popcon::EcalTPGLutGroupHandler::getNewObjects().

{
  return m_vec_runiov;
}

RunTag RunList::getRunTag

(

)

const

Definition at line 30 of file RunList.cc.

{
  return m_runTag;
}

void RunList::setRunTag

(

const RunTag &

tag

)

Definition at line 22 of file RunList.cc.

References GlobalPosition_Frontier_DevDB_cff::tag.

Referenced by EcalCondDBInterface::fetchGlobalRunListByLocation(), EcalCondDBInterface::fetchNonEmptyGlobalRunList(), EcalCondDBInterface::fetchNonEmptyRunList(), EcalCondDBInterface::fetchRunList(), EcalCondDBInterface::fetchRunListByLocation(), and EcalCondDBInterface::fetchRunListLastNRuns().

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

Friends And Related Function Documentation

friend class EcalCondDBInterface

friend

Definition at line 18 of file RunList.h.

Member Data Documentation

RunTag RunList::m_runTag

private

Definition at line 45 of file RunList.h.

std::vector<RunIOV> RunList::m_vec_runiov

private

Definition at line 44 of file RunList.h.