Common database connection class. More...

#include <database_connection.h>

Inheritance diagram for isc::db::DatabaseConnection:

Public Types
typedef std::map< std::string, std::string >	ParameterMap
	Database configuration parameter map. More...

Public Member Functions
	DatabaseConnection (const ParameterMap &parameters, DbCallback callback=DbCallback())
	Constructor. More...

virtual	~DatabaseConnection ()
	Destructor. More...

void	checkUnusable ()
	Throws an exception if the connection is not usable. More...

bool	configuredReadOnly () const
	Convenience method checking if database should be opened with read only access. More...

std::string	getParameter (const std::string &name) const
	Returns value of a connection parameter. More...

bool	isUnusable ()
	Flag which indicates if connection is unusable. More...

virtual void	makeReconnectCtl (const std::string &timer_name)
	Instantiates a ReconnectCtl based on the connection's reconnect parameters. More...

ReconnectCtlPtr	reconnectCtl ()
	The reconnect settings. More...

Static Public Member Functions
static bool	invokeDbFailedCallback (const ReconnectCtlPtr &db_reconnect_ctl)
	Invokes the connection's restore failed connectivity callback. More...

static bool	invokeDbLostCallback (const ReconnectCtlPtr &db_reconnect_ctl)
	Invokes the connection's lost connectivity callback. More...

static bool	invokeDbRecoveredCallback (const ReconnectCtlPtr &db_reconnect_ctl)
	Invokes the connection's restored connectivity callback. More...

static ParameterMap	parse (const std::string &dbaccess)
	Parse database access string. More...

static std::string	redactedAccessString (const ParameterMap &parameters)
	Redact database access string. More...

static isc::data::ElementPtr	toElement (const ParameterMap &params)
	Unparse a parameter map. More...

static isc::data::ElementPtr	toElementDbAccessString (const std::string &dbaccess)
	Unparse an access string. More...

Static Public Attributes
static DbCallback	db_failed_callback_ = 0
	Optional callback function to invoke if an opened connection recovery failed. More...

static DbCallback	db_lost_callback_ = 0
	Optional callback function to invoke if an opened connection is lost. More...

static DbCallback	db_recovered_callback_ = 0
	Optional callback function to invoke if an opened connection recovery succeeded. More...

static const time_t	MAX_DB_TIME = 2147483647
	Defines maximum value for time that can be reliably stored. More...

Protected Member Functions
void	markUnusable ()
	Sets the unusable flag to true. More...

Protected Attributes
DbCallback	callback_
	The callback used to recover the connection. More...

Detailed Description

Common database connection class.

This class provides functions that are common for establishing connection with different types of databases; enables operations on access parameters strings. In particular, it provides a way to parse parameters in key=value format. This class is expected to be a base class for all isc::dhcp::LeaseMgr and possibly isc::dhcp::BaseHostDataSource derived classes.

Definition at line 221 of file database_connection.h.

Member Typedef Documentation

typedef std::map<std::string, std::string> isc::db::DatabaseConnection::ParameterMap

Database configuration parameter map.

Definition at line 233 of file database_connection.h.

Constructor & Destructor Documentation

isc::db::DatabaseConnection::DatabaseConnection	(	const ParameterMap &	parameters,
		DbCallback	callback = `DbCallback()`
	)

inline

Constructor.

Parameters

parameters	A data structure relating keywords and values concerned with the database.
callback	The connection recovery callback.

Definition at line 240 of file database_connection.h.

virtual isc::db::DatabaseConnection::~DatabaseConnection ( )

inlinevirtual

Destructor.

Definition at line 246 of file database_connection.h.

Member Function Documentation

void isc::db::DatabaseConnection::checkUnusable ( )

inline

Throws an exception if the connection is not usable.

Exceptions

DbConnectionUnusable

Definition at line 341 of file database_connection.h.

References isc_throw.

Referenced by isc::db::PgSqlConnection::commit(), isc::db::MySqlConnection::commit(), isc::db::MySqlConnection::insertQuery(), isc::db::PgSqlConnection::rollback(), isc::db::MySqlConnection::rollback(), isc::db::MySqlConnection::selectQuery(), isc::db::MySqlConnection::startTransaction(), isc::db::PgSqlConnection::startTransaction(), and isc::db::MySqlConnection::updateDeleteQuery().

