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::shared_ptr< T >	fetchPayload (const cond::Hash &payloadHash)
bool	fetchPayloadData (const cond::Hash &payloadHash, std::string &payloadType, cond::Binary &payloadData, cond::Binary &streamerInfoData)
bool	getIovRange (const std::string &tag, cond::Time_t begin, cond::Time_t end, std::vector< std::tuple< cond::Time_t, cond::Hash > > &range)
RunInfoProxy	getRunInfo (cond::Time_t start, cond::Time_t end)
IOVProxy	iovProxy ()
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, bool full=false)
IOVProxy	readIov (const std::string &tag, const boost::posix_time::ptime &snapshottime, bool full=false)
	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 62 of file Session.h.

Constructor & Destructor Documentation

Session::Session

(

)

Definition at line 38 of file Session.cc.

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

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

explicit

Definition at line 43 of file Session.cc.

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

Session::Session

(

const Session &

rhs

)

Definition at line 48 of file Session.cc.

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

Session::~Session ( )

virtual

Definition at line 53 of file Session.cc.

                     {
    }

Member Function Documentation

void Session::clearIov

(

const std::string &

tag

)

Definition at line 155 of file Session.cc.

References m_session.

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

void Session::close

(

void

)

Definition at line 62 of file Session.cc.

References m_session.

Referenced by cond::persistency::PayloadReader::close(), popcon::L1RPCHwConfigSourceHandler::DisconnectOnlineDB(), popcon::RPCEMapSourceHandler::DisconnectOnlineDB(), lumiQTWidget.ApplicationWindow::fileQuit(), FillInfoPopConSourceHandler::getNewObjects(), DTLVStatusHandler::getNewObjects(), DTHVStatusHandler::getNewObjects(), esMonitoring.AsyncLineReaderMixin::handle_close(), esMonitoring.FDJsonServer::handle_close(), Vispa.Gui.BoxContentDialog.BoxContentDialog::keyPressEvent(), Vispa.Gui.FindDialog.FindDialog::keyPressEvent(), and l1t::DataManager::~DataManager().

                       {
      m_session->close();
    }

std::string Session::connectionString

(

)

Definition at line 224 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;
    }

coral::ISessionProxy & Session::coralSession

(

)

Definition at line 228 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(), LHCInfoPopConSourceHandler::getDipData(), 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; 
    }

void Session::createDatabase

(

)

Definition at line 77 of file Session.cc.

References m_session.

Referenced by cond::persistency::importIovs(), and cond::service::PoolDBOutputService::initDB().

                                {
      m_session->openDb();
    }

GTEditor Session::createGlobalTag

(

const std::string &

name

)

Definition at line 165 of file Session.cc.

References idDealer::editor, m_session, 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;
    }

template<typename T >

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

inline

Definition at line 185 of file Session.h.

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

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

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

Definition at line 115 of file Session.cc.

References idDealer::editor, m_session, 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;
    }

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 124 of file Session.cc.

References idDealer::editor, m_session, 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;
    }

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

Definition at line 136 of file Session.cc.

References idDealer::editor, m_session, SiPixelClusterizer_cfi::payloadType, AlCaHLTBitMon_QueryRunRegistry::string, and cond::persistency::throwException().

Referenced by cond::service::PoolDBOutputService::createNewIOV().

                                                                     {
      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;      
    }

GTEditor Session::editGlobalTag

(

const std::string &

name

)

Definition at line 173 of file Session.cc.

References idDealer::editor, cond::persistency::GTEditor::load(), and m_session.

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

IOVEditor Session::editIov

(

const std::string &

tag

)

Definition at line 148 of file Session.cc.

References idDealer::editor, cond::persistency::IOVEditor::load(), and m_session.

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

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

RunInfoEditor Session::editRunInfo

(

)

Definition at line 218 of file Session.cc.

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

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

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

bool Session::existsDatabase

(

)

Definition at line 71 of file Session.cc.

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

