PoolDbTupleCallback.h

Go to the documentation of this file.

// $Id: PoolDbTupleCallback.h,v 1.3 2006/01/27 08:27:02 hmd Exp $
//====================================================================
// NTuple callback class definition
//--------------------------------------------------------------------
//
//  Package    : PoolDb ( The LHCb Offline System)
//  Author     : M.Frank
//
//====================================================================
#ifndef POOL_POOLDBTUPLECALLBACK_H
#define POOL_POOLDBTUPLECALLBACK_H

// Include files
#include "StorageSvc/DbBlob.h"
#include "StorageSvc/DbContainer.h"
#include "StorageSvc/DbObjectCallBack.h"
#include "StorageSvc/DbDefaultDataHandler.h"
#include "GaudiPoolDb/PoolDbNTupleDescriptor.h"
#include "GaudiKernel/Kernel.h"

// Forward declarations
class INTuple;
class DbSelect;
class DataObject;
class ISelectStatement;
namespace pool {
  class DbTypeInfo;
  class IContainer;
  class ITokenIterator;
}

class GAUDI_API PoolDbTupleCallback
  : public pool::DbDefaultDataHandler,
    public pool::DbObjectCallBack
{
  typedef const ROOT::Reflex::Type& TypeH;
  std::vector< void* >          m_addr;
  std::vector<PoolDbTokenWrap>  m_links;
  std::vector<PoolDbTokenWrap*> m_plinks;
  std::vector<int>              m_map;
  pool::DbSelect*               m_iter;
  pool::DbBlob                  m_stream;
  pool::DbContainer             m_cntH;
  long                          m_refCount;

public:

  PoolDbTupleCallback(DataObject* pObj);
  virtual ~PoolDbTupleCallback();
  virtual pool::DataCallBack* clone() const;
  virtual void release();
  std::vector<void*>& addresses()               {  return m_addr;     }
  const std::vector<int>& mapping()             {  return m_map;      }
  std::vector<PoolDbTokenWrap*>& links()        {  return m_plinks; }
  pool::DbBlob& stream()                        {  return m_stream;   }
  pool::DbSelect* iterator() const              {  return m_iter;     }
  pool::DbSelect* select(ISelectStatement* sel);
  void configure(const INTuple* pTuple,
                 const pool::DbTypeInfo* typ,
                 const pool::DbContainer& cntH);

  virtual pool::DbStatus start (CallType  action_type,
                                void*     pObj,
                                void**    context);

  virtual pool::DbStatus end(CallType action_type, void* context);

  virtual pool::DbStatus bind(CallType              action_type,
                              const pool::DbColumn* col_ident,
                              int                   col_number,
                              void*                 context,
                              void**                data_pointer);
};
#endif // POOL_POOLDBTUPLECALLBACK_H