cond::TagCollectionRetriever Class Reference

#include <TagCollectionRetriever.h>

Public Member Functions
bool	existsTagCollection (const std::string &globaltag)
bool	existsTagDatabase ()
void	getTagCollection (const std::string &globaltag, std::set< cond::TagMetadata > &result)
bool	selectTagCollection (const std::string &globaltag, std::set< cond::TagMetadata > &result)
	TagCollectionRetriever (cond::DbSession &coraldb)
	constructor More...
	TagCollectionRetriever (cond::DbSession &coraldb, std::string const &prefix, std::string const &postfix)
	~TagCollectionRetriever ()
	destructor More...

Private Member Functions
std::pair< std::string, std::string >	parseglobaltag (const std::string &globaltag)
	parse global tag string returns result in pair <treename,nodename> More...

Private Attributes
cond::DbSession	m_coraldb
PfnEditor	pfnEditor

Detailed Description

Definition at line 20 of file TagCollectionRetriever.h.

Constructor & Destructor Documentation

TagCollectionRetriever::TagCollectionRetriever ( cond::DbSession &  coraldb )

explicit

constructor

Definition at line 18 of file TagCollectionRetriever.cc.

                                                                          :
  m_coraldb(coraldb)
{}

TagCollectionRetriever::TagCollectionRetriever	(	cond::DbSession &	coraldb,
		std::string const &	prefix,
		std::string const &	postfix
	)

Definition at line 23 of file TagCollectionRetriever.cc.

                                                         :
  m_coraldb(coraldb), pfnEditor(prefix,postfix)
{}

TagCollectionRetriever::~TagCollectionRetriever

(

)

destructor

Definition at line 31 of file TagCollectionRetriever.cc.

{}

Member Function Documentation

bool TagCollectionRetriever::existsTagCollection

(

const std::string &

globaltag

)

Definition at line 38 of file TagCollectionRetriever.cc.

References i, AlCaHLTBitMon_QueryRunRegistry::string, and cond::tagTreeTablePrefix.

Referenced by cond::persistency::OraGTTable::select().

                                                                                {
  if(!existsTagDatabase()){
    throw cond::nonExistentGlobalTagInventoryException("TagCollectionRetriever::selectTagCollection");
  }
  std::pair<std::string,std::string> treenodepair=parseglobaltag(globaltag);
  std::string treename=treenodepair.first;
  std::string nodename=treenodepair.second;
  std::string treetablename(cond::tagTreeTablePrefix);
  if( !treename.empty() ){
    for(unsigned int i=0; i<treename.size(); ++i){
      treename[i]=std::toupper(treename[i]);    
    }
    treetablename+="_";
    treetablename+=treename;
  }
  return m_coraldb.nominalSchema().existsTable(treetablename);
}

bool TagCollectionRetriever::existsTagDatabase

(

)

Definition at line 33 of file TagCollectionRetriever.cc.

References cond::tagInventoryTable.

Referenced by cond::persistency::OraGTSchema::exists().

                                                  {
  return m_coraldb.nominalSchema().existsTable(cond::tagInventoryTable);
}

void TagCollectionRetriever::getTagCollection	(	const std::string &	globaltag,
		std::set< cond::TagMetadata > &	result
	)

given global tag return the basic tag collection. The global tag has the format TreeName::NodeName

Definition at line 57 of file TagCollectionRetriever.cc.

Referenced by cond::RDBMS::globalTag().

                                                                                 {
  if(!selectTagCollection( globaltag, result ) )
    throw cond::nonExistentGlobalTagException("TagCollectionRetriever::getTagCollection",globaltag);
}

std::pair< std::string, std::string > TagCollectionRetriever::parseglobaltag ( const std::string &  globaltag )

private

parse global tag string returns result in pair <treename,nodename>

Definition at line 152 of file TagCollectionRetriever.cc.

References align_cfg::globaltag, and query::result.

                                                                    {
  std::pair<std::string,std::string> result;
  std::size_t pos=globaltag.find("::");
  if(pos==std::string::npos){
    result.first="";
    result.second=globaltag;
  }else{
    result.first=globaltag.substr(0,pos);
    result.second=globaltag.substr(pos+2);
  }
  return result;
}

bool TagCollectionRetriever::selectTagCollection	(	const std::string &	globaltag,
		std::set< cond::TagMetadata > &	result
	)

Definition at line 64 of file TagCollectionRetriever.cc.

References Exception, i, cond::TagMetadata::labelname, cond::TagMetadata::objectname, cond::TagMetadata::pfn, o2o::query, cond::TagMetadata::recordname, AlCaHLTBitMon_QueryRunRegistry::string, cond::TagMetadata::tag, cond::tagInventoryTable, createPayload::tagname, and cond::tagTreeTablePrefix.

Referenced by cond::persistency::OraGTMapTable::select().

                                                            {
  if(!m_coraldb.nominalSchema().existsTable(cond::tagInventoryTable)){
    throw cond::nonExistentGlobalTagInventoryException("TagCollectionRetriever::selectTagCollection");
  }
  std::pair<std::string,std::string> treenodepair=parseglobaltag(globaltag);
  std::string treename=treenodepair.first;
  std::string nodename=treenodepair.second;
  //std::cout<<"treename "<<treename<<std::endl;
  //std::cout<<"nodename "<<nodename<<std::endl;
  std::string treetablename(cond::tagTreeTablePrefix);
  if( !treename.empty() ){
    for(unsigned int i=0; i<treename.size(); ++i){
      treename[i]=std::toupper(treename[i]);    
    }
    treetablename+="_";
    treetablename+=treename;
  }
  if( !m_coraldb.nominalSchema().existsTable(treetablename) ) return false;

  coral::IQuery* query=m_coraldb.nominalSchema().newQuery();
  //std::cout<<"treetablename "<<treetablename<<std::endl;
  query->addToTableList( treetablename, "p1" );
  query->addToTableList( treetablename, "p2" );
  query->addToOutputList( "p1.tagid" );
  query->setRowCacheSize( 100 );
  coral::AttributeList bindData;
  bindData.extend( "nodelabel",typeid(std::string) );
  bindData.extend( "tagid",typeid(unsigned int) );
  bindData["tagid"].data<unsigned int>()=0;
  bindData["nodelabel"].data<std::string>()=nodename;
  query->setCondition( "p1.lft BETWEEN p2.lft AND p2.rgt AND p2.nodelabel = :nodelabel AND p1.tagid <> :tagid", bindData );
  coral::AttributeList qresult;
  qresult.extend("tagid", typeid(unsigned int));
  query->defineOutput(qresult);
  std::vector<unsigned int> leaftagids;
  leaftagids.reserve(100);
  coral::ICursor& cursor = query->execute();
  while( cursor.next() ) {
    const coral::AttributeList& row = cursor.currentRow();
    leaftagids.push_back(row["tagid"].data<unsigned int>());
  }
  cursor.close();
  delete query;
  std::vector<unsigned int>::iterator it;
  std::vector<unsigned int>::iterator itBeg=leaftagids.begin();
  std::vector<unsigned int>::iterator itEnd=leaftagids.end();
  coral::ITable& tagInventorytable=m_coraldb.nominalSchema().tableHandle(cond::tagInventoryTable);
  for( it=itBeg; it!=itEnd; ++it ){
    coral::IQuery* leaftagquery=tagInventorytable.newQuery();
    leaftagquery->addToOutputList( "tagname" );
    leaftagquery->addToOutputList( "pfn" );
    leaftagquery->addToOutputList( "recordname" );
    leaftagquery->addToOutputList( "objectname" );
    leaftagquery->addToOutputList( "labelname" );
    coral::AttributeList myresult;
    myresult.extend("tagname",typeid(std::string));
    myresult.extend("pfn",typeid(std::string));
    myresult.extend("recordname",typeid(std::string));
    myresult.extend("objectname",typeid(std::string));
    myresult.extend("labelname",typeid(std::string));
    leaftagquery->defineOutput( myresult );
    coral::AttributeList bindVariableList;
    bindVariableList.extend("tagid",typeid(unsigned int));
    leaftagquery->setCondition( "tagid = :tagid",bindVariableList );
    leaftagquery->limitReturnedRows(1,0);
    bindVariableList["tagid"].data<unsigned int>()=*it;
    coral::ICursor& cursor2 =leaftagquery->execute();
    if( cursor2.next() ){
      const coral::AttributeList& row = cursor2.currentRow();
      cond::TagMetadata tagmetadata;
      std::string tagname=row["tagname"].data<std::string>();
      tagmetadata.tag=tagname;
      tagmetadata.pfn=pfnEditor(row["pfn"].data<std::string>());
      tagmetadata.recordname=row["recordname"].data<std::string>();
      tagmetadata.objectname=row["objectname"].data<std::string>();
      tagmetadata.labelname=row["labelname"].data<std::string>();
      if(! result.insert(tagmetadata).second ){
    throw cond::Exception("cond::TagCollectionRetriever::getTagCollection tag "+tagname+" from "+tagmetadata.pfn+" already exist, cannot insert in the tag collection ");
      }
    }
    cursor2.close();
    delete leaftagquery;
  }
  return true;
}

Member Data Documentation

cond::DbSession cond::TagCollectionRetriever::m_coraldb

private

Definition at line 44 of file TagCollectionRetriever.h.

PfnEditor cond::TagCollectionRetriever::pfnEditor

private

Definition at line 45 of file TagCollectionRetriever.h.