EcalCondDBInterface Class Reference

#include <EcalCondDBInterface.h>

Inheritance diagram for EcalCondDBInterface:

Public Member Functions
void	dummy ()
	EcalCondDBInterface (std::string host, std::string sid, std::string user, std::string pass, int port=1521)
	EcalCondDBInterface (std::string sid, std::string user, std::string pass)
CaliIOV	fetchCaliIOV (CaliTag *tag, const Tm &evenTm) noexcept(false)
template<class DATT , class ICONF >
void	fetchConfigDataSet (std::vector< DATT > *fillMap, ICONF *iconf) noexcept(false)
template<class ICONF >
void	fetchConfigSet (ICONF *iconf) noexcept(false)
template<class DATT , class IOVT >
void	fetchDataSet (std::map< EcalLogicID, DATT > *fillMap, IOVT *iov) noexcept(false)
template<class DATT , class IOVT >
void	fetchDataSetWithMap (std::map< EcalLogicID, DATT > *fillMap, IOVT *iov, std::string mapping_name) noexcept(false)
template<class DATT >
void	fetchDCSDataSet (std::list< std::pair< Tm, std::map< EcalLogicID, DATT > > > *fillMap, const Tm &t) noexcept(false)
DCSPTMTempList	fetchDCSPTMTempList (const EcalLogicID &ecid) noexcept(false)
DCSPTMTempList	fetchDCSPTMTempList (const EcalLogicID &ecid, const Tm &start, const Tm &end) noexcept(false)
DCUIOV	fetchDCUIOV (DCUTag *tag, const Tm &evenTm) noexcept(false)
std::list< ODDelaysDat >	fetchFEDelaysForRun (RunIOV *iov) noexcept(false)
RunList	fetchGlobalRunListByLocation (const RunTag &tag, int min_run, int max_run, const LocationDef &locDef) noexcept(false)
template<class ICONF >
void	fetchLastConfigSet (ICONF *iconf) noexcept(false)
RunIOV	fetchLMFLastRun () const
LMFRunIOV	fetchLMFRunIOV (RunTag *runtag, LMFRunTag *lmftag, run_t run, subrun_t lmfrun) noexcept(false)
bool	fetchLMFRunIOV (const LMFSeqDat &, LMFRunIOV &, int lmr, int type, int color) const
MonRunIOV	fetchMonRunIOV (RunTag *runtag, MonRunTag *montag, run_t run, subrun_t monrun) noexcept(false)
MonRunList	fetchMonRunList (const RunTag &tag, const MonRunTag &monruntag) noexcept(false)
MonRunList	fetchMonRunList (const RunTag &tag, const MonRunTag &monruntag, int min_run, int max_run) noexcept(false)
MonRunList	fetchMonRunListLastNRuns (const RunTag &tag, const MonRunTag &monruntag, int max_run, int n_runs) noexcept(false)
RunList	fetchNonEmptyGlobalRunList (const RunTag &tag, int min_run, int max_run) noexcept(false)
RunList	fetchNonEmptyRunList (const RunTag &tag, int min_run, int max_run) noexcept(false)
RunIOV	fetchRunIOV (RunTag *tag, run_t run) noexcept(false)
RunIOV	fetchRunIOV (std::string location, run_t run) noexcept(false)
RunIOV	fetchRunIOV (std::string location, const Tm &t) noexcept(false)
RunList	fetchRunList (const RunTag &tag) noexcept(false)
RunList	fetchRunList (const RunTag &tag, int min_run, int max_run) noexcept(false)
RunList	fetchRunListByLocation (const RunTag &tag, int min_run, int max_run, const LocationDef &locDef) noexcept(false)
RunList	fetchRunListLastNRuns (const RunTag &tag, int max_run, int n_runs) noexcept(false)
template<class DATT , class IOVT >
void	fetchValidDataSet (std::map< EcalLogicID, DATT > *fillMap, IOVT *fillIOV, RunTag *tag, run_t run=(unsigned int)-1) noexcept(false)
template<class DATT , class IOVT >
void	fetchValidDataSet (std::map< EcalLogicID, DATT > *fillMap, IOVT *fillIOV, std::string location, run_t run=(unsigned int)-1) noexcept(false)
DateHandler *	getDateHandler ()
std::map< int, int >	getDetId2LogicIdMap ()
int	getDetIdFromLogicId (int logic_id)
EcalLogicID	getEcalLogicID (std::string name, int id1=EcalLogicID::NULLID, int id2=EcalLogicID::NULLID, int id3=EcalLogicID::NULLID, std::string mapsTo="") noexcept(false)
EcalLogicID	getEcalLogicID (int logicID) noexcept(false)
std::map< int, int >	getEcalLogicID2LmrMap ()
std::vector< EcalLogicID >	getEcalLogicIDForLMPN (int lmr_logic_id)
std::vector< EcalLogicID >	getEcalLogicIDForLMPN (const EcalLogicID &lmr_logic_id)
std::vector< EcalLogicID >	getEcalLogicIDForLMR (int lmr_logic_id)
std::vector< EcalLogicID >	getEcalLogicIDForLMR (const EcalLogicID &lmr_logic_id)
std::vector< EcalLogicID >	getEcalLogicIDMappedTo (int logic_id, std::string maps_to)
std::vector< EcalLogicID >	getEcalLogicIDSet (std::string name, int fromId1=EcalLogicID::NULLID, int toId1=EcalLogicID::NULLID, int fromId2=EcalLogicID::NULLID, int toId2=EcalLogicID::NULLID, int fromId3=EcalLogicID::NULLID, int toId3=EcalLogicID::NULLID, std::string mapsTo="") noexcept(false)
std::vector< EcalLogicID >	getEcalLogicIDSetOrdered (std::string name, int fromId1, int toId1, int fromId2=EcalLogicID::NULLID, int toId2=EcalLogicID::NULLID, int fromId3=EcalLogicID::NULLID, int toId3=EcalLogicID::NULLID, std::string mapsTo="", int orderedBy=EcalLogicID::NULLID) noexcept(false)
std::map< int, int >	getLogicId2DetIdMap ()
int	getLogicIdFromDetId (int det_id)
template<class DATT , class ICONF >
void	insertConfigDataArraySet (const std::vector< DATT > &data, ICONF *iconf) noexcept(false)
template<class DATT , class ICONF >
void	insertConfigDataSet (const std::vector< DATT > data, ICONF *iconf) noexcept(false)
template<class ICONF >
void	insertConfigSet (ICONF *iconf) noexcept(false)
template<class DATT , class IOVT >
void	insertDataArraySet (const std::map< EcalLogicID, DATT > *data, IOVT *iov) noexcept(false)
template<class DATT , class IOVT >
void	insertDataSet (const std::map< EcalLogicID, DATT > *data, IOVT *iov) noexcept(false)
template<class DATT , class IOVT >
void	insertDataSetVector (const std::vector< EcalLogicID > &ecid, const std::vector< IOVT > &run_iov, const std::vector< DATT > &data) noexcept(false)
void	insertDCUIOV (DCUIOV *iov) noexcept(false)
void	insertLmfDat (LMFDat *dat) noexcept(false)
void	insertLmfDat (std::list< LMFDat * > dat) noexcept(false)
void	insertLmfIOV (LMFIOV *iov) noexcept(false)
void	insertLmfLmrSubIOV (LMFLmrSubIOV *iov) noexcept(false)
void	insertLmfRunIOV (LMFRunIOV *iov) noexcept(false)
void	insertLmfSeq (LMFSeqDat *iov) noexcept(false)
void	insertMonRunIOV (MonRunIOV *iov) noexcept(false)
void	insertRunIOV (RunIOV *iov) noexcept(false)
void	updateRunConfig (ODRunConfigInfo *od) noexcept(false)
void	updateRunIOV (RunIOV *iov) noexcept(false)
void	updateRunIOVEndTime (RunIOV *iov) noexcept(false)
void	updateRunIOVStartTime (RunIOV *iov) noexcept(false)
	~EcalCondDBInterface () noexcept(false) override
Public Member Functions inherited from EcalDBConnection
void	commit ()
oracle::occi::Statement *	createStatement ()
	EcalDBConnection (std::string host, std::string sid, std::string user, std::string pass, int port=1521) noexcept(false)
	EcalDBConnection (std::string sid, std::string user, std::string pass) noexcept(false)
oracle::occi::Clob	getClobLocator ()
oracle::occi::Connection *	getConn () const
oracle::occi::Environment *	getEnv () const
void	rollback ()
void	terminateStatement (oracle::occi::Statement *stmt)
virtual	~EcalDBConnection () noexcept(false)

Private Member Functions
	EcalCondDBInterface ()=delete
	EcalCondDBInterface (const EcalCondDBInterface &copy)=delete
void	fillLogicId2DetIdMaps ()

Private Attributes
std::map< int, int >	_detId2LogicId
std::map< int, int >	_logicId2DetId
DateHandler *	dh

Additional Inherited Members
Protected Attributes inherited from EcalDBConnection
oracle::occi::Connection *	conn
oracle::occi::Environment *	env
std::string	host
std::string	pass
int	port
std::string	sid
oracle::occi::Statement *	stmt
std::string	user

Detailed Description

Definition at line 38 of file EcalCondDBInterface.h.

