ImplicitCollection.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2025 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef COLLECTIONSVC_IMPLICITCOLLECTION_H
#define COLLECTIONSVC_IMPLICITCOLLECTION_H
 
#include "CollectionSvc/ICollection.h"
#include "CollectionSvc/CollectionDescription.h"
#include "CollectionSvc/CollectionRowBuffer.h"
#include "POOLCore/DbPrint.h"
 
#include "CxxUtils/checker_macros.h"
#include "Gaudi/PluginService.h"
 
namespace pool {
 
  // forward declarations
   class ISession;
   class IContainer;
   class ICollectionQuery;
   class ICollectionIterator;
   class ImplicitCollectionIterator;

  class ATLAS_NOT_THREAD_SAFE ImplicitCollection : virtual public ICollection, public APRMessaging
  //    ^ due to not thread-safe ImplicitCollectionIterator
  {
  public:
    typedef Gaudi::PluginService::Factory<ICollection*( const CollectionDescription*, ICollection::OpenMode, ISession*)> Factory;  

    ImplicitCollection( const CollectionDescription* description,
                        ICollection::OpenMode mode,
                        ISession* session );
    
    ~ImplicitCollection();
 
    ImplicitCollection (const ImplicitCollection&) = delete;
    ImplicitCollection& operator= (const ImplicitCollection&) = delete;

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

    void commit(bool reopen=false) override;

    void close() override;

    void open() override;

    virtual const CollectionDescription& description() const override;

    virtual ICollectionCursor& cursor() final override;
 
  protected:
    void open( ICollection::OpenMode mode, ISession* session );
 
  private:
    IContainer*                 m_container;
 
    CollectionDescription       m_description;
  };
}
 
#endif