---

cond::PoolTransaction Class Reference

#include <CondCore/DBCommon/interface/PoolTransaction.h>

Inheritance diagram for cond::PoolTransaction:

List of all members.

Public Member Functions
void	commit ()
	commit transaction. Will disconnect from database if connection timeout==0 or connectted time close to the threshold
virtual bool	isReadOnly () const
	current transaction is active
virtual IConnectionProxy &	parentConnection ()
	get handle to the parent connection
pool::IDataSvc &	poolDataSvc ()
	get pool dataSvc handle
	PoolTransaction (cond::PoolConnectionProxy *parentConnection)
void	resetPoolDataSvc (pool::IDataSvc *datasvc) const
void	rollback ()
	rollback transaction
void	start (bool readOnly)
	start transaction
	~PoolTransaction ()
Private Member Functions
void	forceCommit ()
void	upgrade ()
Private Attributes
int	m_count
pool::IDataSvc *	m_datasvc
cond::PoolConnectionProxy *	m_parentConnection

---

Detailed Description

Definition at line 19 of file PoolTransaction.h.

---

Constructor & Destructor Documentation

PoolTransaction::PoolTransaction

(

cond::PoolConnectionProxy *

parentConnection

)

[explicit]

Definition at line 8 of file PoolTransaction.cc.

References cond::ITransaction::attach(), and m_parentConnection.

                                                                             :m_parentConnection(parentConnection),m_datasvc(0), m_count(0){
  this->attach(m_parentConnection);
}

PoolTransaction::~PoolTransaction

(

)

Definition at line 12 of file PoolTransaction.cc.

{}

---

Member Function Documentation

void PoolTransaction::commit

(

)

[virtual]

commit transaction. Will disconnect from database if connection timeout==0 or connectted time close to the threshold

Implements cond::ITransaction.

Definition at line 32 of file PoolTransaction.cc.

References forceCommit(), and m_count.

Referenced by cond::service::PoolDBOutputService::add(), cond::service::PoolDBOutputService::createNewIOV(), DTDBSession::disconnect(), cond::IOVServiceImpl::exportIOVRangeWithPayload(), l1t::DataReader::loadIntervals(), DataProxy< RecordT, DataT >::make(), DataProxy< IdealGeometryRecord, DDCompactView >::make(), l1t::DataReader::payloadToken(), l1t::DataReader::readKey(), l1t::DataReader::readPayload(), PoolDBESSource::setIntervalFor(), cond::service::PoolDBOutputService::tagInfo(), l1t::DataWriter::updateIOV(), l1t::DataWriter::writeKey(), l1t::DataWriter::writeKeyList(), l1t::DataWriter::writePayload(), CondBasicIter::~CondBasicIter(), cond::PoolTransactionSentry::Elem::~Elem(), cond::impl::IOVImpl::~IOVImpl(), and popcon::PopConSourceHandler< T >::Ref::~Ref().

                           {
  if (0==m_count) return;
  m_count--;
  if (0==m_count) forceCommit();
}

void PoolTransaction::forceCommit

(

)

[private]

Definition at line 46 of file PoolTransaction.cc.

References Exception, m_datasvc, and cond::ITransaction::NotifyEndOfTransaction().

Referenced by commit(), and upgrade().

                                 {
  if(!m_datasvc) throw cond::Exception("PoolTransaction::commit: database not connected");
  if(!m_datasvc->transaction().commit()){
    m_datasvc->transaction().rollback();
    throw cond::TransactionException("cond::PoolTransaction::commit","An Error ocurred, transaction rolled back");
  }
  this->NotifyEndOfTransaction();
}

bool PoolTransaction::isReadOnly

(

)

const [virtual]

current transaction is active

current transaction is readonly

Implements cond::ITransaction.

Definition at line 63 of file PoolTransaction.cc.

References m_datasvc.

Referenced by cond::GenericRef::exportTo(), cond::GenericRef::GenericRef(), and start().

                                    {
  if(m_datasvc->transaction().type()==pool::ITransaction::READ) return true;
  return false;
}

cond::IConnectionProxy & PoolTransaction::parentConnection

(

)

[virtual]

get handle to the parent connection

Implements cond::ITransaction.

Definition at line 68 of file PoolTransaction.cc.

References m_parentConnection.