Constructor & Destructor Documentation

EcalCondDBInterface::EcalCondDBInterface ( std::string  host, std::string  sid, std::string  user, std::string  pass, int  port = 1521  )

inline

Constructor, makes connection to DB without TNS_ADMIN === Parameters === host: DB host machine sid: DB SID (name) user: User to connect pass: Password for user port: port number to connect, default 1521

Definition at line 54 of file EcalCondDBInterface.h.

References EcalDBConnection::conn, dh, and EcalDBConnection::env.

    : EcalDBConnection( host, sid, user, pass, port )
    {
      // call the parent constructor

      // create a DateHandler
      dh = new DateHandler(env, conn);
    }

EcalCondDBInterface::EcalCondDBInterface ( std::string  sid, std::string  user, std::string  pass  )

inline

Constructor, makes connection to DB with TNS_ADMIN === Parameters === sid: DB SID (name) user: User to connect pass: Password for user

Definition at line 76 of file EcalCondDBInterface.h.

References EcalDBConnection::conn, dh, and EcalDBConnection::env.

    : EcalDBConnection( sid, user, pass )
    {
      // call the parent constructor

      // create a DateHandler
      dh = new DateHandler(env, conn);
    }

EcalCondDBInterface::~EcalCondDBInterface ( )

inlineoverridenoexcept

Destructor

Definition at line 91 of file EcalCondDBInterface.h.

References dh.

    {
      // call the parent destructor
      
      // destroy the DateHandler
      delete(dh);
    }

EcalCondDBInterface::EcalCondDBInterface ( )

privatedelete

EcalCondDBInterface::EcalCondDBInterface ( const EcalCondDBInterface &  copy )

privatedelete

Member Function Documentation

void EcalCondDBInterface::dummy

(

)

Definition at line 919 of file EcalCondDBInterface.cc.

Referenced by getDetId2LogicIdMap().

{
}

CaliIOV EcalCondDBInterface::fetchCaliIOV ( CaliTag *  tag, const Tm &  evenTm  )

noexcept

Return a Calibration IOV object

Definition at line 791 of file EcalCondDBInterface.cc.

References web.browse_db::env, CaliIOV::setByTm(), IDBObject::setConnection(), and GlobalPosition_Frontier_DevDB_cff::tag.

Referenced by getDateHandler().

{
  CaliIOV caliiov;
  caliiov.setConnection(env, conn);
  caliiov.setByTm(tag, eventTm);
  return caliiov;
}

template<class DATT , class ICONF >

void EcalCondDBInterface::fetchConfigDataSet ( std::vector< DATT > *  fillMap, ICONF *  iconf  )

inlinenoexcept

Definition at line 557 of file EcalCondDBInterface.h.

References EcalDBConnection::conn, and EcalDBConnection::env.

Referenced by popcon::EcalChannelStatusHandler::daqOut(), popcon::EcalDAQHandler::getNewObjects(), popcon::EcalTPGBadTTHandler::getNewObjects(), popcon::EcalTPGBadStripHandler::getNewObjects(), and popcon::EcalTPGBadXTHandler::getNewObjects().

  {

    DATT datiface;
    datiface.setConnection(env, conn);
    datiface.createReadStatement();
    datiface.setPrefetchRowCount(1024);
    datiface.fetchData( fillMap, iconf );
    datiface.terminateReadStatement();

  }

template<class ICONF >

void EcalCondDBInterface::fetchConfigSet ( ICONF *  iconf )

inlinenoexcept

Definition at line 448 of file EcalCondDBInterface.h.

References EcalDBConnection::conn, and EcalDBConnection::env.

Referenced by popcon::EcalChannelStatusHandler::daqOut(), popcon::EcalSRPHandler::getNewObjects(), and popcon::EcalDAQHandler::getNewObjects().

  {

    iconf->clear();
    iconf->setConnection(env, conn);
    iconf->createReadStatement();
    iconf->fetchData(iconf);
    iconf->terminateReadStatement();

  }

template<class DATT , class IOVT >

void EcalCondDBInterface::fetchDataSet ( std::map< EcalLogicID, DATT > *  fillMap, IOVT *  iov  )

inlinenoexcept

Definition at line 580 of file EcalCondDBInterface.h.

References EcalDBConnection::conn, and EcalDBConnection::env.

Referenced by EcalTPGParamBuilder::analyze(), popcon::EcalChannelStatusHandler::daqOut(), ecaldqm::fetchAndFill(), popcon::EcalSRPHandler::getNewObjects(), popcon::EcalTPGWeightIdMapHandler::getNewObjects(), popcon::EcalDAQHandler::getNewObjects(), popcon::EcalTPGLinConstHandler::getNewObjects(), popcon::EcalTPGLutIdMapHandler::getNewObjects(), popcon::EcalTPGBadStripHandler::getNewObjects(), popcon::EcalTPGPhysicsConstHandler::getNewObjects(), popcon::EcalTPGBadTTHandler::getNewObjects(), popcon::EcalTPGWeightGroupHandler::getNewObjects(), popcon::EcalTPGFineGrainEBIdMapHandler::getNewObjects(), popcon::EcalTPGBadXTHandler::getNewObjects(), popcon::EcalTPGFineGrainTowerEEHandler::getNewObjects(), popcon::EcalTPGFineGrainEBGroupHandler::getNewObjects(), popcon::EcalTPGPedestalsHandler::getNewObjects(), popcon::EcalTPGSlidingWindowHandler::getNewObjects(), popcon::EcalTPGFineGrainStripEEHandler::getNewObjects(), popcon::EcalTPGLutGroupHandler::getNewObjects(), popcon::EcalTPGSpikeThresholdHandler::getNewObjects(), popcon::EcalADCToGeVHandler::getNewObjects(), popcon::EcalDCSHandler::getNewObjects(), popcon::EcalChannelStatusHandler::getNewObjects(), popcon::EcalPedestalsHandler::getNewObjectsH2(), and popcon::EcalPedestalsHandler::getNewObjectsP5().

  {
    fillMap->clear();

    DATT datiface;
    datiface.setConnection(env, conn);
    datiface.createReadStatement();
    datiface.setPrefetchRowCount(1024);
    datiface.fetchData( fillMap, iov );
    datiface.terminateReadStatement();

  }

template<class DATT , class IOVT >

void EcalCondDBInterface::fetchDataSetWithMap ( std::map< EcalLogicID, DATT > *  fillMap, IOVT *  iov, std::string  mapping_name  )

inlinenoexcept

Definition at line 624 of file EcalCondDBInterface.h.

References EcalDBConnection::conn, and EcalDBConnection::env.

  {
    fillMap->clear();

    DATT datiface;
    datiface.setConnection(env, conn);
    datiface.createReadStatement();
    datiface.setPrefetchRowCount(1024);
    datiface.fetchData( fillMap, iov , mapping_name);
    datiface.terminateReadStatement();

  }

template<class DATT >

void EcalCondDBInterface::fetchDCSDataSet ( std::list< std::pair< Tm, std::map< EcalLogicID, DATT > > > *  fillMap, const Tm &  t  )

inlinenoexcept

Definition at line 601 of file EcalCondDBInterface.h.

References EcalDBConnection::conn, and EcalDBConnection::env.

  {
    fillMap->clear();
    
    DATT datiface;
    datiface.setConnection(env, conn);
    datiface.createReadStatement();
    datiface.setPrefetchRowCount(1024);
    datiface.fetchHistoricalData( fillMap, t );
    datiface.terminateReadStatement();
    
  }

DCSPTMTempList EcalCondDBInterface::fetchDCSPTMTempList ( const EcalLogicID &  ecid )

noexcept

Return a PTM Temp List

Definition at line 800 of file EcalCondDBInterface.cc.

References web.browse_db::env, DCSPTMTempList::fetchValuesForECID(), alignCSCRings::r, and IDBObject::setConnection().

Referenced by getDateHandler().

{  
  DCSPTMTempList r;
  r.setConnection(env, conn);
  r.fetchValuesForECID(ecid);
  return r;
}

DCSPTMTempList EcalCondDBInterface::fetchDCSPTMTempList ( const EcalLogicID &  ecid, const Tm &  start, const Tm &  end  )

noexcept

Definition at line 809 of file EcalCondDBInterface.cc.

References end, web.browse_db::env, DCSPTMTempList::fetchValuesForECIDAndTime(), alignCSCRings::r, and IDBObject::setConnection().

{  
  DCSPTMTempList r;
  r.setConnection(env, conn);
  r.fetchValuesForECIDAndTime(ecid, start, end);
  return r;
}

DCUIOV EcalCondDBInterface::fetchDCUIOV ( DCUTag *  tag, const Tm &  evenTm  )

noexcept

Return a DCU IOV object

Definition at line 736 of file EcalCondDBInterface.cc.

References web.browse_db::env, DCUIOV::setByTm(), IDBObject::setConnection(), and GlobalPosition_Frontier_DevDB_cff::tag.

Referenced by getDateHandler().

{
  DCUIOV dcuiov;
  dcuiov.setConnection(env, conn);
  dcuiov.setByTm(tag, eventTm);
  return dcuiov;
}

std::list< ODDelaysDat > EcalCondDBInterface::fetchFEDelaysForRun ( RunIOV *  iov )

noexcept

