ora::OraReferenceStreamerBase Class Reference

#include <OraReferenceStreamer.h>

Inheritance diagram for ora::OraReferenceStreamerBase:

Public Member Functions
void	bindDataForRead (void *data)
void	bindDataForUpdate (const void *data)
bool	buildDataElement (DataElement &dataElement, IRelationalData &relationalData)
	OraReferenceStreamerBase (const edm::TypeWithDict &objectType, MappingElement &mapping, ContainerSchema &schema)
virtual	~OraReferenceStreamerBase ()

Private Attributes
int	m_columnIndexes [2]
DataElement *	m_dataElement
DataElement *	m_dataElemOId0
DataElement *	m_dataElemOId1
MappingElement &	m_mapping
edm::TypeWithDict	m_objectType
IRelationalData *	m_relationalData
ContainerSchema &	m_schema

Detailed Description

Definition at line 13 of file OraReferenceStreamer.h.

Constructor & Destructor Documentation

ora::OraReferenceStreamerBase::OraReferenceStreamerBase ( const edm::TypeWithDict &  objectType, MappingElement &  mapping, ContainerSchema &  schema  )

explicit

Definition at line 14 of file OraReferenceStreamer.cc.

References m_columnIndexes.

                                                                                 :
  m_objectType( objectType ),
  m_mapping( mapping ),
  m_schema( schema ),
  m_dataElement( 0 ),
  m_dataElemOId0( 0 ),
  m_dataElemOId1( 0 ),
  m_relationalData( 0 ){
  m_columnIndexes[0] = -1;
  m_columnIndexes[1] = -1;
}

ora::OraReferenceStreamerBase::~OraReferenceStreamerBase ( )

virtual

Definition at line 28 of file OraReferenceStreamer.cc.

                                                      {
}

Member Function Documentation

void ora::OraReferenceStreamerBase::bindDataForRead

(

void *

data

)

Definition at line 86 of file OraReferenceStreamer.cc.

References ora::IReferenceHandler::onLoad(), and ora::throwException().

                                                             {
  if(!m_relationalData){
    throwException("The streamer has not been built.",
                   "OraReferenceStreamerBase::bindDataForRead");
  }

  void* oid0Address = m_dataElemOId0->address( data );
  coral::Attribute& oid0Attr = m_relationalData->data()[ m_columnIndexes[0] ];
  *static_cast<int*>(oid0Address) = oid0Attr.data<int>();
  void* oid1Address = m_dataElemOId1->address( data );
  coral::Attribute& oid1Attr = m_relationalData->data()[ m_columnIndexes[1] ];
  *static_cast<int*>( oid1Address ) = oid1Attr.data<int>();
  IReferenceHandler* refHandler = m_schema.referenceHandler();
  void* refPtr = m_dataElement->address( data );
  if(refHandler) refHandler->onLoad( *static_cast<Reference*>( refPtr ) );
}

void ora::OraReferenceStreamerBase::bindDataForUpdate

(

const void *

data

)

Definition at line 69 of file OraReferenceStreamer.cc.

References ora::IReferenceHandler::onSave(), and ora::throwException().

                                                                     {
  if(!m_relationalData){
    throwException("The streamer has not been built.",
                   "OraReferenceStreamerBase::bindDataForUpdate");
  }
  
  void* oid0Address = m_dataElemOId0->address( data );
  coral::Attribute& oid0Attr = m_relationalData->data()[ m_columnIndexes[0] ];
  oid0Attr.data<int>()= *static_cast<int*>(oid0Address);
  void* oid1Address = m_dataElemOId1->address( data );
  coral::Attribute& oid1Attr = m_relationalData->data()[ m_columnIndexes[1] ];
  oid1Attr.data<int>()= *static_cast<int*>(oid1Address) ;
  IReferenceHandler* refHandler = m_schema.referenceHandler();
  void* refPtr = m_dataElement->address( data );
  if(refHandler) refHandler->onSave( *static_cast<Reference*>( refPtr ) );
}

bool ora::OraReferenceStreamerBase::buildDataElement	(	DataElement &	dataElement,
		IRelationalData &	relationalData
	)

Definition at line 32 of file OraReferenceStreamer.cc.

References ora::DataElement::addChild(), ora::IRelationalData::addData(), edm::TypeWithDict::dataMemberByName(), ora::ClassUtils::findBaseType(), i, edm::MemberWithDict::offset(), and ora::throwException().

                                                                                     {
  m_dataElement = &dataElement;
  // first resolve the oid0 and oid2 data elements...
  edm::TypeWithDict refType( typeid(Reference) );
  //edm::TypeWithDict oidType = edm::TypeWithDict::ByTypeInfo( typeid(OId) );
  size_t baseOffsetFunc = 0;
  if( m_objectType != refType ){
    bool foundRef = ClassUtils::findBaseType( m_objectType, refType, baseOffsetFunc );
    if(!foundRef){
      throwException("Type \""+m_objectType.cppName()+"\" is not an Ora Reference.",
                     "OraReferenceStreamerBase::buildDataElement");
    } 
  }
  edm::MemberWithDict contIdMember = refType.dataMemberByName("m_containerId");
  edm::MemberWithDict itemIdMember = refType.dataMemberByName("m_itemId");
  if( !contIdMember || !itemIdMember ){
    throwException("Data members for class OId not found.",
                   "OraReferenceStreamerBase::buildDataElement");
  }
  m_dataElemOId0 = &dataElement.addChild( contIdMember.offset(), baseOffsetFunc );
  m_dataElemOId1 = &dataElement.addChild( itemIdMember.offset(), baseOffsetFunc);
  // then book the columns in the data attribute... 
  const std::vector<std::string>& columns =  m_mapping.columnNames();
  if( columns.size() < 2 ){
      throwException("Expected column names have not been found in the mapping.",
                     "OraReferenceStreamerBase::buildDataElement");    
  }
  const std::type_info& attrType = typeid(int);
  for( size_t i=0; i<2; i++ ){
    m_columnIndexes[i] = relationalData.addData( columns[i],attrType ); 
  }
  m_relationalData = &relationalData;
  return true;
}

Member Data Documentation

int ora::OraReferenceStreamerBase::m_columnIndexes[2]

private

Definition at line 31 of file OraReferenceStreamer.h.

Referenced by OraReferenceStreamerBase().

DataElement* ora::OraReferenceStreamerBase::m_dataElement

private

Definition at line 33 of file OraReferenceStreamer.h.

DataElement* ora::OraReferenceStreamerBase::m_dataElemOId0

private

Definition at line 34 of file OraReferenceStreamer.h.

DataElement* ora::OraReferenceStreamerBase::m_dataElemOId1

private

Definition at line 35 of file OraReferenceStreamer.h.

MappingElement& ora::OraReferenceStreamerBase::m_mapping

private

Definition at line 30 of file OraReferenceStreamer.h.

edm::TypeWithDict ora::OraReferenceStreamerBase::m_objectType

private

Definition at line 29 of file OraReferenceStreamer.h.

IRelationalData* ora::OraReferenceStreamerBase::m_relationalData

private

Definition at line 36 of file OraReferenceStreamer.h.

ContainerSchema& ora::OraReferenceStreamerBase::m_schema

private

Definition at line 32 of file OraReferenceStreamer.h.