SiStripPayloadMapTableCreator.cc

Go to the documentation of this file.

// system includes
#include <iostream>

// user includes
#include "CondCore/CondDB/interface/ConnectionPool.h"
#include "CoralBase/Attribute.h"
#include "CoralBase/AttributeList.h"
#include "CoralBase/TimeStamp.h"
#include "FWCore/Framework/interface/one/EDAnalyzer.h"
#include "FWCore/Framework/interface/Event.h"
#include "FWCore/Framework/interface/MakerMacros.h"
#include "FWCore/ParameterSet/interface/ParameterSet.h"
#include "FWCore/ServiceRegistry/interface/Service.h"
#include "RelationalAccess/ISchema.h"
#include "RelationalAccess/ISessionProxy.h"
#include "RelationalAccess/ITable.h"
#include "RelationalAccess/ITransaction.h"
#include "RelationalAccess/TableDescription.h"

class SiStripPayloadMapTableCreator : public edm::one::EDAnalyzer<> {
public:
  explicit SiStripPayloadMapTableCreator(const edm::ParameterSet& iConfig);
  ~SiStripPayloadMapTableCreator() override = default;
  void analyze(const edm::Event& evt, const edm::EventSetup& evtSetup) override;

private:
  cond::persistency::ConnectionPool m_connectionPool;
  std::string m_configMapDb;
};

SiStripPayloadMapTableCreator::SiStripPayloadMapTableCreator(const edm::ParameterSet& iConfig)
    : m_connectionPool(), m_configMapDb(iConfig.getParameter<std::string>("configMapDatabase")) {
  m_connectionPool.setParameters(iConfig.getParameter<edm::ParameterSet>("DBParameters"));
  m_connectionPool.configure();
}

void SiStripPayloadMapTableCreator::analyze(const edm::Event& evt, const edm::EventSetup& evtSetup) {
  std::shared_ptr<coral::ISessionProxy> cmDbSession = m_connectionPool.createCoralSession(m_configMapDb, true);
  coral::TableDescription mapTable;
  mapTable.setName("STRIP_CONFIG_TO_PAYLOAD_MAP");
  mapTable.insertColumn("CONFIG_HASH", coral::AttributeSpecification::typeNameForType<std::string>());
  mapTable.insertColumn("PAYLOAD_HASH", coral::AttributeSpecification::typeNameForType<std::string>());
  mapTable.insertColumn("PAYLOAD_TYPE", coral::AttributeSpecification::typeNameForType<std::string>());
  mapTable.insertColumn("CONFIG_STRING", coral::AttributeSpecification::typeNameForType<std::string>());
  mapTable.insertColumn("INSERTION_TIME", coral::AttributeSpecification::typeNameForType<coral::TimeStamp>());
  mapTable.setPrimaryKey("CONFIG_HASH");
  mapTable.setNotNullConstraint("CONFIG_HASH");
  mapTable.setNotNullConstraint("PAYLOAD_HASH");
  mapTable.setNotNullConstraint("PAYLOAD_TYPE");
  mapTable.setNotNullConstraint("CONFIG_STRING");
  mapTable.setNotNullConstraint("INSERTION_TIME");

  cmDbSession->transaction().start(false);
  cmDbSession->nominalSchema().createTable(mapTable);
  cmDbSession->transaction().commit();
}

// ------
DEFINE_FWK_MODULE(SiStripPayloadMapTableCreator);