Database/AthenaPOOL/PoolSvc/src/Database.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2026 CERN for the benefit of the ATLAS collaboration
*/
 
#ifndef POOLSVC_DATABASE_H
#define POOLSVC_DATABASE_H
 
#include "AthenaBaseComps/AthMessaging.h"
#include "DataModelRoot/RootType.h"
#include "GaudiKernel/IFileMgr.h"
 
namespace Gaudi {
  class IFileCatalog;
}
namespace pool {
  class FileDescriptor;
}
 
class SessionTool;
class DatabaseHandler;
class DatabaseRegistry;
class Container;
class Token;

class Database final : public AthMessaging
{
public:
  struct Specification {
    enum NameType { UNDEFINED,
                    PFN,    
                    FID,    
                    LFN     
    };
  };

  Database( SessionTool& session,
            const std::string& name,
            const Specification::NameType nameType );

  ~Database();

  void connectForRead();

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

  void connectForWrite();

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

  void disconnect();

  Io::IoFlag openMode() const;

  const std::string& fid();

  const std::string& pfn();

  bool setTechnology( long technology );

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

  Container* containerHandle( const std::string& name );
 
  // expose FileDescriptor object for the technology specific DB implementation
  pool::FileDescriptor* fileDescriptor();
 
  bool attributeOfType( const std::string& attributeName,
                        void* data,
                        const std::type_info& typeInfo,
                        const std::string& option );
 
  bool setAttributeOfType( const std::string& attributeName,
                           const void* data,
                           const std::type_info& typeInfo,
                           const std::string& option );
private:
  SessionTool&                            m_session;
  Gaudi::IFileCatalog&                    m_catalog;
  Io::IoFlag                              m_transactionType;
  DatabaseRegistry&                       m_registry;
  std::string                             m_name;
  Specification::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