RDBVersionAccessor.cxx

Go to the documentation of this file.

/*
  Copyright (C) 2002-2024 CERN for the benefit of the ATLAS collaboration
*/
 
#include "RDBVersionAccessor.h"
 
#include "RelationalAccess/ISessionProxy.h"
#include "RelationalAccess/ICursor.h"
#include "RelationalAccess/ITable.h"
#include "RelationalAccess/ISchema.h"
#include "RelationalAccess/IQuery.h"
#include "RelationalAccess/SchemaException.h"
 
#include "CxxUtils/checker_macros.h"
 
#include "CoralBase/Attribute.h"
#include "CoralBase/AttributeList.h"
 
#include "GaudiKernel/MsgStream.h"
 
#include <stdexcept>
#include <sstream>
 
RDBVersionAccessor::RDBVersionAccessor(const std::string& childNode
                       , const std::string& parentNode
                       , const std::string& parentTag
                       , coral::ISessionProxy* session
                       , MsgStream& msgStream)
  : m_session(session)
  , m_childNode(childNode)
  , m_parentNode(parentNode)
  , m_parentTag(parentTag)
  , m_tagName("")
  , m_tagID("")
  , m_isChildLeaf(false)
  , m_msgStream(msgStream)
{
}
 
void RDBVersionAccessor::getChildTagData()
{
  std::string parentNodeId, childNodeId, parentTagId;
  int nRows;
 
  if(!m_session) {
    m_msgStream << MSG::ERROR << "VersionAccessor: No connection to database!" << endmsg;
    return;
  }
 
  try {
    if(m_msgStream.level()==MSG::VERBOSE) {
      m_msgStream << MSG::VERBOSE << "VersionAccessor:  Version accessor for \n    ChildNode = " << m_childNode 
          << "     ParentNode = " << m_parentNode 
          << "     ParentTag = " << m_parentTag << endmsg;
    }
 
    coral::ITable& tableTag2Node = m_session->nominalSchema().tableHandle("HVS_TAG2NODE");
    coral::ITable& tableNode = m_session->nominalSchema().tableHandle("HVS_NODE");
    coral::ITable& tableLtag2Ltag = m_session->nominalSchema().tableHandle("HVS_LTAG2LTAG");
 
    //
    // STEP 1. Get TagId for parentTag 
    // 
    // Query: "SELECT TAG_ID FROM HVS_TAG2NODE WHERE TAG_NAME='m_parentTag'"
    //
    coral::IQuery *queryTag2Node = tableTag2Node.newQuery();
    queryTag2Node->addToOutputList("TAG_ID");
    queryTag2Node->setMemoryCacheSize(1);
    coral::AttributeList bindsTag2Node ATLAS_THREAD_SAFE;
    bindsTag2Node.extend<std::string>("tagN");
    queryTag2Node->setCondition("TAG_NAME=:tagN", bindsTag2Node);
    bindsTag2Node[0].data<std::string>() = m_parentTag;
 
    coral::ICursor& cursorTag2Node = queryTag2Node->execute();
    nRows = 0;
    while(cursorTag2Node.next()) {
      if(++nRows>1) {
    delete queryTag2Node;
    throw std::runtime_error( "The tag " + m_parentTag + " is not unique in HVS_TAG2NODE table!");
      }      
 
      const coral::AttributeList& row = cursorTag2Node.currentRow();
      parentTagId = attribute2String(row,"TAG_ID");
 
    }
    if(nRows==0) {
      delete queryTag2Node;
      throw std::runtime_error( "The tag " + m_parentTag + " not found in HVS_TAG2NODE table!");
    }
 
    delete queryTag2Node;
    if(m_msgStream.level()==MSG::VERBOSE) {
      m_msgStream << MSG::VERBOSE << "VersionAccessor:  Parent Tag Id = " << parentTagId << endmsg;
    }
 
    //
    // STEP 2. Get NodeIDs for parentNode and child 
    //
    // Query: "SELECT NODE_NAME, NODE_ID, BRANCH_FLAG FROM HVS_NODE
    //         WHERE NODE_NAME='m_parentNode' OR NODE_NAME='m_childNode'"
    //
 
    coral::IQuery* queryNodeIDs = tableNode.newQuery();
 
    queryNodeIDs->addToOutputList("NODE_NAME");
    queryNodeIDs->addToOutputList("NODE_ID");
    queryNodeIDs->addToOutputList("BRANCH_FLAG");
    queryNodeIDs->setMemoryCacheSize(2);
 
    coral::AttributeList bindsNodeIDs ATLAS_THREAD_SAFE;
    bindsNodeIDs.extend<std::string>("parentN");
    bindsNodeIDs.extend<std::string>("childN");
 
    queryNodeIDs->setCondition( "NODE_NAME=:parentN OR NODE_NAME=:childN", bindsNodeIDs);
 
    bindsNodeIDs[0].data<std::string>() = m_parentNode;
    bindsNodeIDs[1].data<std::string>() = m_childNode;
 
    coral::ICursor& cursorNodeIDs = queryNodeIDs->execute();
 
    nRows = 0;
    while(cursorNodeIDs.next()) {
      if(++nRows>2) {
    break;
      }
      const coral::AttributeList& row = cursorNodeIDs.currentRow();
 
      if(attribute2String(row,"NODE_NAME")==m_childNode) {
    childNodeId = attribute2String(row,"NODE_ID");
    m_isChildLeaf = (attribute2String(row,"BRANCH_FLAG")=="0");
      }
      else {
    parentNodeId = attribute2String(row,"NODE_ID");
      }
    }
    if(nRows!=2 && m_childNode!=m_parentNode) {
      delete queryNodeIDs;
      throw std::runtime_error("Error processing HVS_NODE, Number of fetched records !=2");
    }
 
    if(m_msgStream.level()==MSG::VERBOSE) {
      m_msgStream << MSG::VERBOSE << "VersionAccessor:  Child Node Id = " << childNodeId << endmsg;
      m_msgStream << MSG::VERBOSE << "VersionAccessor:  Parent Node Id = " << parentNodeId << endmsg;
    }
 
    delete queryNodeIDs;
 
    if(m_childNode==m_parentNode) {
      m_tagName = m_parentTag;
      m_tagID = parentTagId;
      return;
    }
 
    //
    // STEP 3.
    //
    // *********************** THIS IS A TEMPORARY SOLUTION ************************
    // ***                                                                       ***
    // *** 1. First we determine a path from childNode to parentNode querying    ***
    // ***    HVS_NODE few times                                                 ***
    // *** 2. Then we query HVS_LTAG2LTAG few times to get tag of childNode      ***
    // ***    of childNode                                                       ***
    // ***                                                                       ***
    // *********** ************ ********** ************* ************ **************
 
    std::vector<std::string> path;
    path.push_back(childNodeId);
    std::string currentParrent = childNodeId;
    std::string currentChild = childNodeId;
 
    coral::AttributeList bindsNode ATLAS_THREAD_SAFE;
    bindsNode.extend<std::string>("nodeId");
 
    while(currentParrent != parentNodeId) {
      //
      // Query: "SELECT PARENT_ID FROM HVS_NODE WHERE NODE_ID='currentChild'"
      //
      coral::IQuery* queryNode(tableNode.newQuery());
 
      queryNode->addToOutputList("PARENT_ID");
      queryNode->setMemoryCacheSize(1);
 
      queryNode->setCondition("NODE_ID=:nodeId", bindsNode);
      bindsNode[0].data<std::string>()=currentChild;
 
      coral::ICursor& cursorNode = queryNode->execute();
 
      nRows = 0;
 
      // Process Query results
      while(cursorNode.next()) {
    if(++nRows>1) {
      delete queryNode;
      throw std::runtime_error("The node " + currentChild + " has more than one parent!");
    }   
 
    const coral::AttributeList& row = cursorNode.currentRow();
    
    if(row[0].isNull()) {
      delete queryNode;
      throw std::runtime_error("The requested child and parent nodes are not on the same branch!");
    }   
 
    currentParrent = attribute2String(row,"PARENT_ID");
    currentChild = currentParrent;
    path.push_back(currentParrent);
      }
      if(nRows==0) {
    delete queryNode;
    throw std::runtime_error("The node " + currentChild + " has no parent!");
      }
 
      delete queryNode;
      if(m_msgStream.level()==MSG::VERBOSE) {
    m_msgStream << MSG::VERBOSE << "VersionAccessor:  Current Child = " << currentChild << endmsg;
    m_msgStream << MSG::VERBOSE << "VersionAccessor:  Current Parrent = " << currentParrent << endmsg;
      }
    }
 
    coral::AttributeList bindsLtag2Ltag ATLAS_THREAD_SAFE;
    bindsLtag2Ltag.extend<std::string>("childN");
    bindsLtag2Ltag.extend<std::string>("parentT");
    bindsLtag2Ltag.extend<std::string>("parentN");
 
 
    for(unsigned int ind=1; ind<path.size(); ind++) {
      // Query: "SELECT CHILD_TAG FROM HVS_LTAG2LTAG WHERE
      //         CHILD_NODE  = 'path[path.size()-ind-1]' AND
      //         PARENT_TAG  = 'parentTagId' AND
      //         PARENT_NODE = 'path[path.size()-ind]'
      coral::IQuery* queryLtag2Ltag(tableLtag2Ltag.newQuery());
 
      queryLtag2Ltag->addToOutputList("CHILD_TAG");
      queryLtag2Ltag->setMemoryCacheSize(1);
 
      std::string conditionString = "CHILD_NODE =:childN AND PARENT_TAG =:parentT AND PARENT_NODE =:parentN";
      queryLtag2Ltag->setCondition(conditionString, bindsLtag2Ltag);
 
      bindsLtag2Ltag[0].data<std::string>() = path[path.size()-ind-1];
      bindsLtag2Ltag[1].data<std::string>() = parentTagId;
      bindsLtag2Ltag[2].data<std::string>() = path[path.size()-ind];
 
      coral::ICursor& cursorLtag2Ltag = queryLtag2Ltag->execute();
 
      nRows = 0;
      // Process Query results
      while(cursorLtag2Ltag.next()) {
    if(++nRows>1) {
      delete queryLtag2Ltag;
      throw std::runtime_error("Version " + parentTagId + 
                   " has more than one child of type " + path[path.size()-ind-1] + "!");
    }
 
    const coral::AttributeList& row = cursorLtag2Ltag.currentRow();
    parentTagId = attribute2String(row,"CHILD_TAG");
      }
      if(nRows==0) {
    delete queryLtag2Ltag;
    throw std::runtime_error("Version " + parentTagId + " has no child of type " + path[path.size()-ind-1] + "!");
      }
 
      delete queryLtag2Ltag;
 
      if(m_msgStream.level()==MSG::VERBOSE) {
    m_msgStream << MSG::VERBOSE << "VersionAccessor:  Parent Tag Id = " << parentTagId << endmsg;
      }
    }
 
    //
    // STEP 4. Get tag name for obtained TAG_ID
    //
    // Query: "SELECT TAG_NAME from HVS_TAG2NODE WHERE TAG_ID='parentTagId'"
    //
    coral::IQuery* queryTagName(tableTag2Node.newQuery());
 
    queryTagName->addToOutputList("TAG_NAME");
    queryTagName->setMemoryCacheSize(1);
 
    coral::AttributeList bindsTagName ATLAS_THREAD_SAFE;
    bindsTagName.extend<std::string>("tagId");
 
    queryTagName->setCondition("TAG_ID=:tagId", bindsTagName);
    bindsTagName[0].data<std::string>() = parentTagId;
 
    coral::ICursor& cursorTagName = queryTagName->execute();
 
    nRows = 0;
    while(cursorTagName.next()) {
      if(++nRows>1) {
    delete queryTagName;
    throw std::runtime_error("More than one record retrieved when getting tag name for given ID");
      }  
 
      const coral::AttributeList& row = cursorTagName.currentRow();
 
      m_tagName =attribute2String(row,"TAG_NAME"); 
      m_tagID = parentTagId;
 
      if(m_msgStream.level()==MSG::VERBOSE) {
    m_msgStream << MSG::VERBOSE << "VersionAccessor:  Child Tag Name = " << m_tagName << endmsg;
      }
    }
    delete queryTagName;
 
  }
  catch(coral::SchemaException& se) 
  {
     m_msgStream << MSG::ERROR << "VersionAccessor: Schema Exception : " << se.what() << endmsg;
  }
  catch(std::exception& e)
  {
    if(m_msgStream.level()<=MSG::DEBUG)
      m_msgStream << MSG::DEBUG << e.what() << endmsg;
  }
  catch(...) 
  {
    m_msgStream << MSG::ERROR << "VersionAccessor: Exception caught(...)" << endmsg;
  }
}
 
std::string RDBVersionAccessor::attribute2String(const coral::AttributeList& attList,
                         const std::string& fieldName)
{
  std::ostringstream streamValue;
  attList[fieldName].toOutputStream(streamValue);
  std::string stringValue = streamValue.str();
  unsigned int position = stringValue.find(") :");
  return stringValue.substr(position+4);
}