#include <RunInfoSchema.h>

Inheritance diagram for cond::persistency::RUN_INFO::Table:

Public Member Functions
void	create () override

bool	exists () override

bool	getInclusiveRunRange (cond::Time_t lower, cond::Time_t upper, std::vector< std::tuple< cond::Time_t, boost::posix_time::ptime, boost::posix_time::ptime > > &runData) override

bool	getInclusiveTimeRange (const boost::posix_time::ptime &lower, const boost::posix_time::ptime &upper, std::vector< std::tuple< cond::Time_t, boost::posix_time::ptime, boost::posix_time::ptime > > &runData) override

cond::Time_t	getLastInserted () override

void	insert (const std::vector< std::tuple< cond::Time_t, boost::posix_time::ptime, boost::posix_time::ptime > > &runs) override

void	insertOne (cond::Time_t runNumber, const boost::posix_time::ptime &start, const boost::posix_time::ptime &end) override

bool	select (cond::Time_t runNumber, boost::posix_time::ptime &start, boost::posix_time::ptime &end) override

	Table (coral::ISchema &schema)

void	updateEnd (cond::Time_t runNumber, const boost::posix_time::ptime &end) override

	~Table () override

Public Member Functions inherited from cond::persistency::IRunInfoTable
virtual	~IRunInfoTable ()

Private Attributes
coral::ISchema &	m_schema

Detailed Description

Definition at line 46 of file RunInfoSchema.h.

Constructor & Destructor Documentation

Table::Table ( coral::ISchema & schema )

explicit

Definition at line 10 of file RunInfoSchema.cc.

References m_schema, and cond::persistency::RUN_INFO::tname.

                                               :
       m_schema( schema ){
     }

cond::persistency::RUN_INFO::Table::~Table ( )

inlineoverride

Definition at line 49 of file RunInfoSchema.h.

References beamerCreator::create(), end, edm::eventsetup::heterocontainer::insert(), convertSQLiteXML::runNumber, writedatasetfile::runs, TauGenJetsDecayModeSelectorAllHadrons_cfi::select, and pileupCalc::upper.

49 {}

Member Function Documentation

void Table::create ( )

overridevirtual

Implements cond::persistency::IRunInfoTable.

Definition at line 18 of file RunInfoSchema.cc.

References exists(), cond::persistency::TableDescription< Types >::get(), m_schema, cond::persistency::TableDescription< Types >::setPrimaryKey(), cond::persistency::throwException(), and cond::persistency::RUN_INFO::tname.

Referenced by cond::persistency::RunInfoSchema::create(), and o2olib.O2OTool::execute().

                               {
       if( exists() ){
     throwException( "RUN_INFO table already exists in this schema.",
             "RUN_INFO::Table::create");
       }
       TableDescription< RUN_NUMBER, START_TIME, END_TIME > descr( tname );
       descr.setPrimaryKey<RUN_NUMBER>();
       createTable( m_schema, descr.get() );
     }

bool cond::persistency::RUN_INFO::Table::exists ( )

overridevirtual

Implements cond::persistency::IRunInfoTable.

Referenced by create(), and cond::persistency::RunInfoSchema::exists().

bool Table::getInclusiveRunRange	(	cond::Time_t	lower,
		cond::Time_t	upper,
		std::vector< std::tuple< cond::Time_t, boost::posix_time::ptime, boost::posix_time::ptime > > &	runData
	)

overridevirtual

Implements cond::persistency::IRunInfoTable.

Definition at line 54 of file RunInfoSchema.cc.

References cond::persistency::Query< Types >::addCondition(), m_schema, q1, alignCSCRings::r, and pileupCalc::upper.

                                                                                                              {
       // first find the lowest existing run >= upper
       Query< MIN_RUN_NUMBER > q0(m_schema);
       q0.addCondition< RUN_NUMBER >( upper,">=" );
       for( auto r: q0 ) upper = std::get<0>(r);
       // then find the inclusive range
       Query< RUN_NUMBER, START_TIME, END_TIME > q1(m_schema);
       q1.addCondition< RUN_NUMBER >( lower, ">=").addCondition< RUN_NUMBER >( upper, "<=");
       size_t prevSize = runData.size();
       for( auto r: q1 ){
     runData.push_back( r );
       }
       return runData.size()>prevSize;    
     }

bool Table::getInclusiveTimeRange	(	const boost::posix_time::ptime &	lower,
		const boost::posix_time::ptime &	upper,
		std::vector< std::tuple< cond::Time_t, boost::posix_time::ptime, boost::posix_time::ptime > > &	runData
	)

overridevirtual

Implements cond::persistency::IRunInfoTable.

Definition at line 70 of file RunInfoSchema.cc.