Referenced by cond::PoolContainerManager::exportContainer(), cond::GenericRef::exportTo(), cond::GenericRef::GenericRef(), and cond::PoolContainerManager::listAll().

                                     {
  return *m_parentConnection;
}

pool::IDataSvc & PoolTransaction::poolDataSvc

(

)

get pool dataSvc handle

Definition at line 76 of file PoolTransaction.cc.

References m_datasvc.

Referenced by cond::PoolContainerManager::exportContainer(), cond::GenericRef::exportTo(), cond::PoolContainerManager::listAll(), DataProxy< RecordT, DataT >::make(), and DataProxy< IdealGeometryRecord, DDCompactView >::make().

                                {
  return *m_datasvc;
}

void PoolTransaction::resetPoolDataSvc

(

pool::IDataSvc *

datasvc

)

const

Definition at line 72 of file PoolTransaction.cc.

References m_datasvc.

                                                                {
  m_datasvc=datasvc;
}

void PoolTransaction::rollback

(

)

[virtual]

rollback transaction

Implements cond::ITransaction.

Definition at line 57 of file PoolTransaction.cc.

References Exception, m_datasvc, and cond::ITransaction::NotifyEndOfTransaction().

                             {
  if(!m_datasvc) throw cond::Exception("PoolTransaction::rollback: database not connected");
   m_datasvc->transaction().rollback();
   this->NotifyEndOfTransaction();
}

void PoolTransaction::start

(

bool

readOnly

)

[virtual]

start transaction

Implements cond::ITransaction.

Definition at line 15 of file PoolTransaction.cc.

References Exception, isReadOnly(), m_count, m_datasvc, cond::ITransaction::NotifyStartOfTransaction(), UPDATE, and upgrade().

Referenced by cond::service::PoolDBOutputService::add(), DTDBSession::connect(), CondBasicIter::create(), cond::service::PoolDBOutputService::createNewIOV(), cond::PoolTransactionSentry::Elem::Elem(), cond::IOVServiceImpl::exportIOVRangeWithPayload(), cond::impl::IOVImpl::IOVImpl(), l1t::DataReader::loadIntervals(), DataProxy< RecordT, DataT >::make(), DataProxy< IdealGeometryRecord, DDCompactView >::make(), l1t::DataReader::payloadToken(), l1t::DataReader::readKey(), l1t::DataReader::readPayload(), popcon::PopConSourceHandler< T >::Ref::Ref(), PoolDBESSource::setIntervalFor(), cond::service::PoolDBOutputService::tagInfo(), l1t::DataWriter::updateIOV(), l1t::DataWriter::writeKey(), l1t::DataWriter::writeKeyList(), and l1t::DataWriter::writePayload().

                                       {
  m_count++;
  if (1==m_count) {
    this->NotifyStartOfTransaction();
    if(!m_datasvc) throw cond::Exception("PoolTransaction::start: database not connected");
    if(!readOnly){
      m_datasvc->transaction().start( pool::ITransaction::UPDATE );
    }else{
      m_datasvc->transaction().start( pool::ITransaction::READ );
    }
    return;
  }
  if (!readOnly && isReadOnly()) upgrade();

}

void PoolTransaction::upgrade

(

)

[private]

Definition at line 39 of file PoolTransaction.cc.

References forceCommit(), m_datasvc, cond::ITransaction::NotifyStartOfTransaction(), and UPDATE.

Referenced by start().

                             {
  forceCommit();
  this->NotifyStartOfTransaction();
  m_datasvc->transaction().start( pool::ITransaction::UPDATE );
}

---

Member Data Documentation

int cond::PoolTransaction::m_count [private]

Definition at line 47 of file PoolTransaction.h.

Referenced by commit(), and start().

pool::IDataSvc* cond::PoolTransaction::m_datasvc [mutable, private]

Definition at line 44 of file PoolTransaction.h.

Referenced by forceCommit(), isReadOnly(), poolDataSvc(), resetPoolDataSvc(), rollback(), start(), and upgrade().

cond::PoolConnectionProxy* cond::PoolTransaction::m_parentConnection [private]

Definition at line 43 of file PoolTransaction.h.

Referenced by parentConnection(), and PoolTransaction().

---

The documentation for this class was generated from the following files:

• CondCore/DBCommon/interface/PoolTransaction.h
• CondCore/DBCommon/src/PoolTransaction.cc

---