Return run Fe Config Dat objects for a given run

Definition at line 106 of file EcalCondDBInterface.cc.

References edmIntegrityCheck::d, MillePedeFileConverter_cfg::e, web.browse_db::env, RunFEConfigDat::fetchData(), ODDelaysDat::fetchData(), ODFEDAQConfig::fetchData(), ODFEDAQConfig::getDelayId(), getEcalLogicID(), mps_fire::i, globals_cff::id1, globals_cff::id2, mps_check::msg, dataset::name, noexcept, EcalLogicID::NULLID, IDBObject::setConnection(), ODFEDAQConfig::setId(), AlCaHLTBitMon_QueryRunRegistry::string, and groupFilesInBlocks::temp.

Referenced by getDateHandler().

{
  std::list<ODDelaysDat> ret;
  RunFEConfigDat d;
  std::map<EcalLogicID, RunFEConfigDat > fillMap;
  try {
    d.setConnection(env, conn);
    d.fetchData(&fillMap, iov);
  } catch (std::runtime_error &e) {
    throw e;
  }
  std::map<EcalLogicID, RunFEConfigDat >::const_iterator i = fillMap.begin();
  std::map<EcalLogicID, RunFEConfigDat >::const_iterator e = fillMap.end();
  while (i != e) {
    ODFEDAQConfig feDaqConfig;
    ODFEDAQConfig temp;
    temp.setId(i->second.getConfigId());
    feDaqConfig.setConnection(env, conn);
    feDaqConfig.fetchData(&temp);
    std::vector<ODDelaysDat> delays;
    ODDelaysDat temp2;
    temp2.setConnection(env, conn);
    temp2.fetchData(&delays, temp.getDelayId());
    std::vector<ODDelaysDat>::const_iterator di = delays.begin();
    std::vector<ODDelaysDat>::const_iterator de = delays.end();
    while (di != de) {
      ret.push_back(*di++);
    }
    i++;
  }
  return ret;
}

RunList EcalCondDBInterface::fetchGlobalRunListByLocation ( const RunTag &  tag, int  min_run, int  max_run, const LocationDef &  locDef  )

noexcept

Definition at line 861 of file EcalCondDBInterface.cc.

References web.browse_db::env, RunList::fetchGlobalRunsByLocation(), alignCSCRings::r, IDBObject::setConnection(), RunList::setRunTag(), and GlobalPosition_Frontier_DevDB_cff::tag.

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

                  {
  RunList r;
  r.setConnection(env, conn);
  r.setRunTag(tag);
  r.fetchGlobalRunsByLocation( min_run,  max_run, locDef);
  return r;
}

template<class ICONF >

void EcalCondDBInterface::fetchLastConfigSet ( ICONF *  iconf )

inlinenoexcept

Definition at line 464 of file EcalCondDBInterface.h.

References EcalDBConnection::conn, and EcalDBConnection::env.

  {

    iconf->clear();
    iconf->setConnection(env, conn);
    iconf->createReadStatement();
    iconf->fetchLastData(iconf);
    iconf->terminateReadStatement();

  }

RunIOV EcalCondDBInterface::fetchLMFLastRun

(

)

const

Definition at line 745 of file EcalCondDBInterface.cc.

References web.browse_db::env, and LMFSeqDat::fetchLastRun().

Referenced by getDateHandler().

                                                  {
  LMFSeqDat seq(env, conn);
  return seq.fetchLastRun();
}

LMFRunIOV EcalCondDBInterface::fetchLMFRunIOV ( RunTag *  runtag, LMFRunTag *  lmftag, run_t  run, subrun_t  lmfrun  )

noexcept

Return a laser monitoring farm run object

Definition at line 750 of file EcalCondDBInterface.cc.

References web.browse_db::env, writedatasetfile::run, and IDBObject::setConnection().

Referenced by getDateHandler().

{
  RunIOV runiov = fetchRunIOV(runtag, run);
  LMFRunIOV lmfiov;
  lmfiov.setConnection(env, conn);
  //  lmfiov.setByRun(lmftag, &runiov, subrun);
  return lmfiov;
}

bool EcalCondDBInterface::fetchLMFRunIOV	(	const LMFSeqDat &	seq,
		LMFRunIOV &	iov,
		int	lmr,
		int	type,
		int	color
	)		const

Definition at line 760 of file EcalCondDBInterface.cc.

References gather_cfg::cout, web.browse_db::env, LMFRunIOV::fetchBySequence(), LMFRunIOV::fetchLastBeforeSequence(), LMFUnique::getID(), ntuplemaker::iovlist, alignCSCRings::s, and IDBObject::setConnection().

                                                          {
  bool ret = false;
  iov.setConnection(env, conn);
  std::list<LMFRunIOV> iovlist = iov.fetchBySequence(seq, lmr, type, color);
  int s = iovlist.size();
  if (s > 0) {
    iov = iovlist.front();
    ret = true;
    if (s > 1) {
      // should not happen
      std::cout << "################################" << std::endl;
      std::cout << "################################" << std::endl;
      std::cout << "WARNING: More than one LMFRUNIOV" << std::endl;
      std::cout << "         Found for seq " << seq.getID() << std::endl;
      std::cout << "         lmr " << lmr << " type " << type << std::endl;
      std::cout << "         and color " << color << std::endl;
      std::cout << "################################" << std::endl;
      std::cout << "################################" << std::endl;
    }
  } else {
    // find the most recent data
    iovlist = iov.fetchLastBeforeSequence(seq, lmr, type, color);
    s = iovlist.size();
    if (s == 1) {
      iov = iovlist.front();
    } 
  }
  return ret;
}

MonRunIOV EcalCondDBInterface::fetchMonRunIOV ( RunTag *  runtag, MonRunTag *  montag, run_t  run, subrun_t  monrun  )

noexcept

Return a monitoring run object

Definition at line 724 of file EcalCondDBInterface.cc.

References web.browse_db::env, writedatasetfile::run, MonRunIOV::setByRun(), and IDBObject::setConnection().

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

{
  RunIOV runiov = fetchRunIOV(runtag, run);
  MonRunIOV moniov;
  moniov.setConnection(env, conn);
  moniov.setByRun(montag, &runiov, subrun);
  return moniov;
}

MonRunList EcalCondDBInterface::fetchMonRunList ( const RunTag &  tag, const MonRunTag &  monruntag  )

noexcept

Definition at line 884 of file EcalCondDBInterface.cc.

References web.browse_db::env, MonRunList::fetchRuns(), alignCSCRings::r, IDBObject::setConnection(), MonRunList::setMonRunTag(), MonRunList::setRunTag(), and GlobalPosition_Frontier_DevDB_cff::tag.

Referenced by getDateHandler(), popcon::EcalChannelStatusHandler::getNewObjects(), popcon::EcalPedestalsHandler::getNewObjectsH2(), and popcon::EcalPedestalsHandler::getNewObjectsP5().

{  
  MonRunList r;
  r.setConnection(env, conn);
  r.setRunTag(tag);
  r.setMonRunTag(monrunTag);
  r.fetchRuns();
  return r;
}

MonRunList EcalCondDBInterface::fetchMonRunList ( const RunTag &  tag, const MonRunTag &  monruntag, int  min_run, int  max_run  )

noexcept

Definition at line 895 of file EcalCondDBInterface.cc.

References web.browse_db::env, MonRunList::fetchRuns(), alignCSCRings::r, IDBObject::setConnection(), MonRunList::setMonRunTag(), MonRunList::setRunTag(), and GlobalPosition_Frontier_DevDB_cff::tag.

{  
  MonRunList r;
  r.setConnection(env, conn);
  r.setRunTag(tag);
  r.setMonRunTag(monrunTag);
  r.fetchRuns(min_run, max_run);
  return r;
}

MonRunList EcalCondDBInterface::fetchMonRunListLastNRuns ( const RunTag &  tag, const MonRunTag &  monruntag, int  max_run, int  n_runs  )

noexcept

Definition at line 906 of file EcalCondDBInterface.cc.

References web.browse_db::env, MonRunList::fetchLastNRuns(), alignCSCRings::r, IDBObject::setConnection(), MonRunList::setMonRunTag(), MonRunList::setRunTag(), and GlobalPosition_Frontier_DevDB_cff::tag.

Referenced by getDateHandler().

{  
  MonRunList r;
  r.setConnection(env, conn);
  r.setRunTag(tag);
  r.setMonRunTag(monrunTag);
  r.fetchLastNRuns(max_run, n_runs );
  return r;
}

RunList EcalCondDBInterface::fetchNonEmptyGlobalRunList ( const RunTag &  tag, int  min_run, int  max_run  )

noexcept

Definition at line 844 of file EcalCondDBInterface.cc.

References web.browse_db::env, RunList::fetchNonEmptyGlobalRuns(), alignCSCRings::r, IDBObject::setConnection(), RunList::setRunTag(), and GlobalPosition_Frontier_DevDB_cff::tag.

Referenced by getDateHandler().

                                                                                                                  {
  RunList r;
  r.setConnection(env, conn);
  r.setRunTag(tag);
  r.fetchNonEmptyGlobalRuns( min_run,  max_run);
  return r;
}

RunList EcalCondDBInterface::fetchNonEmptyRunList ( const RunTag &  tag, int  min_run, int  max_run  )

