#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 676 of file DbCore.h.

Constructor & Destructor Documentation

◆ BulkInserter()

template<typename... Types>

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

inline

Definition at line 679 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

◆ flush()

template<typename... Types>

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

inline

Definition at line 693 of file DbCore.h.

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

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

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

◆ insert()

template<typename... Types>

template<typename P >

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

inline

Definition at line 686 of file DbCore.h.

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