PoolCollectionConverter Class Reference

This class provides an interface to POOL collections. More...

#include <PoolCollectionConverter.h>

Collaboration diagram for PoolCollectionConverter:

Public Member Functions
	PoolCollectionConverter (const std::string &inputCollection, unsigned int contextId, const IPoolSvc *svc)
	Constructor.
virtual	~PoolCollectionConverter ()
	Destructor.
StatusCode	initialize ()
	Required by all Gaudi Services.
StatusCode	disconnectDb ()
	Disconnect Database.
StatusCode	isValid () const
	Check whether has valid pool::ICollection*.
std::unique_ptr< pool::ICollectionCursor >	selectAll ()
const std::string &	lastError () const

Private Member Functions
	PoolCollectionConverter (const PoolCollectionConverter &rhs)
PoolCollectionConverter &	operator= (const PoolCollectionConverter &rhs)

Private Attributes
std::string	m_inputCollection
unsigned int	m_contextId
const IPoolSvc *	m_poolSvc
pool::ICollection *	m_poolCollection
std::string	m_lastError

Detailed Description

This class provides an interface to POOL collections.

Definition at line 27 of file PoolCollectionConverter.h.

Constructor & Destructor Documentation

PoolCollectionConverter() [1/2]

PoolCollectionConverter::PoolCollectionConverter	(	const std::string &	inputCollection,
		unsigned int	contextId,
		const IPoolSvc *	svc )

Constructor.

Parameters

svc	[IN] pointer to the PoolSvc.
contextId	[IN] id for PoolSvc persistency service to use for input.

Definition at line 28 of file PoolCollectionConverter.cxx.

                         :
    m_inputCollection(inputCollection),
    m_contextId(contextId),
    m_poolSvc(svc),
    m_poolCollection(nullptr) {
}

~PoolCollectionConverter()

PoolCollectionConverter::~PoolCollectionConverter ( )

virtual

Destructor.

Definition at line 38 of file PoolCollectionConverter.cxx.

                                                  {
   if (m_poolCollection) {
      m_poolCollection->close();
      delete m_poolCollection; m_poolCollection = nullptr;
   }
}

PoolCollectionConverter() [2/2]

PoolCollectionConverter::PoolCollectionConverter ( const PoolCollectionConverter & rhs )

private

Member Function Documentation

disconnectDb()

StatusCode PoolCollectionConverter::disconnectDb

(

)

Disconnect Database.

Definition at line 67 of file PoolCollectionConverter.cxx.

                                                 {
   if (m_poolCollection == nullptr) {
      return StatusCode::SUCCESS;
   }
   return m_poolSvc->disconnectDb(m_inputCollection);
}

initialize()

StatusCode PoolCollectionConverter::initialize

(

)

Required by all Gaudi Services.

Definition at line 45 of file PoolCollectionConverter.cxx.

                                               {
   // Check if already prefixed
   if (!m_inputCollection.starts_with( "PFN:")
           && !m_inputCollection.starts_with( "LFN:")
           && !m_inputCollection.starts_with( "FID:")) {
      // Prefix with PFN:
      m_inputCollection = std::format("PFN:{}", m_inputCollection);
   }
   StatusCode sc = m_poolSvc->connectCollection(m_inputCollection, "Input", m_contextId);
   try {
      m_poolCollection = pool::CollectionService::open("Input", m_inputCollection, m_poolSvc->getInputContextSession(m_contextId));
      m_lastError.clear();
   } catch (std::exception &e) {
      m_lastError = std::format("Failed to open collection '{}': {}", m_inputCollection, e.what());
   }
   if( sc.isRecoverable() || m_poolCollection == nullptr ) {
      return m_poolSvc->checkCollection(m_inputCollection, m_contextId, m_poolCollection == nullptr);
   }
   return StatusCode::SUCCESS;
}

isValid()

StatusCode PoolCollectionConverter::isValid

(

)

const

Check whether has valid pool::ICollection*.

Definition at line 74 of file PoolCollectionConverter.cxx.

                                                  {
   return m_poolCollection != nullptr ? StatusCode::SUCCESS : StatusCode::FAILURE;
}

lastError()

const std::string & PoolCollectionConverter::lastError ( ) const

inline

Definition at line 52 of file PoolCollectionConverter.h.

{ return m_lastError; }

operator=()

PoolCollectionConverter & PoolCollectionConverter::operator= ( const PoolCollectionConverter & rhs )

private

selectAll()

std::unique_ptr< pool::ICollectionCursor > PoolCollectionConverter::selectAll

(

)

Returns

ICollectionCursor over all entries

Definition at line 78 of file PoolCollectionConverter.cxx.

                                                                        {
   if (m_poolCollection == nullptr)[[unlikely]] {
     throw std::runtime_error("PoolCollectionConverter::selectAll: m_poolCollection is nullptr.");
   }
   return m_poolCollection->cursor();
}

Member Data Documentation

m_contextId

unsigned int PoolCollectionConverter::m_contextId

private

Definition at line 56 of file PoolCollectionConverter.h.

m_inputCollection

std::string PoolCollectionConverter::m_inputCollection

private

Definition at line 55 of file PoolCollectionConverter.h.

m_lastError

std::string PoolCollectionConverter::m_lastError

private

Definition at line 60 of file PoolCollectionConverter.h.

m_poolCollection

pool::ICollection* PoolCollectionConverter::m_poolCollection

private

Definition at line 58 of file PoolCollectionConverter.h.

m_poolSvc

const IPoolSvc* PoolCollectionConverter::m_poolSvc

private

Definition at line 57 of file PoolCollectionConverter.h.

---

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

• PoolCollectionConverter.h
• PoolCollectionConverter.cxx