noexcept

Definition at line 836 of file EcalCondDBInterface.cc.

References web.browse_db::env, RunList::fetchNonEmptyRuns(), alignCSCRings::r, IDBObject::setConnection(), RunList::setRunTag(), and GlobalPosition_Frontier_DevDB_cff::tag.

Referenced by getDateHandler().

                                                                                                            {
  RunList r;
  r.setConnection(env, conn);
  r.setRunTag(tag);
  r.fetchNonEmptyRuns( min_run,  max_run);
  return r;
}

RunIOV EcalCondDBInterface::fetchRunIOV ( RunTag *  tag, run_t  run  )

noexcept

Return a run IOV object for a given tag

Definition at line 666 of file EcalCondDBInterface.cc.

References web.browse_db::env, writedatasetfile::run, RunIOV::setByRun(), IDBObject::setConnection(), and GlobalPosition_Frontier_DevDB_cff::tag.

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

{  
  RunIOV iov;
  iov.setConnection(env, conn);
  iov.setByRun(tag, run);
  return iov;
}

RunIOV EcalCondDBInterface::fetchRunIOV ( std::string  location, run_t  run  )

noexcept

Return a run IOV object for a given location. It is not guarunteed that a run is unique for a location only, so an exception is thrown if more than one result exists.

Definition at line 677 of file EcalCondDBInterface.cc.

References web.browse_db::env, writedatasetfile::run, RunIOV::setByRun(), and IDBObject::setConnection().

{  
  RunIOV iov;
  iov.setConnection(env, conn);
  iov.setByRun(location, run);
  return iov;
}

RunIOV EcalCondDBInterface::fetchRunIOV ( std::string  location, const Tm &  t  )

noexcept

Definition at line 686 of file EcalCondDBInterface.cc.

References web.browse_db::env, RunIOV::setByTime(), IDBObject::setConnection(), and protons_cff::t.

{
  RunIOV iov;
  iov.setConnection(env, conn);
  iov.setByTime(location, t);
  return iov;
}

RunList EcalCondDBInterface::fetchRunList ( const RunTag &  tag )

noexcept

Return a Run List

Definition at line 818 of file EcalCondDBInterface.cc.

References web.browse_db::env, RunList::fetchRuns(), alignCSCRings::r, IDBObject::setConnection(), RunList::setRunTag(), and GlobalPosition_Frontier_DevDB_cff::tag.

Referenced by getDateHandler().

{  
  RunList r;
  r.setConnection(env, conn);
  r.setRunTag(tag);
  r.fetchRuns();
  return r;
}

RunList EcalCondDBInterface::fetchRunList ( const RunTag &  tag, int  min_run, int  max_run  )

noexcept

Definition at line 828 of file EcalCondDBInterface.cc.

References web.browse_db::env, RunList::fetchRuns(), alignCSCRings::r, IDBObject::setConnection(), RunList::setRunTag(), and GlobalPosition_Frontier_DevDB_cff::tag.

                                                                                                    {
  RunList r;
  r.setConnection(env, conn);
  r.setRunTag(tag);
  r.fetchRuns( min_run,  max_run);
  return r;
}

RunList EcalCondDBInterface::fetchRunListByLocation ( const RunTag &  tag, int  min_run, int  max_run, const LocationDef &  locDef  )

noexcept

Definition at line 852 of file EcalCondDBInterface.cc.

References web.browse_db::env, RunList::fetchRunsByLocation(), alignCSCRings::r, IDBObject::setConnection(), RunList::setRunTag(), and GlobalPosition_Frontier_DevDB_cff::tag.

Referenced by getDateHandler(), popcon::EcalSRPHandler::getNewObjects(), and popcon::EcalDAQHandler::getNewObjects().

                  {
  RunList r;
  r.setConnection(env, conn);
  r.setRunTag(tag);
  r.fetchRunsByLocation( min_run,  max_run, locDef);
  return r;
}

RunList EcalCondDBInterface::fetchRunListLastNRuns ( const RunTag &  tag, int  max_run, int  n_runs  )

noexcept

Definition at line 870 of file EcalCondDBInterface.cc.

References web.browse_db::env, RunList::fetchLastNRuns(), alignCSCRings::r, IDBObject::setConnection(), RunList::setRunTag(), and GlobalPosition_Frontier_DevDB_cff::tag.

Referenced by getDateHandler().

                 {
  RunList r;
  r.setConnection(env, conn);
  r.setRunTag(tag);
  r.fetchLastNRuns( max_run,  n_runs);
  return r;
}

template<class DATT , class IOVT >

void EcalCondDBInterface::fetchValidDataSet ( std::map< EcalLogicID, DATT > *  fillMap, IOVT *  fillIOV, RunTag *  tag, run_t  run = (unsigned int)-1  )

inlinenoexcept

Definition at line 646 of file EcalCondDBInterface.h.

References EcalDBConnection::conn, EcalDBConnection::env, writedatasetfile::run, IDBObject::setConnection(), and GlobalPosition_Frontier_DevDB_cff::tag.

Referenced by popcon::EcalADCToGeVHandler::getNewObjects(), and popcon::EcalDCSHandler::getNewObjects().

  {
    fillMap->clear();
    DATT datiface;
    fillIOV->setConnection(env, conn);
    fillIOV->setByRecentData(datiface.getTable(), tag, run);
    datiface.setConnection(env, conn);
    datiface.createReadStatement();
    datiface.setPrefetchRowCount(1024);
    datiface.fetchData( fillMap, fillIOV );
    datiface.terminateReadStatement();
  }

template<class DATT , class IOVT >

void EcalCondDBInterface::fetchValidDataSet ( std::map< EcalLogicID, DATT > *  fillMap, IOVT *  fillIOV, std::string  location, run_t  run = (unsigned int)-1  )

inlinenoexcept

Definition at line 670 of file EcalCondDBInterface.h.

References EcalDBConnection::conn, EcalDBConnection::env, writedatasetfile::run, and IDBObject::setConnection().

  {
    fillMap->clear();
    DATT datiface;
    fillIOV->setConnection(env, conn);
    fillIOV->setByRecentData(datiface.getTable(), location, run);
    datiface.setConnection(env, conn);
    datiface.createReadStatement();
    datiface.setPrefetchRowCount(1024);
    datiface.fetchData( fillMap, fillIOV );
    datiface.terminateReadStatement();
  }

void EcalCondDBInterface::fillLogicId2DetIdMaps ( )

private

Private method: fill a private map used to associate logicIds to DetIds

Definition at line 28 of file EcalCondDBInterface.cc.

References EcalLogicID::NULLID.

Referenced by getDetId2LogicIdMap(), getDetIdFromLogicId(), getLogicId2DetIdMap(), and getLogicIdFromDetId().

                                                {
  // retrieve the lists of logic_ids, to build the detids
  std::vector<EcalLogicID> crystals_EB  =
    getEcalLogicIDSetOrdered( "EB_crystal_angle",
                  -85,85,1,360,
                  EcalLogicID::NULLID,EcalLogicID::NULLID,
                  "EB_crystal_number", 4 );
  std::vector<EcalLogicID> crystals_EE  =
    getEcalLogicIDSetOrdered( "EE_crystal_number",
                  -1,1,1,100,
                  1,100,
                  "EE_crystal_number", 4 );
  // fill the barrel map
  std::vector<EcalLogicID>::const_iterator ieb = crystals_EB.begin();
  std::vector<EcalLogicID>::const_iterator eeb = crystals_EB.end();
  while (ieb != eeb) {
    int iEta = ieb->getID1();
    int iPhi = ieb->getID2();
    EBDetId ebdetid(iEta,iPhi);
    _logicId2DetId[ieb->getLogicID()] = ebdetid;
    _detId2LogicId[ebdetid] = ieb->getLogicID();
    ieb++;
  }

  // fill the endcap map
  std::vector<EcalLogicID>::const_iterator iee = crystals_EE.begin();
  std::vector<EcalLogicID>::const_iterator eee = crystals_EE.end();

  while (iee != eee) {
    int iSide = iee->getID1();
    int iX    = iee->getID2();
    int iY    = iee->getID3();
    EEDetId eedetidpos(iX,iY,iSide);
    _logicId2DetId[iee->getLogicID()] = eedetidpos;
    _detId2LogicId[eedetidpos] = iee->getLogicID();
    iee++;
  }
  
}

DateHandler* EcalCondDBInterface::getDateHandler ( )

inline

Return a date handler associated with this connection

Definition at line 104 of file EcalCondDBInterface.h.

References create_public_lumi_plots::color, dh, end, fetchCaliIOV(), fetchDCSPTMTempList(), fetchDCUIOV(), fetchFEDelaysForRun(), fetchGlobalRunListByLocation(), fetchLMFLastRun(), fetchLMFRunIOV(), fetchMonRunIOV(), fetchMonRunList(), fetchMonRunListLastNRuns(), fetchNonEmptyGlobalRunList(), fetchNonEmptyRunList(), fetchRunIOV(), fetchRunList(), fetchRunListByLocation(), fetchRunListLastNRuns(), getEcalLogicID(), getEcalLogicID2LmrMap(), getEcalLogicIDForLMPN(), getEcalLogicIDForLMR(), getEcalLogicIDMappedTo(), getEcalLogicIDSet(), getEcalLogicIDSetOrdered(), globals_cff::id1, globals_cff::id2, insertDCUIOV(), insertLmfDat(), insertLmfIOV(), insertLmfLmrSubIOV(), insertLmfRunIOV(), insertLmfSeq(), insertMonRunIOV(), insertRunIOV(), dataset::name, noexcept, EcalLogicID::NULLID, writedatasetfile::run, AlCaHLTBitMon_QueryRunRegistry::string, protons_cff::t, GlobalPosition_Frontier_DevDB_cff::tag, updateRunConfig(), updateRunIOV(), updateRunIOVEndTime(), and updateRunIOVStartTime().

    {
      return dh;
    }

