DummyCondDBWriter.h

Go to the documentation of this file.

#ifndef CalibTracker_SiStripESProducer_DummyCondDBWriter_h
#define CalibTracker_SiStripESProducer_DummyCondDBWriter_h

// user include files
#include "FWCore/Framework/interface/EDAnalyzer.h"
#include "FWCore/Framework/interface/ESHandle.h"
#include "FWCore/Framework/interface/Run.h"
#include "FWCore/ParameterSet/interface/ParameterSet.h"
#include "FWCore/MessageLogger/interface/MessageLogger.h"
#include "FWCore/ServiceRegistry/interface/Service.h"
#include "CondCore/DBOutputService/interface/PoolDBOutputService.h"
#include "CondCore/DBCommon/interface/Time.h"

#include "FWCore/Utilities/interface/Exception.h"

#include <string>



template< typename TObject , typename TObjectO , typename TRecord>
class DummyCondDBWriter : public edm::EDAnalyzer {

public:

  explicit DummyCondDBWriter(const edm::ParameterSet& iConfig);
  ~DummyCondDBWriter();
  void analyze(const edm::Event& e, const edm::EventSetup&es){};

  void endRun(const edm::Run & run, const edm::EventSetup & es);

 private:
  edm::ParameterSet iConfig_;
  unsigned long long cacheID;
};

template< typename TObject , typename TObjectO ,typename TRecord>
DummyCondDBWriter<TObject,TObjectO,TRecord>::DummyCondDBWriter(const edm::ParameterSet& iConfig):iConfig_(iConfig),cacheID(0){
  edm::LogInfo("DummyCondDBWriter") << "DummyCondDBWriter constructor for typename " << typeid(TObject).name() << " and record " << typeid(TRecord).name() << std::endl;
}


template< typename TObject , typename TObjectO ,typename TRecord >
DummyCondDBWriter<TObject,TObjectO,TRecord>::~DummyCondDBWriter(){
 edm::LogInfo("DummyCondDBWriter") << "DummyCondDBWriter::~DummyCondDBWriter()" << std::endl;
}

template< typename TObject , typename TObjectO ,typename TRecord >
void DummyCondDBWriter<TObject,TObjectO,TRecord>::endRun(const edm::Run & run, const edm::EventSetup & es){

  std::string rcdName=iConfig_.getParameter<std::string>("record");

  if( cacheID == es.get<TRecord>().cacheIdentifier()){
      edm::LogInfo("DummyCondDBWriter") << "not needed to store objects with Record "<< rcdName << " at run " << run.run() << std::endl;    return;
  }
  cacheID = es.get<TRecord>().cacheIdentifier();

  edm::ESHandle<TObject> esobj;
  es.get<TRecord>().get( esobj );
  TObjectO *obj= new TObjectO(*(esobj.product()));
  cond::Time_t Time_;  
  
  //And now write  data in DB
  edm::Service<cond::service::PoolDBOutputService> dbservice;
  if( dbservice.isAvailable() ){

    std::string openIovAt=iConfig_.getUntrackedParameter<std::string>("OpenIovAt","beginOfTime");
    if(openIovAt=="beginOfTime")
      Time_=dbservice->beginOfTime();
    else if (openIovAt=="currentTime")
      Time_=dbservice->currentTime();
    else
      Time_=iConfig_.getUntrackedParameter<uint32_t>("OpenIovAtTime",1);
    
    dbservice->writeOne(obj, Time_, rcdName);
  } else{
    edm::LogError("SiStripFedCablingBuilder")<<"Service is unavailable"<<std::endl;
  }
}

#endif