#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.

53 {

54 }

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(), 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(), SiStripPayloadHandler< SiStripPayload >::analyze(), SiStripDetVOffTrendPlotter::analyze(), popcon::PopConBTransitionSourceHandler< T >::checkBOn(), cond::persistency::PayloadReader::fetch(), 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(), DTHVStatusHandler::getLayerSplit(), FillInfoPopConSourceHandler::getNewObjects(), 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(), 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().

Public Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation