#include <Session.h>

Public Member Functions
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	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 ()

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)

	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	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::addToMigrationLog	(	const std::string &	sourceAccount,
		const std::string &	sourceTag,
		const std::string &	destinationTag,
		cond::MigrationStatus	status
	)

Definition at line 196 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 186 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 127 of file Session.cc.

References m_session.

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

                                                 {
       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(), DTUserKeyedConfigHandler::getNewObjects(), DTKeyedConfigHandler::getNewObjects(), Vispa.Gui.BoxContentDialog.BoxContentDialog::keyPressEvent(), and Vispa.Gui.FindDialog.FindDialog::keyPressEvent().

                        {
       m_session->close();
     }

std::string Session::connectionString ( )

Definition at line 215 of file Session.cc.

References m_session.

Referenced by cond::persistency::compareTags(), cond::persistency::copyIov(), 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 219 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(), and cond::persistency::importIovs().

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

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

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

References ora::ClassUtils::demangledName().

Referenced by cond::persistency::copyIov(), cond::persistency::copyTag(), 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::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::createIovForPayload	(	const Hash &	payloadHash,
		const std::string &	tag,
		cond::TimeType	timeType,
		cond::SynchronizationType	synchronizationType = `cond::OFFLINE`
	)

Definition at line 108 of file Session.cc.

References cond::persistency::SessionImpl::CREATE, idDealer::editor, m_session, 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 145 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 120 of file Session.cc.

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

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

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

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

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

Definition at line 132 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(), and cond::persistency::importIovs().

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

References fetchPayloadData(), isOraSession(), AlCaHLTBitMon_QueryRunRegistry::string, and cond::persistency::throwException().

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" );
       return deserialize<T>(  payloadType, payloadData, streamerInfoData, isOraSession() );
     }

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

Definition at line 174 of file Session.cc.

References m_session.

Referenced by cond::persistency::fetch(), 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 182 of file Session.cc.

References m_session.

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

                               {
       return m_session->isOra();
     }

coral::ISchema & Session::nominalSchema ( )

Definition at line 224 of file Session.cc.

References coralSession().

Referenced by DTUserKeyedConfigHandler::chkConfigList(), DTKeyedConfigHandler::chkConfigList(), DTUserKeyedConfigHandler::getNewObjects(), and DTKeyedConfigHandler::getNewObjects().

                                         {
       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 152 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 159 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(), cond::persistency::BasePayloadProxy::loadTag(), 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 182 of file Session.h.

References ora::ClassUtils::demangledName(), isOraSession(), cond::serialize(), storePayloadData(), and AlCaHLTBitMon_QueryRunRegistry::string.

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));
       return storePayloadData( payloadObjectType, serialize( payload, isOraSession() ), creationTime ); 
     }

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

private

Definition at line 166 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(), DTKeyedConfigHandler::getNewObjects(), DTUserKeyedConfigHandler::getNewObjects(), cond::persistency::importIovs(), cond::persistency::KeyList::load(), cond::persistency::BasePayloadProxy::loadTag(), cond::persistency::PayloadProxy< std::vector< cond::Time_t > >::make(), l1t::DataWriter::payloadToken(), l1t::DataWriter::readObject(), l1t::WriterProxyT< Record, Type >::save(), cond::persistency::BasePayloadProxy::setIntervalFor(), and l1t::DataWriter::writeKeyList().

                                      {
       return m_transaction;
     }

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

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

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

Transaction cond::persistency::Session::m_transaction

private

Definition at line 175 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