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

#include <DbCore.h>

Public Member Functions
void	addStaticCondition (const std::string &condition)
	BulkDeleter (coral::ISchema &schema, const char *tableName)
template<typename P >
void	erase (const P &params)
void	flush ()

Static Public Attributes
static constexpr size_t	cacheSize = 1000

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

Detailed Description

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

Definition at line 709 of file DbCore.h.

Constructor & Destructor Documentation

BulkDeleter()

template<typename... Types>

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

inlineexplicit

Definition at line 712 of file DbCore.h.

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

Member Function Documentation

addStaticCondition()

template<typename... Types>

void cond::persistency::BulkDeleter< Types >::addStaticCondition ( const std::string &  condition )

inline

Definition at line 718 of file DbCore.h.

References cond::persistency::ConditionBuffer< Columns >::addStaticCondition(), and cond::persistency::BulkDeleter< Types >::m_buffer.

{ m_buffer.addStaticCondition(condition); }

erase()

template<typename... Types>

template<typename P >

void cond::persistency::BulkDeleter< Types >::erase ( const P &  params )

inline

Definition at line 721 of file DbCore.h.

References cond::persistency::BulkDeleter< Types >::cacheSize, cond::persistency::ConditionBuffer< Columns >::get(), cond::persistency::ConditionBuffer< Columns >::getClause(), cond::persistency::BulkDeleter< Types >::m_buffer, cond::persistency::BulkDeleter< Types >::m_coralDeleter, cond::persistency::BulkDeleter< Types >::m_schema, cond::persistency::BulkDeleter< Types >::m_tableName, submitPVValidationJobs::params, and cond::persistency::ConditionBuffer< Columns >::set().

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

flush()

template<typename... Types>

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

inline

Definition at line 730 of file DbCore.h.

References cond::persistency::BulkDeleter< Types >::m_coralDeleter.

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

Member Data Documentation

cacheSize

template<typename... Types>

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

static

Definition at line 711 of file DbCore.h.

Referenced by cond::persistency::BulkDeleter< Types >::erase().

m_buffer

template<typename... Types>

ConditionBuffer<Types...> cond::persistency::BulkDeleter< Types >::m_buffer

private

Definition at line 740 of file DbCore.h.

Referenced by cond::persistency::BulkDeleter< Types >::addStaticCondition(), and cond::persistency::BulkDeleter< Types >::erase().

m_coralDeleter

template<typename... Types>

std::unique_ptr<coral::IBulkOperation> cond::persistency::BulkDeleter< Types >::m_coralDeleter

private

Definition at line 741 of file DbCore.h.

Referenced by cond::persistency::BulkDeleter< Types >::erase(), and cond::persistency::BulkDeleter< Types >::flush().

m_schema

template<typename... Types>

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

private

Definition at line 737 of file DbCore.h.

Referenced by cond::persistency::BulkDeleter< Types >::erase().

m_tableName

template<typename... Types>

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

private

Definition at line 738 of file DbCore.h.

Referenced by cond::persistency::BulkDeleter< Types >::erase().