/afs/cern.ch/work/a/aaltunda/public/www/CMSSW_6_2_7/src/CondCore/ORA/src/CArrayStreamer.h

Go to the documentation of this file.

#ifndef INCLUDE_ORA_CARRAYSTREAMER_H
#define INCLUDE_ORA_CARRAYSTREAMER_H

#include "DataElement.h"
#include "IRelationalStreamer.h"
#include "RelationalDeleter.h"
//
#include <memory>
// externals
#include "Reflex/Type.h"

namespace ora {

  class MappingElement;
  class ContainerSchema;

  class IArrayHandler;
  class MultiRecordInsertOperation;
  class MultiRecordSelectOperation;

  class CArrayWriter : public IRelationalWriter {
    
    public:
      CArrayWriter( const Reflex::Type& objectType, MappingElement& mapping, ContainerSchema& contSchema );
      virtual ~CArrayWriter();

      bool build( DataElement& offset, IRelationalData& relationalData, RelationalBuffer& operationBuffer );
      
      void setRecordId( const std::vector<int>& identity );

      void write( int oid,const void* data );

    private:
      Reflex::Type m_objectType;
      MappingElement& m_mappingElement;
      ContainerSchema& m_schema;
      std::vector<int> m_recordId;
      DataElement m_localElement;

    private:
      DataElement* m_offset;
      MultiRecordInsertOperation* m_insertOperation;
      std::auto_ptr<IArrayHandler> m_arrayHandler;
      std::auto_ptr<IRelationalWriter> m_dataWriter;
      
  };
  
  class CArrayUpdater : public IRelationalUpdater {

    public:

    CArrayUpdater(const Reflex::Type& objectType, MappingElement& mapping, ContainerSchema& contSchema );

    virtual ~CArrayUpdater();

    bool build( DataElement& offset, IRelationalData& relationalData, RelationalBuffer& operationBuffer);

    void setRecordId( const std::vector<int>& identity );

    void update( int oid,const void* data );

    private:

    RelationalDeleter m_deleter;
    CArrayWriter m_writer;
  };

  class CArrayReader : public IRelationalReader {

    public:
    
    CArrayReader(const Reflex::Type& objectType, MappingElement& mapping, ContainerSchema& contSchema );

    virtual ~CArrayReader();
    
    bool build( DataElement& offset, IRelationalData& relationalData );

    void select( int oid );
    
    void setRecordId( const std::vector<int>& identity );

    void read( void* address );

    void clear();

    private:
      Reflex::Type m_objectType;
      MappingElement& m_mappingElement;
      ContainerSchema& m_schema;
      std::vector<int> m_recordId;
      DataElement m_localElement;
      
    private:
      DataElement* m_offset;
      std::auto_ptr<MultiRecordSelectOperation> m_query;
      std::auto_ptr<IArrayHandler> m_arrayHandler;
      std::auto_ptr<IRelationalReader> m_dataReader;
  };

  class CArrayStreamer : public IRelationalStreamer 
  {
    public:
    CArrayStreamer( const Reflex::Type& objectType, MappingElement& mapping, ContainerSchema& contSchema );

    ~CArrayStreamer();

    IRelationalWriter* newWriter();

    IRelationalUpdater* newUpdater();

    IRelationalReader* newReader();
    
    private:
    Reflex::Type m_objectType;
    MappingElement& m_mapping;
    ContainerSchema& m_schema;
  }; 

  
}

#endif