ora::IteratorBuffer Class Reference

#include <DatabaseContainer.h>

Public Member Functions
void *	getItem ()
void *	getItemAsType (const Reflex::Type &type)
int	itemId ()
	IteratorBuffer (ContainerSchema &schema, ReadBuffer &buffer)
bool	next ()
void	reset ()
const Reflex::Type &	type ()
	~IteratorBuffer ()

Private Attributes
int	m_itemId
SelectOperation	m_query
ReadBuffer &	m_readBuffer

Detailed Description

Definition at line 26 of file DatabaseContainer.h.

Constructor & Destructor Documentation

ora::IteratorBuffer::IteratorBuffer	(	ContainerSchema &	schema,
		ReadBuffer &	buffer
	)

Definition at line 253 of file DatabaseContainer.cc.

References ora::SelectOperation::addId(), ora::SelectOperation::addOrderId(), ora::MappingElement::columnNames(), m_query, ora::ContainerSchema::mapping(), and ora::MappingTree::topElement().

                                                         :
  m_query( schema.mapping().topElement().tableName(), schema.storageSchema() ),
  m_itemId( -1 ),
  m_readBuffer( buffer ){
  const std::string& idCol = schema.mapping().topElement().columnNames()[0];
  m_query.addId( idCol );
  m_query.addOrderId( idCol );
}

ora::IteratorBuffer::~IteratorBuffer

(

)

Definition at line 263 of file DatabaseContainer.cc.

                                  {
}

Member Function Documentation

void * ora::IteratorBuffer::getItem

(

)

Definition at line 284 of file DatabaseContainer.cc.

References runTheMatrix::ret.

Referenced by ora::DatabaseUtilitySession::importContainer().

                                {
  void* ret = 0;
  if( m_itemId != -1 ){
    ret =  m_readBuffer.read( m_itemId );
  }
  return ret;
}

void * ora::IteratorBuffer::getItemAsType

(

const Reflex::Type &

type

)

Definition at line 292 of file DatabaseContainer.cc.

References ora::ClassUtils::isType(), and ora::throwException().

                                                                {
  if( !ClassUtils::isType( type(), asType ) ){
    throwException("Provided output object type \""+asType.Name(Reflex::SCOPED)+"\" does not match with the container type \""+
                   type().Name(Reflex::SCOPED)+"\"","IteratorBuffer::getItemAsType");
  } 
  return getItem();
}

int ora::IteratorBuffer::itemId

(

)

Definition at line 300 of file DatabaseContainer.cc.

                             {
  return m_itemId;
}

bool ora::IteratorBuffer::next

(

void

)

Definition at line 270 of file DatabaseContainer.cc.

Referenced by ora::DatabaseUtilitySession::importContainer().

                            {
  bool prevValid = (m_itemId != -1);
  bool currValid = false;
  m_itemId = -1;
  if( m_query.nextCursorRow() ){
    coral::AttributeList& row = m_query.data();
    m_itemId = row.begin()->data<int>();
    currValid = true;
  }
  
  if( !currValid && prevValid ) m_query.clear();
  return currValid;
}

void ora::IteratorBuffer::reset

(

void

)

Definition at line 266 of file DatabaseContainer.cc.

Referenced by runTheMatrix.MatrixReader::__init__(), and BeautifulSoup.BeautifulStoneSoup::__init__().

                             {
  m_query.execute();
}

const Reflex::Type & ora::IteratorBuffer::type

(

)

Definition at line 304 of file DatabaseContainer.cc.

Referenced by python.Vispa.Plugins.ConfigEditor.ConfigDataAccessor.ConfigDataAccessor::inputCommands(), python.Vispa.Plugins.ConfigEditor.ConfigDataAccessor.ConfigDataAccessor::outputCommands(), python.Vispa.Plugins.ConfigEditor.ConfigDataAccessor.ConfigDataAccessor::outputEventContent(), and python.Vispa.Plugins.ConfigEditor.ConfigDataAccessor.ConfigDataAccessor::properties().

                                         {
  return m_readBuffer.type();
}

Member Data Documentation

int ora::IteratorBuffer::m_itemId

private

Definition at line 46 of file DatabaseContainer.h.

SelectOperation ora::IteratorBuffer::m_query

private

Definition at line 45 of file DatabaseContainer.h.

Referenced by IteratorBuffer().

ReadBuffer& ora::IteratorBuffer::m_readBuffer

private

Definition at line 47 of file DatabaseContainer.h.