std::map<int, int> EcalCondDBInterface::getDetId2LogicIdMap ( )

inline

Definition at line 715 of file EcalCondDBInterface.h.

References _detId2LogicId, _logicId2DetId, dummy(), and fillLogicId2DetIdMaps().

                                                {
    if (_logicId2DetId.empty()) {
      fillLogicId2DetIdMaps();
    }
    return _detId2LogicId;
  }

int EcalCondDBInterface::getDetIdFromLogicId ( int  logic_id )

inline

Definition at line 686 of file EcalCondDBInterface.h.

References _logicId2DetId, and fillLogicId2DetIdMaps().

                                               {
    int detid = -1;
    if (_logicId2DetId.empty()) {
      fillLogicId2DetIdMaps();
    }
    if (_logicId2DetId.find(logic_id) != _logicId2DetId.end()) {
      detid = _logicId2DetId[logic_id];
    }
    return detid;
  }

EcalLogicID EcalCondDBInterface::getEcalLogicID ( std::string  name, int  id1 = EcalLogicID::NULLID, int  id2 = EcalLogicID::NULLID, int  id3 = EcalLogicID::NULLID, std::string  mapsTo = ""  )

noexcept

Look up the "human readable" ids and return an EcalLogicID object which contains the "database readable" logic_id === Parameters === name: name of the channel type you are specifying id1, id2, id3: ids of the channel type mapsTo: name of the channel type you are mapping to

Referenced by EcalTPGParamBuilder::analyze(), popcon::EcalLaserHandler::dumpBarrelPayload(), popcon::EcalLaserHandler::dumpEndcapPayload(), fetchFEDelaysForRun(), getDateHandler(), and EcalPedOffset::writeDb().

EcalLogicID EcalCondDBInterface::getEcalLogicID ( int  logicID )

noexcept

Look up the database logic_id and return the EcalLogicID object which contains the "human readable" ids === Parameters === logicID: DB logic_id

Definition at line 69 of file EcalCondDBInterface.cc.

References MillePedeFileConverter_cfg::e, globals_cff::id1, globals_cff::id2, mps_check::msg, dataset::name, EcalLogicID::NULLID, and AlCaHLTBitMon_QueryRunRegistry::string.

{

  string sql = "SELECT name, logic_id, id1, id2, id3, maps_to FROM channelView WHERE logic_id = :logicID AND name=maps_to";
  
  int id1, id2, id3;
  string name, mapsTo;
  
  try {
    stmt->setSQL(sql);
    stmt->setInt(1, logicID);
    ResultSet* rset = stmt->executeQuery();

    if (rset->next()) {
      name = rset->getString(1);
      logicID = rset->getInt(2);
      id1 = rset->getInt(3);
      if (rset->isNull(3)) { id1 = EcalLogicID::NULLID; }
      id2 = rset->getInt(4);
      if (rset->isNull(4)) { id2 = EcalLogicID::NULLID; }
      id3 = rset->getInt(5);
      if (rset->isNull(5)) { id3 = EcalLogicID::NULLID; }
      mapsTo = rset->getString(6);
    } else {
      stringstream msg;
      msg << "ERROR:  Cannot build EcalLogicID for logic_id " << logicID;
      throw(std::runtime_error(msg.str()));
    }

  } catch (SQLException &e) {    
    throw(std::runtime_error(std::string("ERROR:  Failed to retrive ids:  ") + e.getMessage()));
  }
  
  return EcalLogicID( name, logicID, id1, id2, id3, mapsTo );  
}

std::map< int, int > EcalCondDBInterface::getEcalLogicID2LmrMap

(

)

Definition at line 294 of file EcalCondDBInterface.cc.

References mps_fire::i, and EcalLogicID::NULLID.

Referenced by getDateHandler(), and popcon::EcalLaserHandler::getNewObjects().

                                                            {
  std::map<int, int> ret;
  std::vector<EcalLogicID> crystals_EB  =
    getEcalLogicIDSetOrdered( "EB_crystal_number",
                  1,36,1,1700,
                  EcalLogicID::NULLID,EcalLogicID::NULLID,
                  "EB_crystal_number", EcalLogicID::NULLID);
  std::vector<EcalLogicID> crystals_EE  =
    getEcalLogicIDSetOrdered( "EE_crystal_number",
                  -1,1,1,100,
                  1,100,
                  "EE_crystal_number", EcalLogicID::NULLID);
  std::vector<EcalLogicID> EB_lmr  =
    getEcalLogicIDSetOrdered( "EB_crystal_number",
                  1,36,1,1700,
                  EcalLogicID::NULLID,EcalLogicID::NULLID,
                  "ECAL_LMR", EcalLogicID::NULLID);
  std::vector<EcalLogicID> EE_lmr  =
    getEcalLogicIDSetOrdered( "EE_crystal_number",
                  -1,1,1,100,
                  1,100,
                  "ECAL_LMR", EcalLogicID::NULLID);
  unsigned int neb = crystals_EB.size();
  unsigned int nee = crystals_EE.size();
  if (neb != EB_lmr.size()) {
    throw(std::runtime_error("ERROR: EB Vectors size do not agree"));
  }
  if (nee != EE_lmr.size()) {
    throw(std::runtime_error("ERROR: EE Vectors size do not agree"));
  }
  for (unsigned int i = 0; i < neb; i++) {
    ret[crystals_EB[i].getLogicID()] = EB_lmr[i].getLogicID() % 100;
  }
  for (unsigned int i = 0; i < nee; i++) {
    ret[crystals_EE[i].getLogicID()] = EE_lmr[i].getLogicID() % 100;
  }
  return ret;
}

std::vector< EcalLogicID > EcalCondDBInterface::getEcalLogicIDForLMPN

(

int

lmr_logic_id

)

Definition at line 388 of file EcalCondDBInterface.cc.

Referenced by getDateHandler().

                                                                         {
  if ((lmr / 1000000000) == 2) {
    return getEcalLogicIDMappedTo(lmr, "EE_LM_PN");
  } else {
    return getEcalLogicIDMappedTo(lmr, "EB_LM_PN");
  }
}

std::vector< EcalLogicID > EcalCondDBInterface::getEcalLogicIDForLMPN

(

const EcalLogicID &

lmr_logic_id

)

Definition at line 396 of file EcalCondDBInterface.cc.

References EcalLogicID::getLogicID().

                                                                                        {
  return getEcalLogicIDForLMR(lmr.getLogicID());
}

std::vector< EcalLogicID > EcalCondDBInterface::getEcalLogicIDForLMR

(

int

lmr_logic_id

)

Definition at line 380 of file EcalCondDBInterface.cc.

Referenced by getDateHandler().

                                                                        {
  return getEcalLogicIDMappedTo(lmr, "ECAL_LMR");
}

std::vector< EcalLogicID > EcalCondDBInterface::getEcalLogicIDForLMR

(

const EcalLogicID &

lmr_logic_id

)

Definition at line 384 of file EcalCondDBInterface.cc.

References EcalLogicID::getLogicID().

                                                                                       {
  return getEcalLogicIDForLMR(lmr.getLogicID());
}

std::vector< EcalLogicID > EcalCondDBInterface::getEcalLogicIDMappedTo	(	int	logic_id,
		std::string	maps_to
	)

Build various reverse maps Map an LMR, or a Ex_LM_PN into the set of components

Definition at line 333 of file EcalCondDBInterface.cc.

