RDBRecordset Class Reference

RDBRecordset is an implementation of IRDBRecordset interface. More...

#include <RDBRecordset.h>

Inheritance diagram for RDBRecordset:

Collaboration diagram for RDBRecordset:

Public Types
typedef RecordsVector::const_iterator	const_iterator

Public Member Functions
	RDBRecordset (RDBAccessSvc *accessSvc)
	Construct empty recordset. More...
void	getData (coral::ISessionProxy *session, const std::string &nodeName, const std::string &tagName, const std::string &tagId)
	Constructs SQL query and retrieves the data from DB. More...
unsigned int	size () const override
std::string	nodeName () const override
std::string	tagName () const override
const IRDBRecord *	operator[] (unsigned int index) const override
IRDBRecordset::const_iterator	begin () const override
IRDBRecordset::const_iterator	end () const override
bool	operator!= (const RDBRecordset &rhs) const
void	compare (const RDBRecordset &rec, std::ostream &os) const
void	setNodeName (const std::string &nodeName)

Private Attributes
std::string	m_tableName {}
std::string	m_tagName {}
RecordsVector	m_records
RDBAccessSvc *	m_accessSvc {nullptr}

Detailed Description

RDBRecordset is an implementation of IRDBRecordset interface.

Definition at line 38 of file RDBRecordset.h.

Member Typedef Documentation

const_iterator

typedef RecordsVector::const_iterator IRDBRecordset::const_iterator

inherited

Definition at line 52 of file IRDBRecordset.h.

Constructor & Destructor Documentation

RDBRecordset()

RDBRecordset::RDBRecordset ( RDBAccessSvc *  accessSvc )

inline

Construct empty recordset.

Definition at line 42 of file RDBRecordset.h.

    : m_accessSvc(accessSvc) {}

Member Function Documentation

begin()

IRDBRecordset::const_iterator RDBRecordset::begin ( ) const

overridevirtual

Returns

begin iterator

Implements IRDBRecordset.

Definition at line 140 of file RDBRecordset.cxx.

{
  return m_records.begin();
}

compare()

void RDBRecordset::compare	(	const RDBRecordset &	rec,
		std::ostream &	os
	)		const

Definition at line 165 of file RDBRecordset.cxx.

{
  if(m_tableName!=rec.m_tableName) {
    os << "Recordsets correspond to different nodes" << std::endl;
    return;
  }
 
  if(m_tagName!=rec.m_tagName) {
    os << "Recordsets correspond to different tags" << std::endl;
    return;
  }
 
  std::set<size_t> uniq0, uniq1;
  std::vector<long> dataId0, dataId1;
 
  // change table name to upper case
  std::string upperName = m_tableName;
  for (char& ch : upperName) {
    ch = std::toupper (static_cast<unsigned int>(ch));
  }
 
  // Collect data_id's for both recordsets
  for(size_t i=0; i<m_records.size(); ++i) {
    dataId0.push_back(m_records[i]->getLong(upperName+"_DATA_ID"));
  }
 
  for(size_t i=0; i<rec.m_records.size(); ++i) {
    dataId1.push_back(rec.m_records[i]->getLong(upperName+"_DATA_ID"));
  }
 
  // print out possible diffs of recordsets with same data id's
  // collect indices of records with data_id's unique to rec0 (this)
  bool diffFound = false;
  for(size_t i=0; i<dataId0.size(); ++i) {
    long id0 = dataId0[i];
    bool found = false;
    size_t i1(0);
    for(size_t ii=0; ii<dataId1.size(); ++ii) {
      if(id0==dataId1[ii]) {
    found = true;
    i1 = ii;
    break;
      }
    }
    if(found) {
      RDBRecord* record0 = dynamic_cast<RDBRecord*>(m_records[i].get());
      RDBRecord* record1 = dynamic_cast<RDBRecord*>(rec.m_records[i1].get());
      if(record0!=0
     && record1!=0
     && *record0!=*record1) {
    if(!diffFound) {
      os << "Records with the same data id and different contents:" << std::endl;
      diffFound = true;
    }
    os << "< " << *record0 << std::endl; 
    os << "> " << *record1 << std::endl; 
    os << "--" << std::endl;
      }
    }
    else
      uniq0.insert(i);
  }
 
  // collect indices of records with data_id's unique to rec1
  for(size_t i=0; i<dataId1.size(); ++i) {
    long id1 = dataId1[i];
    bool found = false;
    for(size_t ii=0; ii<dataId0.size(); ++ii) {
      if(id1==dataId0[ii]) {
    found = true;
    break;
      }
    }
    if(!found) {
      uniq1.insert(i);
    }
  }
 
  // print out results
  if(uniq0.size()>0) {
    os << "Records with the following data ids are present in recordset 0 and missing in recordset 1: " << std::endl;
    std::set<size_t>::const_iterator it = uniq0.begin();
    for(; it!=uniq0.end(); ++it) {
      os << m_records[*it]->getLong(upperName+"_DATA_ID") << " ";
    }
    os << std::endl;
  }
  if(uniq1.size()>0) {
    os << "Records with the following data ids are present in recordset 1 and missing in recordset 0: " << std::endl;
    std::set<size_t>::const_iterator it = uniq1.begin();
    for(; it!=uniq1.end(); ++it) {
      os << rec.m_records[*it]->getLong(upperName+"_DATA_ID") << " ";
    }
    os << std::endl;
  }
 
}

