SiStripCoralIface Class Reference

An interface class to the PVSS cond DB. More...

#include <SiStripCoralIface.h>

Public Member Functions
void	doNameQuery (std::vector< std::string > &vec_dpname, std::vector< uint32_t > &vec_dpid)
void	doQuery (std::string queryType, const coral::TimeStamp &startTime, const coral::TimeStamp &endTime, std::vector< coral::TimeStamp > &, std::vector< float > &, std::vector< std::string > &)
void	doSettingsQuery (const coral::TimeStamp &startTime, const coral::TimeStamp &endTime, std::vector< coral::TimeStamp > &, std::vector< float > &, std::vector< std::string > &, std::vector< uint32_t > &)
	SiStripCoralIface (std::string connectionString, std::string authenticationPath, const bool debug)
	~SiStripCoralIface ()

Private Member Functions
void	initialize ()

Private Attributes
bool	debug_
cond::DbConnection	m_connection
std::string	m_connectionString
std::map< std::string, unsigned int >	m_id_map
cond::DbSession	m_session
std::auto_ptr < cond::DbScopedTransaction >	m_transaction

Detailed Description

An interface class to the PVSS cond DB.

Author

J.Chen, J.Cole

Definition at line 20 of file SiStripCoralIface.h.

Constructor & Destructor Documentation

SiStripCoralIface::SiStripCoralIface	(	std::string	connectionString,
		std::string	authenticationPath,
		const bool	debug
	)

constructor

Definition at line 21 of file SiStripCoralIface.cc.

References cond::DbConnection::configuration(), cond::DbConnection::configure(), gather_cfg::cout, initialize(), m_connection, and cond::DbConnectionConfiguration::setAuthenticationPath().

                                                                                                                 : m_connectionString(connectionString), m_session(), debug_(debug)
{
  std::cout << "Building coral interface" << std::endl;
  m_connection.configuration().setAuthenticationPath(authenticationPath);
  m_connection.configure();
  initialize();
}

SiStripCoralIface::~SiStripCoralIface

(

)

destructor

Definition at line 30 of file SiStripCoralIface.cc.

References LogTrace.

                                      { 
  LogTrace("SiStripCoralIface") << "[SiStripCoralIface::" << __func__ << "] Destructor called."; 
  // m_connection.close();
}

Member Function Documentation

void SiStripCoralIface::doNameQuery	(	std::vector< std::string > &	vec_dpname,
		std::vector< uint32_t > &	vec_dpid
	)

Definition at line 158 of file SiStripCoralIface.cc.

References LogTrace, m_session, o2o::query, cond::DbSession::schema(), and AlCaHLTBitMon_QueryRunRegistry::string.

{
  std::auto_ptr<coral::IQuery> query( m_session.schema(std::string("CMS_TRK_DCS_PVSS_COND")).newQuery());
  query->addToOutputList("DP_NAME2ID.DPNAME","DPNAME");
  query->addToOutputList("DP_NAME2ID.ID","DPID");
  query->addToTableList("DP_NAME2ID");

  std::string condition = "DP_NAME2ID.dpname like '%easyBoard%' ";
  query->setCondition( condition, coral::AttributeList() );

  query->setMemoryCacheSize( 100 );
  coral::ICursor& cursor = query->execute();
  int numberRow=0;
  while( cursor.next() ){
    const coral::AttributeList& row = cursor.currentRow();
    numberRow++;
    uint32_t id = (uint32_t)row["DPID"].data<float>();
    vec_dpid.push_back(id);
    std::string id_name = (std::string)row["DPNAME"].data<std::string>();
    vec_dpname.push_back(id_name);
  }
  cursor.close();
  LogTrace("SiStripCoralIface") << "[SiStripCoralIface::" << __func__ << "] " << numberRow << " rows retrieved from PVSS Cond DB";
}

void SiStripCoralIface::doQuery	(	std::string	queryType,
		const coral::TimeStamp &	startTime,
		const coral::TimeStamp &	endTime,
		std::vector< coral::TimeStamp > &	vec_changedate,
		std::vector< float > &	vec_actualValue,
		std::vector< std::string > &	vec_dpname
	)

Method to retrieve information from status change table or lastValue table. queryType defines which table is to be accessed.

Definition at line 51 of file SiStripCoralIface.cc.

References gather_cfg::cout, debug_, LogTrace, m_session, o2o::query, builder_last_value_cfg::queryType, cond::DbSession::schema(), and AlCaHLTBitMon_QueryRunRegistry::string.