References MillePedeFileConverter_cfg::e, IDBObject::ECALDB_NROWS, globals_cff::id1, globals_cff::id2, dataset::name, EcalLogicID::NULLID, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by getDateHandler().

                                                                                                      {
  std::string name = "EB_crystal_angle";
  std::string sql = "SELECT LOGIC_ID, ID1, ID2, ID3 "
    "FROM CHANNELVIEW WHERE NAME = 'EB_crystal_angle' AND LOGIC_ID IN "
    "(SELECT LOGIC_ID FROM CHANNELVIEW WHERE NAME = 'EB_crystal_number' AND "
    "ID1*10000+ID2 IN (SELECT DISTINCT ID1*10000+ID2 FROM CHANNELVIEW "
    "WHERE LOGIC_ID = :1 AND NAME = 'EB_crystal_number' AND MAPS_TO = :2) "
    "AND NAME = MAPS_TO)"; 
  if ((lmr_logic_id / 1000000000) == 2) {
    name = "EE_crystal_number";
    sql = "SELECT LOGIC_ID, ID1, ID2, ID3 "
      "FROM CHANNELVIEW WHERE NAME = 'EE_crystal_number' AND LOGIC_ID IN "
      "(SELECT LOGIC_ID FROM CHANNELVIEW WHERE NAME = 'EE_crystal_number' AND "
      "ID1*10000000+ID2*10000+ID3 IN (SELECT DISTINCT "
      "ID1*10000000+ID2*10000+ID3 FROM CHANNELVIEW "
      "WHERE LOGIC_ID = :1 AND NAME = 'EE_crystal_number' AND MAPS_TO = :2) "
      "AND NAME = MAPS_TO) AND NAME = MAPS_TO"; 
  }
  std::vector<EcalLogicID> ret;
  try {
    stmt->setSQL(sql);
    stmt->setInt(1, lmr_logic_id);
    stmt->setString(2, maps_to);
    stmt->setPrefetchRowCount(IDBObject::ECALDB_NROWS);    
    
    ResultSet* rset = stmt->executeQuery();
    
    while (rset->next()) {
      int logic_id = rset->getInt(1);
      int id1 = rset->getInt(2);
      if (rset->isNull(2)) { id1 = EcalLogicID::NULLID; }
      int id2 = rset->getInt(3);
      if (rset->isNull(3)) { id2 = EcalLogicID::NULLID; }
      int id3 = rset->getInt(4);
      if (rset->isNull(4)) { id3 = EcalLogicID::NULLID; }
      
      EcalLogicID ecid = EcalLogicID( name, logic_id, id1, id2, id3, maps_to );
      ret.push_back(ecid);
    }
    stmt->setPrefetchRowCount(0);
  }
  catch (SQLException &e) {
    throw(std::runtime_error(std::string("ERROR:  Failure while getting EcalLogicID set:  ") + e.getMessage()));
  }
  return ret;
}

std::vector< EcalLogicID > EcalCondDBInterface::getEcalLogicIDSet ( std::string  name, int  fromId1 = EcalLogicID::NULLID, int  toId1 = EcalLogicID::NULLID, int  fromId2 = EcalLogicID::NULLID, int  toId2 = EcalLogicID::NULLID, int  fromId3 = EcalLogicID::NULLID, int  toId3 = EcalLogicID::NULLID, std::string  mapsTo = ""  )

noexcept

Get a set of EcalLogicID in one transaction === Parameters === name: name of the channel type you are specifying fromId1, toId1: Range of id1 in the DB to retrieve fromId2, toId2: Range of id2 in the DB to retrieve fromId3, toId3: Range of id3 in the DB to retrieve string mapsTo: channel type name these ids map to

Definition at line 202 of file EcalCondDBInterface.cc.

References MillePedeFileConverter_cfg::e, IDBObject::ECALDB_NROWS, mps_fire::i, globals_cff::id1, globals_cff::id2, dataset::name, EcalLogicID::NULLID, mps_fire::result, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by popcon::EcalChannelStatusHandler::daqOut(), and getDateHandler().

{
  if (mapsTo.empty()) {
    mapsTo = name;
  }
  
  int idArray[] = { fromId1, toId1, fromId2, toId2, fromId3, toId3 };
  int from, to;
  
  stringstream ss;
  ss << "SELECT name, logic_id, id1, id2, id3, maps_to FROM channelView WHERE name = :name AND ";
  
  // loop through the three ids
  for (int i=1; i<=3; i++) {
    from = idArray[2*(i-1)];
    to   = idArray[2*(i-1) + 1];
    
    // check the id arguments in pairs
    if ((from == EcalLogicID::NULLID && to != EcalLogicID::NULLID) || // one is null
    (from != EcalLogicID::NULLID && to == EcalLogicID::NULLID) || //   but not the other
    (from > to)) { // negative interval
      throw(std::runtime_error("ERROR:  Bad arguments for getEcalLogicIDSet"));
    }
    
    // build the sql
    if (from == EcalLogicID::NULLID && to == EcalLogicID::NULLID) {
      ss << "id" << i << " IS NULL AND ";
    } else {
      ss << "id" << i << " >= :id" << i << "from AND " <<
    "id" << i << " <= :id" << i << "to AND ";
    }
  }
  ss << "maps_to = :maps_to ORDER BY id1, id2, id3";
  
  std::vector<EcalLogicID> result;
  
  try {
    stmt->setSQL(ss.str());

    // bind the parameters
    int j = 1;  // parameter number counter
    stmt->setString(j, name);
    j++;
    
    for (int i=0; i<3; i++) {
      from = idArray[2*i];
      to   = idArray[2*i + 1];
      if (from != EcalLogicID::NULLID) {
    stmt->setInt(j, from);
    j++;
    stmt->setInt(j, to);
    j++;
      }
    }

    stmt->setString(j, mapsTo);

  
    stmt->setPrefetchRowCount(IDBObject::ECALDB_NROWS);    

    ResultSet* rset = stmt->executeQuery();

    int id1, id2, id3, logicId;

    while (rset->next()) {
      name = rset->getString(1);
      logicId = rset->getInt(2);
      id1 = rset->getInt(3);
      if (rset->isNull(3)) { id1 = EcalLogicID::NULLID; }
      id2 = rset->getInt(4);
      if (rset->isNull(4)) { id2 = EcalLogicID::NULLID; }
      id3 = rset->getInt(5);
      if (rset->isNull(5)) { id3 = EcalLogicID::NULLID; }
      mapsTo = rset->getString(6);

      EcalLogicID ecid = EcalLogicID( name, logicId, id1, id2, id3, mapsTo );
      result.push_back(ecid);
    }
    stmt->setPrefetchRowCount(0);

  } catch (SQLException &e) {
    throw(std::runtime_error(std::string("ERROR:  Failure while getting EcalLogicID set:  ") + e.getMessage()));    
  }

  return result;
}

std::vector< EcalLogicID > EcalCondDBInterface::getEcalLogicIDSetOrdered ( std::string  name, int  fromId1, int  toId1, int  fromId2 = EcalLogicID::NULLID, int  toId2 = EcalLogicID::NULLID, int  fromId3 = EcalLogicID::NULLID, int  toId3 = EcalLogicID::NULLID, std::string  mapsTo = "", int  orderedBy = EcalLogicID::NULLID  )

noexcept

Definition at line 400 of file EcalCondDBInterface.cc.

References MillePedeFileConverter_cfg::e, IDBObject::ECALDB_NROWS, mps_fire::i, globals_cff::id1, globals_cff::id2, dataset::name, EcalLogicID::NULLID, mps_fire::result, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by EcalTPGParamBuilder::analyze(), getDateHandler(), popcon::EcalTPGWeightGroupHandler::getNewObjects(), popcon::EcalTPGBadStripHandler::getNewObjects(), popcon::EcalTPGBadTTHandler::getNewObjects(), popcon::EcalTPGBadXTHandler::getNewObjects(), popcon::EcalTPGFineGrainTowerEEHandler::getNewObjects(), popcon::EcalLaserHandler::getNewObjects(), popcon::EcalTPGSlidingWindowHandler::getNewObjects(), popcon::EcalTPGFineGrainStripEEHandler::getNewObjects(), popcon::EcalTPGLutGroupHandler::getNewObjects(), and popcon::EcalDCSHandler::getNewObjects().

{
  if (mapsTo.empty()) {
    mapsTo = name;
  }
  
  int idArray[] = { fromId1, toId1, fromId2, toId2, fromId3, toId3 };
  int from, to;
  
  stringstream ss;
  ss << "SELECT name, logic_id, id1, id2, id3, maps_to FROM channelView WHERE name = :name AND ";
  
  // loop through the three ids
  for (int i=1; i<=3; i++) {
    from = idArray[2*(i-1)];
    to   = idArray[2*(i-1) + 1];
    
    // check the id arguments in pairs
    if ((from == EcalLogicID::NULLID && to != EcalLogicID::NULLID) || // one is null
    (from != EcalLogicID::NULLID && to == EcalLogicID::NULLID) || //   but not the other
    (from > to)) { // negative interval
      throw(std::runtime_error("ERROR:  Bad arguments for getEcalLogicIDSet"));
    }
    
    // build the sql
    if (from == EcalLogicID::NULLID && to == EcalLogicID::NULLID) {
      ss << "id" << i << " IS NULL AND ";
    } else {
      ss << "id" << i << " >= :id" << i << "from AND " <<
    "id" << i << " <= :id" << i << "to AND ";
    }
  }
  ss << "maps_to = :maps_to ";

  if(orderedBy==EcalLogicID::NULLID){
    ss<<"  ORDER BY id1, id2, id3";
  } else if(orderedBy==1 || orderedBy==12 || orderedBy==123){
    ss<<"  ORDER BY id1, id2, id3 ";
  } else if (orderedBy==213 || orderedBy==21 ){ 
    ss<<"  ORDER BY id2, id1, id3 ";
  } else if (orderedBy==231|| orderedBy==23){ 
    ss<<"  ORDER BY id2, id3, id1 ";
  } else if (orderedBy==321|| orderedBy==32){
    ss<<"  ORDER BY id3, id2, id1 ";
  } else if (orderedBy==312|| orderedBy==31){
    ss<<"  ORDER BY id3, id1, id2 ";
  } else if (orderedBy==132|| orderedBy==13){ 
    ss<<"  ORDER BY id1, id3, id2 ";
  } else if (orderedBy==1234 ){ 
    ss<<"  ORDER BY id1, id2, id3, logic_id ";
  } else if (orderedBy==4) {
    ss<<"  ORDER BY logic_id ";
  } else {
    ss<<"  ORDER BY id1, id2, id3";
  }
  
  std::vector<EcalLogicID> result;
  
  try {
    stmt->setSQL(ss.str());

    // bind the parameters
    int j = 1;  // parameter number counter
    stmt->setString(j, name);
    j++;
    
    for (int i=0; i<3; i++) {
      from = idArray[2*i];
      to   = idArray[2*i + 1];
      if (from != EcalLogicID::NULLID) {
    stmt->setInt(j, from);
    j++;
    stmt->setInt(j, to);
    j++;
      }
    }

    stmt->setString(j, mapsTo);

  
    stmt->setPrefetchRowCount(IDBObject::ECALDB_NROWS);    

    ResultSet* rset = stmt->executeQuery();

    int id1, id2, id3, logicId;

    while (rset->next()) {
      name = rset->getString(1);
      logicId = rset->getInt(2);
      id1 = rset->getInt(3);
      if (rset->isNull(3)) { id1 = EcalLogicID::NULLID; }
      id2 = rset->getInt(4);
      if (rset->isNull(4)) { id2 = EcalLogicID::NULLID; }
      id3 = rset->getInt(5);
      if (rset->isNull(5)) { id3 = EcalLogicID::NULLID; }
      mapsTo = rset->getString(6);

      EcalLogicID ecid = EcalLogicID( name, logicId, id1, id2, id3, mapsTo );
      result.push_back(ecid);
    }
    stmt->setPrefetchRowCount(0);

  } catch (SQLException &e) {
    throw(std::runtime_error(std::string("ERROR:  Failure while getting EcalLogicID set:  ") + e.getMessage()));    
  }

  return result;
}

