l1t::WriterProxyT< Record, Type > Class Template Reference

#include <WriterProxy.h>

Inheritance diagram for l1t::WriterProxyT< Record, Type >:

Public Member Functions
virtual std::string	save (const edm::EventSetup &setup) const
virtual	~WriterProxyT ()
Public Member Functions inherited from l1t::WriterProxy
virtual	~WriterProxy ()

Detailed Description

template<class Record, class Type>
class l1t::WriterProxyT< Record, Type >

Definition at line 46 of file WriterProxy.h.

Constructor & Destructor Documentation

template<class Record , class Type >

virtual l1t::WriterProxyT< Record, Type >::~WriterProxyT ( )

inlinevirtual

Definition at line 49 of file WriterProxy.h.

{}

Member Function Documentation

template<class Record , class Type >

virtual std::string l1t::WriterProxyT< Record, Type >::save ( const edm::EventSetup &  setup ) const

inlinevirtual

tr.start(false);

tr.commit();

Implements l1t::WriterProxy.

Definition at line 52 of file WriterProxy.h.

References cond::service::PoolDBOutputService::forceInit(), edm::EventSetup::get(), patZpeak::handle, edm::Service< T >::isAvailable(), edm::ESHandle< class >::product(), cond::service::PoolDBOutputService::session(), dataDML::session, cond::persistency::Session::storePayload(), AlCaHLTBitMon_QueryRunRegistry::string, and cond::persistency::Session::transaction().

Referenced by Vispa.Main.TabController.TabController::allowClose(), Vispa.Main.TabController.TabController::checkModificationTimestamp(), and SpecificationBuilder_cfi.Specification::saveAll().

        {
            // load record and type from EventSetup and save them in db
            edm::ESHandle<Type> handle;

        try
          {
        setup.get<Record> ().get (handle);
          }
        catch( l1t::DataAlreadyPresentException& ex )
          {
        return std::string() ;
          }

        // If handle is invalid, then data is already in DB
       
        edm::Service<cond::service::PoolDBOutputService> poolDb;
        if (!poolDb.isAvailable())
          {
        throw cond::Exception( "DataWriter: PoolDBOutputService not available."
                       ) ;
          }
            poolDb->forceInit();  
        cond::persistency::Session session = poolDb->session();
        cond::persistency::TransactionScope tr(session.transaction());
        // if throw transaction will unroll

            std::shared_ptr<Type> pointer = std::make_shared<Type>(*(handle.product ()));
        std::string payloadToken =  session.storePayload( *pointer );
            tr.close();
        return payloadToken ;
        }