References cond::persistency::Query< Types >::addCondition(), m_schema, q1, alignCSCRings::r, up, and pileupCalc::upper.

                                                                                                               {
       boost::posix_time::ptime up = upper;
       // first find the lowest existing run >= upper
       Query< MIN_START_TIME > q0(m_schema);
       q0.addCondition< START_TIME >( upper,">=" );
       for( auto r: q0 ) up = std::get<0>(r);
       // then find the inclusive range
       Query< RUN_NUMBER, START_TIME, END_TIME> q1(m_schema);
       q1.addCondition< END_TIME >( lower, ">=").addCondition< START_TIME >( up, "<=");
       size_t prevSize = runData.size();
       for( auto r: q1 ){
     runData.push_back( r );
       }
       return runData.size()>prevSize;    
     }

cond::Time_t Table::getLastInserted ( )

overridevirtual

Implements cond::persistency::IRunInfoTable.

Definition at line 39 of file RunInfoSchema.cc.

References MillePedeFileConverter_cfg::e, m_schema, cond::time::MIN_VAL(), alignCSCRings::r, writedatasetfile::run, and AlCaHLTBitMon_QueryRunRegistry::string.

                                              {
       cond::Time_t run = cond::time::MIN_VAL;
       Query< MAX_RUN_NUMBER > q0(m_schema);
       try{
     for( auto r: q0 ) {
       run = std::get<0>(r);
     }
     // cope with mis-beahviour in the sqlite plugin: no result for MAX() returns NULL
       } catch ( const coral::AttributeException& e ){
     std::string message(e.what());
         if(  message.find( "Attempt to access data of NULL attribute" ) != 0 ) throw;
       }
       return run;
     }

void Table::insert ( const std::vector< std::tuple< cond::Time_t, boost::posix_time::ptime, boost::posix_time::ptime > > & runs )

overridevirtual

Implements cond::persistency::IRunInfoTable.

Definition at line 92 of file RunInfoSchema.cc.

References cond::persistency::BulkInserter< Types >::flush(), cond::persistency::BulkInserter< Types >::insert(), m_schema, writedatasetfile::run, writedatasetfile::runs, and cond::persistency::RUN_INFO::tname.

Referenced by BeautifulSoup.PageElement::append().

                                                                                                                       {
       BulkInserter< RUN_NUMBER, START_TIME, END_TIME > inserter( m_schema, tname );
       for( auto run : runs ) inserter.insert( run );
       inserter.flush();
     }

void Table::insertOne	(	cond::Time_t	runNumber,
		const boost::posix_time::ptime &	start,
		const boost::posix_time::ptime &	end
	)

overridevirtual

Implements cond::persistency::IRunInfoTable.

Definition at line 87 of file RunInfoSchema.cc.

References cond::persistency::RowBuffer< Columns >::get(), m_schema, and cond::persistency::RUN_INFO::tname.

                                                                                                                           {
       RowBuffer< RUN_NUMBER, START_TIME, END_TIME > dataToInsert( std::tie(runNumber, start, end ) );
       insertInTable( m_schema, tname, dataToInsert.get() );
     }

bool Table::select	(	cond::Time_t	runNumber,
		boost::posix_time::ptime &	start,
		boost::posix_time::ptime &	end
	)

overridevirtual

Implements cond::persistency::IRunInfoTable.

Definition at line 28 of file RunInfoSchema.cc.

References cond::persistency::Query< Types >::addCondition(), m_schema, lumiQueryAPI::q, alignCSCRings::r, and convertSQLiteXML::runNumber.

Referenced by Vispa.Views.LineDecayView.LineDecayContainer::createObject(), Vispa.Plugins.Browser.BrowserTabController.BrowserTabController::find(), Vispa.Views.LineDecayView.LineDecayContainer::mousePressEvent(), Vispa.Gui.PortConnection.PointToPointConnection::mousePressEvent(), Vispa.Gui.VispaWidget.VispaWidget::mousePressEvent(), and Vispa.Views.AbstractView.AbstractView::restoreSelection().

                                                                                                             {
       Query< START_TIME, END_TIME > q(m_schema);
       q.addCondition< RUN_NUMBER >( runNumber );
       bool ret = false;
       for( auto r: q){
     ret = true;
         std::tie( start, end ) = r;
       }
       return ret;
     }

void Table::updateEnd	(	cond::Time_t	runNumber,
		const boost::posix_time::ptime &	end
	)

overridevirtual

Implements cond::persistency::IRunInfoTable.

Definition at line 98 of file RunInfoSchema.cc.

References cond::persistency::UpdateBuffer::addWhereCondition(), edmScanValgrind::buffer, m_schema, convertSQLiteXML::runNumber, cond::persistency::UpdateBuffer::setColumnData(), and cond::persistency::RUN_INFO::tname.

                                                                                         {
       UpdateBuffer buffer;
       buffer.setColumnData< END_TIME >( std::tie( end ) );
       buffer.addWhereCondition<RUN_NUMBER>( runNumber );
       updateTable( m_schema, tname, buffer );
     }

Member Data Documentation

coral::ISchema& cond::persistency::RUN_INFO::Table::m_schema

private

Definition at line 63 of file RunInfoSchema.h.

Referenced by create(), getInclusiveRunRange(), getInclusiveTimeRange(), getLastInserted(), insert(), insertOne(), select(), Table(), and updateEnd().

Public Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation