cond::persistency::Session Class Reference

#include <Session.h>

Public Member Functions
void	clearIov (const std::string &tag)
void	close ()
std::string	connectionString ()
coral::ISessionProxy &	coralSession ()
void	createDatabase ()
GTEditor	createGlobalTag (const std::string &name)
template<typename T >
IOVEditor	createIov (const std::string &tag, cond::TimeType timeType, cond::SynchronizationType synchronizationType=cond::SYNCH_ANY)
IOVEditor	createIov (const std::string &payloadType, const std::string &tag, cond::TimeType timeType, cond::SynchronizationType synchronizationType=cond::SYNCH_ANY)
IOVEditor	createIov (const std::string &payloadType, const std::string &tag, cond::TimeType timeType, cond::SynchronizationType synchronizationType, const boost::posix_time::ptime &creationTime)
IOVEditor	createIovForPayload (const Hash &payloadHash, const std::string &tag, cond::TimeType timeType, cond::SynchronizationType synchronizationType=cond::SYNCH_ANY)
GTEditor	editGlobalTag (const std::string &name)
IOVEditor	editIov (const std::string &tag)
RunInfoEditor	editRunInfo ()
bool	existsDatabase ()
bool	existsGlobalTag (const std::string &name)
bool	existsIov (const std::string &tag)
template<typename T >
std::unique_ptr< T >	fetchPayload (const cond::Hash &payloadHash)
bool	fetchPayloadData (const cond::Hash &payloadHash, std::string &payloadType, cond::Binary &payloadData, cond::Binary &streamerInfoData)
cond::RunInfo_t	getLastRun ()
RunInfoProxy	getRunInfo (cond::Time_t start, cond::Time_t end)
coral::ISchema &	nominalSchema ()
Session &	operator= (const Session &rhs)
GTProxy	readGlobalTag (const std::string &name)
GTProxy	readGlobalTag (const std::string &name, const std::string &preFix, const std::string &postFix)
IOVProxy	readIov (const std::string &tag)
IOVProxy	readIov (const std::string &tag, const boost::posix_time::ptime &snapshottime)
	Session ()
	Session (const std::shared_ptr< SessionImpl > &sessionImpl)
	Session (const Session &rhs)
template<typename T >
cond::Hash	storePayload (const T &payload, const boost::posix_time::ptime &creationTime=boost::posix_time::microsec_clock::universal_time())
cond::Hash	storePayloadData (const std::string &payloadObjectType, const std::pair< Binary, Binary > &payloadAndStreamerInfoData, const boost::posix_time::ptime &creationTime)
Transaction &	transaction ()
virtual	~Session ()

Private Attributes
std::shared_ptr< SessionImpl >	m_session
Transaction	m_transaction

Detailed Description

Definition at line 63 of file Session.h.

Constructor & Destructor Documentation

Session() [1/3]

Session::Session

(

)

Definition at line 35 of file Session.cc.

: m_session(new SessionImpl), m_transaction(*m_session) {}

Session() [2/3]

Session::Session ( const std::shared_ptr< SessionImpl > &  sessionImpl )

explicit

Definition at line 37 of file Session.cc.

        : m_session(sessionImpl), m_transaction(*m_session) {}

Session() [3/3]

Session::Session

(

const Session &

rhs

)

Definition at line 40 of file Session.cc.

: m_session(rhs.m_session), m_transaction(rhs.m_transaction) {}

~Session()

Session::~Session ( )

virtual

Definition at line 42 of file Session.cc.

{}

Member Function Documentation

clearIov()

void Session::clearIov

(

const std::string &

tag

)

Definition at line 137 of file Session.cc.

References m_session, and makeGlobalPositionRcd_cfg::tag.

                                               {
      m_session->openIovDb();
      m_session->iovSchema().iovTable().erase(tag);
    }

close()

void Session::close

(

void

)

Definition at line 50 of file Session.cc.

References m_session.

Referenced by cond::persistency::PayloadReader::close(), FillInfoPopConSourceHandler::getNewObjects(), DTLVStatusHandler::getNewObjects(), DTHVStatusHandler::getNewObjects(), esMonitoring.AsyncLineReaderMixin::handle_close(), esMonitoring.FDJsonServer::handle_close(), and l1t::DataManager::~DataManager().

{ m_session->close(); }

connectionString()

std::string Session::connectionString

(

)

Definition at line 216 of file Session.cc.

References m_session.

Referenced by PCLMetadataWriter::endRun(), cond::persistency::PayloadReader::fetch(), cond::persistency::importIovs(), and popcon::PopCon::initialize().

{ return m_session->connectionString; }

coralSession()

coral::ISessionProxy & Session::coralSession

(

)

Definition at line 218 of file Session.cc.

References m_session, and cond::persistency::throwException().

Referenced by l1t::OMDSReader::basicQuery(), l1t::OMDSReader::basicQueryGenericKey(), l1t::OMDSReader::basicQueryView(), l1t::OMDSReader::columnNames(), l1t::OMDSReader::columnNamesView(), SiStripCoralIface::doNameQuery(), SiStripCoralIface::doQuery(), SiStripCoralIface::doSettingsQuery(), LHCInfoPopConSourceHandler::getCTTPSData(), LHCInfoPerLSPopConSourceHandler::getCTTPSData(), LHCInfoPerFillPopConSourceHandler::getCTTPSData(), FillInfoPopConSourceHandler::getNewObjects(), L1CaloHcalScaleConfigOnlineProd::newObject(), nominalSchema(), and L1RCTOmdsFedVectorProducer::produce().

                                              {
      if (!m_session->coralSession.get())
        throwException("The session is not active.", "Session::coralSession");
      return *m_session->coralSession;
    }

createDatabase()

void Session::createDatabase

(

)

Definition at line 61 of file Session.cc.

References m_session.

Referenced by cond::persistency::importIovs().

{ m_session->openDb(); }

createGlobalTag()

GTEditor Session::createGlobalTag

(

const std::string &

name

)

Definition at line 147 of file Session.cc.

References m_session, Skims_PA_cff::name, and cond::persistency::throwException().

                                                           {
      m_session->openGTDb();
      if (m_session->gtSchema().gtTable().select(name))
        throwException("The specified Global Tag \"" + name + "\" already exist in the database.",
                       "Session::createGlobalTag");
      GTEditor editor(m_session, name);
      return editor;
    }

createIov() [1/3]

template<typename T >

IOVEditor Session::createIov ( const std::string &  tag, cond::TimeType  timeType, cond::SynchronizationType  synchronizationType = cond::SYNCH_ANY  )

inline

Definition at line 179 of file Session.h.

References makeGlobalPositionRcd_cfg::tag.

Referenced by SiStripDetVOffHandler::analyze(), SiStripPayloadHandler< SiStripPayload >::analyze(), cond::persistency::copyIov(), popcon::PopConBTransitionSourceHandler< T >::getObjectsForBTransition(), popcon::PopConESTransitionSourceHandler< T >::getObjectsForESTransition(), cond::persistency::importIovs(), and cond::service::PoolDBOutputService::writeMany().

                                                                                     {
      return createIov(cond::demangledName(typeid(T)), tag, timeType, synchronizationType);
    }

createIov() [2/3]

IOVEditor Session::createIov	(	const std::string &	payloadType,
		const std::string &	tag,
		cond::TimeType	timeType,
		cond::SynchronizationType	synchronizationType = cond::SYNCH_ANY
	)

Definition at line 91 of file Session.cc.

References m_session, HLT_2023v12_cff::payloadType, makeGlobalPositionRcd_cfg::tag, and cond::persistency::throwException().

                                                                              {
      m_session->openDb();
      if (m_session->iovSchema().tagTable().select(tag))
        throwException("The specified tag \"" + tag + "\" already exist in the database.", "Session::createIov");
      IOVEditor editor(m_session, tag, timeType, payloadType, synchronizationType);
      return editor;
    }

createIov() [3/3]

IOVEditor Session::createIov	(	const std::string &	payloadType,
		const std::string &	tag,
		cond::TimeType	timeType,
		cond::SynchronizationType	synchronizationType,
		const boost::posix_time::ptime &	creationTime
	)

Definition at line 102 of file Session.cc.

References beamSpotPI::creationTime, m_session, HLT_2023v12_cff::payloadType, makeGlobalPositionRcd_cfg::tag, and cond::persistency::throwException().

                                                                           {
      m_session->openDb();
      if (m_session->iovSchema().tagTable().select(tag))
        throwException("The specified tag \"" + tag + "\" already exist in the database.", "Session::createIov");
      IOVEditor editor(m_session, tag, timeType, payloadType, synchronizationType, creationTime);
      return editor;
    }

