cond::persistency::BulkInserter< Types > Class Template Reference

#include <DbCore.h>

Public Member Functions
	BulkInserter (coral::ISchema &schema, const char *tableName)
void	flush ()
template<typename P >
void	insert (const P &params)

Static Public Attributes
static size_t	cacheSize = 1000

Private Attributes
RowBuffer< Types... >	m_buffer
std::unique_ptr< coral::IBulkOperation >	m_coralInserter
coral::ISchema &	m_schema
std::string	m_tableName

Detailed Description

template<typename... Types>
class cond::persistency::BulkInserter< Types >

Definition at line 578 of file DbCore.h.

Constructor & Destructor Documentation

template<typename... Types>

cond::persistency::BulkInserter< Types >::BulkInserter ( coral::ISchema &  schema, const char *  tableName  )

inline

Definition at line 581 of file DbCore.h.

                                                               :
      m_schema( schema ),
      m_tableName( tableName ),
      m_buffer(),
      m_coralInserter(){
      //fix me: maybe with 
      //m_coralInserter.reset(  schema.tableHandle( std::string(tableName ) ).dataEditor().bulkInsert( m_buffer.get(), cacheSize ) );
    }

Member Function Documentation

template<typename... Types>

void cond::persistency::BulkInserter< Types >::flush ( )

inline

Definition at line 596 of file DbCore.h.

Referenced by cond::persistency::RUN_INFO::Table::insert(), cond::persistency::GLOBAL_TAG_MAP::Table::insert(), and cond::persistency::IOV::Table::insertMany().

                {
      if( m_coralInserter.get() ) m_coralInserter->flush();
    }

template<typename... Types>

template<typename P >

void cond::persistency::BulkInserter< Types >::insert ( const P &  params )

inline

Definition at line 590 of file DbCore.h.

Referenced by BeautifulSoup.PageElement::append(), cond::persistency::RUN_INFO::Table::insert(), cond::persistency::GLOBAL_TAG_MAP::Table::insert(), and cond::persistency::IOV::Table::insertMany().

                                                        {
      m_buffer.set( params );
      if( !m_coralInserter.get() ) m_coralInserter.reset(  m_schema.tableHandle( m_tableName ).dataEditor().bulkInsert( m_buffer.get(), cacheSize ) );
      m_coralInserter->processNextIteration(); 
    }

Member Data Documentation

template<typename... Types>

size_t cond::persistency::BulkInserter< Types >::cacheSize = 1000

static

Definition at line 580 of file DbCore.h.

template<typename... Types>

RowBuffer<Types...> cond::persistency::BulkInserter< Types >::m_buffer

private

Definition at line 604 of file DbCore.h.

template<typename... Types>

std::unique_ptr<coral::IBulkOperation> cond::persistency::BulkInserter< Types >::m_coralInserter

private

Definition at line 605 of file DbCore.h.

template<typename... Types>

coral::ISchema& cond::persistency::BulkInserter< Types >::m_schema

private

Definition at line 601 of file DbCore.h.

template<typename... Types>

std::string cond::persistency::BulkInserter< Types >::m_tableName

private

Definition at line 602 of file DbCore.h.