cond::DbSession Class Reference

#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	open (boost::shared_ptr< coral::ISessionProxy > &coralSession, const std::string &connectionString, const std::string &schemaName="")
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)
std::string	storeObject (const ora::Object &objectRef, 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 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 139 of file DbSession.cc.

                        :
  m_implementation( new SessionImpl ){ 
}

DbSession::DbSession ( const DbConnection &  connection )

explicit

Definition at line 143 of file DbSession.cc.

                                                        :
  m_implementation( new SessionImpl ( connection ) ){
}

DbSession::DbSession

(

const DbSession &

rhs

)

Definition at line 147 of file DbSession.cc.

                                              :
  m_implementation( rhs.m_implementation ){ 
}

DbSession::~DbSession ( )

virtual

Definition at line 151 of file DbSession.cc.

                         {
}

Member Function Documentation

const std::string & DbSession::blobStreamingService

(

)

const

Definition at line 203 of file DbSession.cc.

{
  return m_implementation->blobStreamingService;
}

std::string DbSession::classNameForItem

(

const std::string &

objectId

)

Definition at line 292 of file DbSession.cc.

References generateEDF::cont, ora::OId::containerId(), ora::OId::fromString(), ora::OId::isInvalid(), ora::Container::realClassName(), run_regression::ret, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by cond::ExportIOVUtilities::execute(), cond::AlignSplitIOV::execute(), cond::persistency::OraPayloadTable::getType(), and cond::persistency::OraTagTable::select().

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

void DbSession::close

(

void

)

Definition at line 179 of file DbSession.cc.

Referenced by cond::CondDB::closeSession(), lumiQTWidget.ApplicationWindow::fileQuit(), FillInfoPopConSourceHandler::getNewObjects(), DTLVStatusHandler::getNewObjects(), DTHVStatusHandler::getNewObjects(), esMonitoring.AsyncLineReaderMixin::handle_close(), esMonitoring.FDJsonServer::handle_close(), 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 194 of file DbSession.cc.

                                                         {
  return *(m_implementation->connection);
}

const std::string & DbSession::connectionString

(

)

const

Definition at line 188 of file DbSession.cc.

                                                       {
  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 221 of file DbSession.cc.

References AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by cond::persistency::OraIOVSchema::create(), 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 248 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 274 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 303 of file DbSession.cc.

Referenced by cond::persistency::OraPayloadTable::insertIfNew().

                         {
  storage().flush();
}

ora::Object DbSession::getObject

(

const std::string &

objectId

)

Definition at line 268 of file DbSession.cc.

References ora::OId::fromString().

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

                                                              {
  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 126 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(), TestFunct::ReadWithIOV(), 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 254 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 282 of file DbSession.cc.

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

                                                                                             {
  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 230 of file DbSession.cc.

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

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 184 of file DbSession.cc.

                                 {
  return m_implementation->isOpen;
}

bool DbSession::isTransactional

(

)

const

Definition at line 199 of file DbSession.cc.

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

coral::ISchema & DbSession::nominalSchema

(

)

Definition at line 243 of file DbSession.cc.

Referenced by l1t::OMDSReader::basicQuery(), l1t::OMDSReader::basicQueryGenericKey(), l1t::OMDSReader::basicQueryView(), DTHVStatusHandler::checkForPeriod(), DTHVStatusHandler::checkNewData(), l1t::OMDSReader::columnNames(), l1t::OMDSReader::columnNamesView(), TestFunct::CreateMetaTable(), DTHVStatusHandler::createSnapshot(), DTHVStatusHandler::dumpHVAliases(), DTHVStatusHandler::dumpSnapshot(), DTHVStatusHandler::getChannelMap(), DTHVStatusHandler::getChannelSplit(), cond::persistency::getInsertionLogs(), DTHVStatusHandler::getLayerSplit(), TestFunct::GetMetadata(), FillInfoPopConSourceHandler::getNewObjects(), TestFunct::Read(), DTHVStatusHandler::recoverSnapshot(), TestFunct::Write(), and TestFunct::WriteWithIOV().

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

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

Definition at line 159 of file DbSession.cc.

References AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by cond::persistency::checkBackendType(), l1t::DataManager::connect(), cond::RDBMS::getDB(), HcalO2OManager::getListOfPoolIovs(), HcalO2OManager::getListOfPoolTags(), FillInfoPopConSourceHandler::getNewObjects(), DTLVStatusHandler::getNewObjects(), DTHVStatusHandler::getNewObjects(), cond::RDBMS::getReadOnlyDB(), cond::RDBMS::globalTag(), Vispa.Plugins.ConfigEditor.ConfigEditorTabController.ConfigEditorTabController::importConfig(), SiStripCoralIface::initialize(), cond::Utilities::newDbSession(), cond::PayLoadInspector< DataT >::plot(), cond::persistency::SessionImpl::startTransaction(), 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 165 of file DbSession.cc.

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

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

void DbSession::open	(	boost::shared_ptr< coral::ISessionProxy > &	coralSession,
		const std::string &	connectionString,
		const std::string &	schemaName = ""
	)

Definition at line 175 of file DbSession.cc.

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

                                                                                                                                           {
  m_implementation->open( coralSession, connectionString, schemaName  );
}

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

Definition at line 170 of file DbSession.cc.

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

cond::DbSession & DbSession::operator=

(

const DbSession &

rhs

)

Definition at line 154 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 238 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 215 of file DbSession.cc.

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

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

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

Referenced by cond::persistency::OraPayloadTable::insertIfNew(), cond::insertIOV(), cond::AlignSplitIOV::processPayloadContainer(), TestFunct::Write(), 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
	)

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

Referenced by cond::BasePayloadProxy::BasePayloadProxy(), cond::persistency::checkBackendType(), cond::persistency::OraTransaction::commit(), cond::CondDB::commitTransaction(), l1t::OMDSReader::connect(), cond::ExportIOVUtilities::execute(), cond::AlignSplitIOV::execute(), cond::persistency::getInsertionLogs(), FillInfoPopConSourceHandler::getNewObjects(), DTLVStatusHandler::getNewObjects(), DTHVStatusHandler::getNewObjects(), cond::RDBMS::globalTag(), cond::persistency::OraTransaction::isActive(), cond::KeyList::load(), cond::BasePayloadProxy::loadIov(), cond::BasePayloadProxy::loadTag(), cond::BasePayloadProxy::make(), l1t::OMDSReader::OMDSReader(), cond::PayLoadInspector< DataT >::plot(), cond::BasePayloadProxy::refresh(), cond::persistency::OraTransaction::rollback(), cond::CondDB::startReadOnlyTransaction(), cond::persistency::SessionImpl::startTransaction(), cond::CondDB::startTransaction(), cond::PayLoadInspector< DataT >::summary(), and cond::PayLoadInspector< DataT >::trend_plot().

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

Referenced by operator=().