ImplicitCollection.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2022 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef INCLUDE_IMPLICITCOLLECTION_IMPLICITCOLLECTION_H
#define INCLUDE_IMPLICITCOLLECTION_IMPLICITCOLLECTION_H
 
#include "CollectionBase/ICollection.h"
#include "CollectionBase/CollectionDescription.h"
#include "CollectionBase/CollectionRowBuffer.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
  //    ^ due to not thread-safe ImplicitCollectionIterator
  {
  public:
    typedef Gaudi::PluginService::Factory<ICollection*( const ICollectionDescription*, ICollection::OpenMode, ISession*)> Factory;  
 
    ImplicitCollection( ISession* session,
                        const std::string& connection,
                        const std::string& name,
                        ICollection::OpenMode mode );
 
    ImplicitCollection( const ICollectionDescription* description,
                        ICollection::OpenMode mode,
                        ISession* session );
    
    ~ImplicitCollection();
 
    ImplicitCollection (const ImplicitCollection&) = delete;
    ImplicitCollection& operator= (const ImplicitCollection&) = delete;
 
    virtual ICollection::OpenMode openMode() const; 
    
 
    ImplicitCollectionIterator* select( const std::string & primaryQuery = "",
                                        std::string secondaryQuery = "",
                                        std::string options = "" );
 
    virtual void insertRow( const pool::CollectionRowBuffer& inputRowBuffer );
 
    void commit(bool reopen=false);
 
    void rollback();
 
    void close();
 
    void open();
 
    bool isOpen() const;
 
 
    virtual const ICollectionDescription& description() const;
 
    virtual ICollectionQuery*                 newQuery();
 
 protected:
 
    void open( ICollection::OpenMode mode, ISession* session );
 
 
  private:
    IContainer                        *m_container;
 
    CollectionDescription        m_description;
  };
}
 
#endif