#include <OraDbSchema.h>

Inheritance diagram for cond::persistency::OraIOVTable:

Public Member Functions
void	create ()

void	erase (const std::string &tag)

bool	exists ()

bool	getLastIov (const std::string &tag, cond::Time_t &since, cond::Hash &hash)

bool	getSize (const std::string &tag, size_t &size)

bool	getSnapshotSize (const std::string &tag, const boost::posix_time::ptime &snapshotTime, size_t &size)

void	insertMany (const std::string &tag, const std::vector< std::tuple< cond::Time_t, cond::Hash, boost::posix_time::ptime > > &iovs)

void	insertOne (const std::string &tag, cond::Time_t since, cond::Hash payloadHash, const boost::posix_time::ptime &insertTime)

	OraIOVTable (IOVCache &cache)

size_t	selectGroups (const std::string &tag, std::vector< cond::Time_t > &groups)

size_t	selectLatest (const std::string &tag, std::vector< std::tuple< cond::Time_t, cond::Hash > > &iovs)

size_t	selectLatestByGroup (const std::string &tag, cond::Time_t lowerGroup, cond::Time_t upperGroup, std::vector< std::tuple< cond::Time_t, cond::Hash > > &iovs)

size_t	selectSnapshotByGroup (const std::string &tag, cond::Time_t lowerGroup, cond::Time_t upperGroup, const boost::posix_time::ptime &snapshotTime, std::vector< std::tuple< cond::Time_t, cond::Hash > > &iovs)

size_t	selectSnapshotGroups (const std::string &tag, const boost::posix_time::ptime &snapshotTime, std::vector< cond::Time_t > &groups)

virtual	~OraIOVTable ()

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

Private Attributes
IOVCache &	m_cache

Detailed Description

Definition at line 85 of file OraDbSchema.h.

Constructor & Destructor Documentation

cond::persistency::OraIOVTable::OraIOVTable ( IOVCache & cache )

explicit

Definition at line 154 of file OraDbSchema.cc.

                                                 :
       m_cache( iovCache ){
     }

virtual cond::persistency::OraIOVTable::~OraIOVTable ( )

inlinevirtual

Definition at line 88 of file OraDbSchema.h.

88 {}

Member Function Documentation

void cond::persistency::OraIOVTable::create ( )

inlinevirtual

Implements cond::persistency::IIOVTable.

Definition at line 92 of file OraDbSchema.h.

92 {

93 }

void cond::persistency::OraIOVTable::erase ( const std::string & tag )

virtual

Implements cond::persistency::IIOVTable.

Definition at line 242 of file OraDbSchema.cc.

References cond::persistency::throwException().

                                              {
       throwException( "Erase iovs from ORA database is not supported.",
               "OraIOVTable::erase" );
     }

bool cond::persistency::OraIOVTable::exists ( )

inlinevirtual

Implements cond::persistency::IIOVTable.

Definition at line 89 of file OraDbSchema.h.

                    {
     return true;
       }

bool cond::persistency::OraIOVTable::getLastIov	(	const std::string &	tag,
		cond::Time_t &	since,
		cond::Hash &	hash
	)

virtual

Implements cond::persistency::IIOVTable.

Definition at line 204 of file OraDbSchema.cc.

References cond::IOVProxy::end(), cond::persistency::IOVCache::iovSequence(), prof2calltree::last, cond::persistency::IOVCache::load(), m_cache, cond::IOVElementProxy::since(), cond::IOVProxy::size(), and cond::IOVElementProxy::token().

                                                                                          {
       if(!m_cache.load( tag ) || m_cache.iovSequence().size()==0 ) return false;
       cond::IOVElementProxy last = *(--m_cache.iovSequence().end());
       since = last.since();
       hash = last.token();
       return true;
     }

bool cond::persistency::OraIOVTable::getSize	(	const std::string &	tag,
		size_t &	size
	)

virtual

Implements cond::persistency::IIOVTable.

Definition at line 212 of file OraDbSchema.cc.

References cond::persistency::IOVCache::iovSequence(), cond::persistency::IOVCache::load(), m_cache, and cond::IOVProxy::size().

Referenced by getSnapshotSize().

                                                                  {
       if(!m_cache.load( tag )) return false;
       size = m_cache.iovSequence().size();
       return true;
     }

bool cond::persistency::OraIOVTable::getSnapshotSize	(	const std::string &	tag,
		const boost::posix_time::ptime &	snapshotTime,
		size_t &	size
	)

virtual

Implements cond::persistency::IIOVTable.

Definition at line 218 of file OraDbSchema.cc.

References getSize().

                                                                                                       {
       // no (easy) way to do it...
       return getSize( tag,size );
     }

void cond::persistency::OraIOVTable::insertMany	(	const std::string &	tag,
		const std::vector< std::tuple< cond::Time_t, cond::Hash, boost::posix_time::ptime > > &	iovs
	)

virtual

Implements cond::persistency::IIOVTable.

Definition at line 230 of file OraDbSchema.cc.

