#include <DbSession.h>

Public Member Functions
const std::string &	blobStreamingService () const

std::string	classNameForItem (const std::string &objectId)

void	close ()

const DbConnection &	connection () const

const std::string &	connectionString () const

bool	createDatabase ()

	DbSession ()

	DbSession (const DbConnection &connection)

	DbSession (const DbSession &rhs)

bool	deleteMapping (const std::string &mappingVersion)

bool	deleteObject (const std::string &objectId)

void	flush ()

ora::Object	getObject (const std::string &objectId)

template<typename T >
boost::shared_ptr< T >	getTypedObject (const std::string &objectId)

bool	importMapping (const std::string &sourceConnectionString, const std::string &contName)

std::string	importObject (cond::DbSession &fromDatabase, const std::string &objectId)

bool	isOldSchema ()

bool	isOpen () const

bool	isTransactional () const

coral::ISchema &	nominalSchema ()

void	open (const std::string &connectionString, bool readOnly=false)

void	open (const std::string &connectionString, const std::string &role, bool readOnly=false)

void	openReadOnly (const std::string &connectionString, const std::string &id)

DbSession &	operator= (const DbSession &rhs)

coral::ISchema &	schema (const std::string &schemaName)

ora::Database &	storage ()

template<typename T >
std::string	storeObject (const T *object, const std::string &containerName)

DbTransaction &	transaction ()

template<typename T >
bool	updateObject (const T *object, const std::string &objectId)

virtual	~DbSession ()

Static Public Attributes
static const char *	CHANGE_SCHEMA_VERSION = "2.0.0"

static const char *	COND_SCHEMA_VERSION = "2.0.0"

Private Member Functions
std::string	storeObject (const ora::Object &objectRef, const std::string &containerName)

Private Attributes
boost::shared_ptr< SessionImpl >	m_implementation

Detailed Description

Definition at line 31 of file DbSession.h.

Constructor & Destructor Documentation

DbSession::DbSession ( )

Definition at line 124 of file DbSession.cc.

                         :
   m_implementation( new SessionImpl ){ 
 }

DbSession::DbSession ( const DbConnection & connection )

explicit

Definition at line 128 of file DbSession.cc.

                                                         :
   m_implementation( new SessionImpl ( connection ) ){
 }

DbSession::DbSession ( const DbSession & rhs )

Definition at line 132 of file DbSession.cc.

                                               :
   m_implementation( rhs.m_implementation ){ 
 }

DbSession::~DbSession ( )

virtual

Definition at line 136 of file DbSession.cc.

136 {

137 }

Member Function Documentation

const std::string & DbSession::blobStreamingService ( ) const

Definition at line 184 of file DbSession.cc.

 {
   return m_implementation->blobStreamingService;
 }

std::string DbSession::classNameForItem ( const std::string & objectId )

Definition at line 277 of file DbSession.cc.

References ora::Container::className(), cont, ora::OId::containerId(), ora::OId::fromString(), ora::OId::isInvalid(), and run_regression::ret.

Referenced by cond::ExportIOVUtilities::execute(), and cond::AlignSplitIOV::execute().

                                                                     {
   ora::OId oid;
   oid.fromString( objectId );
   std::string ret("");
   if( !oid.isInvalid() ){
     ora::Container cont = storage().containerHandle( oid.containerId() );
     ret = cont.className();
   }
   return ret; 
 }

void DbSession::close ( void )

Definition at line 160 of file DbSession.cc.

Referenced by cond::CondDB::closeSession(), lumiQTWidget.ApplicationWindow::fileQuit(), FillInfoPopConSourceHandler::getNewObjects(), DTLVStatusHandler::getNewObjects(), DTKeyedConfigHandler::getNewObjects(), DTUserKeyedConfigHandler::getNewObjects(), DTHVStatusHandler::getNewObjects(), Vispa.Gui.BoxContentDialog.BoxContentDialog::keyPressEvent(), Vispa.Gui.FindDialog.FindDialog::keyPressEvent(), cond::PayLoadInspector< DataT >::summary(), cond::PayLoadInspector< DataT >::trend_plot(), and l1t::DataManager::~DataManager().

 {
   m_implementation->close();
 }