end()

IRDBRecordset::const_iterator RDBRecordset::end ( ) const

overridevirtual

Returns

end iterator

Implements IRDBRecordset.

Definition at line 145 of file RDBRecordset.cxx.

{
  return m_records.end();
}

getData()

void RDBRecordset::getData	(	coral::ISessionProxy *	session,
		const std::string &	nodeName,
		const std::string &	tagName,
		const std::string &	tagId
	)

Constructs SQL query and retrieves the data from DB.

Parameters

session	[IN] active relational session
taginfo	[IN] object holding information about the node tag

Definition at line 39 of file RDBRecordset.cxx.

{
  if(m_accessSvc->msg().level() <= MSG::DEBUG) {
    m_accessSvc->msg() << MSG::DEBUG << "Recordset get data " << nodeName << ", " 
               << tagName << ", " 
               << tagId << endmsg;
  }
 
  if(session==0) {
    m_accessSvc->msg() << MSG::ERROR << "RT: No connection to database!" << endmsg;
    return;
  }
 
  try 
  {
    m_tableName = nodeName;
 
    if(tagId.empty()) {
      if(m_accessSvc->msg().level() <= MSG::DEBUG)
    m_accessSvc->msg() << MSG::DEBUG << "RT: Could not get the tag for " << m_tableName 
               << " node. Returning empty recordset" << endmsg;
      return;
    }
 
    m_tagName = tagName;
 
    // change table name to upper case
    std::string upperName = m_tableName;
    for (char& ch : upperName) {
      ch = std::toupper (static_cast<unsigned int>(ch));
    }
 
    coral::IQuery* queryStructure = session->nominalSchema().newQuery();
 
    // Compose the list of output fields for queryStructure
    const coral::ITableDescription& dataTableDesc = session->nominalSchema().tableHandle(upperName + "_DATA").description();
    for(int i=0; i<dataTableDesc.numberOfColumns(); i++) {
      queryStructure->addToOutputList(upperName + "_DATA." + dataTableDesc.columnDescription(i).name());
    }
 
    // Create table list for query >> data and data2vers tables
    queryStructure->addToTableList(upperName + "_DATA");
    queryStructure->addToTableList(upperName + "_DATA2TAG");
 
    coral::AttributeList bindsData ATLAS_THREAD_SAFE;
    bindsData.extend<std::string>("tagID");
 
    // Compose condition for structure query
    std::string queryStructCondition = upperName +"_DATA2TAG." + upperName + "_TAG_ID =:tagID";
    queryStructCondition += " AND " + upperName +"_DATA." + upperName + "_DATA_ID=" + upperName + "_DATA2TAG." + upperName + "_DATA_ID";
 
    queryStructure->setCondition(queryStructCondition , bindsData);
    bindsData[0].data<std::string>() = tagId;
 
    queryStructure->addToOrderList(upperName + "_DATA." + upperName + "_DATA_ID");
    queryStructure->setMemoryCacheSize(1);
 
    coral::ICursor& cursorStructure = queryStructure->execute();
 
    // Process Query results
    while(cursorStructure.next()) {
      const coral::AttributeList& row = cursorStructure.currentRow();
      m_records.push_back(IRDBRecord_ptr(new RDBRecord(row,upperName + "_DATA")));
    }
 
    delete queryStructure;
  }
  catch(coral::SchemaException& se) {
     m_accessSvc->msg() << MSG::ERROR<< "RT: Schema Exception : " << se.what() << endmsg;
  }
  catch(std::exception& e) {
    m_accessSvc->msg() << MSG::ERROR << e.what() << endmsg;
  }
  catch(...) {
    m_accessSvc->msg() << MSG::ERROR << "RT: Exception caught(...)" << endmsg;
  }
 
}

