lumi::HLTConf2DB Class Reference

Inheritance diagram for lumi::HLTConf2DB:

Public Member Functions
const std::string	dataType () const override
	HLTConf2DB (const std::string &dest)
unsigned long long	retrieveData (unsigned int) override
const std::string	sourceType () const override
	~HLTConf2DB () override
Public Member Functions inherited from lumi::DataPipe
	DataPipe (const std::string &)
	DataPipe (const DataPipe &)=delete
std::string	getAuthPath () const
std::string	getMode () const
float	getNorm () const
std::string	getSource () const
const DataPipe &	operator= (const DataPipe &)=delete
void	setAuthPath (const std::string &authpath)
void	setMode (const std::string &mode)
void	setNoCheckingStableBeam ()
void	setNorm (float norm)
void	setNoValidate ()
void	setSource (const std::string &source)
virtual	~DataPipe ()

Additional Inherited Members
Protected Attributes inherited from lumi::DataPipe
std::string	m_authpath
std::string	m_dest
std::string	m_mode
bool	m_nocheckingstablebeam
float	m_norm
bool	m_novalidate
std::string	m_source

Detailed Description

Definition at line 31 of file HLTConf2DB.cc.

Constructor & Destructor Documentation

HLTConf2DB()

lumi::HLTConf2DB::HLTConf2DB ( const std::string &  dest )

explicit

Definition at line 42 of file HLTConf2DB.cc.

: DataPipe(dest) {}

~HLTConf2DB()

lumi::HLTConf2DB::~HLTConf2DB ( )

override

Definition at line 228 of file HLTConf2DB.cc.

{}

Member Function Documentation

dataType()

const std::string lumi::HLTConf2DB::dataType ( ) const

overridevirtual

Implements lumi::DataPipe.

Definition at line 226 of file HLTConf2DB.cc.

{ return "HLTConf"; }

retrieveData()

unsigned long long lumi::HLTConf2DB::retrieveData ( unsigned int  runnumber )

overridevirtual

select paths.name,stringparamvalues.value from stringparamvalues,paths,parameters,superidparameterassoc,modules,moduletemplates,pathmoduleassoc,configurationpathassoc,configurations where parameters.paramid=stringparamvalues.paramid and superidparameterassoc.paramid=parameters.paramid and modules.superid=superidparameterassoc.superid and moduletemplates.superid=modules.templateid and pathmoduleassoc.moduleid=modules.superid and paths.pathid=pathmoduleassoc.pathid and configurationpathassoc.pathid=paths.pathid and configurations.configid=configurationpathassoc.configid and moduletemplates.name='HLTLevel1GTSeed' and parameters.name='L1SeedsLogicalExpression' and configurations.configid=1905;

Implements lumi::DataPipe.

Definition at line 43 of file HLTConf2DB.cc.

References gather_cfg::cout, Exception, lumi::DataPipe::m_authpath, lumi::DataPipe::m_dest, lumi::DataPipe::m_source, cond::runnumber, alignCSCRings::s, lumi::DBConfig::setAuthentication(), AlCaHLTBitMon_QueryRunRegistry::string, and lumi::LumiNames::trghltMapTableName().

                                                                    {
    std::string runinfoschema("CMS_RUNINFO");
    //std::string hltschema("CMS_HLT_V0");
    std::string hltschema("CMS_HLT");
    std::string runsessiontable("RUNSESSION_PARAMETER");
    //
    //must login as cms_hlt_r
    coral::ConnectionService* svc = new coral::ConnectionService;
    lumi::DBConfig dbconf(*svc);
    if (!m_authpath.empty()) {
      dbconf.setAuthentication(m_authpath);
    }
    //std::cout<<"m_source "<<m_source<<std::endl;
    coral::ISessionProxy* srcsession = svc->connect(m_source, coral::ReadOnly);
    coral::ITypeConverter& tpc = srcsession->typeConverter();
    tpc.setCppTypeForSqlType("unsigned int", "NUMBER(38)");
    //
    //select string_value from CMS_RUNINFO.runsession_parameter where name='CMS.LVL0:HLT_KEY_DESCRIPTION' and runnumber=xx;
    //
    std::string hltkey("");
    std::vector<std::pair<std::string, std::string> > hlt2l1map;
    hlt2l1map.reserve(200);
    try {
      srcsession->transaction().start(true);
      coral::ISchema& runinfoSchemaHandle = srcsession->schema(runinfoschema);
      if (!runinfoSchemaHandle.existsTable(runsessiontable)) {
        throw lumi::Exception("missing runsession table", "retrieveData", "HLTConf2DB");
      }
      coral::AttributeList rfBindVariableList;
      rfBindVariableList.extend("name", typeid(std::string));
      rfBindVariableList.extend("runnumber", typeid(unsigned int));
      rfBindVariableList["name"].data<std::string>() = std::string("CMS.LVL0:HLT_KEY_DESCRIPTION");
      rfBindVariableList["runnumber"].data<unsigned int>() = runnumber;
      coral::IQuery* kq = runinfoSchemaHandle.newQuery();
      coral::AttributeList runinfoOut;
      runinfoOut.extend("STRING_VALUE", typeid(std::string));
      kq->addToTableList(runsessiontable);
      kq->setCondition("NAME = :name AND RUNNUMBER = :runnumber", rfBindVariableList);
      kq->addToOutputList("STRING_VALUE");
      kq->defineOutput(runinfoOut);
      coral::ICursor& kcursor = kq->execute();
      unsigned int s = 0;
      while (kcursor.next()) {
        const coral::AttributeList& row = kcursor.currentRow();
        hltkey = row["STRING_VALUE"].data<std::string>();
        ++s;
      }
      if (s == 0 || hltkey.empty()) {
        kcursor.close();
        delete kq;
        srcsession->transaction().rollback();
        throw lumi::Exception(std::string("requested run has no or invalid hltkey"), "retrieveData", "TRG2DB");
      }
      if (s > 1) {
        kcursor.close();
        delete kq;
        srcsession->transaction().rollback();
        throw lumi::Exception(std::string("requested run has multile hltkey"), "retrieveData", "TRG2DB");
      }
    } catch (const coral::Exception& er) {
      std::cout << "source runinfo database problem " << er.what() << std::endl;
      srcsession->transaction().rollback();
      delete srcsession;
      delete svc;
      throw er;
    }
    coral::ISchema& confSchemaHandle = srcsession->nominalSchema();
    try {
      //srcsession->transaction().start(true);
      if (!confSchemaHandle.existsTable("PATHS") || !confSchemaHandle.existsTable("STRINGPARAMVALUES") ||
          !confSchemaHandle.existsTable("PARAMETERS") || !confSchemaHandle.existsTable("SUPERIDPARAMETERASSOC") ||
          !confSchemaHandle.existsTable("MODULES") || !confSchemaHandle.existsTable("MODULETEMPLATES") ||
          !confSchemaHandle.existsTable("PATHMODULEASSOC") || !confSchemaHandle.existsTable("CONFIGURATIONPATHASSOC") ||
          !confSchemaHandle.existsTable("CONFIGURATIONS")) {
        throw lumi::Exception("missing hlt conf tables", "retrieveData", "HLTConf2DB");
      }
      coral::AttributeList q1BindVariableList;
      q1BindVariableList.extend("hltseed", typeid(std::string));
      q1BindVariableList.extend("l1seedexpr", typeid(std::string));
      q1BindVariableList.extend("hltkey", typeid(std::string));
      q1BindVariableList["hltseed"].data<std::string>() = std::string("HLTLevel1GTSeed");
      q1BindVariableList["l1seedexpr"].data<std::string>() = std::string("L1SeedsLogicalExpression");
      q1BindVariableList["hltkey"].data<std::string>() = hltkey;
      coral::IQuery* q1 = confSchemaHandle.newQuery();
      q1->addToOutputList("PATHS.NAME", "hltpath");
      q1->addToOutputList("STRINGPARAMVALUES.VALUE", "l1expression");

      q1->addToTableList("PATHS");
      q1->addToTableList("STRINGPARAMVALUES");
      q1->addToTableList("PARAMETERS");
      q1->addToTableList("SUPERIDPARAMETERASSOC");
      q1->addToTableList("MODULES");
      q1->addToTableList("MODULETEMPLATES");
      q1->addToTableList("PATHMODULEASSOC");
      q1->addToTableList("CONFIGURATIONPATHASSOC");
      q1->addToTableList("CONFIGURATIONS");

      q1->setCondition(
          "PARAMETERS.PARAMID=STRINGPARAMVALUES.PARAMID and SUPERIDPARAMETERASSOC.PARAMID=PARAMETERS.PARAMID and "
          "MODULES.SUPERID=SUPERIDPARAMETERASSOC.SUPERID and MODULETEMPLATES.SUPERID=MODULES.TEMPLATEID and "
          "PATHMODULEASSOC.MODULEID=MODULES.SUPERID and PATHS.PATHID=PATHMODULEASSOC.PATHID and "
          "CONFIGURATIONPATHASSOC.PATHID=PATHS.PATHID and CONFIGURATIONS.CONFIGID=CONFIGURATIONPATHASSOC.CONFIGID and "
          "MODULETEMPLATES.NAME = :hltseed and PARAMETERS.NAME = :l1seedexpr and CONFIGURATIONS.CONFIGDESCRIPTOR = "
          ":hltkey",
          q1BindVariableList);

      coral::ICursor& cursor1 = q1->execute();
      while (cursor1.next()) {
        const coral::AttributeList& row = cursor1.currentRow();
        std::string hltpath = row["hltpath"].data<std::string>();
        std::string l1expression = row["l1expression"].data<std::string>();
        hlt2l1map.push_back(std::make_pair(hltpath, l1expression));
      }
      cursor1.close();
      delete q1;
    } catch (const coral::Exception& er) {
      std::cout << "database problem with source hlt confdb" << er.what() << std::endl;
      srcsession->transaction().rollback();
      delete srcsession;
      throw er;
    }
    srcsession->transaction().commit();
    delete srcsession;
    std::vector<std::pair<std::string, std::string> >::const_iterator mIt;
    std::vector<std::pair<std::string, std::string> >::const_iterator mBeg = hlt2l1map.begin();
    std::vector<std::pair<std::string, std::string> >::const_iterator mEnd = hlt2l1map.end();

    coral::ISessionProxy* destsession = svc->connect(m_dest, coral::Update);
    try {
      //check if hltkey already exists
      destsession->transaction().start(true);
      bool hltkeyExists = false;
      coral::AttributeList kQueryBindList;
      kQueryBindList.extend("hltkey", typeid(std::string));
      coral::IQuery* kQuery = destsession->nominalSchema().tableHandle(LumiNames::trghltMapTableName()).newQuery();
      kQuery->setCondition("HLTKEY =:hltkey", kQueryBindList);
      kQueryBindList["hltkey"].data<std::string>() = hltkey;
      coral::ICursor& kResult = kQuery->execute();
      while (kResult.next()) {
        hltkeyExists = true;
      }
      if (hltkeyExists) {
        std::cout << "hltkey " << hltkey << " already registered , do nothing" << std::endl;
        destsession->transaction().commit();
        delete kQuery;
        delete svc;
        return 0;
      }
      destsession->transaction().commit();
      destsession->transaction().start(false);
      coral::ISchema& destschema = destsession->nominalSchema();
      coral::ITable& hltconftable = destschema.tableHandle(LumiNames::trghltMapTableName());
      coral::AttributeList hltconfData;
      hltconfData.extend<std::string>("HLTKEY");
      hltconfData.extend<std::string>("HLTPATHNAME");
      hltconfData.extend<std::string>("L1SEED");
      coral::IBulkOperation* hltconfInserter = hltconftable.dataEditor().bulkInsert(hltconfData, 200);
      hltconfData["HLTKEY"].data<std::string>() = hltkey;
      std::string& hltpathname = hltconfData["HLTPATHNAME"].data<std::string>();
      std::string& l1seedname = hltconfData["L1SEED"].data<std::string>();
      for (mIt = mBeg; mIt != mEnd; ++mIt) {
        hltpathname = mIt->first;
        l1seedname = mIt->second;
        hltconfInserter->processNextIteration();
        //std::cout<<mIt->first<<" "<<mIt->second<<std::endl;
      }
      hltconfInserter->flush();
      delete hltconfInserter;
      destsession->transaction().commit();
    } catch (const coral::Exception& er) {
      std::cout << "database problem " << er.what() << std::endl;
      destsession->transaction().rollback();
      delete destsession;
      delete svc;
      throw er;
    }
    delete destsession;
    delete svc;
    return 0;
  }

sourceType()

const std::string lumi::HLTConf2DB::sourceType ( ) const

overridevirtual

Implements lumi::DataPipe.

Definition at line 227 of file HLTConf2DB.cc.

{ return "DB"; }