cond::DbConnection const & DbSession::connection ( ) const

Definition at line 175 of file DbSession.cc.

                                                          {
   return *(m_implementation->connection);
 }

const std::string & DbSession::connectionString ( ) const

Definition at line 169 of file DbSession.cc.

Referenced by PCLMetadataWriter::endRun(), and popcon::PopCon::initialize().

                                                        {
   if(!m_implementation->database.get())
     throw cond::Exception("DbSession::connectionString: cannot get connection string. Session has not been open.");
   return m_implementation->database->connectionString();
 }

bool DbSession::createDatabase ( )

Definition at line 206 of file DbSession.cc.

Referenced by cond::AlignSplitIOV::processPayloadContainer(), TestFunct::Write(), and TestFunct::WriteWithIOV().

                                   {
   bool created = false;
   if ( !storage().exists() ){
     created = true;
     storage().create( std::string(COND_SCHEMA_VERSION) );
   }  
   return created;
 }

bool DbSession::deleteMapping ( const std::string & mappingVersion )

Definition at line 233 of file DbSession.cc.

References ora::DatabaseUtility::eraseMapping().

                                                                   {
   ora::DatabaseUtility utility = storage().utility();
   utility.eraseMapping( mappingVersion );
   return true;
 }

bool DbSession::deleteObject ( const std::string & objectId )

Definition at line 259 of file DbSession.cc.

References ora::OId::fromString().

Referenced by TestFunct::DropItem().

                                                            {
   ora::OId oid;
   oid.fromString( objectId );
   storage().erase( oid );
   storage().flush();
   return true;
 }

void DbSession::flush ( )

Definition at line 288 of file DbSession.cc.

                          {
   storage().flush();
 }

ora::Object DbSession::getObject ( const std::string & objectId )

Definition at line 253 of file DbSession.cc.

References ora::OId::fromString().

Referenced by importObject(), and cond::PayLoadInspector< DataT >::load().

                                                               {
   ora::OId oid;
   oid.fromString( objectId );
   return storage().fetchItem( oid );
 }

template<typename T >

boost::shared_ptr< T > DbSession::getTypedObject ( const std::string & objectId )

inline

Definition at line 125 of file DbSession.h.

References ora::Database::fetch(), ora::OId::fromString(), and storage().

Referenced by cond::PayloadRef< std::vector< cond::Time_t > >::load(), cond::KeyList::load(), cond::loadIOV(), cond::PayLoadInspector< DataT >::plot(), cond::AlignSplitIOV::processPayloadContainer(), TestFunct::Read(), l1t::DataWriter::readObject(), TestFunct::ReadWithIOV(), popcon::PopConSourceHandler< T >::Ref::Ref(), cond::IOVProxyData::refresh(), cond::PayLoadInspector< DataT >::summary(), and cond::PayLoadInspector< DataT >::trend_plot().

                                                                                                       {
     ora::OId oid;
     oid.fromString( objectId );
     return storage().fetch<T>( oid );
   }

bool DbSession::importMapping	(	const std::string &	sourceConnectionString,
		const std::string &	contName
	)

Definition at line 239 of file DbSession.cc.

References cond::buildTechnologyProxy(), and ora::DatabaseUtility::importContainerSchema().

                                                                 { 
   ora::DatabaseUtility utility = storage().utility();
   std::auto_ptr<cond::TechnologyProxy> technologyProxy = buildTechnologyProxy(sourceConnectionString, *(m_implementation->connection));
   utility.importContainerSchema( (*technologyProxy).getRealConnectString( sourceConnectionString ), contName );
   return true;
 }

std::string DbSession::importObject	(	cond::DbSession &	fromDatabase,
		const std::string &	objectId
	)

Definition at line 267 of file DbSession.cc.

References cont, ora::Database::containerHandle(), ora::OId::containerId(), data, ora::Object::destruct(), ora::OId::fromString(), getObject(), ora::Container::name(), run_regression::ret, and storage().

                                                                                              {
   ora::OId oid;
   oid.fromString( objectId );
   ora::Object data = fromDatabase.getObject( objectId );
   ora::Container cont = fromDatabase.storage().containerHandle( oid.containerId() );
   std::string ret = storeObject( data, cont.name() );
   data.destruct();
   return ret;
 }

bool DbSession::isOldSchema ( )

Definition at line 215 of file DbSession.cc.

References ora::Version::fromString(), and ora::Version::poolSchemaVersion().

Referenced by cond::insertIOV(), cond::loadIOV(), cond::IOVProxyData::refresh(), and cond::updateIOV().

 {
   ora::Version dbVer = storage().schemaVersion();
   if (dbVer == ora::Version::poolSchemaVersion()) return true;
   dbVer = storage().schemaVersion( true );
   return dbVer < ora::Version::fromString( std::string( CHANGE_SCHEMA_VERSION ) );
 }

bool DbSession::isOpen ( ) const

Definition at line 165 of file DbSession.cc.

                                  {
   return m_implementation->isOpen;
 }

bool DbSession::isTransactional ( ) const

Definition at line 180 of file DbSession.cc.

                                           {
   return m_implementation->technologyProxy->isTransactional();
 }

coral::ISchema & DbSession::nominalSchema ( )

Definition at line 228 of file DbSession.cc.

 {
   return storage().storageAccessSession().get().nominalSchema(); 
 }

void DbSession::open	(	const std::string &	connectionString,
		bool	readOnly = `false`
	)

Definition at line 144 of file DbSession.cc.

Referenced by l1t::DataManager::connect(), CondDBESSource::fillTagCollectionFromDB(), cond::RDBMS::getDB(), HcalO2OManager::getListOfPoolIovs(), HcalO2OManager::getListOfPoolTags(), FillInfoPopConSourceHandler::getNewObjects(), DTLVStatusHandler::getNewObjects(), DTKeyedConfigHandler::getNewObjects(), DTUserKeyedConfigHandler::getNewObjects(), DTHVStatusHandler::getNewObjects(), cond::RDBMS::getReadOnlyDB(), cond::RDBMS::globalTag(), Vispa.Plugins.ConfigEditor.ConfigEditorTabController.ConfigEditorTabController::importConfig(), SiStripCoralIface::initialize(), L1ConfigOnlineProdBase< TRcd, TData >::L1ConfigOnlineProdBase(), cond::PayLoadInspector< DataT >::plot(), cond::service::PoolDBOutputService::PoolDBOutputService(), cond::PayLoadInspector< DataT >::summary(), and cond::PayLoadInspector< DataT >::trend_plot().

 {
   std::string emptyRole("");
   m_implementation->open( connectionString, emptyRole, readOnly );
 }

void DbSession::open	(	const std::string &	connectionString,
		const std::string &	role,
		bool	readOnly = `false`
	)

Definition at line 150 of file DbSession.cc.

Referenced by Vispa.Plugins.ConfigEditor.ConfigEditorTabController.ConfigEditorTabController::importConfig().

 {
   m_implementation->open( connectionString, asRole, readOnly );
 }

void DbSession::openReadOnly	(	const std::string &	connectionString,
		const std::string &	id
	)

Definition at line 155 of file DbSession.cc.

Referenced by CondDBESSource::CondDBESSource(), and CondDBESSource::setIntervalFor().

 {
   m_implementation->openReadOnly( connectionString, id );
 }

cond::DbSession & DbSession::operator= ( const DbSession & rhs )

Definition at line 139 of file DbSession.cc.

References m_implementation.

                                                                  {
   if(this!=&rhs) m_implementation = rhs.m_implementation;
   return *this;
 }

coral::ISchema & DbSession::schema ( const std::string & schemaName )

Definition at line 223 of file DbSession.cc.

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(), and L1CaloHcalScaleConfigOnlineProd::newObject().

 {
   return storage().storageAccessSession().get().schema( schemaName );
 }

ora::Database & DbSession::storage ( )

Definition at line 198 of file DbSession.cc.

Referenced by cond::ExportIOVUtilities::execute(), getTypedObject(), importObject(), cond::insertIOV(), cond::loadIOV(), cond::IOVProxyData::refresh(), storeObject(), cond::updateIOV(), and updateObject().

                                    {
   if(!m_implementation->connection.get() || !m_implementation->connection->isOpen())
     throw cond::Exception("DbSession::storage: cannot access the storage. Underlying connection is closed.");
   if(!m_implementation->database.get())
     throw cond::Exception("DbSession::storage: cannot access the database. Session has not been open.");
   return *m_implementation->database;
 }

template<typename T >

std::string DbSession::storeObject	(	const T *	object,
		const std::string &	containerName
	)

inline

Definition at line 131 of file DbSession.h.

References ora::Database::flush(), ora::Database::insert(), run_regression::ret, storage(), and ora::OId::toString().

Referenced by cond::insertIOV(), cond::service::GetTokenFromPointer< T >::operator()(), cond::AlignSplitIOV::processPayloadContainer(), l1t::WriterProxyT< Record, Type >::save(), TestFunct::Write(), l1t::DataWriter::writeKeyList(), and TestFunct::WriteWithIOV().

                                                                                                    {
     std::string ret("");
     if( object ){
       ora::OId oid = storage().insert( containerName, *object );
       storage().flush();
       ret =  oid.toString();
     }
     return ret;
   }

std::string DbSession::storeObject	(	const ora::Object &	objectRef,
		const std::string &	containerName
	)

private

Definition at line 247 of file DbSession.cc.

References ora::OId::toString().

                                                                                               {
   ora::OId oid = storage().insertItem( containerName, object );
   storage().flush();
   return oid.toString();
 }

cond::DbTransaction & DbSession::transaction ( )

Definition at line 189 of file DbSession.cc.

Referenced by cond::BasePayloadProxy::BasePayloadProxy(), cond::CondDB::commitTransaction(), l1t::OMDSReader::connect(), cond::ExportIOVUtilities::execute(), cond::AlignSplitIOV::execute(), CondDBESSource::fillTagCollectionFromDB(), FillInfoPopConSourceHandler::getNewObjects(), DTLVStatusHandler::getNewObjects(), DTKeyedConfigHandler::getNewObjects(), DTUserKeyedConfigHandler::getNewObjects(), DTHVStatusHandler::getNewObjects(), cond::RDBMS::globalTag(), cond::KeyList::load(), cond::BasePayloadProxy::loadIov(), cond::BasePayloadProxy::loadTag(), cond::BasePayloadProxy::make(), l1t::OMDSReader::OMDSReader(), cond::PayLoadInspector< DataT >::plot(), cond::BasePayloadProxy::refresh(), cond::CondDB::startReadOnlyTransaction(), cond::CondDB::startTransaction(), cond::PayLoadInspector< DataT >::summary(), and cond::PayLoadInspector< DataT >::trend_plot().

 {
   if(!m_implementation->connection.get() || !m_implementation->connection->isOpen())
     throw cond::Exception("DbSession::transaction: cannot open transaction. Underlying connection is closed.");
   if(!m_implementation->transaction.get())
     throw cond::Exception("DbSession::transaction: cannot get transaction. Session has not been open.");
   return *m_implementation->transaction;
 }

template<typename T >

bool DbSession::updateObject	(	const T *	object,
		const std::string &	objectId
	)

inline

Definition at line 142 of file DbSession.h.

References ora::Database::flush(), ora::OId::fromString(), run_regression::ret, storage(), and ora::Database::update().

Referenced by cond::updateIOV().

                                                                                         {
     bool ret = false;
     if( object ){
       ora::OId oid;
       oid.fromString( objectId );
       storage().update( oid, *object );
       storage().flush();
       ret =  true;
     }
     return ret;
   }

Member Data Documentation

const char * DbSession::CHANGE_SCHEMA_VERSION = "2.0.0"

static

Definition at line 34 of file DbSession.h.

const char * DbSession::COND_SCHEMA_VERSION = "2.0.0"

static

Definition at line 33 of file DbSession.h.

Referenced by cond::IOVSchemaUtility::createIOVContainer().

boost::shared_ptr<SessionImpl> cond::DbSession::m_implementation

private

Definition at line 100 of file DbSession.h.

Referenced by operator=().

Public Member Functions

Static Public Attributes

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation