RootCollection.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2026 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef ROOTCOLLECTION_ROOTCOLLECTION_H
#define ROOTCOLLECTION_ROOTCOLLECTION_H
 
#include "CollectionSvc/ICollection.h"
#include "CollectionSvc/CollectionDescription.h"
#include "CollectionSvc/CollectionRowBuffer.h"
#include "StorageSvc/DbPrint.h"
#include "StorageSvc/FileDescriptor.h"
#include "StorageSvc/DbContainer.h"
#include "CollectionCursor.h"
 
#include <string>
#include <memory>
 
 
namespace pool {
 
   class ISession;
   class IStorageSvc;
 
   class Attribute;
 
   // Create and Overwrite is only option, we'll never update
   constexpr const char* const poolOptToRootOpt[] = {"UPDATE", "READ"};
   // Collection open mode mapping to StorageSvc open mode
   inline const Io::IoFlag collModeToPoolMode[]   = { Io::WRITE, Io::READ };
 

   class RootCollection :  public ICollection, public APRMessaging {
 
     public:
        RootCollection( const pool::CollectionDescription* description,
                        pool::ICollection::OpenMode mode );

        ~RootCollection();
 

        virtual void open() final override;

        virtual void insertRow( const pool::CollectionRowBuffer& inputRowBuffer ) final override;

        virtual void commit( bool restartTransaction = false ) final override;

        virtual void close() final override;

        virtual const CollectionDescription& description() const final override;

        virtual std::unique_ptr<ICollectionCursor> cursor() final override;
 
     private:

        RootCollection(const RootCollection &) = delete;
        RootCollection& operator = (const RootCollection &) = delete;
 
        void writeColumn( const std::string& columnName, const void* data,  const std::type_info& typeInfo);
 
 
        CollectionDescription                m_description;
 
        std::string                          m_name;
        std::string                          m_fileName;
        std::string                          m_containerPrefix;
        ICollection::OpenMode                m_mode;
 
        bool                                 m_open;
 
        std::unique_ptr<IStorageSvc>         m_storageSvc;
        pool::FileDescriptor                 m_fileDescr;
        ContainerMap                         m_containerMap;
   };
}
#endif