{
  std::auto_ptr<coral::IQuery> query( m_session.schema(std::string("CMS_TRK_DCS_PVSS_COND")).newQuery());
  std::string condition;

  LogTrace("SiStripCoralIface") << "[SiStripCoralIface::" << __func__ << "] table to be accessed: " << queryType;

  if (queryType == "STATUSCHANGE") {
    query->addToOutputList("FWCAENCHANNEL.CHANGE_DATE","CHANGE_DATE");
    query->addToOutputList("FWCAENCHANNEL.ACTUAL_STATUS","ACTUAL_STATUS");
    query->addToOutputList("DP_NAME2ID.DPNAME","DPNAME");
    query->addToOrderList("FWCAENCHANNEL.CHANGE_DATE");
    query->addToTableList("FWCAENCHANNEL");
    query->addToTableList("DP_NAME2ID");
    condition = "FWCAENCHANNEL.DPID = DP_NAME2ID.id AND FWCAENCHANNEL.CHANGE_DATE<=:tmax AND FWCAENCHANNEL.ACTUAL_STATUS IS NOT NULL AND FWCAENCHANNEL.CHANGE_DATE >=:tmin AND (DP_NAME2ID.dpname like '%easyBoard%')";
  } else if (queryType == "LASTVALUE") {
    query->addToOutputList("DCSLASTVALUE_VOLTAGE.CHANGE_DATE","CHANGE_DATE");
    query->addToOutputList("DCSLASTVALUE_VOLTAGE.ACTUAL_VMON","ACTUAL_VMON");
    query->addToOutputList("DP_NAME2ID.DPNAME","DPNAME");
    query->addToOrderList("DCSLASTVALUE_VOLTAGE.CHANGE_DATE");
    query->addToTableList("DCSLASTVALUE_VOLTAGE");
    query->addToTableList("DP_NAME2ID");
    condition = "DCSLASTVALUE_VOLTAGE.DPID = DP_NAME2ID.id AND DCSLASTVALUE_VOLTAGE.CHANGE_DATE<=:tmax AND DCSLASTVALUE_VOLTAGE.CHANGE_DATE>=:tmin AND DCSLASTVALUE_VOLTAGE.ACTUAL_VMON IS NOT NULL AND (DP_NAME2ID.dpname like '%easyBoard%')";
  }

  coral::AttributeList conditionData;
  conditionData.extend<coral::TimeStamp>( "tmax" );
  conditionData.extend<coral::TimeStamp>( "tmin" );
  query->setCondition( condition, conditionData );
  conditionData[0].data<coral::TimeStamp>() = endTime;
  conditionData[1].data<coral::TimeStamp>() = startTime;

  query->setMemoryCacheSize( 100 );
  std::cout<<"Executing query"<<std::endl;
  if (debug_) std::cout<<"[SiStripCoralIface::"<<__func__<<"] Dumping all query results:"<<std::endl;
  coral::ICursor& cursor = query->execute();
  int numberRow=0;
  while( cursor.next() ){
    const coral::AttributeList& row = cursor.currentRow();
    //DEBUG
    //Output the query results directly to cout,
    //Can be subsequently parsed by Python validation code
    if( debug_ ) row.toOutputStream( std::cout ) << std::endl;
    numberRow++;
    if (queryType == "STATUSCHANGE") {
      coral::TimeStamp ts =  row["CHANGE_DATE"].data<coral::TimeStamp>();
      vec_changedate.push_back(ts);
      float as = (float)row["ACTUAL_STATUS"].data<float>();
      vec_actualValue.push_back(as);
      std::string id_name = (std::string)row["DPNAME"].data<std::string>();
      vec_dpname.push_back(id_name);
    } else if (queryType == "LASTVALUE") {
      coral::TimeStamp ts =  row["CHANGE_DATE"].data<coral::TimeStamp>();
      vec_changedate.push_back(ts);
      float av = (float)row["ACTUAL_VMON"].data<float>();
      vec_actualValue.push_back(av);
      std::string id_name = (std::string)row["DPNAME"].data<std::string>();
      vec_dpname.push_back(id_name);
    }
  }
  cursor.close();
  if (debug_) std::cout<<"[SiStripCoralIface::"<<__func__<<"] Finished dumping query results, "<< numberRow<<" rows were retrieved from PVSS Cond DB (both Pixel and Strip CAEN supplies)"<<std::endl;
  LogTrace("SiStripCoralIface") << "[SiStripCoralIface::" << __func__ << "] " << numberRow << " rows retrieved from PVSS Cond DB";
}

void SiStripCoralIface::doSettingsQuery	(	const coral::TimeStamp &	startTime,
		const coral::TimeStamp &	endTime,
		std::vector< coral::TimeStamp > &	vec_changedate,
		std::vector< float > &	vec_settings,
		std::vector< std::string > &	vec_dpname,
		std::vector< uint32_t > &	vec_dpid
	)

Method to access the settings for each channel stored in the status change table

Definition at line 118 of file SiStripCoralIface.cc.

References gather_cfg::cout, debug_, LogTrace, m_session, o2o::query, cond::DbSession::schema(), and AlCaHLTBitMon_QueryRunRegistry::string.

{
  std::auto_ptr<coral::IQuery> query( m_session.schema(std::string("CMS_TRK_DCS_PVSS_COND")).newQuery());
  query->addToOutputList("FWCAENCHANNEL.CHANGE_DATE","CHANGE_DATE");
  query->addToOutputList("FWCAENCHANNEL.SETTINGS_V0","VSET");
  query->addToOutputList("FWCAENCHANNEL.DPID","DPID");
  query->addToOutputList("DP_NAME2ID.DPNAME","DPNAME");
  query->addToOrderList("FWCAENCHANNEL.CHANGE_DATE");
  query->addToTableList("FWCAENCHANNEL");
  query->addToTableList("DP_NAME2ID");
  std::string condition = "FWCAENCHANNEL.DPID = DP_NAME2ID.id AND FWCAENCHANNEL.CHANGE_DATE<=:tmax AND FWCAENCHANNEL.SETTINGS_V0 IS NOT NULL AND FWCAENCHANNEL.CHANGE_DATE >=:tmin AND (DP_NAME2ID.dpname like '%easyBoard%')";

  coral::AttributeList conditionData;
  conditionData.extend<coral::TimeStamp>( "tmax" );
  conditionData.extend<coral::TimeStamp>( "tmin" );
  query->setCondition( condition, conditionData );
  conditionData[0].data<coral::TimeStamp>() = endTime;
  conditionData[1].data<coral::TimeStamp>() = startTime;

  query->setMemoryCacheSize( 100 );
  coral::ICursor& cursor = query->execute();
  int numberRow=0;
  while( cursor.next() ){
    const coral::AttributeList& row = cursor.currentRow();
    if( debug_ ) row.toOutputStream( std::cout ) << std::endl;
    numberRow++;
    coral::TimeStamp ts =  row["CHANGE_DATE"].data<coral::TimeStamp>();
    vec_changedate.push_back(ts);
    float vs = (float)row["VSET"].data<float>();
    vec_settings.push_back(vs);
    uint32_t id = (uint32_t)row["DPID"].data<float>();
    vec_dpid.push_back(id);
    std::string id_name = (std::string)row["DPNAME"].data<std::string>();
    vec_dpname.push_back(id_name);
  }
  cursor.close();
  LogTrace("SiStripCoralIface") << "[SiStripCoralIface::" << __func__ << "] " << numberRow << " rows retrieved from PVSS Cond DB";
}

void SiStripCoralIface::initialize ( )

private

Set up the connection to the database

Definition at line 36 of file SiStripCoralIface.cc.

References cond::DbConnection::createSession(), cmsRelvalreport::exit, LogTrace, m_connection, m_connectionString, m_session, m_transaction, and cond::DbSession::open().

Referenced by SiStripCoralIface().

                                    {
  m_session = m_connection.createSession();
  m_session.open(m_connectionString);
  try {
    m_transaction.reset( new cond::DbScopedTransaction(m_session) );
    m_transaction->start(true);
    LogTrace("SiStripCoralIface") << "[SiStripCoralIface::" << __func__ << "] Database connection opened"; 
  }
  catch (...) {
    edm::LogError("SiStripCoralIface") << "Database connection failed";     
    exit(1);
  }
}

Member Data Documentation

bool SiStripCoralIface::debug_

private

Definition at line 47 of file SiStripCoralIface.h.

Referenced by doQuery(), and doSettingsQuery().

cond::DbConnection SiStripCoralIface::m_connection

private

Definition at line 41 of file SiStripCoralIface.h.

Referenced by initialize(), and SiStripCoralIface().

std::string SiStripCoralIface::m_connectionString

private

Definition at line 38 of file SiStripCoralIface.h.

Referenced by initialize().

std::map<std::string,unsigned int> SiStripCoralIface::m_id_map

private

Definition at line 39 of file SiStripCoralIface.h.

cond::DbSession SiStripCoralIface::m_session

private

Definition at line 42 of file SiStripCoralIface.h.

Referenced by doNameQuery(), doQuery(), doSettingsQuery(), and initialize().

std::auto_ptr<cond::DbScopedTransaction> SiStripCoralIface::m_transaction

private

Definition at line 45 of file SiStripCoralIface.h.

Referenced by initialize().