RDBQuery Class Reference

RDBQuery is an implementation of IRDBQuery interface. More...

#include <RDBQuery.h>

Inheritance diagram for RDBQuery:

Collaboration diagram for RDBQuery:

Public Member Functions
	RDBQuery (const Athena::DBLock &dblock, RDBAccessSvc *accessSvc, const std::string &nodeName, const std::string &tagId, const std::string &connName)
virtual	~RDBQuery () override
virtual void	execute () override
virtual long	size () override
virtual void	finalize () override
virtual void	setOrder (const std::string &) override
virtual void	addToOutput (const std::string &) override
virtual bool	next () override
template<typename T >
const T &	data (const std::string &)
template<typename T >
const T &	data (unsigned int)
bool	isNull (const std::string &)
bool	isNull (unsigned int)

Protected Attributes
const coral::AttributeList *	m_attrList {nullptr}

Private Member Functions
	RDBQuery ()=delete

Private Attributes
Athena::DBLock	m_dblock
coral::IQuery *	m_query
coral::IQuery *	m_queryCount
RDBAccessSvc *	m_accessSvc
std::string	m_nodeName
std::string	m_tagId
std::string	m_connName
long	m_size
std::vector< std::string >	m_fields
coral::ICursor *	m_cursor
std::string	m_orderField
bool	m_executed

Detailed Description

RDBQuery is an implementation of IRDBQuery interface.

Definition at line 29 of file RDBQuery.h.

Constructor & Destructor Documentation

RDBQuery() [1/2]

RDBQuery::RDBQuery	(	const Athena::DBLock &	dblock,
		RDBAccessSvc *	accessSvc,
		const std::string &	nodeName,
		const std::string &	tagId,
		const std::string &	connName
	)

Definition at line 24 of file RDBQuery.cxx.

  : IRDBQuery()
  , m_dblock (dblock)
  , m_query(nullptr)
  , m_queryCount(nullptr)
  , m_accessSvc(accessSvc)
  , m_nodeName(nodeName)
  , m_tagId(tagId)
  , m_connName(connName)
  , m_size(0)
  , m_cursor(nullptr)
  , m_executed(false)
{
}

~RDBQuery()

RDBQuery::~RDBQuery ( )

overridevirtual

Definition at line 43 of file RDBQuery.cxx.

{
  delete m_query;
  delete m_queryCount;
}

RDBQuery() [2/2]

RDBQuery::RDBQuery ( )

privatedelete

Member Function Documentation

addToOutput()

void RDBQuery::addToOutput ( const std::string &  field )

overridevirtual

Implements IRDBQuery.

Definition at line 171 of file RDBQuery.cxx.

{
  m_fields.push_back(field);
}

data() [1/2]

template<typename T >

const T & IRDBQuery::data ( const std::string &  field )

inherited

Definition at line 35 of file IRDBQuery.h.

{
  return (*m_attrList)[field].data<T>();
}

data() [2/2]

template<typename T >

const T & IRDBQuery::data ( unsigned int  fieldInd )

inherited

Definition at line 40 of file IRDBQuery.h.

{
  return (*m_attrList)[fieldInd].data<T>();
}

execute()

void RDBQuery::execute ( )

overridevirtual

Implements IRDBQuery.

Definition at line 49 of file RDBQuery.cxx.

