#include <Session.h>

Public Member Functions
void	addMigratedPayload (const std::string &sourceAccount, const std::string &sourceToken, const std::string &payloadId)

void	addToMigrationLog (const std::string &sourceAccount, const std::string &sourceTag, const std::string &destinationTag, cond::MigrationStatus status)

bool	checkMigrationLog (const std::string &sourceAccount, const std::string &sourceTag, std::string &destinationTag, cond::MigrationStatus &status)

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)

bool	existsDatabase ()

bool	existsGlobalTag (const std::string &name)

bool	existsIov (const std::string &tag)

template<typename T >
boost::shared_ptr< T >	fetchPayload (const cond::Hash &payloadHash)

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

IOVProxy	iovProxy ()

bool	isOraSession ()

bool	lookupMigratedPayload (const std::string &sourceAccount, const std::string &sourceToken, std::string &payloadId)

coral::ISchema &	nominalSchema ()

Session &	operator= (const Session &rhs)

std::string	parsePoolToken (const std::string &poolToken)

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())

Transaction &	transaction ()

void	updateMigratedPayload (const std::string &sourceAccount, const std::string &sourceToken, const std::string &payloadId)

void	updateMigrationLog (const std::string &sourceAccount, const std::string &sourceTag, cond::MigrationStatus status)

virtual	~Session ()

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

Private Attributes
std::shared_ptr< SessionImpl >	m_session

Transaction	m_transaction

Detailed Description

Definition at line 59 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::addMigratedPayload	(	const std::string &	sourceAccount,
		const std::string &	sourceToken,
		const std::string &	payloadId
	)

Definition at line 244 of file Session.cc.

References m_session.

                                                   {
       m_session->openIovDb();
       if(! m_session->iovSchema().payloadMigrationTable().exists() ) m_session->iovSchema().payloadMigrationTable().create();
       m_session->iovSchema().payloadMigrationTable().insert( sourceAccount, sourceToken, payloadId,
                                  boost::posix_time::microsec_clock::universal_time() );             
     }

void Session::addToMigrationLog	(	const std::string &	sourceAccount,
		const std::string &	sourceTag,
		const std::string &	destinationTag,
		cond::MigrationStatus	status
	)

Definition at line 217 of file Session.cc.

References m_session.

                                                 {
       m_session->openIovDb();
       if(! m_session->iovSchema().tagMigrationTable().exists() ) m_session->iovSchema().tagMigrationTable().create();
       m_session->iovSchema().tagMigrationTable().insert( sourceAccount, sourceTag, destTag,  (int)status,
                      boost::posix_time::microsec_clock::universal_time() );
     }

bool Session::checkMigrationLog	(	const std::string &	sourceAccount,
		const std::string &	sourceTag,
		std::string &	destinationTag,
		cond::MigrationStatus &	status
	)

Definition at line 207 of file Session.cc.

References m_session.

                                                   {
       m_session->openIovDb();
       if(! m_session->iovSchema().tagMigrationTable().exists() ) m_session->iovSchema().tagMigrationTable().create();
       //throwException( "Migration Log Table does not exist in this schema.","Session::checkMigrationLog");
       return m_session->iovSchema().tagMigrationTable().select( sourceAccount, sourceTag, destTag, (int&)status );
     }

void Session::clearIov ( const std::string & tag )

Definition at line 148 of file Session.cc.

References m_session.