createIovForPayload()

IOVEditor Session::createIovForPayload	(	const Hash &	payloadHash,
		const std::string &	tag,
		cond::TimeType	timeType,
		cond::SynchronizationType	synchronizationType = cond::SYNCH_ANY
	)

Definition at line 114 of file Session.cc.

References m_session, HLT_2023v12_cff::payloadType, AlCaHLTBitMon_QueryRunRegistry::string, makeGlobalPositionRcd_cfg::tag, and cond::persistency::throwException().

                                                                                        {
      m_session->openDb();
      if (m_session->iovSchema().tagTable().select(tag))
        throwException("The specified tag \"" + tag + "\" already exist in the database.",
                       "Session::createIovForPayload");
      std::string payloadType("");
      if (!m_session->iovSchema().payloadTable().getType(payloadHash, payloadType))
        throwException("The specified payloadId \"" + payloadHash + "\" does not exist in the database.",
                       "Session::createIovForPayload");
      IOVEditor editor(m_session, tag, timeType, payloadType, synchronizationType);
      return editor;
    }

editGlobalTag()

GTEditor Session::editGlobalTag

(

const std::string &

name

)

Definition at line 156 of file Session.cc.

References cond::persistency::GTEditor::load(), m_session, and Skims_PA_cff::name.

                                                         {
      m_session->openGTDb();
      GTEditor editor(m_session);
      editor.load(name);
      return editor;
    }

editIov()

IOVEditor Session::editIov

(

const std::string &

tag

)

Definition at line 130 of file Session.cc.

References cond::persistency::IOVEditor::load(), m_session, and makeGlobalPositionRcd_cfg::tag.

Referenced by SiStripDetVOffHandler::analyze(), cond::persistency::copyIov(), popcon::PopConBTransitionSourceHandler< T >::getObjectsForBTransition(), popcon::PopConESTransitionSourceHandler< T >::getObjectsForESTransition(), cond::persistency::importIovs(), and cond::service::PoolDBOutputService::writeMany().

                                                   {
      m_session->openIovDb();
      IOVEditor editor(m_session);
      editor.load(tag);
      return editor;
    }

editRunInfo()

RunInfoEditor Session::editRunInfo

(

)

Definition at line 210 of file Session.cc.

References cond::persistency::RunInfoEditor::init(), and m_session.

Referenced by RunInfoUpdate::appendNewRun(), and RunInfoUpdate::import().

                                       {
      RunInfoEditor editor(m_session);
      editor.init();
      return editor;
    }

existsDatabase()

bool Session::existsDatabase

(

)

Definition at line 55 of file Session.cc.

References cond::persistency::SessionImpl::DO_NOT_THROW, and m_session.

Referenced by SiStripDetVOffHandler::analyze(), cond::persistency::importIovs(), and popcon::PopCon::initialize().

                                 {
      m_session->openIovDb(SessionImpl::DO_NOT_THROW);
      return m_session->transaction->iovDbExists;
    }

existsGlobalTag()

bool Session::existsGlobalTag

(

const std::string &

name

)

Definition at line 142 of file Session.cc.

References m_session, and Skims_PA_cff::name.

                                                       {
      m_session->openGTDb();
      return m_session->gtSchema().gtTable().select(name);
    }

existsIov()

bool Session::existsIov

(

const std::string &

tag

)

Definition at line 77 of file Session.cc.

References m_session, and makeGlobalPositionRcd_cfg::tag.

Referenced by SiStripDetVOffHandler::analyze(), cond::persistency::copyIov(), popcon::PopConBTransitionSourceHandler< T >::getObjectsForBTransition(), popcon::PopConESTransitionSourceHandler< T >::getObjectsForESTransition(), cond::persistency::importIovs(), and popcon::PopCon::initialize().

                                                {
      m_session->openIovDb();
      return m_session->iovSchema().tagTable().select(tag);
    }

fetchPayload()

template<typename T >

std::unique_ptr< T > Session::fetchPayload ( const cond::Hash &  payloadHash )

inline

Definition at line 213 of file Session.h.

References MillePedeFileConverter_cfg::e, fetchPayloadData(), HLT_2023v12_cff::payloadType, runTheMatrix::ret, AlCaHLTBitMon_QueryRunRegistry::string, and cond::persistency::throwException().

Referenced by SiStripDetVOffHandler::analyze(), SiStripDetVOffTkMapPlotter::analyze(), SiStripDetVOffPrinter::analyze(), SiStripPayloadHandler< SiStripPayload >::analyze(), SiStripDetVOffTrendPlotter::analyze(), BeamSpotRcdPrinter::analyze(), FastSiPixelFEDChannelContainerFromQuality::analyze(), popcon::PopConBTransitionSourceHandler< T >::checkBOn(), cond::persistency::PayloadReader::fetch(), cond::payloadInspector::PlotBase::fetchPayload(), LHCInfoPopConSourceHandler::getNewObjects(), LHCInfoPerLSPopConSourceHandler::getNewObjects(), LHCInfoPerFillPopConSourceHandler::getNewObjects(), RunInfoUpdate::import(), popcon::PopConSourceHandler< CastorPedestals >::lastPayload(), cond::persistency::PayloadProxy< std::vector< cond::Time_t > >::loadPayload(), l1t::DataWriter::readObject(), and l1t::DataWriterExt::readObject().

                                                                             {
      cond::Binary payloadData;
      cond::Binary streamerInfoData;
      std::string payloadType;
      if (!fetchPayloadData(payloadHash, payloadType, payloadData, streamerInfoData))
        throwException("Payload with id " + payloadHash + " has not been found in the database.",
                       "Session::fetchPayload");
      std::unique_ptr<T> ret;
      try {
        ret = deserialize<T>(payloadType, payloadData, streamerInfoData);
      } catch (const cond::persistency::Exception& e) {
        std::string em(e.what());
        throwException("Payload of type " + payloadType + " with id " + payloadHash + " could not be loaded. " + em,
                       "Session::fetchPayload");
      }
      return ret;
    }

fetchPayloadData()

bool Session::fetchPayloadData	(	const cond::Hash &	payloadHash,
		std::string &	payloadType,
		cond::Binary &	payloadData,
		cond::Binary &	streamerInfoData
	)

Definition at line 185 of file Session.cc.

References m_session, and HLT_2023v12_cff::payloadType.

Referenced by cond::persistency::fetch(), cond::persistency::fetchIfExists(), fetchPayload(), and cond::persistency::importPayload().

                                                                 {
      m_session->openIovDb();
      return m_session->iovSchema().payloadTable().select(payloadHash, payloadType, payloadData, streamerInfoData);
    }

getLastRun()

cond::RunInfo_t Session::getLastRun

(

)

Definition at line 201 of file Session.cc.

References m_session, runTheMatrix::ret, and cond::persistency::throwException().

                                      {
      if (!m_session->transaction.get())
        throwException("The transaction is not active.", "Session::getRunInfo");
      m_session->openRunInfoDb();
      cond::RunInfo_t ret;
      ret.run = m_session->runInfoSchema().runInfoTable().getLastInserted(ret.start, ret.end);
      return ret;
    }

getRunInfo()

RunInfoProxy Session::getRunInfo	(	cond::Time_t	start,
		cond::Time_t	end
	)

Definition at line 193 of file Session.cc.

References cond::persistency::RunInfoProxy::load(), m_session, and cond::persistency::throwException().

Referenced by cond::payloadInspector::TimeHistoryPlot< PayloadType, std::pair< double, double > >::fill().

                                                                     {
      if (!m_session->transaction.get())
        throwException("The transaction is not active.", "Session::getRunInfo");
      RunInfoProxy proxy(m_session);
      proxy.load(start, end);
      return proxy;
    }

nominalSchema()

coral::ISchema & Session::nominalSchema

(

)

Definition at line 224 of file Session.cc.

References coralSession().

Referenced by DTHVStatusHandler::checkForPeriod(), DTHVStatusHandler::checkNewData(), DTHVStatusHandler::createSnapshot(), DTHVStatusHandler::dumpHVAliases(), DTHVStatusHandler::dumpSnapshot(), DTHVStatusHandler::getChannelMap(), DTHVStatusHandler::getChannelSplit(), LHCInfoPopConSourceHandler::getEcalData(), LHCInfoPerFillPopConSourceHandler::getEcalData(), DTHVStatusHandler::getLayerSplit(), FillInfoPopConSourceHandler::getNewObjects(), and DTHVStatusHandler::recoverSnapshot().

