cond::DbSession Class Reference

#include <DbSession.h>

Public Member Functions
const std::string &	blobStreamingService () const
void	close ()
const DbConnection &	connection () const
const std::string &	connectionString () const
	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	isOpen () const
bool	isTransactional () const
coral::ISchema &	nominalSchema ()
void	open (const std::string &connectionString, bool readOnly=false)
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 ()

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 36 of file DbSession.h.

Constructor & Destructor Documentation

DbSession::DbSession

(

)

Definition at line 99 of file DbSession.cc.

                        :
  m_implementation( new SessionImpl ){ 
}

DbSession::DbSession ( const DbConnection &  connection )

explicit

Definition at line 103 of file DbSession.cc.

                                                        :
  m_implementation( new SessionImpl ( connection ) ){
}

DbSession::DbSession

(

const DbSession &

rhs

)

Definition at line 107 of file DbSession.cc.

                                              :
  m_implementation( rhs.m_implementation ){ 
}

DbSession::~DbSession ( )

virtual

Definition at line 111 of file DbSession.cc.

                         {
}

Member Function Documentation

const std::string & DbSession::blobStreamingService

(

)

const

Definition at line 148 of file DbSession.cc.

{
  return m_implementation->blobStreamingService;
}

void DbSession::close

(

void

)

Definition at line 124 of file DbSession.cc.

Referenced by DTLVStatusHandler::getNewObjects(), DTKeyedConfigHandler::getNewObjects(), DTUserKeyedConfigHandler::getNewObjects(), DTHVStatusHandler::getNewObjects(), python.Vispa.Gui.BoxContentDialog.BoxContentDialog::keyPressEvent(), python.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 139 of file DbSession.cc.

                                                         {
  return *(m_implementation->connection);
}

const std::string & DbSession::connectionString

(

)

const

Definition at line 133 of file DbSession.cc.

Referenced by cond::IOVEditor::debugInfo(), 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::deleteMapping

(

const std::string &

mappingVersion

)

Definition at line 180 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 207 of file DbSession.cc.

References cont, ora::Container::erase(), ora::Container::flush(), and cond::parseToken().

Referenced by cond::IOVEditor::deleteEntries(), and cond::IOVEditor::truncate().

                                                           {
  std::pair<std::string,int> oidData = parseToken( objectId );
  ora::Container cont = storage().containerHandle(  oidData.first );
  cont.erase( oidData.second );
  cont.flush();
  return true;
}

void DbSession::flush

(

)

Definition at line 223 of file DbSession.cc.

                         {
  storage().flush();
}

ora::Object DbSession::getObject

(

const std::string &

objectId

)

Definition at line 201 of file DbSession.cc.

References cont, ora::Container::fetchItem(), and cond::parseToken().

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

                                                              {
  std::pair<std::string,int> oidData = parseToken( objectId );
  ora::Container cont = storage().containerHandle(  oidData.first );
  return cont.fetchItem( oidData.second );
}

template<typename T >

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

inline

Definition at line 98 of file DbSession.h.

References cont, ora::Database::containerHandle(), ora::Container::fetch(), cond::parseToken(), and storage().

Referenced by cond::AlignSplitIOV::execute(), cond::IOVService::exportIOVRangeWithPayload(), cond::IOVEditor::import(), cond::IOVEditor::init(), cond::PayloadRef< std::vector< cond::Time_t > >::load(), cond::KeyList::load(), cond::PayLoadInspector< DataT >::plot(), l1t::DataWriter::readObject(), popcon::PopConSourceHandler< T >::Ref::Ref(), cond::impl::IOVImpl::refresh(), cond::PayLoadInspector< DataT >::summary(), and cond::PayLoadInspector< DataT >::trend_plot().

                                                                                                      {
    std::pair<std::string,int> oidData = parseToken( objectId );
    ora::Container cont = storage().containerHandle(  oidData.first );
    return cont.fetch<T>( oidData.second );
  }

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

Definition at line 186 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(), contName );
  return true;
}

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

Definition at line 215 of file DbSession.cc.

References runTheMatrix::data, ora::Object::destruct(), getObject(), and cond::parseToken().

Referenced by cond::IOVService::exportIOVRangeWithPayload(), and cond::IOVService::exportIOVWithPayload().

                                                                                             {
  std::pair<std::string,int> oidData = parseToken( objectId );
  ora::Object data = fromDatabase.getObject( objectId );
  std::string tok = storeObject( data, oidData.first );
  data.destruct();
  return tok;
}

bool DbSession::isOpen

(

)

const

Definition at line 129 of file DbSession.cc.

Referenced by popcon::PopConSourceHandler< T >::Ref::~Ref().

                                 {
  return m_implementation->isOpen;
}

bool DbSession::isTransactional

(

)

const

Definition at line 144 of file DbSession.cc.

Referenced by CondDBESSource::CondDBESSource().

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

coral::ISchema & DbSession::nominalSchema

(

)

Definition at line 175 of file DbSession.cc.

Referenced by l1t::OMDSReader::basicQuery(), l1t::OMDSReader::basicQueryGenericKey(), l1t::OMDSReader::basicQueryView(), DTHVStatusHandler::checkForPeriod(), DTHVStatusHandler::checkNewData(), DTUserKeyedConfigHandler::chkConfigList(), DTKeyedConfigHandler::chkConfigList(), l1t::OMDSReader::columnNames(), l1t::OMDSReader::columnNamesView(), DTHVStatusHandler::createSnapshot(), DTHVStatusHandler::dumpHVAliases(), DTHVStatusHandler::dumpSnapshot(), DTHVStatusHandler::getChannelMap(), DTHVStatusHandler::getChannelSplit(), DTHVStatusHandler::getLayerSplit(), DTKeyedConfigHandler::getNewObjects(), DTUserKeyedConfigHandler::getNewObjects(), and DTHVStatusHandler::recoverSnapshot().

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

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

Definition at line 119 of file DbSession.cc.

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

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

cond::DbSession & DbSession::operator=

(

const DbSession &

rhs

)

Definition at line 114 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 170 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(), and L1CaloHcalScaleConfigOnlineProd::newObject().

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

ora::Database & DbSession::storage

(

)

Definition at line 162 of file DbSession.cc.

Referenced by getTypedObject(), storeObject(), 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 104 of file DbSession.h.

References ora::Container::className(), cont, ora::Database::containerHandle(), ora::Database::flush(), ora::Container::id(), ora::Database::insert(), ora::OId::itemId(), runTheMatrix::ret, storage(), and cond::writeToken().

Referenced by cond::IOVEditor::create(), cond::AlignSplitIOV::execute(), cond::IOVService::exportIOVRangeWithPayload(), cond::IOVService::exportIOVWithPayload(), cond::service::GetTokenFromPointer< T >::operator()(), l1t::WriterProxyT< Record, Type >::save(), and l1t::DataWriter::writeKeyList().

                                                                                                   {
    std::string ret("");
    if( object ){
      ora::OId oid = storage().insert( containerName, *object );
      storage().flush();
      ora::Container cont = storage().containerHandle( containerName );
      int oid0 = cont.id(); // contID does not start from 0...
      ret =  writeToken( containerName, oid0, oid.itemId(), cont.className() );
    }
    return ret;
  }

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

private

Definition at line 194 of file DbSession.cc.

References ora::OId::containerId(), ora::OId::itemId(), and cond::writeToken().

                                                                                              {
  ora::OId oid = storage().insertItem( containerName, object );
  storage().flush();
  int oid0 = oid.containerId(); // no clue why in POOL contId does not start from 0...
  return writeToken( containerName, oid0, oid.itemId(), object.typeName() );
}

cond::DbTransaction & DbSession::transaction

(

)

Definition at line 153 of file DbSession.cc.

Referenced by cond::CondDB::allTags(), CondDBESSource::CondDBESSource(), l1t::OMDSReader::connect(), cond::PoolTransactionSentry::Elem::Elem(), cond::AlignSplitIOV::execute(), DTLVStatusHandler::getNewObjects(), DTKeyedConfigHandler::getNewObjects(), DTUserKeyedConfigHandler::getNewObjects(), DTHVStatusHandler::getNewObjects(), cond::impl::IOVImpl::IOVImpl(), cond::CondDB::iovToken(), cond::KeyList::load(), cond::BasePayloadProxy::make(), l1t::OMDSReader::OMDSReader(), cond::PayLoadInspector< DataT >::PayLoadInspector(), cond::PayLoadInspector< DataT >::plot(), popcon::PopConSourceHandler< T >::Ref::Ref(), cond::PayLoadInspector< DataT >::summary(), cond::PayLoadInspector< DataT >::trend_plot(), cond::PoolTransactionSentry::Elem::~Elem(), cond::impl::IOVImpl::~IOVImpl(), and popcon::PopConSourceHandler< T >::Ref::~Ref().

{
  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 117 of file DbSession.h.

References cont, ora::Database::containerHandle(), ora::Container::flush(), cond::parseToken(), runTheMatrix::ret, storage(), and ora::Container::update().

Referenced by cond::IOVEditor::append(), cond::IOVEditor::bulkAppend(), cond::IOVService::exportIOVRangeWithPayload(), cond::IOVEditor::freeInsert(), cond::IOVEditor::insert(), cond::IOVEditor::stamp(), cond::IOVEditor::truncate(), and cond::IOVEditor::updateClosure().

                                                                                        {
    bool ret = false;
    if( object ){
      std::pair<std::string,int> oidData = parseToken( objectId );
      ora::Container cont = storage().containerHandle( oidData.first );
      cont.update( oidData.second, *object );
      cont.flush();
      ret =  true;
    }
    return ret;
  }

Member Data Documentation

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

private

Definition at line 95 of file DbSession.h.

Referenced by operator=().