Referenced by SiStripDetVOffHandler::analyze(), cond::persistency::importIovs(), and cond::service::PoolDBOutputService::initDB().

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

bool Session::existsGlobalTag

(

const std::string &

name

)

Definition at line 160 of file Session.cc.

References m_session.

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

bool Session::existsIov

(

const std::string &

tag

)

Definition at line 97 of file Session.cc.

References m_session.

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

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

template<typename T >

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

inline

Definition at line 215 of file Session.h.

References MillePedeFileConverter_cfg::e, SiPixelClusterizer_cfi::payloadType, AlCaHLTBitMon_QueryRunRegistry::string, cond::persistency::throwException(), and cms::Exception::what().

Referenced by SiStripDetVOffHandler::analyze(), SiStripDetVOffTkMapPlotter::analyze(), SiStripDetVOffTrendPlotter::analyze(), SiStripPayloadHandler< SiStripPayload >::analyze(), popcon::PopConBTransitionSourceHandler< T >::checkBOn(), cond::persistency::PayloadReader::fetch(), LHCInfoPopConSourceHandler::getNewObjects(), RunInfoUpdate::import(), L1ConfigOnlineProdBaseExt< TRcd, TData >::produce(), L1ConfigOnlineProdBase< TRcd, TData >::produce(), 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::shared_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;
    }

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

Definition at line 202 of file Session.cc.

References m_session.

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

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

bool Session::getIovRange	(	const std::string &	tag,
		cond::Time_t	begin,
		cond::Time_t	end,
		std::vector< std::tuple< cond::Time_t, cond::Hash > > &	range
	)

Definition at line 108 of file Session.cc.

References m_session, and loadRecoTauTagMVAsFromPrepDB_cfi::snapshotTime.

Referenced by cond::payloadInspector::PlotBase::process().

                                                                  {
      m_session->openIovDb();
      boost::posix_time::ptime snapshotTime;
      return m_session->iovSchema().iovTable().getRange( tag, begin, end, snapshotTime, range );
    }

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

Definition at line 210 of file Session.cc.

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

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

IOVProxy Session::iovProxy

(

)

Definition at line 102 of file Session.cc.

References m_session.

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

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

coral::ISchema & Session::nominalSchema

(

)

Definition at line 233 of file Session.cc.

References coralSession().

Referenced by DTHVStatusHandler::checkForPeriod(), DTHVStatusHandler::checkNewData(), DTHVStatusHandler::createSnapshot(), DTHVStatusHandler::dumpHVAliases(), DTHVStatusHandler::dumpSnapshot(), DTHVStatusHandler::getChannelMap(), DTHVStatusHandler::getChannelSplit(), LHCInfoPopConSourceHandler::getEcalData(), DTHVStatusHandler::getLayerSplit(), LHCInfoPopConSourceHandler::getLumiData(), FillInfoPopConSourceHandler::getNewObjects(), LHCInfoImpl::makeFillDataQuery(), popcon::RPCEMapSourceHandler::readEMap1(), popcon::L1RPCHwConfigSourceHandler::readHwConfig1(), and DTHVStatusHandler::recoverSnapshot().

                                        {
      return coralSession().nominalSchema();
    }

Session & Session::operator=

(

const Session &

rhs

)

Definition at line 56 of file Session.cc.

References m_session, and m_transaction.

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

GTProxy Session::readGlobalTag

(

const std::string &

name

)

Definition at line 180 of file Session.cc.

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

Referenced by CondDBESSource::fillTagCollectionFromGT().

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

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

Definition at line 187 of file Session.cc.

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

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

IOVProxy Session::readIov	(	const std::string &	tag,
		bool	full = false
	)

Definition at line 81 of file Session.cc.

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

