DQMSummaryReader Class Reference

#include <DQMSummaryReader.h>

Inheritance diagram for DQMSummaryReader:

Public Member Functions
	DQMSummaryReader (const std::string &connectionString, const std::string &user, const std::string &pass)
DQMSummary	readData (const std::string &table, const long long r_number)
void	run ()
virtual	~DQMSummaryReader ()
Public Member Functions inherited from TestBase
void	setVerbosityLevel (coral::MsgLevel level)
void	setVerbosityLevel (coral::MsgLevel level)
	TestBase ()
	TestBase ()
virtual	~TestBase ()
virtual	~TestBase ()

Private Attributes
std::string	m_connectionString
std::string	m_pass
std::string	m_tableToRead
std::string	m_user

Additional Inherited Members
Protected Member Functions inherited from TestBase
coral::ISession *	connect (const std::string &connectionString, const std::string &user, const std::string &password)
coral::ISession *	connect (const std::string &connectionString, const std::string &user, const std::string &password)

Detailed Description

Definition at line 8 of file DQMSummaryReader.h.

Constructor & Destructor Documentation

DQMSummaryReader::DQMSummaryReader	(	const std::string &	connectionString,
		const std::string &	user,
		const std::string &	pass
	)

Definition at line 21 of file DQMSummaryReader.cc.

References m_tableToRead.

                                         :
  TestBase(), /*ReadBase(),*/
  m_connectionString( connectionString ),
  m_user( user ),
  m_pass( pass ) {
  m_tableToRead="";
}

DQMSummaryReader::~DQMSummaryReader ( )

virtual

Definition at line 31 of file DQMSummaryReader.cc.

{}

Member Function Documentation

DQMSummary DQMSummaryReader::readData	(	const std::string &	table,
		const long long	r_number
	)

Definition at line 35 of file DQMSummaryReader.cc.

References TestBase::connect(), gather_cfg::cout, alignCSCRings::e, cppFunctionSkipper::exception, Exception, m_connectionString, m_pass, DQMSummary::m_run, DQMSummary::m_summary, m_tableToRead, m_user, o2o::query, dataDML::schema, models::session, AlCaHLTBitMon_QueryRunRegistry::string, and TableParser::table.

