DbContainerObj.h

Go to the documentation of this file.

/*
  Copyright (C) 2002-2025 CERN for the benefit of the ATLAS collaboration
*/
 
//====================================================================
//  DbContainerObj class definitions
//--------------------------------------------------------------------
//
//  Package    : StorageSvc  (The POOL project)
//  @author      M.Frank
//====================================================================
#ifndef POOL_DBCONTAINEROBJ_H
#define POOL_DBCONTAINEROBJ_H 1
 
// Framework include files
#include "PersistentDataModel/Token.h"
#include "StorageSvc/DbDatabase.h"
#include "StorageSvc/DbAccessObj.h"
#include "StorageSvc/DbContainer.h"
#include "POOLCore/DbPrint.h"
 
/*
 *  POOL namespace declaration
 */
namespace pool  {
 
  typedef const class Shape        *ShapeH;

  struct DbObjectHolder  {
    DbObject* m_obj;
    explicit DbObjectHolder(DbObject* p) : m_obj(p) {}
    int release();
  };
  class DbContainerObj : public  DbAccessObj<DbObject*, DbObjectHolder >, public APRMessaging {
  private:
    IDbContainer*                 m_info;
    const Token*                  m_tokH;
    DbDatabase                    m_dbH;
    bool                          m_isOpen;

    bool hasAccess();
  public:

    DbContainerObj( DbDatabase&        dbH,
                    const std::string& nam,
                    const DbType&      dbtyp,
                    DbAccessMode       mod);
    virtual ~DbContainerObj();
    const IDbContainer* info()  const       {  return m_info;         }
    IDbContainer* info()                    {  return m_info;         }
    const DbTypeInfo* objectShape(const Guid& nam);
    DbDatabase& database()                  {  return m_dbH;          }
    const Token* token() const              {  return m_tokH;         }
    bool isOpen() const                     {  return m_isOpen;       }
    bool isReadOnly() const      
    { return !(mode()&pool::UPDATE) && !(mode()&pool::CREATE);    }

    void cancelTransaction()                { }
    uint64_t size();
    DbStatus open(const DbTypeInfo* typ);
    DbStatus checkAccess();
    DbStatus close();
    DbStatus retire();
    DbStatus transAct(Transaction::Action);
    DbStatus setOption(const DbOption& opt);
    DbStatus getOption(DbOption& refOpt);


    DbStatus store(const void* object, DbContainer& cntH, ShapeH shape);

    DbStatus allocate(DbContainer& cntH, const void* object, ShapeH shape, Token::OID_t& oid);

    DbStatus load( void** ptr, ShapeH shape,
                   const Token::OID_t& linkH,
                   Token::OID_t&       oid,
                   bool          any_next);

    DbStatus select(DbSelect& sel);
    DbStatus fetch(DbSelect& sel);
  };
}       // End namespace pool
#endif  // POOL_DBCONTAINEROBJ_H