Referenced by SiStripDetVOffHandler::analyze(), SiStripDetVOffTkMapPlotter::analyze(), SiStripDetVOffTrendPlotter::analyze(), SiStripPayloadHandler< SiStripPayload >::analyze(), popcon::PopConBTransitionSourceHandler< T >::checkBOn(), cond::persistency::copyIov(), popcon::PopConBTransitionSourceHandler< T >::getObjectsForBTransition(), RunInfoUpdate::import(), cond::persistency::importIovs(), popcon::PopCon::initialize(), cond::persistency::BasePayloadProxy::loadTag(), l1t::DataWriter::payloadToken(), l1t::DataWriterExt::payloadToken(), and cond::service::PoolDBOutputService::tagInfo().

                                                              {
      m_session->openIovDb();
      IOVProxy proxy( m_session );
      proxy.load( tag, full );
      return proxy;
    }

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

Definition at line 88 of file Session.cc.

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

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

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 189 of file Session.h.

References MillePedeFileConverter_cfg::e, cond::serialize(), AlCaHLTBitMon_QueryRunRegistry::string, cond::persistency::throwException(), and cms::Exception::what().

Referenced by SiStripDetVOffHandler::analyze(), SiStripPayloadHandler< SiStripPayload >::analyze(), l1t::WriterProxyT< Record, Type >::save(), l1t::DataWriter::writeKeyList(), and l1t::DataWriterExt::writeKeyList().

                                                                                                                           {
      
      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;
    }

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

Definition at line 194 of file Session.cc.

References m_session.

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

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

Transaction & Session::transaction

(

)

Definition at line 66 of file Session.cc.

References m_transaction.

Referenced by SiStripDetVOffHandler::analyze(), SiStripDetVOffTkMapPlotter::analyze(), SiStripPayloadHandler< SiStripPayload >::analyze(), SiStripDetVOffTrendPlotter::analyze(), cond::service::PoolDBOutputService::appendSinceTime(), popcon::PopConBTransitionSourceHandler< T >::checkBOn(), cond::service::PoolDBOutputService::closeIOV(), l1t::OMDSReader::connect(), cond::persistency::copyIov(), cond::service::PoolDBOutputService::createNewIOV(), cond::persistency::PayloadReader::fetch(), CondDBESSource::fillTagCollectionFromGT(), popcon::PopCon::finalize(), FillInfoPopConSourceHandler::getNewObjects(), LHCInfoPopConSourceHandler::getNewObjects(), DTLVStatusHandler::getNewObjects(), DTHVStatusHandler::getNewObjects(), popcon::PopConBTransitionSourceHandler< T >::getObjectsForBTransition(), cond::persistency::importIovs(), cond::service::PoolDBOutputService::initDB(), SiStripCoralIface::initialize(), popcon::PopCon::initialize(), cond::persistency::KeyList::load(), cond::persistency::BasePayloadProxy::loadTag(), cond::service::PoolDBOutputService::lookUpRecord(), l1t::OMDSReader::OMDSReader(), l1t::DataWriterExt::payloadToken(), l1t::DataWriter::payloadToken(), cond::service::PoolDBOutputService::postEndJob(), cond::payloadInspector::PlotBase::process(), L1ConfigOnlineProdBaseExt< TRcd, TData >::produce(), L1ConfigOnlineProdBase< TRcd, TData >::produce(), L1RCTOmdsFedVectorProducer::produce(), popcon::RPCEMapSourceHandler::readEMap1(), popcon::L1RPCHwConfigSourceHandler::readHwConfig1(), l1t::DataWriter::readObject(), l1t::WriterProxyT< Record, Type >::save(), cond::persistency::BasePayloadProxy::setIntervalFor(), l1t::DataWriter::writeKeyList(), l1t::DataWriterExt::writeKeyList(), l1t::DataWriter::writePayload(), cond::service::PoolDBOutputService::~PoolDBOutputService(), and popcon::PopCon::~PopCon().

                                     {
      return m_transaction;
    }

Member Data Documentation

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

private

Definition at line 181 of file Session.h.

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

Transaction cond::persistency::Session::m_transaction

private

Definition at line 182 of file Session.h.

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