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 &collectionType, const std::string &inputCollection, unsigned int contextId, const IPoolSvc *svc)
	Constructor. More...
virtual	~PoolCollectionConverter ()
	Destructor. More...
StatusCode	initialize ()
	Required by all Gaudi Services. More...
StatusCode	disconnectDb ()
	Disconnect Database. More...
StatusCode	isValid () const
	Check whether has valid pool::ICollection*. More...
pool::ICollectionCursor &	selectAll ()

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

Private Attributes
std::string	m_collectionType
std::string	m_connection
std::string	m_inputCollection
unsigned int	m_contextId
const IPoolSvc *	m_poolSvc
pool::ICollection *	m_poolCollection
pool::ICollectionQuery *	m_collectionQuery
std::string	m_inputContainer

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 &	collectionType,
		const std::string &	inputCollection,
		unsigned int	contextId,
		const IPoolSvc *	svc
	)

Constructor.

Parameters

collectionType	[IN] type of the collection ("RootCollection", or "ImplicitCollection").
inputCollection	[IN] name of the collection.
svc	[IN] pointer to the PoolSvc.
contextId	[IN] id for PoolSvc persistency service to use for input.

Definition at line 31 of file PoolCollectionConverter.cxx.

                         :
    m_collectionType(collectionType),
    m_connection(),
    m_inputCollection(inputCollection),
    m_contextId(contextId),
    m_poolSvc(svc),
    m_poolCollection(nullptr),
    m_collectionQuery(nullptr),
    m_inputContainer() {
}

~PoolCollectionConverter()

PoolCollectionConverter::~PoolCollectionConverter ( )

virtual

Destructor.

Definition at line 45 of file PoolCollectionConverter.cxx.

                                                  {
   if (m_poolCollection) {
      m_poolCollection->close();
      delete m_collectionQuery; m_collectionQuery = nullptr;
      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 96 of file PoolCollectionConverter.cxx.

                                                 {
   if (m_poolCollection == nullptr) {
      return StatusCode::SUCCESS;
   }
   if (m_poolCollection->description().type() == "ImplicitCollection") {
      return m_poolSvc->disconnectDb(m_connection);
   }
   return StatusCode::SUCCESS;
}

initialize()

StatusCode PoolCollectionConverter::initialize

(

)

Required by all Gaudi Services.

Definition at line 53 of file PoolCollectionConverter.cxx.

                                               {
   // Find out if the user specified a container
   const std::string collectionType = m_collectionType;
   std::string::size_type p_colon = collectionType.rfind(':');
   if (p_colon != std::string::npos) {
      m_inputContainer = collectionType.substr(p_colon + 1);
      m_collectionType = collectionType.substr(0, p_colon);
   }
   if (m_collectionType == "ImplicitCollection") {
      // Check if already prefixed
      if (m_inputCollection.starts_with( "PFN:")
          || m_inputCollection.starts_with( "LFN:")
          || m_inputCollection.starts_with( "FID:")) {
         // Already prefixed
         m_connection = m_inputCollection;
      } else {
         // Prefix with PFN:
         m_connection = std::format("PFN:{}", m_inputCollection);
      }
      try {
         m_poolCollection = m_poolSvc->createCollection("RootCollection", m_connection, m_inputCollection, m_contextId);
      } catch (std::exception &e) {
         m_poolCollection = nullptr;
      }
      if (m_poolCollection == nullptr) {
         // Now set where to look in the implicit file
         m_inputCollection = std::format("{}(DataHeader)", m_inputContainer);
      }
   }
   try {
      if (m_poolCollection == nullptr) {
         m_poolCollection = m_poolSvc->createCollection(m_collectionType, m_connection, m_inputCollection, m_contextId);
      }
      if (m_poolCollection == nullptr && m_collectionType == "ImplicitCollection") {
         m_inputCollection = std::format("{}_DataHeader", m_inputContainer);
         m_poolCollection = m_poolSvc->createCollection(m_collectionType, m_connection, m_inputCollection, m_contextId);
      }
   } catch (std::exception &e) {
      return StatusCode::RECOVERABLE;
   }
   return StatusCode::SUCCESS;
}

isValid()

StatusCode PoolCollectionConverter::isValid

(

)

const

Check whether has valid pool::ICollection*.

Definition at line 106 of file PoolCollectionConverter.cxx.

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

operator=()

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

private

selectAll()

pool::ICollectionCursor & PoolCollectionConverter::selectAll

(

)

Returns

ICollectionCursor over all entries

Definition at line 110 of file PoolCollectionConverter.cxx.

                                                          {
   delete m_collectionQuery; m_collectionQuery = nullptr;
   m_collectionQuery = m_poolCollection->newQuery();
   m_collectionQuery->selectAll();
   return m_collectionQuery->execute();
}

Member Data Documentation

m_collectionQuery

pool::ICollectionQuery* PoolCollectionConverter::m_collectionQuery

private

Definition at line 63 of file PoolCollectionConverter.h.

m_collectionType

std::string PoolCollectionConverter::m_collectionType

private

Definition at line 57 of file PoolCollectionConverter.h.

m_connection

std::string PoolCollectionConverter::m_connection

private

Definition at line 58 of file PoolCollectionConverter.h.

m_contextId

unsigned int PoolCollectionConverter::m_contextId

private

Definition at line 60 of file PoolCollectionConverter.h.

m_inputCollection

std::string PoolCollectionConverter::m_inputCollection

private

Definition at line 59 of file PoolCollectionConverter.h.

m_inputContainer

std::string PoolCollectionConverter::m_inputContainer

private

Definition at line 64 of file PoolCollectionConverter.h.

m_poolCollection

pool::ICollection* PoolCollectionConverter::m_poolCollection

private

Definition at line 62 of file PoolCollectionConverter.h.

m_poolSvc

const IPoolSvc* PoolCollectionConverter::m_poolSvc

private

Definition at line 61 of file PoolCollectionConverter.h.

---

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

• PoolCollectionConverter.h
• PoolCollectionConverter.cxx