cond::persistency::RunInfoEditor Class Reference

#include <RunInfoEditor.h>

Public Member Functions
size_t	flush ()
cond::Time_t	getLastInserted ()
void	init ()
void	insert (cond::Time_t runNumber, const boost::posix_time::ptime &start, const boost::posix_time::ptime &end)
void	insertNew (cond::Time_t runNumber, const boost::posix_time::ptime &start, const boost::posix_time::ptime &end)
RunInfoEditor &	operator= (const RunInfoEditor &rhs)
	RunInfoEditor ()
	RunInfoEditor (const std::shared_ptr< SessionImpl > &session)
	RunInfoEditor (const RunInfoEditor &rhs)

Private Member Functions
void	checkTransaction (const std::string &ctx)

Private Attributes
std::shared_ptr< RunInfoEditorData >	m_data
std::shared_ptr< SessionImpl >	m_session

Detailed Description

Definition at line 28 of file RunInfoEditor.h.

Constructor & Destructor Documentation

RunInfoEditor::RunInfoEditor

(

)

Definition at line 22 of file RunInfoEditor.cc.

                                :
      m_data(),
      m_session(){
    }

RunInfoEditor::RunInfoEditor ( const std::shared_ptr< SessionImpl > &  session )

explicit

Definition at line 27 of file RunInfoEditor.cc.

                                                                           :
      m_data( new RunInfoEditorData ),
      m_session( session ){
      
    }

RunInfoEditor::RunInfoEditor

(

const RunInfoEditor &

rhs

)

Definition at line 33 of file RunInfoEditor.cc.

                                                          :
      m_data( rhs.m_data ),
      m_session( rhs.m_session ){
    }

Member Function Documentation

void RunInfoEditor::checkTransaction ( const std::string &  ctx )

private

Definition at line 107 of file RunInfoEditor.cc.

References m_session, and cond::persistency::throwException().

Referenced by flush(), getLastInserted(), and init().

                                                              {
      if( !m_session.get() ) throwException("The session is not active.",ctx );
      if( !m_session->isTransactionActive( false ) ) throwException("The transaction is not active.",ctx );
    }

size_t RunInfoEditor::flush

(

)

Definition at line 67 of file RunInfoEditor.cc.

References checkTransaction(), m_data, m_session, mps_check::msg, cond::persistency::throwException(), and update.

Referenced by RunInfoUpdate::appendNewRun(), and RunInfoUpdate::import().

                               {
      size_t ret = 0;
      if( m_data.get() ){
    checkTransaction( "RunInfoEditor::flush" );
    m_session->runInfoSchema().runInfoTable().insert( m_data->runBuffer );
        ret += m_data->runBuffer.size();
        for( auto update: m_data->updateBuffer ) {
      cond::Time_t newRun = std::get<0>(update);
      boost::posix_time::ptime& newRunStart = std::get<1>(update);
      boost::posix_time::ptime& newRunEnd = std::get<2>(update);
          boost::posix_time::ptime existingRunStart;
          boost::posix_time::ptime existingRunEnd;
          if( m_session->runInfoSchema().runInfoTable().select( newRun, existingRunStart, existingRunEnd ) ){
        if( newRunStart!=existingRunStart ) {
          std::stringstream msg;
              msg<< "Attempt to update start time of existing run "<< newRun;
          throwException(msg.str(),"RunInfoEditor::flush");
        }
            if( existingRunEnd == newRunEnd ){
          // nothing to do
          continue;
        } else {
          if( existingRunEnd!=existingRunStart ){
        std::stringstream msg;
        msg<< "Attempt to update end time of existing run "<< newRun;
        throwException(msg.str(),"RunInfoEditor::flush");
          }
        }
            m_session->runInfoSchema().runInfoTable().updateEnd( newRun, newRunEnd );
      } else {
            m_session->runInfoSchema().runInfoTable().insertOne( newRun, newRunStart, newRunEnd );
      }
          ret++;
    }
        m_data->runBuffer.clear();
        m_data->updateBuffer.clear();
      }
      return ret;
    }

cond::Time_t RunInfoEditor::getLastInserted

(

)

Definition at line 51 of file RunInfoEditor.cc.

References checkTransaction(), m_data, m_session, and cond::time::MIN_VAL().

Referenced by RunInfoUpdate::import().

                                             {
      if( m_data.get() ){
    checkTransaction( "RunInfoEditor::getLastInserted" );
    return m_session->runInfoSchema().runInfoTable().getLastInserted();
      }
      return cond::time::MIN_VAL;
    }

void RunInfoEditor::init

(

void

)

Definition at line 44 of file RunInfoEditor.cc.

References checkTransaction(), m_data, and m_session.

Referenced by cond::persistency::Session::editRunInfo().

                             {
      if( m_data.get() ){
    checkTransaction( "RunInfoEditor::init" );
    if( !m_session->runInfoSchema().exists() ) m_session->runInfoSchema().create();
      }
    }

void RunInfoEditor::insert	(	cond::Time_t	runNumber,
		const boost::posix_time::ptime &	start,
		const boost::posix_time::ptime &	end
	)

Definition at line 59 of file RunInfoEditor.cc.

References m_data.

Referenced by BeautifulSoup.PageElement::append(), and RunInfoUpdate::import().

                                                                                                                        {
      if( m_data.get() ) m_data->runBuffer.push_back( std::tie( runNumber, start, end ) );
    }

void RunInfoEditor::insertNew	(	cond::Time_t	runNumber,
		const boost::posix_time::ptime &	start,
		const boost::posix_time::ptime &	end
	)

Definition at line 63 of file RunInfoEditor.cc.

References m_data.

Referenced by RunInfoUpdate::appendNewRun().

                                                                                                                          {
      if( m_data.get() ) m_data->updateBuffer.push_back( std::tie( runNumber, start, end ) );
    }

RunInfoEditor & RunInfoEditor::operator=

(

const RunInfoEditor &

rhs

)

Definition at line 38 of file RunInfoEditor.cc.

References m_data, and m_session.

                                                                     {
      m_data = rhs.m_data;
      m_session = rhs.m_session;
      return *this;
    }

Member Data Documentation

std::shared_ptr<RunInfoEditorData> cond::persistency::RunInfoEditor::m_data

private

Definition at line 60 of file RunInfoEditor.h.

Referenced by flush(), getLastInserted(), init(), insert(), insertNew(), and operator=().

std::shared_ptr<SessionImpl> cond::persistency::RunInfoEditor::m_session

private

Definition at line 61 of file RunInfoEditor.h.

Referenced by checkTransaction(), flush(), getLastInserted(), init(), and operator=().