{ return coralSession().nominalSchema(); }

operator=()

Session & Session::operator=

(

const Session &

rhs

)

Definition at line 44 of file Session.cc.

References m_session, and m_transaction.

                                                  {
      m_session = rhs.m_session;
      m_transaction = rhs.m_transaction;
      return *this;
    }

readGlobalTag() [1/2]

GTProxy Session::readGlobalTag

(

const std::string &

name

)

Definition at line 163 of file Session.cc.

References cond::persistency::GTProxy::load(), m_session, and Skims_PA_cff::name.

Referenced by CondDBESSource::fillTagCollectionFromGT().

                                                        {
      m_session->openGTDb();
      GTProxy proxy(m_session);
      proxy.load(name);
      return proxy;
    }

readGlobalTag() [2/2]

GTProxy Session::readGlobalTag	(	const std::string &	name,
		const std::string &	preFix,
		const std::string &	postFix
	)

Definition at line 170 of file Session.cc.

References cond::persistency::GTProxy::load(), m_session, and Skims_PA_cff::name.

                                                                                                           {
      m_session->openGTDb();
      GTProxy proxy(m_session);
      proxy.load(name, preFix, postFix);
      return proxy;
    }

readIov() [1/2]

IOVProxy Session::readIov

(

const std::string &

tag

)

Definition at line 63 of file Session.cc.

References cond::persistency::IOVProxy::load(), m_session, and TauJetAlgoParameters_cfi::tagName.

Referenced by SiStripDetVOffHandler::analyze(), SiStripDetVOffTkMapPlotter::analyze(), SiStripDetVOffPrinter::analyze(), SiStripPayloadHandler< SiStripPayload >::analyze(), SiStripDetVOffTrendPlotter::analyze(), BeamSpotRcdPrinter::analyze(), FastSiPixelFEDChannelContainerFromQuality::analyze(), popcon::PopConBTransitionSourceHandler< T >::checkBOn(), popcon::PopConESTransitionSourceHandler< T >::checkLowGain(), cond::persistency::copyIov(), popcon::PopConBTransitionSourceHandler< T >::getObjectsForBTransition(), popcon::PopConESTransitionSourceHandler< T >::getObjectsForESTransition(), cond::payloadInspector::PlotBase::getTagInfo(), RunInfoUpdate::import(), cond::persistency::importIovs(), popcon::PopCon::initialize(), l1t::DataWriter::payloadToken(), l1t::DataWriterExt::payloadToken(), and cond::service::OnlineDBOutputService::preLoadIov().

                                                      {
      m_session->openIovDb();
      IOVProxy proxy(m_session);
      proxy.load(tagName);
      return proxy;
    }

readIov() [2/2]

IOVProxy Session::readIov	(	const std::string &	tag,
		const boost::posix_time::ptime &	snapshottime
	)

Definition at line 70 of file Session.cc.

References cond::persistency::IOVProxy::load(), m_session, and TauJetAlgoParameters_cfi::tagName.

                                                                                                {
      m_session->openIovDb();
      IOVProxy proxy(m_session);
      proxy.load(tagName, snapshottime);
      return proxy;
    }

storePayload()

template<typename T >

cond::Hash Session::storePayload ( const T &  payload, const boost::posix_time::ptime &  creationTime = boost::posix_time::microsec_clock::universal_time()  )

inline

Definition at line 186 of file Session.h.

References beamSpotPI::creationTime, MillePedeFileConverter_cfg::e, jetsAK4_Puppi_cff::payload, runTheMatrix::ret, cond::serialize(), storePayloadData(), AlCaHLTBitMon_QueryRunRegistry::string, and cond::persistency::throwException().

Referenced by SiStripDetVOffHandler::analyze(), SiStripPayloadHandler< SiStripPayload >::analyze(), cond::service::PoolDBOutputService::appendOneIOV(), cond::service::PoolDBOutputService::createOneIOV(), l1t::WriterProxyT< Record, Type >::save(), AlCaRecoTriggerBitsRcdUpdate::writeBitsToDB(), l1t::DataWriter::writeKeyList(), l1t::DataWriterExt::writeKeyList(), cond::service::PoolDBOutputService::writeMany(), and cond::service::PoolDBOutputService::writeOneIOV().

                                                                                                    {
      std::string payloadObjectType = cond::demangledName(typeid(payload));
      cond::Hash ret;
      try {
        ret = storePayloadData(payloadObjectType, serialize(payload), creationTime);
      } catch (const cond::persistency::Exception& e) {
        std::string em(e.what());
        throwException("Payload of type " + payloadObjectType + " could not be stored. " + em, "Session::storePayload");
      }
      return ret;
    }

storePayloadData()

cond::Hash Session::storePayloadData	(	const std::string &	payloadObjectType,
		const std::pair< Binary, Binary > &	payloadAndStreamerInfoData,
		const boost::posix_time::ptime &	creationTime
	)

Definition at line 177 of file Session.cc.

References beamSpotPI::creationTime, and m_session.

Referenced by cond::persistency::importPayload(), and storePayload().

                                                                                   {
      m_session->openDb();
      return m_session->iovSchema().payloadTable().insertIfNew(
          payloadObjectType, payloadAndStreamerInfoData.first, payloadAndStreamerInfoData.second, creationTime);
    }

transaction()

Transaction & Session::transaction

(

)

Definition at line 52 of file Session.cc.

References m_transaction.

Referenced by SiStripDetVOffHandler::analyze(), SiStripDetVOffTkMapPlotter::analyze(), SiStripDetVOffPrinter::analyze(), SiStripPayloadHandler< SiStripPayload >::analyze(), SiStripDetVOffTrendPlotter::analyze(), BeamSpotRcdPrinter::analyze(), FastSiPixelFEDChannelContainerFromQuality::analyze(), cond::service::PoolDBOutputService::appendOneIOV(), popcon::PopConBTransitionSourceHandler< T >::checkBOn(), popcon::PopConESTransitionSourceHandler< T >::checkLowGain(), l1t::OMDSReader::connect(), cond::persistency::copyIov(), cond::service::PoolDBOutputService::createOneIOV(), cond::persistency::PayloadReader::fetch(), CondDBESSource::fillTagCollectionFromGT(), popcon::PopCon::finalize(), FillInfoPopConSourceHandler::getNewObjects(), LHCInfoPopConSourceHandler::getNewObjects(), DTLVStatusHandler::getNewObjects(), DTHVStatusHandler::getNewObjects(), LHCInfoPerLSPopConSourceHandler::getNewObjects(), LHCInfoPerFillPopConSourceHandler::getNewObjects(), popcon::PopConBTransitionSourceHandler< T >::getObjectsForBTransition(), popcon::PopConESTransitionSourceHandler< T >::getObjectsForESTransition(), cond::persistency::importIovs(), popcon::PopCon::initialize(), SiStripCoralIface::initialize(), cond::persistency::PayloadProxy< std::vector< cond::Time_t > >::make(), l1t::OMDSReader::OMDSReader(), l1t::DataWriter::payloadToken(), l1t::DataWriterExt::payloadToken(), cond::service::OnlineDBOutputService::preLoadIov(), L1RCTOmdsFedVectorProducer::produce(), l1t::DataWriter::readObject(), l1t::DataWriterExt::readObject(), l1t::WriterProxyT< Record, Type >::save(), l1t::DataWriter::writeKeyList(), l1t::DataWriterExt::writeKeyList(), cond::service::PoolDBOutputService::writeMany(), cond::service::PoolDBOutputService::writeOneIOV(), l1t::DataWriter::writePayload(), and popcon::PopCon::~PopCon().

{ return m_transaction; }

Member Data Documentation

m_session

std::shared_ptr<SessionImpl> cond::persistency::Session::m_session

private

Definition at line 174 of file Session.h.

Referenced by clearIov(), close(), connectionString(), coralSession(), createDatabase(), createGlobalTag(), createIov(), createIovForPayload(), editGlobalTag(), editIov(), editRunInfo(), existsDatabase(), existsGlobalTag(), existsIov(), fetchPayloadData(), getLastRun(), getRunInfo(), operator=(), readGlobalTag(), readIov(), and storePayloadData().

m_transaction

Transaction cond::persistency::Session::m_transaction

private

Definition at line 175 of file Session.h.

Referenced by operator=(), and transaction().