cet::sqlite::Connection Class Reference

#include <Connection.h>

Public Member Functions
	~Connection () noexcept
	Connection ()=default
	Connection (Connection const &)=delete
	Connection (Connection &&)=delete
Connection &	operator= (Connection const &)=delete
Connection &	operator= (Connection &&)=delete
sqlite3 *	get () const
	operator sqlite3 * ()
template<std::size_t NColumns, typename Row >
int	flush_no_throw (std::vector< Row > const &buffer, sqlite3_stmt *&insertStmt)

Private Member Functions
template<typename DatabaseOpenPolicy >
	Connection (std::string const &filename, std::shared_ptr< std::recursive_mutex >, DatabaseOpenPolicy)

Private Attributes
sqlite3 *	db_ {nullptr}
std::shared_ptr< std::recursive_mutex >	mutex_ {nullptr}

Friends
class	ConnectionFactory

Detailed Description

Definition at line 31 of file Connection.h.

Constructor & Destructor Documentation

Connection::~Connection ( )

noexcept

Definition at line 8 of file Connection.cc.

{
  // It is safe to call sqlite3_close on a null db_.
  sqlite3_close(db_);
}

cet::sqlite::Connection::Connection ( )

explicitdefault

cet::sqlite::Connection::Connection ( Connection const &  )

delete

cet::sqlite::Connection::Connection ( Connection &&  )

delete

template<typename DatabaseOpenPolicy >

cet::sqlite::Connection::Connection ( std::string const &  filename, std::shared_ptr< std::recursive_mutex >  spmutex, DatabaseOpenPolicy  policy  )

explicitprivate

Definition at line 70 of file Connection.h.

    : mutex_{spmutex}
  {
    // No lock necessary since the c'tor is called in a protected
    // environment.
    db_ = policy.open(filename);
  }

Member Function Documentation

template<std::size_t NColumns, typename Row >

int cet::sqlite::Connection::flush_no_throw	(	std::vector< Row > const &	buffer,
		sqlite3_stmt *&	insertStmt
	)

Definition at line 82 of file Connection.h.

  {
    // Guard against concurrent updates to the same database.
    std::lock_guard sentry{*mutex_};
    sqlite::Transaction txn{db_};
    for (auto const& r : buffer) {
      sqlite::detail::bind_parameters<Row, NColumns>::bind(insertStmt, r);
      int const rc{sqlite3_step(insertStmt)};
      if (rc != SQLITE_DONE) {
        return rc;
      }
      sqlite3_reset(insertStmt);
    }
    txn.commit();
    return SQLITE_DONE;
  }

sqlite3* cet::sqlite::Connection::get ( ) const

inline

Definition at line 48 of file Connection.h.

    {
      return db_;
    }

cet::sqlite::Connection::operator sqlite3 * ( )

inline

Definition at line 52 of file Connection.h.

{ return db_; }

Connection& cet::sqlite::Connection::operator= ( Connection const &  )

delete

Connection& cet::sqlite::Connection::operator= ( Connection &&  )

delete

Friends And Related Function Documentation

friend class ConnectionFactory

friend

Definition at line 32 of file Connection.h.

Member Data Documentation

sqlite3* cet::sqlite::Connection::db_ {nullptr}

private

Definition at line 64 of file Connection.h.

std::shared_ptr<std::recursive_mutex> cet::sqlite::Connection::mutex_ {nullptr}

private

Definition at line 66 of file Connection.h.

---

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

• cetlib/cetlib/sqlite/Connection.h
• cetlib/cetlib/sqlite/Connection.cc