References cond::IOVEditor::bulkAppend(), data, cond::persistency::IOVCache::editor(), cond::persistency::IOVCache::load(), m_cache, cond::persistency::throwException(), and findQualityFiles::v.

                                                                                               {
       if(!m_cache.load(tag)) throwException("Tag "+tag+" has not been found in the database.",
                         "OraIOVTable::insertOne");
       std::vector<std::pair<cond::Time_t, std::string > > data;
       data.reserve( iovs.size() );
       for( auto v : iovs ){
     data.push_back( std::make_pair( std::get<0>(v), std::get<1>(v) ) );
       }
       m_cache.editor().bulkAppend( data );
     }

void cond::persistency::OraIOVTable::insertOne	(	const std::string &	tag,
		cond::Time_t	since,
		cond::Hash	payloadHash,
		const boost::posix_time::ptime &	insertTime
	)

virtual

Implements cond::persistency::IIOVTable.

Definition at line 223 of file OraDbSchema.cc.

References cond::IOVEditor::append(), cond::persistency::IOVCache::editor(), cond::persistency::IOVCache::load(), m_cache, and cond::persistency::throwException().

                                               {
       if(!m_cache.load(tag)) throwException("Tag "+tag+" has not been found in the database.",
                         "OraIOVTable::insertOne");
       m_cache.editor().append( since, payloadHash );
     }

size_t cond::persistency::OraIOVTable::selectGroups	(	const std::string &	tag,
		std::vector< cond::Time_t > &	groups
	)

virtual

Implements cond::persistency::IIOVTable.

Definition at line 158 of file OraDbSchema.cc.

References cond::IOVProxy::firstSince(), cond::persistency::IOVCache::iovSequence(), cond::IOVProxy::lastTill(), cond::persistency::IOVCache::load(), m_cache, and cond::IOVProxy::size().

Referenced by selectSnapshotGroups().

                                                                                          {
       if(!m_cache.load( tag )) return 0;
       if( m_cache.iovSequence().size()>0 ){
     groups.push_back( m_cache.iovSequence().firstSince() );
     groups.push_back( m_cache.iovSequence().lastTill() );
     return true;
       }
       return false; 
     }

size_t cond::persistency::OraIOVTable::selectLatest	(	const std::string &	tag,
		std::vector< std::tuple< cond::Time_t, cond::Hash > > &	iovs
	)

virtual

Implements cond::persistency::IIOVTable.

Definition at line 193 of file OraDbSchema.cc.

References o2o::iov, cond::persistency::IOVCache::iovSequence(), cond::persistency::IOVCache::load(), m_cache, and run_regression::ret.

                                                                                                           {
       // avoid this! copying the entire iov sequence...
       if(!m_cache.load( tag )) return 0;
       size_t ret = 0;
       for( auto iov : m_cache.iovSequence() ){
     iovs.push_back( std::make_tuple( iov.since(), iov.token() ) );
     ret++;
       }
       return ret;      
     }

size_t cond::persistency::OraIOVTable::selectLatestByGroup	(	const std::string &	tag,
		cond::Time_t	lowerGroup,
		cond::Time_t	upperGroup,
		std::vector< std::tuple< cond::Time_t, cond::Hash > > &	iovs
	)

virtual

Implements cond::persistency::IIOVTable.

Definition at line 174 of file OraDbSchema.cc.

References o2o::iov, cond::persistency::IOVCache::iovSequence(), cond::persistency::IOVCache::load(), m_cache, cond::IOVProxy::range(), and run_regression::ret.

Referenced by selectSnapshotByGroup().

                                                                          {
       if(!m_cache.load( tag )) return 0;
       cond::IOVRange range = m_cache.iovSequence().range( lowerGroup, upperGroup );
       size_t ret = 0;
       for( auto iov : range ){
     iovs.push_back( std::make_tuple( iov.since(), iov.token() ) );
     ret++;
       }
       return ret;
     }

size_t cond::persistency::OraIOVTable::selectSnapshotByGroup	(	const std::string &	tag,
		cond::Time_t	lowerGroup,
		cond::Time_t	upperGroup,
		const boost::posix_time::ptime &	snapshotTime,
		std::vector< std::tuple< cond::Time_t, cond::Hash > > &	iovs
	)

virtual

Implements cond::persistency::IIOVTable.

Definition at line 186 of file OraDbSchema.cc.

References selectLatestByGroup().

                                                                            {
       // no (easy) way to do it...
       return selectLatestByGroup( tag, lowerGroup, upperGroup, iovs );
     }

size_t cond::persistency::OraIOVTable::selectSnapshotGroups	(	const std::string &	tag,
		const boost::posix_time::ptime &	snapshotTime,
		std::vector< cond::Time_t > &	groups
	)

virtual

Implements cond::persistency::IIOVTable.

Definition at line 168 of file OraDbSchema.cc.

References selectGroups().

                                                          {
       // no (easy) way to do it...
       return selectGroups( tag, groups );
     }

Member Data Documentation

IOVCache& cond::persistency::OraIOVTable::m_cache

private

Definition at line 112 of file OraDbSchema.h.

Referenced by getLastIov(), getSize(), insertMany(), insertOne(), selectGroups(), selectLatest(), and selectLatestByGroup().

Public Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation