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	openGTDb ()
void	openIovDb (FailureOnOpeningPolicy policy=THROW)
void	rollbackTransaction ()
	SessionImpl ()
	SessionImpl (boost::shared_ptr< coral::ISessionProxy > &session, const std::string &connectionString)
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
std::unique_ptr< ITransaction >	transaction

Detailed Description

Definition at line 39 of file SessionImpl.h.

Member Enumeration Documentation

enum cond::persistency::SessionImpl::FailureOnOpeningPolicy

Enumerator
THROW
DO_NOT_THROW
CREATE

Definition at line 41 of file SessionImpl.h.

{ THROW, DO_NOT_THROW, CREATE } FailureOnOpeningPolicy;

Constructor & Destructor Documentation

cond::persistency::SessionImpl::SessionImpl

(

)

Definition at line 60 of file SessionImpl.cc.

                            :
      coralSession(){
    }

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

Definition at line 64 of file SessionImpl.cc.

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

cond::persistency::SessionImpl::~SessionImpl

(

)

Definition at line 69 of file SessionImpl.cc.

References close().

                             {
      close();
    }

Member Function Documentation

void cond::persistency::SessionImpl::close

(

void

)

Definition at line 73 of file SessionImpl.cc.

References coralSession, and transaction.

Referenced by lumiQTWidget.ApplicationWindow::fileQuit(), 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 112 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 170 of file SessionImpl.cc.

References gtSchemaHandle.

Referenced by startTransaction().

                                    {
      return *gtSchemaHandle;
    }

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

(

)

Definition at line 166 of file SessionImpl.cc.

References iovSchemaHandle.

Referenced by startTransaction().

                                      {
      return *iovSchemaHandle;
    }

bool cond::persistency::SessionImpl::isActive

(

)

const

Definition at line 83 of file SessionImpl.cc.

References coralSession.

                                     {
      return coralSession.get();
    }

bool cond::persistency::SessionImpl::isOra

(

)

Definition at line 174 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 133 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::openGTDb

(

)

Definition at line 155 of file SessionImpl.cc.

References gtSchemaHandle, 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 ){
    throwException( "GT Database does not exist.","SessionImpl::openGTDb");
      }
    }

void cond::persistency::SessionImpl::openIovDb

(

SessionImpl::FailureOnOpeningPolicy

policy = THROW

)

Definition at line 139 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 124 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 87 of file SessionImpl.cc.

References connectionString, coralSession, cond::DbConnection::createSession(), gtSchema(), gtSchemaHandle, iovSchema(), iovSchemaHandle, cond::DbSession::open(), cond::DbTransaction::start(), cond::persistency::throwException(), cond::DbSession::transaction(), and transaction.

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

                                                     {
      if( !transaction.get() ){ 
    cond::DbConnection oraConnection;
    cond::DbSession oraSession =  oraConnection.createSession();
    oraSession.open( coralSession, connectionString ); 
    transaction.reset( new OraTransaction( oraSession ) );
    oraSession.transaction().start( readOnly );
    iovSchemaHandle.reset( new OraIOVSchema( oraSession ) );
    gtSchemaHandle.reset( new OraGTSchema( oraSession ) );                 
    if( !iovSchemaHandle->exists() && !gtSchemaHandle->exists() ){
      std::unique_ptr<IIOVSchema> iovSchema( new IOVSchema( coralSession->nominalSchema() ) );
      std::unique_ptr<IGTSchema> gtSchema( new GTSchema( coralSession->nominalSchema() ) );
      if( iovSchema->exists() ){
        iovSchemaHandle = std::move(iovSchema);
        gtSchemaHandle = std::move(gtSchema);
        transaction.reset( new CondDBTransaction( coralSession ) );
      }
    }
      } 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 65 of file SessionImpl.h.

Referenced by startTransaction().

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

Definition at line 63 of file SessionImpl.h.

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

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

Definition at line 68 of file SessionImpl.h.

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

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

Definition at line 67 of file SessionImpl.h.

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

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

Definition at line 66 of file SessionImpl.h.

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