Referenced by popcon::DQMSummarySourceHandler::getNewObjects().

                                                                                         {
  m_tableToRead = table; // to be  CMS_DQM_SUMMARY.summarycontent
  //m_columnToRead = column;  // to be run, lumisec
  DQMSummary dqmSummary;
  dqmSummary.m_run = r_number;
  std::cout<< "Entering readData" << std::endl;
  coral::ISession* session = this->connect(m_connectionString,
                                           m_user, m_pass);
  //coral::ISessionProxy* session = this->connect(m_connectionString,
  //                                              m_user, m_pass);
  try{
    //session->typeConverter().setCppTypeForSqlType(coral::AttributeSpecification::typeNameForId(typeid(std::string)), "VARCHAR2(20)");
    //session->typeConverter().setCppTypeForSqlType(coral::AttributeSpecification::typeNameForId(typeid(std::string)), "VARCHAR2(40)");
    session->transaction().start();
    std::cout<< "Starting session on the connection " << m_connectionString << std::endl;
    coral::ISchema& schema = session->nominalSchema();
    std::cout<< "--- accessing schema for user " << m_user << std::endl;
    std::cout<< "------ trying to handle table " << m_tableToRead << std::endl;
    //defining count query
    coral::IQuery* query = schema.tableHandle(m_tableToRead).newQuery();
    query->addToOutputList("count(*)", "count");
    //condition for the WHERE clause in the count query
    std::string condition = "run=:n_run";
    coral::AttributeList conditionData;
    conditionData.extend<long long>( "n_run" );
    //conditionData[0].setValue<long long>(r_number); 
    conditionData[0].data<long long>() = r_number;
    query->setCondition(condition, conditionData);
    //performing count query
    coral::ICursor& cursor = query->execute();
    DQMSummary::DQMSummary::RunItem runItem;
    DQMSummary::DQMSummary::RunItem::LumiItem lumiItem;
    double nRows = 0;
    if( cursor.next() ) {
      //cursor.currentRow().toOutputStream(std::cout) << std::endl;
      const coral::AttributeList& row = cursor.currentRow();
      nRows = row["count"].data<double>();
      /*const coral::Attribute& count = cursor.currentRow()["count"];
    if(count.specification().type() == typeid(double))
      nRows = count.data<double>();
      else
      nRows = count.data<float>();*/
      std::cout << "Rows for count query " << nRows << std::endl;
      if( nRows != 0 ) {
    std::cout << "Starting to build DQMSummary" << std::endl;
    //defining first query
    coral::IQuery* queryI = schema.tableHandle(m_tableToRead).newQuery();
    queryI->setDistinct();
    queryI->addToOutputList("lumisec");
    //condition for the WHERE clause in the first query
    std::string conditionI = "run=:n_run";
    coral::AttributeList conditionDataI;
    conditionDataI.extend<long long>( "n_run" );
    //conditionDataI[0].setValue<long long>(r_number); 
    conditionDataI[0].data<long long>() = r_number;
    queryI->setCondition(conditionI, conditionDataI);
    //performing query
    coral::ICursor& cursorI = queryI->execute();
    //a little printout, then filling DQMSummary
    int nRowsI = 0;
    while( cursorI.next() ) {
      //cursorI.currentRow().toOutputStream(std::cout) << std::endl;
      ++nRowsI;
      const coral::AttributeList& rowI = cursorI.currentRow();
      runItem.m_lumisec = rowI["lumisec"].data<long long>();
      //defining second query
      coral::IQuery* queryII = schema.tableHandle(m_tableToRead).newQuery();
      queryII->addToOutputList("subsystem");
      queryII->addToOutputList("reportcontent");
      //queryII->addToOutputList("type"); // when implemented in OMDS
      queryII->addToOutputList("status");
      std::string conditionII = "run= :n_run AND lumisec= :n_lumisec";
      coral::AttributeList conditionDataII;
      conditionDataII.extend<long long>( "n_run" );
      //conditionDataII[0].setValue<long long>(r_number); 
      conditionDataII[0].data<long long>() = r_number;
      conditionDataII.extend<long long>( "n_lumisec" );
      //conditionDataII[1].setValue<long long>(rowI["lumisec"].data<long long>()); 
      conditionDataII[1].data<long long>() = rowI["lumisec"].data<long long>();
      queryII->setCondition(conditionII, conditionDataII);
      //performing query
      coral::ICursor& cursorII = queryII->execute();
      //a little printout, then filling DQMSummary
      int nRowsII = 0;
      while( cursorII.next() ) {
        //cursorII.currentRow().toOutputStream(std::cout) << std::endl;
        ++nRowsII;
        const coral::AttributeList& rowII = cursorII.currentRow();
        lumiItem.m_subsystem = rowII["subsystem"].data<std::string>();
        lumiItem.m_reportcontent = rowII["reportcontent"].data<std::string>();
        //lumiItem.m_type = rowII["type"].data<std::string>(); // when implemented in OMDS
        lumiItem.m_type = "reportSummary";
        lumiItem.m_status = rowII["status"].data<double>();
        runItem.m_lumisummary.push_back(lumiItem);
        std::cout << "DQMSummary::DQMSummary::RunItem::LumiItem filled" << std::endl;
      }
      std::cout << "Returned rows for lumisection query " << nRowsII << std::endl;
      dqmSummary.m_summary.push_back(runItem);
      std::cout << "DQMSummary::DQMSummary::RunItem filled" << std::endl;
      delete queryII;
    }
    std::cout << "Returned rows for run number query " << nRowsI << std::endl;
    delete queryI;
      }
      else {
    runItem.m_lumisec = 0;
    lumiItem.m_subsystem = " ";
    lumiItem.m_reportcontent = " ";
    lumiItem.m_type = " ";
    lumiItem.m_status = -2;
    std::cout << "[lumisec (long long) : " << runItem.m_lumisec
          << "], [subsystem (string) : " << lumiItem.m_subsystem
          << "], [reportcontent (string) : " << lumiItem.m_reportcontent
          << "], [type (string) : " << lumiItem.m_type
          << "], [status (double) : " << lumiItem.m_status
          << "]" << std::endl;
    runItem.m_lumisummary.push_back(lumiItem);
    dqmSummary.m_summary.push_back(runItem);
    std::cout << "No information in DQMSummary for run " 
          << r_number <<std::endl;
      }
    }
    else 
      throw cms::Exception("UnconsistentData") << "What is wrong with you?" << std::endl;
    std::cout << "DQMSummary built" << std::endl;
    delete query;
    session->transaction().commit();
  } 
  catch (const std::exception& e) { 
    std::cout << "Exception: "<<e.what()<<std::endl; 
  }
  delete session;
  return dqmSummary;
}

void DQMSummaryReader::run ( )

virtual

Implements TestBase.

Definition at line 33 of file DQMSummaryReader.cc.

Referenced by Types.EventID::cppID(), and Types.LuminosityBlockID::cppID().

{}

Member Data Documentation

std::string DQMSummaryReader::m_connectionString

private

Definition at line 19 of file DQMSummaryReader.h.

Referenced by readData().

std::string DQMSummaryReader::m_pass

private

Definition at line 21 of file DQMSummaryReader.h.

Referenced by readData().

std::string DQMSummaryReader::m_tableToRead

private

Definition at line 17 of file DQMSummaryReader.h.

Referenced by DQMSummaryReader(), and readData().

std::string DQMSummaryReader::m_user

private

Definition at line 20 of file DQMSummaryReader.h.

Referenced by readData().