ora::UpdateBuffer Class Reference

Public Member Functions
size_t	flush ()
void	registerForUpdate (int oid, const void *data)
	UpdateBuffer (ContainerSchema &contSchema)
	~UpdateBuffer ()

Private Attributes
std::vector< std::pair< int, const void * > >	m_buffer
ContainerSchema &	m_contSchema

Detailed Description

Definition at line 78 of file DatabaseContainer.cc.

Constructor & Destructor Documentation

ora::UpdateBuffer::UpdateBuffer ( ContainerSchema &  contSchema )

inlineexplicit

Definition at line 80 of file DatabaseContainer.cc.

                                                          :
        m_buffer(),
        m_contSchema( contSchema ){
      }

ora::UpdateBuffer::~UpdateBuffer ( )

inline

Definition at line 85 of file DatabaseContainer.cc.

                     {
      }

Member Function Documentation

size_t ora::UpdateBuffer::flush ( )

inline

Definition at line 94 of file DatabaseContainer.cc.

References ora::InputRelationalData::addId(), ora::InputRelationalData::addWhereId(), ora::RelationalDeleter::build(), ora::MappingElement::columnNames(), ora::InputRelationalData::data(), data, ora::MappingElement::end(), ora::RelationalDeleter::erase(), ora::MappingElement::find(), m_buffer, m_contSchema, ora::ContainerSchema::mapping(), ora::ContainerSchema::mappingForDependentClasses(), ora::RelationalStreamerFactory::newUpdater(), ora::ContainerSchema::storageSchema(), ora::MappingElement::tableName(), ora::throwException(), ora::MappingTree::topElement(), funct::true, ora::ContainerSchema::type(), and ora::InputRelationalData::whereData().

                    {
        size_t nobj = 0;
    if( m_buffer.size() ){
      RelationalBuffer operationBuffer( m_contSchema.storageSchema() );
      std::vector<MappingElement> dependentMappings;
      m_contSchema.mappingForDependentClasses( dependentMappings );
      RelationalDeleter depDeleter( dependentMappings );
      depDeleter.build( operationBuffer );
      dependentMappings.clear();
      
      MappingElement& topLevelMapping = m_contSchema.mapping( true ).topElement();
      UpdateOperation* topLevelUpdate = &operationBuffer.newUpdate( topLevelMapping.tableName(), true );
      topLevelUpdate->addId(  topLevelMapping.columnNames()[ 0 ] );
      topLevelUpdate->addWhereId(  topLevelMapping.columnNames()[ 0 ] );
      const Reflex::Type& type = m_contSchema.type();
      MappingElement::iterator iMap = topLevelMapping.find( type.Name(Reflex::SCOPED) );
      // the first inner mapping is the relevant...
      if( iMap == topLevelMapping.end()){
        throwException("Could not find a mapping element for class \""+
               type.Name(Reflex::SCOPED)+"\"",
               "UpdateBuffer::flush");
      }
      MappingElement& mapping = iMap->second;
      RelationalStreamerFactory streamerFactory( m_contSchema );
      DataElement topLevelElement;
      std::auto_ptr<IRelationalUpdater> updater( streamerFactory.newUpdater( type, mapping ));
      updater->build( topLevelElement, *topLevelUpdate, operationBuffer );
      for( std::vector<std::pair<int, const void*> >::const_iterator iU = m_buffer.begin();
           iU != m_buffer.end(); ++iU ){
        int oid = iU->first;
        const void* data = iU->second;
        // erase the dependencies (they cannot be updated...)
        depDeleter.erase( oid );
        coral::AttributeList& dataBuff = topLevelUpdate->data();
        dataBuff.begin()->data<int>() = oid;
        coral::AttributeList& whereDataBuff = topLevelUpdate->whereData();
        whereDataBuff.begin()->data<int>() = oid;
        updater->update( oid, data );
        if( operationBuffer.flush()) nobj++;
      }
      m_buffer.clear();
    }
        return nobj;
      }

void ora::UpdateBuffer::registerForUpdate ( int  oid, const void *  data  )

inline

Definition at line 89 of file DatabaseContainer.cc.

References m_buffer.

                                                         {
        m_buffer.push_back( std::make_pair( oid, data ));
      }

Member Data Documentation

std::vector<std::pair<int, const void*> > ora::UpdateBuffer::m_buffer

private

Definition at line 140 of file DatabaseContainer.cc.

Referenced by flush(), and registerForUpdate().

ContainerSchema& ora::UpdateBuffer::m_contSchema

private

Definition at line 141 of file DatabaseContainer.cc.

Referenced by flush().