cond::persistency::Session Class Reference

#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::OFFLINE)
IOVEditor	createIov (const std::string &payloadType, const std::string &tag, cond::TimeType timeType, cond::SynchronizationType synchronizationType=cond::OFFLINE)
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::OFFLINE)
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)
	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.

                     {
    }

Member Function Documentation

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

Definition at line 235 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 208 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 198 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 139 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 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 259 of file Session.cc.

References m_session.

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

                                       {
      return m_session->connectionString;
    }

coral::ISessionProxy & Session::coralSession

(

)

Definition at line 263 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 cond::persistency::SessionImpl::CREATE, and m_session.

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

                                {
      m_session->openIovDb( SessionImpl::CREATE );
    }

GTEditor Session::createGlobalTag

(

const std::string &

name

)

Definition at line 149 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::OFFLINE  )

inline

Definition at line 194 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::OFFLINE
	)

Definition at line 99 of file Session.cc.

References cond::persistency::SessionImpl::CREATE, idDealer::editor, m_session, and cond::persistency::throwException().

                                                               {
      m_session->openIovDb( SessionImpl::CREATE );
      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 108 of file Session.cc.

References cond::persistency::SessionImpl::CREATE, idDealer::editor, m_session, and cond::persistency::throwException().

                                                            {
      m_session->openIovDb( SessionImpl::CREATE );
      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::OFFLINE
	)

Definition at line 120 of file Session.cc.

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

                                                                     {
      m_session->openIovDb( SessionImpl::CREATE );
      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 157 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 132 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 144 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 88 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 211 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::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 186 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 93 of file Session.cc.

References m_session.

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

bool Session::isOraSession

(

)

Definition at line 194 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 227 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 268 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 254 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 164 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 171 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;
    }

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

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

Referenced by storePayload().

                                                                {
      m_session->openIovDb( SessionImpl::CREATE );
      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 cond::persistency::copyIov(), cond::persistency::copyTag(), CondDBESSource::fillTagCollectionFromGT(), popcon::PopCon::finalize(), cond::persistency::importIovs(), popcon::PopCon::initialize(), cond::persistency::KeyList::load(), cond::persistency::BasePayloadProxy::loadTag(), cond::persistency::PayloadProxy< std::vector< cond::Time_t > >::make(), cond::persistency::migrateTag(), l1t::DataWriter::payloadToken(), l1t::DataWriter::readObject(), l1t::WriterProxyT< Record, Type >::save(), cond::persistency::BasePayloadProxy::setIntervalFor(), l1t::DataWriter::writeKeyList(), and popcon::PopCon::~PopCon().

                                     {
      return m_transaction;
    }

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

Definition at line 244 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 218 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

Definition at line 190 of file Session.h.

Referenced by addMigratedPayload(), addToMigrationLog(), checkMigrationLog(), clearIov(), close(), connectionString(), coralSession(), createDatabase(), createGlobalTag(), createIov(), createIovForPayload(), editGlobalTag(), editIov(), existsDatabase(), existsGlobalTag(), existsIov(), fetchPayloadData(), iovProxy(), isOraSession(), lookupMigratedPayload(), operator=(), parsePoolToken(), readGlobalTag(), readIov(), storePayloadData(), updateMigratedPayload(), and updateMigrationLog().

Transaction cond::persistency::Session::m_transaction

private

Definition at line 191 of file Session.h.

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