#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 constexpr 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 543 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 546 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 561 of file DbCore.h.

References cond::persistency::BulkInserter< Types >::m_coralInserter.

                 {
       m_coralInserter->flush();
     }

template<typename... Types>

template<typename P >

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

inline

Definition at line 555 of file DbCore.h.

References cond::persistency::BulkInserter< Types >::cacheSize, cond::persistency::RowBuffer< Columns >::get(), cond::persistency::BulkInserter< Types >::m_buffer, cond::persistency::BulkInserter< Types >::m_coralInserter, cond::persistency::BulkInserter< Types >::m_schema, cond::persistency::BulkInserter< Types >::m_tableName, and cond::persistency::RowBuffer< Columns >::set().

Referenced by BeautifulSoup.PageElement::_invert().

                                                         {
       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(); 
     }