QueryableVectorStreamer.h

Go to the documentation of this file.

#ifndef INCLUDE_ORA_QUERYABLEVECTORSTREAMER_H
#define INCLUDE_ORA_QUERYABLEVECTORSTREAMER_H

#include "PVectorStreamer.h"
#include "DataElement.h"
//
#include <memory>
#include <boost/shared_ptr.hpp>
// externals
#include "Reflex/Type.h"

namespace ora {

  class MappingElement;
  class ContainerSchema;
  class IRelationalData;
  class IArrayHandler;
  class MultiRecordInsertOperation;
  class IVectorLoader;
  
  class QueryableVectorWriter: public IRelationalWriter {
    
    public:
      QueryableVectorWriter( const Reflex::Type& objectType, MappingElement& mapping, ContainerSchema& contSchema );
      virtual ~QueryableVectorWriter();

      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;
      DataElement* m_offset;
      DataElement m_localElement;
    private:  
      PVectorWriter m_writer;
  };
  
  class QueryableVectorUpdater : public IRelationalUpdater {

    public:

    QueryableVectorUpdater(const Reflex::Type& objectType, MappingElement& mapping, ContainerSchema& contSchema );
    virtual ~QueryableVectorUpdater();

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

    private:
      Reflex::Type m_objectType;
      DataElement* m_offset;
      DataElement m_localElement;
    private:
    PVectorUpdater m_updater;
  };

  class QueryableVectorReader : public IRelationalReader {

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

    virtual ~QueryableVectorReader();
    
    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_mapping;
    ContainerSchema& m_schema;
    DataElement* m_dataElement;
    std::vector<boost::shared_ptr<IVectorLoader> > m_loaders;
    std::vector<int> m_tmpIds;
  };

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

    ~QueryableVectorStreamer();

    IRelationalWriter* newWriter();

    IRelationalUpdater* newUpdater();

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

  
}

#endif