CoraCoolObjectIter Class Reference

#include <CoraCoolObjectIter.h>

Collaboration diagram for CoraCoolObjectIter:

Classes
class	QueryBuilder

Public Member Functions
	CoraCoolObjectIter (CoraCoolFolder *coracoolfolder, cool::IObjectIteratorPtr coolptr)
	~CoraCoolObjectIter ()
CoraCoolObjectPtr	next ()
bool	hasNext ()
bool	goToNext ()
CoraCoolObject &	currentRef ()
void	close ()

Private Member Functions
	CoraCoolObjectIter ()
	CoraCoolObjectIter (const CoraCoolObjectIter &)
CoraCoolObjectIter &	operator= (const CoraCoolObjectIter &)
void	readDataToBuffer ()
bool	iHasNext ()
bool	equalAttr (const coral::Attribute &a1, const coral::Attribute &a2) const
bool	isNumAttr (const std::string &spec) const
long long	numAttr (const std::string &spec, const coral::Attribute &a) const

Private Attributes
unsigned int	m_buflen
unsigned int	m_inbuf
unsigned int	m_nextobj
bool	m_refValid
bool	m_allDone
CoraCoolFolder *	m_folder
cool::IObjectIteratorPtr	m_coolitr
coral::AttributeListSpecification *	m_spec
std::vector< CoraCoolObjectPtr >	m_data

Detailed Description

Definition at line 37 of file CoraCoolObjectIter.h.

Constructor & Destructor Documentation

CoraCoolObjectIter() [1/3]

CoraCoolObjectIter::CoraCoolObjectIter	(	CoraCoolFolder *	coracoolfolder,
		cool::IObjectIteratorPtr	coolptr
	)

Definition at line 32 of file CoraCoolObjectIter.cxx.

                                                       :
  m_buflen(OI_BUFLEN),m_inbuf(0),m_nextobj(0),
  m_refValid(false),m_allDone(false),
  m_folder(coracoolfolder),m_coolitr(coolitr) {
  m_data.resize(m_buflen);
  // assemble an AttributeListSpecification to share with the data objects
  const cool::RecordSpecification recspec=m_folder->payloadSpecification();
  const coral::AttributeList speclist = cool::Record(recspec).attributeList();
  m_spec=new coral::AttributeListSpecification();
  for (coral::AttributeList::const_iterator itr=speclist.begin();
       itr!=speclist.end();++itr) {
    const coral::AttributeSpecification& aspec=itr->specification();
    m_spec->extend(aspec.name(),aspec.typeName());
   }
}

~CoraCoolObjectIter()

CoraCoolObjectIter::~CoraCoolObjectIter

(

)

Definition at line 49 of file CoraCoolObjectIter.cxx.

                                        {
  if (m_spec!=0) m_spec->release();
}

CoraCoolObjectIter() [2/3]

CoraCoolObjectIter::CoraCoolObjectIter ( )

private

CoraCoolObjectIter() [3/3]

CoraCoolObjectIter::CoraCoolObjectIter ( const CoraCoolObjectIter &  )

private

Member Function Documentation

close()

void CoraCoolObjectIter::close

(

)

Definition at line 182 of file CoraCoolObjectIter.cxx.

                               {
  // release any resources associated with the query 
  // close underlying COOL query
  m_coolitr->close();
  // release ownership of any CoraCoolObjects we have
  for (unsigned int i=0;i<m_buflen;++i) m_data[i].reset();
}

currentRef()

CoraCoolObject & CoraCoolObjectIter::currentRef

(

)

Definition at line 178 of file CoraCoolObjectIter.cxx.

                                               {
  return *(m_data.at(m_nextobj-1));
}

equalAttr()

bool CoraCoolObjectIter::equalAttr ( const coral::Attribute &  a1, const coral::Attribute &  a2  ) const

private

Definition at line 190 of file CoraCoolObjectIter.cxx.

{
  // compare two Attributes based on type and value
  // deal with some special cases where the types are not the same
  // the easy part - if types are same
  std::string spec1=a1.specification().typeName();
  std::string spec2=a2.specification().typeName();
  if (spec1==spec2) {
    return (a1==a2);
  } else if (isNumAttr(spec1) && isNumAttr(spec2)) {
    // convert to long long and compare
    long long v1=numAttr(spec1,a1);
    long long v2=numAttr(spec2,a2);
    return (v1==v2);
  } else {
   // unhandled case 
    return false;
  }
}

