ora::OraPtrReadBuffer Class Reference

Public Member Functions
bool	build (DataElement &dataElement)
	OraPtrReadBuffer (const Reflex::Type &objectType, MappingElement &mapping, ContainerSchema &contSchema)
void *	read (const std::vector< int > &fullId)
	~OraPtrReadBuffer ()

Private Attributes
DataElement *	m_dataElement
DataElement	m_localElement
MappingElement &	m_mapping
Reflex::Type	m_objectType
SelectOperation	m_query
std::auto_ptr< IRelationalReader >	m_reader
ContainerSchema &	m_schema

Detailed Description

Definition at line 15 of file OraPtrStreamer.cc.

Constructor & Destructor Documentation

ora::OraPtrReadBuffer::OraPtrReadBuffer ( const Reflex::Type &  objectType, MappingElement &  mapping, ContainerSchema &  contSchema  )

inline

Definition at line 17 of file OraPtrStreamer.cc.

                                                                                                            :
        m_objectType( objectType ),
        m_mapping( mapping ),
        m_schema( contSchema ),
        m_localElement(),
        m_query( mapping.tableName(), contSchema.storageSchema() ),
        m_dataElement( 0 ),
        m_reader(){
      }

ora::OraPtrReadBuffer::~OraPtrReadBuffer ( )

inline

Definition at line 27 of file OraPtrStreamer.cc.

                         {
      }

Member Function Documentation

bool ora::OraPtrReadBuffer::build ( DataElement &  dataElement )

inline

Definition at line 30 of file OraPtrStreamer.cc.

References ora::SelectOperation::addWhereId(), ora::DataElement::clear(), ora::MappingElement::columnNames(), ora::MappingElement::end(), ora::MappingElement::find(), i, m_dataElement, m_localElement, m_mapping, m_objectType, m_query, m_reader, m_schema, ora::RelationalStreamerFactory::newReader(), ora::ClassUtils::resolvedType(), AlCaHLTBitMon_QueryRunRegistry::string, and ora::throwException().

Referenced by psClasses.BuildThread::run().

                                            {
        m_dataElement = &dataElement;
        m_localElement.clear();

        const std::vector<std::string>& columns = m_mapping.columnNames();
        size_t cols = columns.size();
        for( size_t i=0; i<cols; i++ ){
          m_query.addWhereId( columns[ i ] );
        }
        
        // Check the  type
        Reflex::Type ptrType = m_objectType.TemplateArgumentAt(0);
        Reflex::Type ptrResolvedType = ClassUtils::resolvedType(ptrType);
        // Check the component type
        if ( ! ptrType || !ptrResolvedType ) {
          throwException( "Missing dictionary information for the type of the pointer \"" +
                          m_objectType.Name(Reflex::SCOPED|Reflex::FINAL) + "\"",
                          "OraPtrReadBuffer::build" );
        }

        std::string ptrTypeName = ptrType.Name();
        // Retrieve the relevant mapping element
        MappingElement::iterator iMe = m_mapping.find( ptrTypeName );
        if ( iMe == m_mapping.end() ) {
          throwException( "Item for \"" + ptrTypeName + "\" not found in the mapping element",
                          "OraPtrReadBuffer::build" );
        }
        RelationalStreamerFactory streamerFactory( m_schema );
        m_reader.reset( streamerFactory.newReader( ptrResolvedType, iMe->second ) );
        return m_reader->build( m_localElement, m_query );     
      }

void* ora::OraPtrReadBuffer::read ( const std::vector< int > &  fullId )

inline

Definition at line 62 of file OraPtrStreamer.cc.

References ora::SelectOperation::clear(), ora::ClassUtils::constructObject(), ora::SelectOperation::execute(), i, m_dataElement, m_objectType, m_query, m_reader, ora::SelectOperation::nextCursorRow(), ora::throwException(), and ora::SelectOperation::whereData().

Referenced by Vispa.Plugins.EdmBrowser.EdmDataAccessor.EdmDataAccessor::goto(), ora::RelationalPtrLoader::load(), and Vispa.Plugins.EdmBrowser.EdmDataAccessor.EdmDataAccessor::setFilterBranches().

                                                {
        if(!m_dataElement) throwException( "Read buffer has not been built.","OraPtrReadBuffer::read");

        if(!fullId.size()) throwException( "Object id set is empty.","OraPtrReadBuffer::read"); 
        
        coral::AttributeList& whereBuff = m_query.whereData();
        coral::AttributeList::iterator iCol = whereBuff.begin();
        size_t i=0;
        for( coral::AttributeList::iterator iCol = whereBuff.begin(); iCol != whereBuff.end(); ++iCol ){
          if( i<fullId.size() ){
            iCol->data<int>() = fullId[i];
          }
          i++;
        }
        
        std::vector<int> recordId( fullId.size()-1 );
        for( size_t i=0; i<fullId.size()-1; i++ ){
          recordId[i] = fullId[i+1];
          ++i;
        }
        
        m_query.execute();
        m_reader->select( fullId[0] );
        void* destination = 0;
        if( m_query.nextCursorRow() ){
          destination = ClassUtils::constructObject( m_objectType.TemplateArgumentAt(0) );
          m_reader->setRecordId( recordId );
          m_reader->read( destination );
        }
        m_query.clear();
        m_reader->clear();
        return destination;
      }

Member Data Documentation

DataElement* ora::OraPtrReadBuffer::m_dataElement

private

Definition at line 102 of file OraPtrStreamer.cc.

Referenced by build(), and read().

DataElement ora::OraPtrReadBuffer::m_localElement

private

Definition at line 100 of file OraPtrStreamer.cc.

Referenced by build().

MappingElement& ora::OraPtrReadBuffer::m_mapping

private

Definition at line 98 of file OraPtrStreamer.cc.

Referenced by build().

Reflex::Type ora::OraPtrReadBuffer::m_objectType

private

Definition at line 97 of file OraPtrStreamer.cc.

Referenced by build(), and read().

SelectOperation ora::OraPtrReadBuffer::m_query

private

Definition at line 101 of file OraPtrStreamer.cc.

Referenced by build(), and read().

std::auto_ptr<IRelationalReader> ora::OraPtrReadBuffer::m_reader

private

Definition at line 103 of file OraPtrStreamer.cc.

Referenced by build(), and read().

ContainerSchema& ora::OraPtrReadBuffer::m_schema

private

Definition at line 99 of file OraPtrStreamer.cc.

Referenced by build().