nodeName()

std::string RDBRecordset::nodeName ( ) const

overridevirtual

Returns

node name

Implements IRDBRecordset.

Definition at line 126 of file RDBRecordset.cxx.

{
  return m_tableName;
}

operator!=()

bool RDBRecordset::operator!=

(

const RDBRecordset &

rhs

)

const

Definition at line 150 of file RDBRecordset.cxx.

{
  if(m_records.size()!=rhs.m_records.size()) return true;
 
  for(size_t i=0; i<m_records.size(); ++i) {
    RDBRecord* rec1 = dynamic_cast<RDBRecord*>(m_records[i].get());
    RDBRecord* rec2 = dynamic_cast<RDBRecord*>(rhs.m_records[i].get());
    if(rec1!=0
       && rec2!=0
       && *rec1!=*rec2) return true;
  }
 
  return false;
}

operator[]()

const IRDBRecord * RDBRecordset::operator[] ( unsigned int  index ) const

overridevirtual

Parameters

index

[IN] index of the record

Returns

RDBRecord by index

Implements IRDBRecordset.

Definition at line 136 of file RDBRecordset.cxx.

{
  return m_records[index].get();
}

setNodeName()

void RDBRecordset::setNodeName

(

const std::string &

nodeName

)

Definition at line 263 of file RDBRecordset.cxx.

{
  if(m_tableName.empty()) m_tableName = nodeName; 
}

size()

unsigned int RDBRecordset::size ( ) const

overridevirtual

Returns

number of records

Implements IRDBRecordset.

Definition at line 121 of file RDBRecordset.cxx.

{
  return m_records.size();
}

tagName()

std::string RDBRecordset::tagName ( ) const

overridevirtual

Returns

tag name

Implements IRDBRecordset.

Definition at line 131 of file RDBRecordset.cxx.

{
  return m_tagName;
}

Member Data Documentation

m_accessSvc

RDBAccessSvc* RDBRecordset::m_accessSvc {nullptr}

private

Definition at line 86 of file RDBRecordset.h.

m_records

RecordsVector RDBRecordset::m_records

private

Definition at line 85 of file RDBRecordset.h.

m_tableName

std::string RDBRecordset::m_tableName {}

private

Definition at line 83 of file RDBRecordset.h.

m_tagName

std::string RDBRecordset::m_tagName {}

private

Definition at line 84 of file RDBRecordset.h.

---

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

• RDBRecordset.h
• RDBRecordset.cxx