goToNext()

bool CoraCoolObjectIter::goToNext

(

)

Definition at line 166 of file CoraCoolObjectIter.cxx.

                                  {
  const bool nextExists=hasNext();
  if (m_inbuf>m_nextobj){
    ++m_nextobj;//just update the index
  } else if (iHasNext()){
    readDataToBuffer();
  } else {
    //throw CoraCoolException("No more data in CoraCoolObjectIter","CoraCoolObjectIter::goToNext");
  }
  return nextExists;
}

hasNext()

bool CoraCoolObjectIter::hasNext

(

)

Definition at line 162 of file CoraCoolObjectIter.cxx.

                                 {
  return (m_inbuf>m_nextobj || iHasNext());
}

iHasNext()

bool CoraCoolObjectIter::iHasNext ( )

private

Definition at line 210 of file CoraCoolObjectIter.cxx.

                                  {
  // implement old-COOL-style iterator behaviour - return if next is valid
  // can be called multiple times - after call currentRef will give data
  if (m_refValid) return true;
  if (m_allDone) return false;
  if (m_coolitr->goToNext()) {
    m_refValid=true;
    return true;
  } else {
    m_refValid=false;
    m_allDone=true;
    return false;
  }
}

isNumAttr()

bool CoraCoolObjectIter::isNumAttr ( const std::string &  spec ) const

private

Definition at line 225 of file CoraCoolObjectIter.cxx.

                                                              {
  return (spec=="long long" || spec=="unsigned long long" ||
      spec=="int" || spec=="unsigned int" ||
      spec=="long" || spec=="unsigned long");
}

next()

CoraCoolObjectPtr CoraCoolObjectIter::next

(

)

Definition at line 53 of file CoraCoolObjectIter.cxx.

                                           {
  if (m_inbuf>m_nextobj) {
    // return data directly from the buffer - just increment counter
    ++m_nextobj;
  } else if (iHasNext()) {
    readDataToBuffer();
  } else {
    throw CoraCoolException("No more data in CoraCoolObjectIter",
                "CoraCoolObjectIter::next");
  }
  return m_data.at(m_nextobj-1);
}

numAttr()

long long CoraCoolObjectIter::numAttr ( const std::string &  spec, const coral::Attribute &  a  ) const

private

Definition at line 231 of file CoraCoolObjectIter.cxx.

                                                     {
  long long v=0;
  if (spec=="long long") {
    v=a.data<long long>();
  } else if (spec=="unsigned long long") {
    v=static_cast<long long>(a.data<unsigned long long>());
  } else if (spec=="int") {
    v=static_cast<long long>(a.data<int>());
  } else if (spec=="unsigned int") {
    v=static_cast<long long>(a.data<unsigned int>());
  } else if (spec=="long") {
    v=static_cast<long long>(a.data<long>());
  } else if (spec=="unsigned long") {
    v=static_cast<long long>(a.data<unsigned long>());
  }
  return v;
}

operator=()

CoraCoolObjectIter& CoraCoolObjectIter::operator= ( const CoraCoolObjectIter &  )

private

readDataToBuffer()

void CoraCoolObjectIter::readDataToBuffer ( )

private

