DbStorageSvc.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2026 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef POOL_DBSTORAGESVC_H
#define POOL_DBSTORAGESVC_H
 
// Framework include files
#include "StorageSvc/DbDomain.h"
#include "StorageSvc/IStorageSvc.h"
#include "StorageSvc/DbPrint.h"
 
/*
 *   POOL namespace declaration
 */
namespace pool  {
 
  // Forward declarations
  class DbOption;
  class IOODatabase;

  class DbStorageSvc  : virtual public IStorageSvc, virtual public APRMessaging
  {
    typedef std::vector<const Token*> TokenVec;
  private:
    std::string         m_name;
    unsigned int        m_refCount;
    DbDomain            m_domH;
    int                 m_ageLimit;
    DbType              m_type;
    IOODatabase*        m_implementation;
 
  public:

    DbStorageSvc();

    explicit DbStorageSvc(const std::string& name);

    virtual ~DbStorageSvc();
 
    DbStorageSvc (const DbStorageSvc&) = delete;
    DbStorageSvc& operator= (const DbStorageSvc&) = delete;

    virtual unsigned int addRef() override final;

    virtual unsigned int release() override final;


    virtual StatusCode initialize();

    virtual StatusCode finalize();

    virtual const std::string& name() const    { return m_name;  }


    virtual StatusCode allocate( FileDescriptor&       refDB,
                                 const std::string&    refCont,
                                 int                   technology,
                                 const void*           object,
                                 ShapeH                shapeH,
                                 Token*&               refpTok) override final;


    virtual StatusCode read(     const FileDescriptor& refDB,
                                 const Token&          persToken,
                                 ShapeH                shapeH,
                                 void**                object) override final;


    virtual std::string getContName(FileDescriptor& refDB,
                                    Token&          persToken) override final;


    virtual StatusCode getShape(  FileDescriptor&       refDB,
                                  const Guid&           objType,
                                  ShapeH&               shapeH) override final;


    virtual ShapeH     createShape( const Guid& shapeID ) override final;


    virtual StatusCode startSession(int mode, int tech) override final;


    virtual StatusCode endSession() override final
    { return m_domH.close(); }


    virtual StatusCode existsConnection(const FileDescriptor& refDB) override final;


    virtual StatusCode connect(int mode, FileDescriptor& refDB) override final;


    virtual StatusCode disconnect(  FileDescriptor&  refDB) override final;


    virtual StatusCode openMode( FileDescriptor&     refDB,
                                 int&                mode ) override final;
 


    virtual StatusCode endTransaction( FileDescriptor& refDB,
                                       Transaction::Action typ) override final;


    virtual StatusCode getDomainOption(DbOption& opt) override final
    { return m_domH.getOption(opt); }


    virtual StatusCode setDomainOption(const DbOption& opt) override final
    { return m_domH.setOption(opt); }
 
  private:
    IOODatabase* db();
 
  };
}       // End namespace pool
#endif  // POOL_DBSTORAGESVC_H