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;
   
 
  namespace PersistencySvc {
    // 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