Definition at line 66 of file CoraCoolObjectIter.cxx.

                                          {
   // read some data from the database - initialise buffer to empty
    m_inbuf=0;
    // coloumn name of the FK in the CORAL table
    const std::string& coralkey=m_folder->coralFKey();
    // buffer to build the query
    QueryBuilder qbuf(QB_SIZE);
    coral::AttributeList fktype;
    std::string fktypestr;
    // keep map of FKvalue to list of associated COOL channels
    typedef std::vector<unsigned int> KeyVec;
    typedef std::unordered_map<long long,KeyVec > KeyMap;
    KeyMap keymap;
 
    while (m_inbuf<m_buflen && iHasNext() && 
       qbuf.size()<QB_SIZE && qbuf.terms()<QB_TERMS) {
      // get the COOL object
      const cool::IObject& coolobj=m_coolitr->currentRef();
      // reset so that next call to iHasNext will read the next one
      m_refValid=false;
      // prepare CoraCoolObject to receive the payload data
      CoraCoolObjectPtr data(new CoraCoolObject(coolobj.since(),
              coolobj.until(),coolobj.channelId(),m_spec));
      m_data[m_inbuf]=data;
      // setup the foreign key reference
      const coral::AttributeList& payload=coolobj.payload().attributeList();
      // remember the type of the FK
      if (m_inbuf==0) {
    fktypestr=payload[0].specification().typeName();
    fktype=payload;
      }
      long long ikeyval=numAttr(fktypestr,payload[0]);
      qbuf.add(ikeyval);
      KeyMap::iterator kdata=keymap.find(ikeyval);
      if (kdata==keymap.end()) {
    // new FK value - create vector of buffer positions for this one
    kdata=keymap.insert(kdata,
          KeyMap::value_type(ikeyval,KeyVec(8)));
    KeyVec& keyvec=kdata->second;
    keyvec.resize(1);
    keyvec[0]=m_inbuf;
      } else {
    // add to list of buffers using this key
    KeyVec& keyvec=kdata->second;
    keyvec.push_back(m_inbuf);
      }
      ++m_inbuf;
    }
    // setup the query 
    std::string bwhere;
    coral::AttributeList bfkeys;
    qbuf.getQuery(bwhere,coralkey,bfkeys,fktype[0].specification());
    // execute the query
    try {
      m_folder->proxy()->transaction().start(true);
      coral::IQuery* query=m_folder->table()->newQuery();
      query->setCondition(bwhere,bfkeys);
      query->setRowCacheSize(OI_ROWCACHE);
      m_folder->setOutputSpec(query);
      coral::ICursor& cursor=query->execute();
      KeyMap::const_iterator kdata=keymap.end();
      long long okeyval=0;
      while (cursor.next()) {
        const coral::AttributeList& res=cursor.currentRow();
    // check which buffer(s) this data is associated with
    // maybe associated with more than one if referenceObject has been used
    // so have to check all - no optimisation possible
    const long long keyval=numAttr(fktypestr,res[coralkey]);
    if (keyval!=okeyval || kdata==keymap.end()) {
      kdata=keymap.find(keyval);
      okeyval=keyval;
    }
    if (kdata!=keymap.end()) {
      KeyVec keyvec=kdata->second;
      for (KeyVec::const_iterator kitr=keyvec.begin();
           kitr!=keyvec.end();++kitr) {
        m_data[*kitr]->add(res);
      }
    } else {
      std::ostringstream skey;
      skey << "CoraCool key remapping error for key " << keyval;
      throw CoraCoolException(skey.str(),"CoraCoolObjectIter::next");
    }
      }
      delete query;
      m_folder->proxy()->transaction().commit();
    }
    catch (coral::Exception& e) {
      throw CoraCoolException(e.what(),"CoraCoolObjectIter::next");
    }
    // next read will access next object from buffer (if existing)
    // this invocation will return first object
    m_nextobj=1;
    return;
}

Member Data Documentation

m_allDone

bool CoraCoolObjectIter::m_allDone

private

Definition at line 110 of file CoraCoolObjectIter.h.

m_buflen

unsigned int CoraCoolObjectIter::m_buflen

private

Definition at line 106 of file CoraCoolObjectIter.h.

m_coolitr

cool::IObjectIteratorPtr CoraCoolObjectIter::m_coolitr

private

Definition at line 112 of file CoraCoolObjectIter.h.

m_data

std::vector<CoraCoolObjectPtr> CoraCoolObjectIter::m_data

private

Definition at line 114 of file CoraCoolObjectIter.h.

m_folder

CoraCoolFolder* CoraCoolObjectIter::m_folder

private

Definition at line 111 of file CoraCoolObjectIter.h.

m_inbuf

unsigned int CoraCoolObjectIter::m_inbuf

private

Definition at line 107 of file CoraCoolObjectIter.h.

m_nextobj

unsigned int CoraCoolObjectIter::m_nextobj

private

Definition at line 108 of file CoraCoolObjectIter.h.

m_refValid

bool CoraCoolObjectIter::m_refValid

private

Definition at line 109 of file CoraCoolObjectIter.h.

m_spec

coral::AttributeListSpecification* CoraCoolObjectIter::m_spec

private

Definition at line 113 of file CoraCoolObjectIter.h.

---

The documentation for this class was generated from the following files:

• CoraCoolObjectIter.h
• CoraCoolObjectIter.cxx