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 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 684 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 687 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 701 of file DbCore.h.

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().

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

insert()

template<typename... Types>

template<typename P >

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

inline

Definition at line 694 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, submitPVValidationJobs::params, and cond::persistency::RowBuffer< Columns >::set().

Referenced by SequenceTypes.Schedule::_replaceIfHeldDirectly(), 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

cacheSize

template<typename... Types>

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

static

Definition at line 686 of file DbCore.h.

Referenced by cond::persistency::BulkInserter< Types >::insert().

m_buffer

template<typename... Types>

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

private

Definition at line 711 of file DbCore.h.

Referenced by cond::persistency::BulkInserter< Types >::insert().

m_coralInserter

template<typename... Types>

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

private

Definition at line 712 of file DbCore.h.

Referenced by cond::persistency::BulkInserter< Types >::flush(), and cond::persistency::BulkInserter< Types >::insert().

m_schema

template<typename... Types>

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

private

Definition at line 708 of file DbCore.h.

Referenced by cond::persistency::BulkInserter< Types >::insert().

m_tableName

template<typename... Types>

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

private

Definition at line 709 of file DbCore.h.

Referenced by cond::persistency::BulkInserter< Types >::insert().