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 633 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 636 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 650 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 643 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 635 of file DbCore.h.

template<typename... Types>

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

private

Definition at line 660 of file DbCore.h.

template<typename... Types>

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

private

Definition at line 661 of file DbCore.h.

template<typename... Types>

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

private

Definition at line 657 of file DbCore.h.

template<typename... Types>

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

private

Definition at line 658 of file DbCore.h.