Referenced by cond::persistency::copyTag(), and cond::persistency::migrateTag().

                                                 {
       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(), lumiQTWidget.ApplicationWindow::fileQuit(), esMonitoring.AsyncLineReaderMixin::handle_close(), esMonitoring.FDJsonServer::handle_close(), Vispa.Gui.BoxContentDialog.BoxContentDialog::keyPressEvent(), and Vispa.Gui.FindDialog.FindDialog::keyPressEvent().

                        {
       m_session->close();
     }

std::string Session::connectionString ( )

Definition at line 268 of file Session.cc.

References m_session.

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

                                        {
       return m_session->connectionString;
     }

coral::ISessionProxy & Session::coralSession ( )

Definition at line 272 of file Session.cc.

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

Referenced by nominalSchema().

                                              {
       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::copyTag(), cond::persistency::importIovs(), and cond::persistency::migrateTag().

                                 {
       m_session->openDb();
     }

GTEditor Session::createGlobalTag ( const std::string & name )

Definition at line 158 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 198 of file Session.h.

References ora::ClassUtils::demangledName().

Referenced by cond::persistency::copyIov(), cond::persistency::copyTag(), cond::persistency::importIovs(), and cond::persistency::migrateTag().

                                                                                                                                                        {
       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 108 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 117 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 129 of file Session.cc.

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

GTEditor Session::editGlobalTag ( const std::string & name )

Definition at line 166 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 141 of file Session.cc.

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

Referenced by cond::persistency::copyIov(), cond::persistency::copyTag(), cond::persistency::importIovs(), and cond::persistency::migrateTag().

                                                     {
       m_session->openIovDb();
       IOVEditor editor( m_session );
       editor.load( tag );
       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 cond::persistency::copyTag(), cond::persistency::importIovs(), and cond::persistency::migrateTag().

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

bool Session::existsGlobalTag ( const std::string & name )

Definition at line 153 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 cond::persistency::copyIov(), cond::persistency::copyTag(), cond::persistency::importIovs(), popcon::PopCon::initialize(), and cond::persistency::migrateTag().

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

template<typename T >

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

inline

Definition at line 215 of file Session.h.

References alignCSCRings::e, fetchPayloadData(), isOraSession(), HLT_25ns14e33_v1_cff::payloadType, run_regression::ret, AlCaHLTBitMon_QueryRunRegistry::string, cond::persistency::throwException(), and cms::Exception::what().

Referenced by cond::persistency::PayloadReader::fetch(), cond::persistency::PayloadProxy< std::vector< cond::Time_t > >::loadPayload(), l1t::DataWriter::readObject(), and popcon::PopConSourceHandler< T >::Ref::Ref().

                                                                                                       {
       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" );
       boost::shared_ptr<T> ret;
       try{ 
     ret = deserialize<T>(  payloadType, payloadData, streamerInfoData, isOraSession() );
       } 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 195 of file Session.cc.

References m_session.

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

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

IOVProxy Session::iovProxy ( )

Definition at line 102 of file Session.cc.

References m_session.

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

bool Session::isOraSession ( )

Definition at line 203 of file Session.cc.

References m_session.

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

                               {
       return m_session->isOra();
     }

bool Session::lookupMigratedPayload	(	const std::string &	sourceAccount,
		const std::string &	sourceToken,
		std::string &	payloadId
	)

Definition at line 236 of file Session.cc.

References m_session.

                                            {
       m_session->openIovDb();
       if(! m_session->iovSchema().payloadMigrationTable().exists() ) return false;
       return m_session->iovSchema().payloadMigrationTable().select( sourceAccount, sourceToken, payloadId );
     }

coral::ISchema & Session::nominalSchema ( )

Definition at line 277 of file Session.cc.

References coralSession().

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

std::string Session::parsePoolToken ( const std::string & poolToken )

Definition at line 263 of file Session.cc.

References m_session.

                                                                  {
       m_session->openIovDb();
       return m_session->iovSchema().parsePoolToken( poolToken );
     }

GTProxy Session::readGlobalTag ( const std::string & name )

Definition at line 173 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 180 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 cond::persistency::copyIov(), cond::persistency::copyTag(), cond::persistency::importIovs(), popcon::PopCon::initialize(), cond::persistency::BasePayloadProxy::loadTag(), cond::persistency::migrateTag(), and l1t::DataWriter::payloadToken().

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

References ora::ClassUtils::demangledName(), alignCSCRings::e, isOraSession(), run_regression::ret, cond::serialize(), storePayloadData(), AlCaHLTBitMon_QueryRunRegistry::string, cond::persistency::throwException(), and cms::Exception::what().

Referenced by cond::service::PoolDBOutputService::appendSinceTime(), cond::service::PoolDBOutputService::createNewIOV(), l1t::WriterProxyT< Record, Type >::save(), l1t::DataWriter::writeKeyList(), and cond::service::PoolDBOutputService::writeOne().

                                                                                                                            {
       
       std::string payloadObjectType = cond::demangledName(typeid(payload));
       cond::Hash ret; 
       try{
     ret = storePayloadData( payloadObjectType, serialize( payload, isOraSession() ), 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
	)

private

Definition at line 187 of file Session.cc.

References m_session.

Referenced by storePayload().

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

                                      {
       return m_transaction;
     }

void Session::updateMigratedPayload	(	const std::string &	sourceAccount,
		const std::string &	sourceToken,
		const std::string &	payloadId
	)

Definition at line 253 of file Session.cc.

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

                                                  {
       m_session->openIovDb();
       if(! m_session->iovSchema().payloadMigrationTable().exists() ) 
     throwException( "Payload Migration Table does not exist in this schema.","Session::updateMigratedPayload");
       m_session->iovSchema().payloadMigrationTable().update( sourceAccount, sourceToken, payloadId,
                                  boost::posix_time::microsec_clock::universal_time() );             
     }

void Session::updateMigrationLog	(	const std::string &	sourceAccount,
		const std::string &	sourceTag,
		cond::MigrationStatus	status
	)

Definition at line 227 of file Session.cc.

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

                                                  {
       m_session->openIovDb();
       if(! m_session->iovSchema().tagMigrationTable().exists() )
     throwException( "Migration Log Table does not exist in this schema.","Session::updateMigrationLog");
       m_session->iovSchema().tagMigrationTable().updateValidationCode( sourceAccount, sourceTag, (int)status );
     }

Member Data Documentation

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

private

Transaction cond::persistency::Session::m_transaction

private

Definition at line 195 of file Session.h.

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

Public Member Functions

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation