cond::persistency::SessionImpl Class Reference

#include <SessionImpl.h>

Public Types
enum	FailureOnOpeningPolicy { THROW, DO_NOT_THROW, CREATE }

Public Member Functions
void	close ()
void	commitTransaction ()
IGTSchema &	gtSchema ()
IIOVSchema &	iovSchema ()
bool	isActive () const
bool	isOra ()
bool	isTransactionActive (bool deep=true) const
void	openDb ()
void	openGTDb (FailureOnOpeningPolicy policy=THROW)
void	openIovDb (FailureOnOpeningPolicy policy=THROW)
void	rollbackTransaction ()
	SessionImpl ()
	SessionImpl (boost::shared_ptr< coral::ISessionProxy > &session, const std::string &connectionString, BackendType backType)
void	startTransaction (bool readOnly=true)
	~SessionImpl ()

Public Attributes
std::string	connectionString
boost::shared_ptr < coral::ISessionProxy >	coralSession
std::unique_ptr< IGTSchema >	gtSchemaHandle
std::unique_ptr< IIOVSchema >	iovSchemaHandle
BackendType	theBackendType
std::unique_ptr< ITransaction >	transaction

Detailed Description

Definition at line 43 of file SessionImpl.h.

Member Enumeration Documentation

enum cond::persistency::SessionImpl::FailureOnOpeningPolicy

Enumerator
THROW
DO_NOT_THROW
CREATE

Definition at line 45 of file SessionImpl.h.

{ THROW, DO_NOT_THROW, CREATE } FailureOnOpeningPolicy;

Constructor & Destructor Documentation

cond::persistency::SessionImpl::SessionImpl

(

)

Definition at line 81 of file SessionImpl.cc.

                            :
      coralSession(),
      theBackendType( UNKNOWN_DB ){
    }

cond::persistency::SessionImpl::SessionImpl	(	boost::shared_ptr< coral::ISessionProxy > &	session,
		const std::string &	connectionString,
		BackendType	backType
	)

Definition at line 86 of file SessionImpl.cc.

                                        :
      coralSession( session ),
      connectionString( connectionStr ),
      theBackendType( backType ){
    }

cond::persistency::SessionImpl::~SessionImpl

(

)

Definition at line 94 of file SessionImpl.cc.

References close().

                             {
      close();
    }

Member Function Documentation

void cond::persistency::SessionImpl::close

(

void

)

Definition at line 98 of file SessionImpl.cc.

References coralSession, and transaction.

Referenced by lumiQTWidget.ApplicationWindow::fileQuit(), esMonitoring.AsyncLineReaderMixin::handle_close(), esMonitoring.FDJsonServer::handle_close(), Vispa.Gui.BoxContentDialog.BoxContentDialog::keyPressEvent(), Vispa.Gui.FindDialog.FindDialog::keyPressEvent(), and ~SessionImpl().

                           {
      if( coralSession.get() ){
    if( coralSession->transaction().isActive() ){
      coralSession->transaction().rollback();
    }
    coralSession.reset();
      }
      transaction.reset();
    }

void cond::persistency::SessionImpl::commitTransaction

(

)

Definition at line 136 of file SessionImpl.cc.

References gtSchemaHandle, iovSchemaHandle, and transaction.

Referenced by cond::persistency::Transaction::commit().

                                       {
      if( transaction ) {
    transaction->clients--;
    if( !transaction->clients ){
      transaction->commit();
      transaction.reset();
      iovSchemaHandle.reset();
      gtSchemaHandle.reset();
    }
      }
    }

IGTSchema & cond::persistency::SessionImpl::gtSchema

(

)

Definition at line 219 of file SessionImpl.cc.

References gtSchemaHandle.

                                    {
      return *gtSchemaHandle;
    }

IIOVSchema & cond::persistency::SessionImpl::iovSchema

(

)

Definition at line 215 of file SessionImpl.cc.

References iovSchemaHandle.

                                      {
      return *iovSchemaHandle;
    }

bool cond::persistency::SessionImpl::isActive

(

)

const

Definition at line 108 of file SessionImpl.cc.

References coralSession.

                                     {
      return coralSession.get();
    }

bool cond::persistency::SessionImpl::isOra

(

)

Definition at line 223 of file SessionImpl.cc.

References cond::persistency::throwException(), and transaction.

                           {
      if(!transaction.get()) throwException( "The transaction is not active.","SessionImpl::open" );
      return transaction->isOra;
    }

bool cond::persistency::SessionImpl::isTransactionActive

(

bool

deep = true

)

const

Definition at line 157 of file SessionImpl.cc.

References transaction.

Referenced by cond::persistency::Transaction::isActive().

                                                           {
      if( !transaction ) return false;
      if( !deep ) return true;
      return transaction->isActive();
    }

void cond::persistency::SessionImpl::openDb

(

)

Definition at line 195 of file SessionImpl.cc.

References gtSchemaHandle, iovSchemaHandle, cond::persistency::throwException(), and transaction.

                            {
      if(!transaction.get()) throwException( "The transaction is not active.","SessionImpl::openIovDb" );
      if( !transaction->iovDbOpen ){
        transaction->iovDbExists = iovSchemaHandle->exists();
        transaction->iovDbOpen = true;
      }
      if( !transaction->gtDbOpen ){
        transaction->gtDbExists = gtSchemaHandle->exists();
        transaction->gtDbOpen = true;
      }
      if( !transaction->iovDbExists ){
    iovSchemaHandle->create();
    transaction->iovDbExists = true;
    if( !transaction->gtDbExists ){
      gtSchemaHandle->create();
      transaction->gtDbExists = true;
    }
      }
    }

void cond::persistency::SessionImpl::openGTDb

(

SessionImpl::FailureOnOpeningPolicy

policy = THROW

)

Definition at line 179 of file SessionImpl.cc.

References CREATE, gtSchemaHandle, THROW, cond::persistency::throwException(), and transaction.

                                                                        {
      if(!transaction.get()) throwException( "The transaction is not active.","SessionImpl::open" );
      if( !transaction->gtDbOpen ){
    transaction->gtDbExists = gtSchemaHandle->exists();
    transaction->gtDbOpen = true;
      }
      if( !transaction->gtDbExists ){
        if( policy==CREATE ){
          gtSchemaHandle->create();
          transaction->gtDbExists = true;
        } else {
          if( policy==THROW) throwException( "GT Database does not exist.","SessionImpl::openGTDb");
    }
      }
    }

void cond::persistency::SessionImpl::openIovDb

(

SessionImpl::FailureOnOpeningPolicy

policy = THROW

)

Definition at line 163 of file SessionImpl.cc.

References CREATE, iovSchemaHandle, THROW, cond::persistency::throwException(), and transaction.

                                                                         {
      if(!transaction.get()) throwException( "The transaction is not active.","SessionImpl::openIovDb" );
      if( !transaction->iovDbOpen ){
    transaction->iovDbExists = iovSchemaHandle->exists();
    transaction->iovDbOpen = true;
      }      
      if( !transaction->iovDbExists ){
    if( policy==CREATE ){
      iovSchemaHandle->create();
      transaction->iovDbExists = true;
    } else {
      if( policy==THROW) throwException( "IOV Database does not exist.","SessionImpl::openIovDb");
    }
      }
    }

void cond::persistency::SessionImpl::rollbackTransaction

(

)

Definition at line 148 of file SessionImpl.cc.

References gtSchemaHandle, iovSchemaHandle, and transaction.

Referenced by cond::persistency::Transaction::rollback().

                                         {
      if( transaction ) {   
    transaction->rollback();
    transaction.reset();
    iovSchemaHandle.reset();
    gtSchemaHandle.reset();
      }
    }

void cond::persistency::SessionImpl::startTransaction

(

bool

readOnly = true

)

Definition at line 112 of file SessionImpl.cc.

References cond::COND_DB, connectionString, coralSession, gtSchemaHandle, iovSchemaHandle, cond::DbSession::open(), cond::ORA_DB, cond::DbTransaction::start(), theBackendType, cond::persistency::throwException(), cond::DbSession::transaction(), and transaction.

Referenced by cond::persistency::Transaction::start().

                                                     {
      if( !transaction.get() ){ 
    if ( theBackendType == ORA_DB ) {
      cond::DbSession oraSession;
      oraSession.open( coralSession, connectionString ); 
      oraSession.transaction().start( readOnly );
      iovSchemaHandle.reset( new OraIOVSchema( oraSession ) );
      gtSchemaHandle.reset( new OraGTSchema( oraSession ) );               
      transaction.reset( new OraTransaction( oraSession ) );
    } else if ( theBackendType == COND_DB ){
      coralSession->transaction().start( readOnly );
      iovSchemaHandle.reset( new IOVSchema( coralSession->nominalSchema() ) );
      gtSchemaHandle.reset( new GTSchema( coralSession->nominalSchema() ) );
      transaction.reset( new CondDBTransaction( coralSession ) );
    } else {
      throwException( "No valid database found.", "SessionImpl::startTransaction" );
    }
      } else {
    if(!readOnly ) throwException( "An update transaction is already active.",
                       "SessionImpl::startTransaction" );
      }
      transaction->clients++;
    }

Member Data Documentation

std::string cond::persistency::SessionImpl::connectionString

Definition at line 73 of file SessionImpl.h.

Referenced by startTransaction().

boost::shared_ptr<coral::ISessionProxy> cond::persistency::SessionImpl::coralSession

Definition at line 71 of file SessionImpl.h.

Referenced by close(), isActive(), and startTransaction().

std::unique_ptr<IGTSchema> cond::persistency::SessionImpl::gtSchemaHandle

Definition at line 77 of file SessionImpl.h.

Referenced by commitTransaction(), gtSchema(), openDb(), openGTDb(), rollbackTransaction(), and startTransaction().

std::unique_ptr<IIOVSchema> cond::persistency::SessionImpl::iovSchemaHandle

Definition at line 76 of file SessionImpl.h.

Referenced by commitTransaction(), iovSchema(), openDb(), openIovDb(), rollbackTransaction(), and startTransaction().

BackendType cond::persistency::SessionImpl::theBackendType

Definition at line 74 of file SessionImpl.h.

Referenced by startTransaction().

std::unique_ptr<ITransaction> cond::persistency::SessionImpl::transaction

Definition at line 75 of file SessionImpl.h.

Referenced by close(), commitTransaction(), isOra(), isTransactionActive(), openDb(), openGTDb(), openIovDb(), rollbackTransaction(), and startTransaction().