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_
std::string	m_authPath
std::string	m_connectionString
std::map< std::string, unsigned int >	m_id_map
cond::persistency::Session	m_session
std::unique_ptr< cond::persistency::TransactionScope >	m_transaction

Detailed Description

An interface class to the PVSS cond DB.

Author

J.Chen, J.Cole

Definition at line 17 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 gather_cfg::cout, and initialize().

    : m_connectionString(connectionString), m_authPath(authenticationPath), m_session(), debug_(debug) {
  std::cout << "Building coral interface" << std::endl;
  initialize();
}

SiStripCoralIface::~SiStripCoralIface

(

)

destructor

Definition at line 28 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 179 of file SiStripCoralIface.cc.

References goodZToMuMu_cfi::condition, cond::persistency::Session::coralSession(), m_session, contentValuesFiles::query, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                                   {
  std::unique_ptr<coral::IQuery> query(
      m_session.coralSession().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();
  edm::LogInfo("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 50 of file SiStripCoralIface.cc.

References goodZToMuMu_cfi::condition, cond::persistency::Session::coralSession(), gather_cfg::cout, debug_, dqmMemoryStats::float, LogTrace, m_session, contentValuesFiles::query, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                  {
  std::unique_ptr<coral::IQuery> query(
      m_session.coralSession().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;
  edm::LogInfo("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 131 of file SiStripCoralIface.cc.

References goodZToMuMu_cfi::condition, cond::persistency::Session::coralSession(), gather_cfg::cout, debug_, dqmMemoryStats::float, m_session, contentValuesFiles::query, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                       {
  std::unique_ptr<coral::IQuery> query(
      m_session.coralSession().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();
  edm::LogInfo("SiStripCoralIface") << "[SiStripCoralIface::" << __func__ << "] " << numberRow
                                    << " rows retrieved from PVSS Cond DB";
}

void SiStripCoralIface::initialize ( )

private

Set up the connection to the database

Definition at line 34 of file SiStripCoralIface.cc.

References cond::persistency::ConnectionPool::configure(), cond::persistency::ConnectionPool::createSession(), beamvalidation::exit(), LogTrace, m_authPath, m_connectionString, m_session, m_transaction, cond::persistency::ConnectionPool::setAuthenticationPath(), and cond::persistency::Session::transaction().

Referenced by SiStripCoralIface().

                                   {
  cond::persistency::ConnectionPool connection;
  connection.setAuthenticationPath(m_authPath);
  connection.configure();
  m_session = connection.createSession(m_connectionString);
  try {
    m_transaction.reset(new cond::persistency::TransactionScope(m_session.transaction()));
    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 53 of file SiStripCoralIface.h.

Referenced by doQuery(), and doSettingsQuery().

std::string SiStripCoralIface::m_authPath

private

Definition at line 46 of file SiStripCoralIface.h.

Referenced by initialize().

std::string SiStripCoralIface::m_connectionString

private

Definition at line 45 of file SiStripCoralIface.h.

Referenced by initialize().

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

private

Definition at line 47 of file SiStripCoralIface.h.

cond::persistency::Session SiStripCoralIface::m_session

private

Definition at line 48 of file SiStripCoralIface.h.

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

std::unique_ptr<cond::persistency::TransactionScope> SiStripCoralIface::m_transaction

private

Definition at line 49 of file SiStripCoralIface.h.

Referenced by initialize().