bool isc::db::DatabaseConnection::configuredReadOnly ( ) const

Convenience method checking if database should be opened with read only access.

Returns: true if "readonly" parameter is specified and set to true; false if "readonly" parameter is not specified or it is specified and set to false.

Definition at line 132 of file database_connection.cc.

References isc_throw.

std::string isc::db::DatabaseConnection::getParameter ( const std::string & name ) const

Returns value of a connection parameter.

Parameters

name	Name of the parameter which value should be returned.

Returns: Value of one of the connection parameters.

Exceptions

BadValue if parameter is not found

Definition at line 29 of file database_connection.cc.

References isc_throw.

Referenced by isc::dhcp::CqlLeaseMgr::getName(), isc::dhcp::CqlHostDataSourceImpl::getName(), isc::dhcp::Memfile_LeaseMgr::Memfile_LeaseMgr(), isc::db::CqlConnection::openDatabase(), isc::db::MySqlConnection::openDatabase(), and isc::db::PgSqlConnection::openDatabase().

bool isc::db::DatabaseConnection::invokeDbFailedCallback ( const ReconnectCtlPtr & db_reconnect_ctl )

static

Invokes the connection's restore failed connectivity callback.

Returns: Returns the result of the callback or false if there is no callback.

Definition at line 209 of file database_connection.cc.

Referenced by isc::dhcp::PgSqlLeaseMgr::dbReconnect(), isc::dhcp::MySqlLeaseMgr::dbReconnect(), isc::dhcp::PgSqlHostDataSourceImpl::dbReconnect(), and isc::dhcp::MySqlHostDataSourceImpl::dbReconnect().

bool isc::db::DatabaseConnection::invokeDbLostCallback ( const ReconnectCtlPtr & db_reconnect_ctl )

static

Invokes the connection's lost connectivity callback.

Returns: Returns the result of the callback or false if there is no callback.

Definition at line 191 of file database_connection.cc.

Referenced by isc::dhcp::PgSqlLeaseMgr::dbReconnect(), isc::dhcp::MySqlLeaseMgr::dbReconnect(), isc::dhcp::PgSqlHostDataSourceImpl::dbReconnect(), and isc::dhcp::MySqlHostDataSourceImpl::dbReconnect().

bool isc::db::DatabaseConnection::invokeDbRecoveredCallback ( const ReconnectCtlPtr & db_reconnect_ctl )

static

Invokes the connection's restored connectivity callback.

Returns: Returns the result of the callback or false if there is no callback.

Definition at line 200 of file database_connection.cc.

Referenced by isc::dhcp::PgSqlLeaseMgr::dbReconnect(), isc::dhcp::MySqlLeaseMgr::dbReconnect(), isc::dhcp::PgSqlHostDataSourceImpl::dbReconnect(), and isc::dhcp::MySqlHostDataSourceImpl::dbReconnect().

bool isc::db::DatabaseConnection::isUnusable ( )

inline

Flag which indicates if connection is unusable.

Returns: true if the connection is unusable, false otherwise

Definition at line 350 of file database_connection.h.

void isc::db::DatabaseConnection::makeReconnectCtl ( const std::string & timer_name )

virtual

Instantiates a ReconnectCtl based on the connection's reconnect parameters.

Parameters

timer_name of the timer used for the ReconnectCtl object.

Definition at line 151 of file database_connection.cc.

void isc::db::DatabaseConnection::markUnusable ( )

inlineprotected

Sets the unusable flag to true.

Definition at line 356 of file database_connection.h.

Referenced by isc::db::MySqlConnection::checkError(), and isc::db::PgSqlConnection::checkStatementError().

DatabaseConnection::ParameterMap isc::db::DatabaseConnection::parse ( const std::string & dbaccess )

static

Parse database access string.

Parses the string of "keyword=value" pairs and separates them out into the map. A value of the password parameter may include whitespace in which case it must be surrounded by apostrophes.

Parameters

dbaccess Database access string.