JetResolutionDBWriter.cc

Go to the documentation of this file.

// Author: Sébastien Brochet
 
#include <memory>
#include <string>
#include <fstream>
#include <iostream>
#include "FWCore/Framework/interface/Frameworkfwd.h"
#include "FWCore/Framework/interface/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 "FWCore/Utilities/interface/EDMException.h"
#include "CondCore/DBOutputService/interface/PoolDBOutputService.h"
#include "CondFormats/JetMETObjects/interface/JetResolutionObject.h"
 
class JetResolutionDBWriter : public edm::EDAnalyzer {
public:
  JetResolutionDBWriter(const edm::ParameterSet&);
  void beginJob() override;
  void analyze(const edm::Event&, const edm::EventSetup&) override {}
  void endJob() override {}
  ~JetResolutionDBWriter() override {}
 
private:
  std::string m_record;
  std::string m_path;
};
 
// Constructor
JetResolutionDBWriter::JetResolutionDBWriter(const edm::ParameterSet& pSet) {
  m_record = pSet.getUntrackedParameter<std::string>("record");
  m_path = pSet.getUntrackedParameter<edm::FileInPath>("file").fullPath();
}
 
// Begin Job
void JetResolutionDBWriter::beginJob() {
  std::cout << "Loading data from '" << m_path << "'" << std::endl;
 
  JME::JetResolutionObject* jerObject = new JME::JetResolutionObject(m_path);
 
  std::cout << "Opening PoolDBOutputService" << std::endl;
 
  // now write it into the DB
  edm::Service<cond::service::PoolDBOutputService> s;
  if (s.isAvailable()) {
    std::cout << "Setting up payload record " << m_record << std::endl;
    cond::Time_t sinceTime = s->isNewTagRequest(m_record) ? s->beginOfTime() : s->currentTime();
    s->writeOne<JME::JetResolutionObject>(jerObject, sinceTime, m_record);
 
    std::cout << "Object saved into the database with the record: " << m_record << std::endl;
  }
}
 
DEFINE_FWK_MODULE(JetResolutionDBWriter);