std::map<int, int> EcalCondDBInterface::getLogicId2DetIdMap ( )

inline

Definition at line 708 of file EcalCondDBInterface.h.

References _logicId2DetId, and fillLogicId2DetIdMaps().

                                                {
    if (_logicId2DetId.empty()) {
      fillLogicId2DetIdMaps();
    }
    return _logicId2DetId;
  }

int EcalCondDBInterface::getLogicIdFromDetId ( int  det_id )

inline

Definition at line 697 of file EcalCondDBInterface.h.

References _detId2LogicId, _logicId2DetId, and fillLogicId2DetIdMaps().

                                             {
    int logic_id = -1;
    if (_logicId2DetId.empty()) {
      fillLogicId2DetIdMaps();
    }
    if (_detId2LogicId.find(det_id) != _detId2LogicId.end()) {
      logic_id = _detId2LogicId[det_id];
    }
    return logic_id;
  }

template<class DATT , class ICONF >

void EcalCondDBInterface::insertConfigDataArraySet ( const std::vector< DATT > &  data, ICONF *  iconf  )

inlinenoexcept

Definition at line 521 of file EcalCondDBInterface.h.

References EcalDBConnection::conn, gather_cfg::cout, data, MillePedeFileConverter_cfg::e, and EcalDBConnection::env.

Referenced by EcalDccWeightBuilder::writeWeightToDB().

  {
    try {
      iconf->setConnection(env, conn);
      // if it has not yet been written then write 
      if(iconf->getId()==0){
    std::cout<<"EcalCondDBInterface>> config_id was not set we retrieve it from DB"<<std::endl;
    iconf->fetchID();
      } 
      if(iconf->getId()==0){
    std::cout<<"EcalCondDBInterface>> configuration info was not written we write it"<<std::endl;
    iconf->writeDB();
      } 
      
      DATT dataIface;
      dataIface.setConnection(env, conn);
      dataIface.prepareWrite();
      
      dataIface.writeArrayDB(data, iconf);
      conn->commit();
      
      dataIface.terminateWriteStatement();
   
    } catch (std::runtime_error &e) {
      conn->rollback();
      throw(e);
    } catch (...) {
      conn->rollback();
      throw(std::runtime_error("EcalCondDBInterface::insertConfigDataArraySet:  Unknown exception caught"));
    }
  }

template<class DATT , class ICONF >

void EcalCondDBInterface::insertConfigDataSet ( const std::vector< DATT >  data, ICONF *  iconf  )

inlinenoexcept

Definition at line 482 of file EcalCondDBInterface.h.

References EcalDBConnection::conn, gather_cfg::cout, data, MillePedeFileConverter_cfg::e, EcalDBConnection::env, and AlCaHLTBitMon_ParallelJobs::p.

  {
    try {
      iconf->setConnection(env, conn);
      // if it has not yet been written then write 
      if(iconf->getId()==0){
    std::cout<<"EcalCondDBInterface>> config_id was not set we retrieve it from DB"<<std::endl;
    iconf->fetchID();
      } 
      if(iconf->getId()==0){
    std::cout<<"EcalCondDBInterface>> configuration info was not written we write it"<<std::endl;
    iconf->writeDB();
      } 
      
      DATT dataIface;
      dataIface.setConnection(env, conn);
      dataIface.prepareWrite();
      
      const DATT* dataitem;

      for (int p = 0; p != data->size(); ++p) {
    dataitem = data[p];
    dataIface.writeDB( dataitem, iconf);
      }
      conn->commit();
      dataIface.terminateWriteStatement();
    } catch (std::runtime_error &e) {
      conn->rollback();
      throw(e);
    } catch (...) {
      conn->rollback();
      throw(std::runtime_error("EcalCondDBInterface::insertConfigDataSet:  Unknown exception caught"));
    }
  }

template<class ICONF >

void EcalCondDBInterface::insertConfigSet ( ICONF *  iconf )

inlinenoexcept

Definition at line 424 of file EcalCondDBInterface.h.

References EcalDBConnection::conn, gather_cfg::cout, MillePedeFileConverter_cfg::e, and EcalDBConnection::env.

Referenced by EcalDccWeightBuilder::writeWeightToDB().

   {
     try {
       iconf->setConnection(env, conn);
       iconf->prepareWrite();
       // if it has not yet been written then write 
       iconf->writeDB();
       std::cout<< "iconf inserted with ID="<<iconf->getId()<<std::endl;
       conn->commit();
       iconf->terminateWriteStatement();
     } catch (std::runtime_error &e) {
       conn->rollback();
       throw(e);
     } catch (...) {
       conn->rollback();
       throw(std::runtime_error("EcalCondDBInterface::insertDataSet:  Unknown exception caught"));
     }
   }

template<class DATT , class IOVT >

void EcalCondDBInterface::insertDataArraySet ( const std::map< EcalLogicID, DATT > *  data, IOVT *  iov  )

inlinenoexcept

Definition at line 347 of file EcalCondDBInterface.h.

References EcalDBConnection::conn, gather_cfg::cout, data, MillePedeFileConverter_cfg::e, EcalDBConnection::env, DCUIOV::fetchID(), DCUIOV::getID(), IDBObject::setConnection(), and DCUIOV::writeDB().

Referenced by ecaldqm::IntegrityWriter::run(), ecaldqm::LaserWriter::run(), ecaldqm::PedestalWriter::run(), ecaldqm::PresampleWriter::run(), ecaldqm::TestPulseWriter::run(), ecaldqm::TimingWriter::run(), ecaldqm::LedWriter::run(), and ecaldqm::OccupancyWriter::run().

  {
    try {
      iov->setConnection(env, conn);
      if(iov->getID()==0){
    std::cout<<"IOV was not set we retrieve it from DB"<<std::endl;
    iov->fetchID();
      } 
      if(iov->getID()==0){
    std::cout<<"IOV was not written we write it"<<std::endl;
    iov->writeDB();
      } 

      std::cout<<"id="<<iov->getID()<<std::endl;

      DATT dataIface;
      dataIface.setConnection(env, conn);
      dataIface.prepareWrite();
      
      dataIface.writeArrayDB(data, iov);
      conn->commit();
      
      dataIface.terminateWriteStatement();
   
    } catch (std::runtime_error &e) {
      conn->rollback();
      throw(e);
    } catch (...) {
      conn->rollback();
      throw(std::runtime_error("EcalCondDBInterface::insertDataSet:  Unknown exception caught"));
    }
  }

template<class DATT , class IOVT >

void EcalCondDBInterface::insertDataSet ( const std::map< EcalLogicID, DATT > *  data, IOVT *  iov  )

inlinenoexcept

Definition at line 307 of file EcalCondDBInterface.h.

References EcalDBConnection::conn, gather_cfg::cout, data, MillePedeFileConverter_cfg::e, EcalDBConnection::env, DCUIOV::fetchID(), DCUIOV::getID(), AlCaHLTBitMon_ParallelJobs::p, IDBObject::setConnection(), and DCUIOV::writeDB().