{
  if(m_executed) {
    m_accessSvc->msg() << MSG::WARNING << "RDBQuery cannot be executed more than once! Query: "
               << m_nodeName << ", "
               << m_tagId << ", "
               << m_orderField << ", "
               << m_fields.size() << endmsg;
    return;
  }
 
  if(m_accessSvc->msg().level() <= MSG::DEBUG) {
    m_accessSvc->msg() << MSG::DEBUG << "Query execute " << m_nodeName << ", "
               << m_tagId << ", "
               << m_orderField << ", "
               << m_fields.size() << endmsg;
  }
 
  if (!m_accessSvc->connect(m_connName)) {
    m_accessSvc->msg() << MSG::ERROR << "Cannot connect to the database: "
                       << m_connName << endmsg;
    throw std::runtime_error( "Cannot connect to the database " + m_connName);
  }
 
  m_executed=true;
  try {
    // ... Get the node name and change to to Upper Case
    std::string upperName = m_nodeName;
    for (char& ch : upperName) {
      ch = std::toupper (static_cast<unsigned int>(ch));
    }
 
    // ... Create query objects
    m_query = m_accessSvc->getSession(m_connName)->nominalSchema().newQuery();
    m_queryCount = m_accessSvc->getSession(m_connName)->nominalSchema().newQuery();
 
    // Add fields
    if(m_fields.size()>0) {
      // Custom fields
      for(unsigned int i=0; i<m_fields.size(); ++i) {
    m_query->addToOutputList(upperName+"_DATA."+m_fields[i]);
      }
    }
    else {
      // All fields from the table
      const coral::ITableDescription& dataTableDesc = m_accessSvc->getSession(m_connName)->nominalSchema().tableHandle(upperName + "_DATA").description();
      for(int i=0; i<dataTableDesc.numberOfColumns(); ++i) {
    m_query->addToOutputList(upperName+"_DATA."+dataTableDesc.columnDescription(i).name());
      }
    }
 
    m_queryCount->addToOutputList("COUNT("+upperName+"_DATA_ID)","SUMREC");
 
    // ... Define table list
    m_query->addToTableList(upperName + "_DATA");
    m_query->addToTableList(upperName + "_DATA2TAG");
 
    m_queryCount->addToTableList(upperName + "_DATA2TAG");    
 
    // ... Define order
    if(m_orderField.empty()) {
      m_query->addToOrderList(upperName + "_DATA." + upperName + "_DATA_ID");
    }
    else {
      m_query->addToOrderList(upperName + "_DATA." + m_orderField);
    }
 
    // ... Define conditions
    coral::AttributeList bindsData ATLAS_THREAD_SAFE;
    bindsData.extend<std::string>("tagID");
 
    std::string queryStructCondition = upperName +"_DATA2TAG." + upperName + "_TAG_ID =:tagID";
    m_queryCount->setCondition(queryStructCondition , bindsData);
    
    queryStructCondition += " AND " + upperName +"_DATA." + upperName + "_DATA_ID=" + upperName + "_DATA2TAG." + upperName + "_DATA_ID";
    m_query->setCondition(queryStructCondition , bindsData);
 
    bindsData[0].data<std::string>() = m_tagId;
 
    m_queryCount->defineOutputType("SUMREC","long");
    m_query->setMemoryCacheSize(1);
 
    // ... Get size of the result set
    coral::ICursor& cursorCount = m_queryCount->execute();
    while(cursorCount.next()) {
      // Just one iteration
      m_size = cursorCount.currentRow()["SUMREC"].data<long>();
    }
 
    // ... Get the data cursor
    m_cursor = &(m_query->execute());
    return;
  }
  catch(coral::SchemaException& se) {
    m_accessSvc->msg() << MSG::WARNING << "QUERY: Schema Exception : " + std::string(se.what()) << endmsg;
  }
  catch(std::exception& e) {
    m_accessSvc->msg() << MSG::WARNING << "QUERY: Exception : " + std::string(e.what()) << endmsg;
  }
  catch(...) {
    m_accessSvc->msg() << MSG::WARNING << "QUERY: Exception caught... "  << endmsg;
  }
 
  m_size = 0; // This indicates that there was a problem with query execution
}

finalize()

void RDBQuery::finalize ( )

overridevirtual

Implements IRDBQuery.

Definition at line 160 of file RDBQuery.cxx.

{
  if(m_cursor) m_cursor->close();
  m_accessSvc->disconnect(m_connName);
}

isNull() [1/2]

bool IRDBQuery::isNull ( const std::string &  field )

inlineinherited

Definition at line 45 of file IRDBQuery.h.

{
  return (*m_attrList)[field].isNull();
}

isNull() [2/2]

bool IRDBQuery::isNull ( unsigned int  fieldInd )

inlineinherited

Definition at line 50 of file IRDBQuery.h.

{
  return (*m_attrList)[fieldInd].isNull();
}

next()

bool RDBQuery::next ( )

overridevirtual

Implements IRDBQuery.

Definition at line 176 of file RDBQuery.cxx.

{
  if(m_cursor->next()) {
    m_attrList = &(m_cursor->currentRow());
    return true;
  }
  else {
    m_attrList = 0;
    return false;
  }
}

setOrder()

void RDBQuery::setOrder ( const std::string &  field )

overridevirtual

Implements IRDBQuery.

Definition at line 166 of file RDBQuery.cxx.

{
  m_orderField = field;
}

size()

long RDBQuery::size ( )

overridevirtual

Implements IRDBQuery.

Definition at line 155 of file RDBQuery.cxx.

{
  return m_size;
}

Member Data Documentation

m_accessSvc

RDBAccessSvc* RDBQuery::m_accessSvc

private

Definition at line 54 of file RDBQuery.h.

m_attrList

const coral::AttributeList* IRDBQuery::m_attrList {nullptr}

protectedinherited

Definition at line 32 of file IRDBQuery.h.

m_connName

std::string RDBQuery::m_connName

private

Definition at line 57 of file RDBQuery.h.

m_cursor

coral::ICursor* RDBQuery::m_cursor

private

Definition at line 60 of file RDBQuery.h.

m_dblock

Athena::DBLock RDBQuery::m_dblock

private

Definition at line 51 of file RDBQuery.h.

m_executed

bool RDBQuery::m_executed

private

Definition at line 62 of file RDBQuery.h.

m_fields

std::vector<std::string> RDBQuery::m_fields

private

Definition at line 59 of file RDBQuery.h.

m_nodeName

std::string RDBQuery::m_nodeName

private

Definition at line 55 of file RDBQuery.h.

m_orderField

std::string RDBQuery::m_orderField

private

Definition at line 61 of file RDBQuery.h.

m_query

coral::IQuery* RDBQuery::m_query

private

Definition at line 52 of file RDBQuery.h.

m_queryCount

coral::IQuery* RDBQuery::m_queryCount

private

Definition at line 53 of file RDBQuery.h.

m_size

long RDBQuery::m_size

private

Definition at line 58 of file RDBQuery.h.

m_tagId

std::string RDBQuery::m_tagId

private

Definition at line 56 of file RDBQuery.h.

---

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

• RDBQuery.h
• RDBQuery.cxx