UserDatabase.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2026 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef INCLUDE_PERSISTENCYSVC_USERDATABASE_H
#define INCLUDE_PERSISTENCYSVC_USERDATABASE_H
 
#include "PersistencySvc/IDatabase.h"
#include "PersistencySvc/ISession.h"
#include "PersistencySvc/ITechnologySpecificAttributes.h"
#include "StorageSvc/DbPrint.h"
 
namespace pool {
  // forward declarations
  class DatabaseConnectionPolicy;
  class IFileCatalog;
   
  // forward declarations
  class UserSession;
  class DatabaseHandler;
  class DatabaseRegistry;

  class UserDatabase : virtual public IDatabase,
                       virtual public ITechnologySpecificAttributes,
                       public APRMessaging
  {
  public:
    UserDatabase( UserSession& session,
                  const std::string& name,
                  const DatabaseSpecification::NameType nameType );

    virtual ~UserDatabase();

    DatabaseHandler& databaseHandler();

    virtual void connectForRead() override;

    virtual void connectForWrite() override;

    virtual void disconnect() override;

    virtual IDatabase::OpenMode openMode() const override;

    virtual const std::string& fid() override;

    virtual const std::string& pfn() override;

    virtual bool setTechnology( long technology ) override;

    virtual long technology() const override;

    virtual std::vector< std::string > containers() override;

    virtual IContainer* containerHandle( const std::string& name ) override;

    virtual const ITechnologySpecificAttributes& technologySpecificAttributes() const override;
    virtual ITechnologySpecificAttributes& technologySpecificAttributes() override;
 
  protected:
    virtual
    bool attributeOfType( const std::string& attributeName,
                          void* data,
                          const std::type_info& typeInfo,
                          const std::string& option ) override;
 
    virtual
    bool setAttributeOfType( const std::string& attributeName,
                             const void* data,
                             const std::type_info& typeInfo,
                             const std::string& option ) override;
  private:
    UserSession&                            m_session;
    const DatabaseConnectionPolicy&         m_policy;
    IFileCatalog&                           m_catalog;
    ITransaction::Type                      m_transactionType;
    DatabaseRegistry&                       m_registry;
    std::string                             m_name;
    DatabaseSpecification::NameType         m_nameType;
    long                                    m_technology;
    bool                                    m_technologySet;
    DatabaseHandler*                        m_databaseHandler;
    IDatabase::OpenMode                     m_openMode;
    bool                                    m_alreadyConnected;
    std::string                             m_the_fid;
    std::string                             m_the_pfn;

    bool checkInRegistry();

    void setTechnologyIdentifier( const std::string& sTechnology );
  };
}
 
#endif