Referenced by ecaldqm::TestPulseWriter::run(), ecaldqm::SummaryWriter::run(), and EcalPedOffset::writeDb().

  {
    try {
      iov->setConnection(env, conn);
      // if it has not yet been written then write 
      if(iov->getID()==0){
    std::cout<<"IOV was not set we retrieve it from DB"<<std::endl;
    iov->fetchID();
      } 
      if(iov->getID()==0){
    std::cout<<"IOV was not written we write it"<<std::endl;
    iov->writeDB();
      } 
      
      DATT dataIface;
      dataIface.setConnection(env, conn);
      dataIface.prepareWrite();
      
      const EcalLogicID* channel;
      const DATT* dataitem;
      typedef typename std::map< EcalLogicID, DATT >::const_iterator CI;
      for (CI p = data->begin(); p != data->end(); ++p) {
    channel = &(p->first);
    dataitem = &(p->second);
    dataIface.writeDB( channel, dataitem, iov);
      }
      conn->commit();
      dataIface.terminateWriteStatement();
    } catch (std::runtime_error &e) {
      conn->rollback();
      throw(e);
    } catch (...) {
      conn->rollback();
      throw(std::runtime_error("EcalCondDBInterface::insertDataSet:  Unknown exception caught"));
    }
  }

template<class DATT , class IOVT >

void EcalCondDBInterface::insertDataSetVector ( const std::vector< EcalLogicID > &  ecid, const std::vector< IOVT > &  run_iov, const std::vector< DATT > &  data  )

inlinenoexcept

Definition at line 382 of file EcalCondDBInterface.h.

References EcalDBConnection::conn, data, MillePedeFileConverter_cfg::e, EcalDBConnection::env, and mps_fire::i.

  {
   
    int nruns= run_iov.size();
   
    if(run_iov.size()!=ecid.size() &&ecid.size()!=data.size()){
      throw(std::runtime_error("EcalCondDBInterface::insertDataSetVector:  vector sizes are different.."));
    } 


    try {
      
      DATT dataIface;
      dataIface.setConnection(env, conn);
      dataIface.prepareWrite();

      for (int i=0; i<nruns; i++){

    run_iov[i].setConnection(env, conn);
    run_iov[i].writeDB();
      
    dataIface.writeDB( &ecid[i], &data[i], &run_iov[i]);
    
    conn->commit();
      }
    } catch (std::runtime_error &e) {
      conn->rollback();
      throw(e);
    } catch (...) {
      conn->rollback();
      throw(std::runtime_error("EcalCondDBInterface::insertDataSet:  Unknown exception caught"));
    }
  }

void EcalCondDBInterface::insertDCUIOV ( DCUIOV *  iov )

noexcept

Insert a DCU IOV object. Nothing is committed in the event of an exception

Definition at line 708 of file EcalCondDBInterface.cc.

References MillePedeFileConverter_cfg::e, and web.browse_db::env.

Referenced by getDateHandler().

{
  try {
    iov->setConnection(env, conn);
    iov->writeDB();
  } catch(std::runtime_error &e) {
    conn->rollback();
    throw(e);
  }
  conn->commit();
}

void EcalCondDBInterface::insertLmfDat ( LMFDat *  dat )

noexcept

Definition at line 570 of file EcalCondDBInterface.cc.

References MillePedeFileConverter_cfg::e, and web.browse_db::env.

Referenced by getDateHandler().

{
  try {
    dat->setConnection(env, conn);
    dat->writeDB();
  } catch(std::runtime_error &e) {
    conn->rollback();
    throw(e);
  }
  conn->commit();
}

void EcalCondDBInterface::insertLmfDat ( std::list< LMFDat * >  dat )

noexcept

Definition at line 583 of file EcalCondDBInterface.cc.

References MillePedeFileConverter_cfg::e, web.browse_db::env, and mps_fire::i.

{
  try {
    std::list<LMFDat *>::iterator i = dat.begin();
    std::list<LMFDat *>::iterator e = dat.end();
    while (i != e) {
      (*i)->setConnection(env, conn);
      (*i)->writeDB();
      i++;
    }
  } catch(std::runtime_error &e) {
    conn->rollback();
    throw(e);
  }
  conn->commit();
}

void EcalCondDBInterface::insertLmfIOV ( LMFIOV *  iov )

noexcept

Definition at line 557 of file EcalCondDBInterface.cc.

References MillePedeFileConverter_cfg::e, and web.browse_db::env.

Referenced by getDateHandler().

{
  try {
    iov->setConnection(env, conn);
    iov->writeDB();
  } catch(std::runtime_error &e) {
    conn->rollback();
    throw(e);
  }
  conn->commit();
}

void EcalCondDBInterface::insertLmfLmrSubIOV ( LMFLmrSubIOV *  iov )

noexcept

Definition at line 544 of file EcalCondDBInterface.cc.

References MillePedeFileConverter_cfg::e, and web.browse_db::env.

Referenced by getDateHandler().

{
  try {
    iov->setConnection(env, conn);
    iov->writeDB();
  } catch(std::runtime_error &e) {
    conn->rollback();
    throw(e);
  }
  conn->commit();
}

void EcalCondDBInterface::insertLmfRunIOV ( LMFRunIOV *  iov )

noexcept

Definition at line 601 of file EcalCondDBInterface.cc.

References MillePedeFileConverter_cfg::e, and web.browse_db::env.

Referenced by getDateHandler().

{
  try {
    iov->setConnection(env, conn);
    iov->writeDB();
  } catch(std::runtime_error &e) {
    conn->rollback();
    throw(e);
  }
  conn->commit();
}

void EcalCondDBInterface::insertLmfSeq ( LMFSeqDat *  iov )

noexcept

Definition at line 531 of file EcalCondDBInterface.cc.

References MillePedeFileConverter_cfg::e, and web.browse_db::env.

Referenced by getDateHandler().

{
  try {
    iov->setConnection(env, conn);
    iov->writeDB();
  } catch(std::runtime_error &e) {
    conn->rollback();
    throw(e);
  }
  conn->commit();
}

void EcalCondDBInterface::insertMonRunIOV ( MonRunIOV *  iov )

noexcept

Insert a monitoring run object. Nothing is committed in the event of an exception

Definition at line 695 of file EcalCondDBInterface.cc.

References MillePedeFileConverter_cfg::e, and web.browse_db::env.

Referenced by EcalCondDBWriter::dqmEndJob(), and getDateHandler().

{
  try {
    iov->setConnection(env, conn);
    iov->writeDB();
  } catch(std::runtime_error &e) {
    conn->rollback();
    throw(e);
  }
  conn->commit();
}

void EcalCondDBInterface::insertRunIOV ( RunIOV *  iov )

noexcept

Insert a run IOV object. Nothing is committed in the event of an exception

Definition at line 518 of file EcalCondDBInterface.cc.

References MillePedeFileConverter_cfg::e, and web.browse_db::env.

Referenced by EcalCondDBWriter::dqmEndJob(), and getDateHandler().

{
  try {
    iov->setConnection(env, conn);
    iov->writeDB();
  } catch(std::runtime_error &e) {
    conn->rollback();
    throw(e);
  }
  conn->commit();
}

void EcalCondDBInterface::updateRunConfig ( ODRunConfigInfo *  od )

noexcept

Definition at line 653 of file EcalCondDBInterface.cc.

References MillePedeFileConverter_cfg::e, and web.browse_db::env.

Referenced by getDateHandler().

{
  try {
    od->setConnection(env, conn);
    od->updateDefaultCycle();
  } catch(std::runtime_error &e) {
    conn->rollback();
    throw(e);
  }
  conn->commit();
}

void EcalCondDBInterface::updateRunIOV ( RunIOV *  iov )

noexcept

Definition at line 614 of file EcalCondDBInterface.cc.

References MillePedeFileConverter_cfg::e, and web.browse_db::env.

Referenced by getDateHandler().

{
  try {
    iov->setConnection(env, conn);
    iov->updateEndTimeDB();
  } catch(std::runtime_error &e) {
    conn->rollback();
    throw(e);
  }
  conn->commit();
}

void EcalCondDBInterface::updateRunIOVEndTime ( RunIOV *  iov )

noexcept

Definition at line 627 of file EcalCondDBInterface.cc.

References MillePedeFileConverter_cfg::e, and web.browse_db::env.

Referenced by getDateHandler().

{
  try {
    iov->setConnection(env, conn);
    iov->updateEndTimeDB();
  } catch(std::runtime_error &e) {
    conn->rollback();
    throw(e);
  }
  conn->commit();
}

void EcalCondDBInterface::updateRunIOVStartTime ( RunIOV *  iov )

noexcept

Definition at line 640 of file EcalCondDBInterface.cc.

References MillePedeFileConverter_cfg::e, and web.browse_db::env.

Referenced by getDateHandler().

{
  try {
    iov->setConnection(env, conn);
    iov->updateStartTimeDB();
  } catch(std::runtime_error &e) {
    conn->rollback();
    throw(e);
  }
  conn->commit();
}

Member Data Documentation

std::map<int, int> EcalCondDBInterface::_detId2LogicId

private

Definition at line 742 of file EcalCondDBInterface.h.

Referenced by getDetId2LogicIdMap(), and getLogicIdFromDetId().

std::map<int, int> EcalCondDBInterface::_logicId2DetId

private

Definition at line 741 of file EcalCondDBInterface.h.

Referenced by getDetId2LogicIdMap(), getDetIdFromLogicId(), getLogicId2DetIdMap(), and getLogicIdFromDetId().

DateHandler* EcalCondDBInterface::dh

private

Definition at line 736 of file EcalCondDBInterface.h.

Referenced by EcalCondDBInterface(), getDateHandler(), and ~EcalCondDBInterface().