UserDatabase.h

Go to the documentation of this file.

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

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

    virtual ~UserDatabase();

    virtual void connectForRead() override;

    void* readObject( const Token& token, void* object = 0 );

    virtual void connectForWrite() override;

    Token* writeObject( const std::string& containerName,
                        long minorTechnology,
                        const void* object,
                        const RootType& type );

    virtual void disconnect() override;

    virtual Io::IoFlag openMode() const override;

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

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

    virtual bool setTechnology( long technology ) override;

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

    virtual IContainer* containerHandle( const std::string& name ) override;
 
    // expose FileDescriptor object for the technology specific DB implementation
    virtual FileDescriptor* fileDescriptor() override final;
 
  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;
    IFileCatalog&                           m_catalog;
    Io::IoFlag                              m_transactionType;
    DatabaseRegistry&                       m_registry;
    std::string                             m_name;
    DatabaseSpecification::NameType         m_nameType;
    long                                    m_technology;
    bool                                    m_technologySet;
    DatabaseHandler*                        m_databaseHandler;
    Io::IoFlag                              m_openMode;
    bool                                    m_alreadyConnected;
    std::string                             m_the_fid;
    std::string                             m_the_pfn;

    bool checkInRegistry();
  };
}
 
#endif