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&);
  virtual void beginJob() override;
  virtual void analyze(const edm::Event&, const edm::EventSetup&) override {}
  virtual void endJob() override {}
  ~JetResolutionDBWriter() {}

 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);