cet::sqlite::Ntuple< Args > Class Template Reference

#include <Ntuple.h>

Public Types
template<typename T >
using	element_t = std::unique_ptr< typename sqlite::permissive_column< T >::element_type >
using	row_t = std::tuple< element_t< Args >... >
using	name_array = sqlite::name_array< nColumns >

Public Member Functions
	~Ntuple () noexcept
	Ntuple (Connection &connection, std::string const &name, name_array const &columns, bool overwriteContents=false, std::size_t bufsize=1000ull)
	Ntuple (Ntuple const &)=delete
Ntuple &	operator= (Ntuple const &)=delete
std::string const &	name () const
void	insert (Args const ...)
void	flush ()

Static Public Attributes
static constexpr auto	nColumns = std::tuple_size_v<row_t>

Private Member Functions
template<std::size_t... I>
	Ntuple (Connection &db, std::string const &name, name_array const &columns, bool overwriteContents, std::size_t bufsize, std::index_sequence< I... >)
int	flush_no_throw ()

Private Attributes
std::recursive_mutex	mutex_ {}
Connection &	connection_
std::string const	name_
std::size_t const	max_
std::vector< row_t >	buffer_ {}
sqlite3_stmt *	insert_statement_ {nullptr}

Static Private Attributes
static constexpr auto	iSequence = std::make_index_sequence<nColumns>()

Detailed Description

template<typename... Args>
class cet::sqlite::Ntuple< Args >

Definition at line 121 of file Ntuple.h.

Member Typedef Documentation

template<typename... Args>

template<typename T >

using cet::sqlite::Ntuple< Args >::element_t = std::unique_ptr<typename sqlite::permissive_column<T>::element_type>

Definition at line 128 of file Ntuple.h.

template<typename... Args>

using cet::sqlite::Ntuple< Args >::name_array = sqlite::name_array<nColumns>

Definition at line 131 of file Ntuple.h.

template<typename... Args>

using cet::sqlite::Ntuple< Args >::row_t = std::tuple<element_t<Args>...>

Definition at line 129 of file Ntuple.h.

Constructor & Destructor Documentation

template<typename... Args>

cet::sqlite::Ntuple< Args >::~Ntuple ( )

noexcept

Definition at line 221 of file Ntuple.h.

{
  if (flush_no_throw() != SQLITE_OK) {
    std::cerr << "SQLite step failure while flushing.\n";
  }
  sqlite3_finalize(insert_statement_);
}

template<typename... Args>

cet::sqlite::Ntuple< Args >::Ntuple	(	Connection &	connection,
		std::string const &	name,
		name_array const &	columns,
		bool	overwriteContents = false,
		std::size_t	bufsize = 1000ull
	)

Definition at line 212 of file Ntuple.h.

  : Ntuple{connection, name, cnames, overwriteContents, bufsize, iSequence}
{}

template<typename... Args>

cet::sqlite::Ntuple< Args >::Ntuple ( Ntuple< Args > const &  )

delete

template<typename... Args>

template<std::size_t... I>

cet::sqlite::Ntuple< Args >::Ntuple ( Connection &  db, std::string const &  name, name_array const &  columns, bool  overwriteContents, std::size_t  bufsize, std::index_sequence< I... >    )

private

Definition at line 179 of file Ntuple.h.

  : connection_{connection}, name_{name}, max_{bufsize}
{
  std::lock_guard sentry{mutex_};
  assert(connection);
  sqlite::createTableIfNeeded(connection,
                              overwriteContents,
                              name,
                              sqlite::permissive_column<Args>{cnames[I]}...);
  std::string sql{"INSERT INTO "};
  sql += name;
  sql += " VALUES (?";
  for (std::size_t i = 1; i < nColumns; ++i) {
    sql += ",?";
  }
  sql += ")";
  int const rc{sqlite3_prepare_v2(
    connection_.get(), sql.c_str(), sql.size(), &insert_statement_, nullptr)};
  if (rc != SQLITE_OK) {
    auto const ec = sqlite3_step(insert_statement_);
    throw sqlite::Exception{sqlite::errors::SQLExecutionError}
      << "Failed to prepare insertion statement.\n"
      << "Return code: " << ec << '\n';
  }
  buffer_.reserve(bufsize);
}

Member Function Documentation

template<typename... Args>

void cet::sqlite::Ntuple< Args >::flush

(

)

Definition at line 258 of file Ntuple.h.

{
  // No lock here -- lock held by flush_no_throw;
  if (flush_no_throw() != SQLITE_OK) {
    throw sqlite::Exception{sqlite::errors::SQLExecutionError}
      << "SQLite step failure while flushing.";
  }
}

template<typename... Args>

int cet::sqlite::Ntuple< Args >::flush_no_throw ( )

private

Definition at line 242 of file Ntuple.h.

{
  // Guard against any modifications to the buffer, which is about to
  // be flushed to the database.
  std::lock_guard sentry{mutex_};
  int const rc{
    connection_.flush_no_throw<nColumns>(buffer_, insert_statement_)};
  if (rc != SQLITE_DONE) {
    return rc;
  }
  buffer_.clear();
  return SQLITE_OK;
}

template<typename... Args>

void cet::sqlite::Ntuple< Args >::insert

(

Args

const ...

)

Definition at line 231 of file Ntuple.h.

{
  std::lock_guard sentry{mutex_};
  if (buffer_.size() == max_) {
    flush();
  }
  buffer_.emplace_back(std::make_unique<Args>(args)...);
}

template<typename... Args>

std::string const& cet::sqlite::Ntuple< Args >::name ( ) const

inline

Definition at line 145 of file Ntuple.h.

    {
      return name_;
    }

template<typename... Args>

Ntuple& cet::sqlite::Ntuple< Args >::operator= ( Ntuple< Args > const &  )

delete

Member Data Documentation

template<typename... Args>

std::vector<row_t> cet::sqlite::Ntuple< Args >::buffer_ {}

private

Definition at line 171 of file Ntuple.h.

template<typename... Args>

Connection& cet::sqlite::Ntuple< Args >::connection_

private

Definition at line 168 of file Ntuple.h.

template<typename... Args>

sqlite3_stmt* cet::sqlite::Ntuple< Args >::insert_statement_ {nullptr}

private

Definition at line 172 of file Ntuple.h.

template<typename... Args>

constexpr auto cet::sqlite::Ntuple< Args >::iSequence = std::make_index_sequence<nColumns>()

staticprivate

Definition at line 153 of file Ntuple.h.

template<typename... Args>

std::size_t const cet::sqlite::Ntuple< Args >::max_

private

Definition at line 170 of file Ntuple.h.

template<typename... Args>

std::recursive_mutex cet::sqlite::Ntuple< Args >::mutex_ {}

private

Definition at line 167 of file Ntuple.h.

template<typename... Args>

std::string const cet::sqlite::Ntuple< Args >::name_

private

Definition at line 169 of file Ntuple.h.

template<typename... Args>

constexpr auto cet::sqlite::Ntuple< Args >::nColumns = std::tuple_size_v<row_t>

static

Definition at line 130 of file Ntuple.h.

---

The documentation for this class was generated from the following file:

• cetlib/cetlib/sqlite/Ntuple.h