cond::persistency::PAYLOAD::Table Class Reference

#include <IOVSchema.h>

Inheritance diagram for cond::persistency::PAYLOAD::Table:

Public Member Functions
void	create () override
bool	exists () override
bool	getType (const cond::Hash &payloadHash, std::string &objectType) override
bool	insert (const cond::Hash &payloadHash, const std::string &objectType, const cond::Binary &payloadData, const cond::Binary &streamerInfoData, const boost::posix_time::ptime &insertionTime)
cond::Hash	insertIfNew (const std::string &objectType, const cond::Binary &payloadData, const cond::Binary &streamerInfoData, const boost::posix_time::ptime &insertionTime) override
bool	select (const cond::Hash &payloadHash)
bool	select (const cond::Hash &payloadHash, std::string &objectType, cond::Binary &payloadData, cond::Binary &streamerInfoData) override
	Table (coral::ISchema &schema)
	~Table () override
Public Member Functions inherited from cond::persistency::IPayloadTable
virtual	~IPayloadTable ()

Private Attributes
coral::ISchema &	m_schema

Detailed Description

Definition at line 59 of file IOVSchema.h.

Constructor & Destructor Documentation

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

explicit

Definition at line 296 of file IOVSchema.cc.

                                             :
      m_schema( schema ){
    }

cond::persistency::PAYLOAD::Table::~Table ( )

inlineoverride

Definition at line 62 of file IOVSchema.h.

References beamerCreator::create(), edm::eventsetup::heterocontainer::insert(), TauGenJetsDecayModeSelectorAllHadrons_cfi::select, and AlCaHLTBitMon_QueryRunRegistry::string.

{}

Member Function Documentation

void Table::create ( )

overridevirtual

Implements cond::persistency::IPayloadTable.

Definition at line 304 of file IOVSchema.cc.

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

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

                             {
      if( exists()){
    throwException( "Payload table already exists in this schema.",
            "PAYLOAD::Schema::create");
      }
      
      TableDescription< HASH, OBJECT_TYPE, DATA, STREAMER_INFO, VERSION, INSERTION_TIME > descr( tname );
      descr.setPrimaryKey<HASH>();
      createTable( m_schema, descr.get() );
    }

bool Table::exists ( )

overridevirtual

Implements cond::persistency::IPayloadTable.

Definition at line 300 of file IOVSchema.cc.

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

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

                             {
      return existsTable( m_schema, tname );
    }

bool Table::getType ( const cond::Hash &  payloadHash, std::string &  objectType  )

overridevirtual

Implements cond::persistency::IPayloadTable.

Definition at line 323 of file IOVSchema.cc.

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

Referenced by Vispa.Plugins.EdmBrowser.EdmDataAccessor.EdmDataAccessor::getDaughterObjects(), Vispa.Plugins.EdmBrowser.EdmDataAccessor.EdmDataAccessor::getObjectRef(), Vispa.Plugins.EdmBrowser.EdmDataAccessor.EdmDataAccessor::getShortType(), and Vispa.Plugins.EdmBrowser.EdmDataAccessor.EdmDataAccessor::properties().

                                                                                  {
      Query< OBJECT_TYPE > q( m_schema );
      q.addCondition<HASH>( payloadHash );
      for ( auto row : q ) {
    objectType = std::get<0>(row);
      }
      
      return q.retrievedRows(); 
    }

bool Table::insert	(	const cond::Hash &	payloadHash,
		const std::string &	objectType,
		const cond::Binary &	payloadData,
		const cond::Binary &	streamerInfoData,
		const boost::posix_time::ptime &	insertionTime
	)

Definition at line 345 of file IOVSchema.cc.

References cond::Binary::copy(), cond::persistency::RowBuffer< Columns >::get(), m_schema, cond::Binary::size(), AlCaHLTBitMon_QueryRunRegistry::string, cond::persistency::PAYLOAD::tname, and jets_cff::version.

Referenced by BeautifulSoup.PageElement::append(), and insertIfNew().

                                                                {
      std::string version("dummy");
      cond::Binary sinfoData( streamerInfoData );
      if( !sinfoData.size() ) sinfoData.copy( std::string("0") );   
      RowBuffer< HASH, OBJECT_TYPE, DATA, STREAMER_INFO, VERSION, INSERTION_TIME > dataToInsert( std::tie( payloadHash, objectType, payloadData, sinfoData, version, insertionTime ) ); 
      bool failOnDuplicate = false;
      return insertInTable( m_schema, tname, dataToInsert.get(), failOnDuplicate );
    }

cond::Hash Table::insertIfNew ( const std::string &  objectType, const cond::Binary &  payloadData, const cond::Binary &  streamerInfoData, const boost::posix_time::ptime &  insertionTime  )

overridevirtual

Implements cond::persistency::IPayloadTable.

Definition at line 358 of file IOVSchema.cc.

References insert(), cond::persistency::makeHash(), and select().

                                                                   {
      cond::Hash payloadHash = makeHash( payloadObjectType, payloadData );
      // the check on the hash existance is only required to avoid the error message printing in SQLite! once this is removed, this check is useless... 
      if( !select( payloadHash ) ){
    insert( payloadHash, payloadObjectType, payloadData, streamerInfoData, insertionTime );
      }
      return payloadHash;
    }

bool Table::select

(

const cond::Hash &

payloadHash

)

Definition at line 315 of file IOVSchema.cc.

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

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

                                                          {
      Query< HASH > q( m_schema );
      q.addCondition<HASH>( payloadHash );
      for ( auto row : q ) {}
      
      return q.retrievedRows();
    }

bool Table::select ( const cond::Hash &  payloadHash, std::string &  objectType, cond::Binary &  payloadData, cond::Binary &  streamerInfoData  )

overridevirtual

Implements cond::persistency::IPayloadTable.

Definition at line 333 of file IOVSchema.cc.

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

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< DATA, STREAMER_INFO, OBJECT_TYPE > q( m_schema );
      q.addCondition<HASH>( payloadHash );
      for ( auto row : q ) {
    std::tie( payloadData, streamerInfoData, objectType ) = row;
      }
      return q.retrievedRows();
    }

Member Data Documentation

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

private

Definition at line 75 of file IOVSchema.h.

Referenced by create(), exists(), getType(), insert(), and select().