ora::IteratorBuffer Class Reference

#include <DatabaseContainer.h>

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

Private Attributes
int	m_itemId
SelectOperation	m_query
ReadBuffer &	m_readBuffer

Detailed Description

Definition at line 27 of file DatabaseContainer.h.

Constructor & Destructor Documentation

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

Definition at line 244 of file DatabaseContainer.cc.

References ora::SelectOperation::addId(), ora::SelectOperation::addOrderId(), ora::MappingElement::columnNames(), m_query, ora::ContainerSchema::mapping(), AlCaHLTBitMon_QueryRunRegistry::string, 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 254 of file DatabaseContainer.cc.

                                  {
}

Member Function Documentation

void * ora::IteratorBuffer::getItem

(

)

Definition at line 275 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 edm::TypeWithDict &

type

)

Definition at line 283 of file DatabaseContainer.cc.

References edm::TypeWithDict::cppName(), ora::ClassUtils::isType(), and ora::throwException().

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

int ora::IteratorBuffer::itemId

(

)

Definition at line 291 of file DatabaseContainer.cc.

                             {
  return m_itemId;
}

bool ora::IteratorBuffer::next

(

void

)

Definition at line 261 of file DatabaseContainer.cc.

Referenced by BeautifulSoup.PageElement::_invert(), and 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 257 of file DatabaseContainer.cc.

Referenced by MatrixReader.MatrixReader::__init__(), and MatrixReader.MatrixReader::showRaw().

                             {
  m_query.execute();
}

const edm::TypeWithDict & ora::IteratorBuffer::type

(

)

Definition at line 295 of file DatabaseContainer.cc.

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

                                              {
  return m_readBuffer.type();
}

Member Data Documentation

int ora::IteratorBuffer::m_itemId

private

Definition at line 47 of file DatabaseContainer.h.

SelectOperation ora::IteratorBuffer::m_query

private

Definition at line 46 of file DatabaseContainer.h.

Referenced by IteratorBuffer().

ReadBuffer& ora::IteratorBuffer::m_readBuffer

private

Definition at line 48 of file DatabaseContainer.h.