Implementation of the MySqlHostDataSource. More...

Public Types
enum	StatementIndex { GET_HOST_DHCPID , GET_HOST_ADDR , GET_HOST_SUBID4_DHCPID , GET_HOST_SUBID6_DHCPID , GET_HOST_SUBID_ADDR , GET_HOST_PREFIX , GET_HOST_SUBID6_ADDR , GET_HOST_ADDR6 , GET_HOST_SUBID4 , GET_HOST_SUBID6 , GET_HOST_HOSTNAME , GET_HOST_HOSTNAME_SUBID4 , GET_HOST_HOSTNAME_SUBID6 , GET_HOST_SUBID4_PAGE , GET_HOST_SUBID6_PAGE , GET_HOST_PAGE4 , GET_HOST_PAGE6 , INSERT_HOST_NON_UNIQUE_IP , INSERT_HOST_UNIQUE_IP , INSERT_V6_RESRV_NON_UNIQUE , INSERT_V6_RESRV_UNIQUE , INSERT_V4_HOST_OPTION , INSERT_V6_HOST_OPTION , DEL_HOST_ADDR4 , DEL_HOST_ADDR6 , DEL_HOST_SUBID4_ID , DEL_HOST_SUBID6_ID , NUM_STATEMENTS }
	Statement Tags. More...

Public Member Functions
	MySqlHostDataSourceImpl (const DatabaseConnection::ParameterMap &parameters)
	Constructor.

	~MySqlHostDataSourceImpl ()
	Destructor.

void	addOption (MySqlHostContextPtr &ctx, const MySqlHostDataSourceImpl::StatementIndex &stindex, const OptionDescriptor &opt_desc, const std::string &opt_space, const Optional< SubnetID > &subnet_id, const HostID &host_id)
	Inserts a single DHCP option into the database.

void	addOptions (MySqlHostContextPtr &ctx, const StatementIndex &stindex, const ConstCfgOptionPtr &options_cfg, const uint64_t host_id)
	Inserts multiple options into the database.

void	addResv (MySqlHostContextPtr &ctx, const IPv6Resrv &resv, const HostID &id)
	Inserts IPv6 Reservation into ipv6_reservation table.

void	addStatement (MySqlHostContextPtr &ctx, MySqlHostDataSourceImpl::StatementIndex stindex, std::vector< MYSQL_BIND > &bind)
	Executes statements which inserts a row into one of the tables.

void	checkError (MySqlHostContextPtr &ctx, const int status, const StatementIndex index, const char *what) const
	Check Error and Throw Exception.

void	checkReadOnly (MySqlHostContextPtr &ctx) const
	Throws exception if database is read only.

MySqlHostContextPtr	createContext () const
	Create a new context.

bool	delStatement (MySqlHostContextPtr &ctx, StatementIndex stindex, MYSQL_BIND *bind)
	Executes statements that delete records.

ConstHostPtr	getHost (MySqlHostContextPtr &ctx, const SubnetID &subnet_id, const Host::IdentifierType &identifier_type, const uint8_t *identifier_begin, const size_t identifier_len, StatementIndex stindex, boost::shared_ptr< MySqlHostExchange > exchange) const
	Retrieves a host by subnet and client's unique identifier.

void	getHostCollection (MySqlHostContextPtr &ctx, StatementIndex stindex, MYSQL_BIND *bind, boost::shared_ptr< MySqlHostExchange > exchange, ConstHostCollection &result, bool single) const
	Creates collection of Host objects with associated information such as IPv6 reservations and/or DHCP options.

std::pair< uint32_t, uint32_t >	getVersion (const std::string &timer_name=std::string()) const
	Returns backend version.

Static Public Member Functions
static bool	dbReconnect (ReconnectCtlPtr db_reconnect_ctl)
	Attempts to reconnect the server to the host DB backend manager.

Public Attributes
bool	ip_reservations_unique_
	Holds the setting whether the IP reservations must be unique or may be non-unique.

DatabaseConnection::ParameterMap	parameters_
	The parameters.

MySqlHostContextPoolPtr	pool_
	The pool of contexts.

std::string	timer_name_
	Timer name used to register database reconnect timer.

bool	unusable_
	Indicates if there is at least one connection that can no longer be used for normal operations.

Static Public Attributes
static const StatementIndex	WRITE_STMTS_BEGIN = INSERT_HOST_NON_UNIQUE_IP
	Index of first statement performing write to the database.

Detailed Description

Implementation of the MySqlHostDataSource.

Definition at line 2077 of file mysql_host_data_source.cc.

Member Enumeration Documentation

◆ StatementIndex

enum isc::dhcp::MySqlHostDataSourceImpl::StatementIndex

Statement Tags.

The contents of the enum are indexes into the list of SQL statements. It is assumed that the order is such that the indices of statements reading the database are less than those of statements modifying the database.

Note: : please add new statements doing read only operations before the WRITE_STMTS_BEGIN position.

Enumerator
GET_HOST_DHCPID
GET_HOST_ADDR
GET_HOST_SUBID4_DHCPID
GET_HOST_SUBID6_DHCPID
GET_HOST_SUBID_ADDR
GET_HOST_PREFIX
GET_HOST_SUBID6_ADDR
GET_HOST_ADDR6
GET_HOST_SUBID4
GET_HOST_SUBID6
GET_HOST_HOSTNAME
GET_HOST_HOSTNAME_SUBID4
GET_HOST_HOSTNAME_SUBID6
GET_HOST_SUBID4_PAGE
GET_HOST_SUBID6_PAGE
GET_HOST_PAGE4
GET_HOST_PAGE6
INSERT_HOST_NON_UNIQUE_IP
INSERT_HOST_UNIQUE_IP
INSERT_V6_RESRV_NON_UNIQUE
INSERT_V6_RESRV_UNIQUE
INSERT_V4_HOST_OPTION
INSERT_V6_HOST_OPTION
DEL_HOST_ADDR4
DEL_HOST_ADDR6
DEL_HOST_SUBID4_ID
DEL_HOST_SUBID6_ID
NUM_STATEMENTS

Definition at line 2088 of file mysql_host_data_source.cc.

Constructor & Destructor Documentation

◆ MySqlHostDataSourceImpl()

isc::dhcp::MySqlHostDataSourceImpl::MySqlHostDataSourceImpl ( const DatabaseConnection::ParameterMap & parameters )

Constructor.

This constructor opens database connection and initializes prepared statements used in the queries.

Definition at line 2875 of file mysql_host_data_source.cc.

References createContext(), dbReconnect(), isc::db::MySqlConnection::ensureSchemaVersion(), pool_, and timer_name_.

Here is the call graph for this function:

◆ ~MySqlHostDataSourceImpl()

isc::dhcp::MySqlHostDataSourceImpl::~MySqlHostDataSourceImpl ( )

Destructor.

Definition at line 2949 of file mysql_host_data_source.cc.

Member Function Documentation

◆ addOption()

void isc::dhcp::MySqlHostDataSourceImpl::addOption	(	MySqlHostContextPtr &	ctx,
		const MySqlHostDataSourceImpl::StatementIndex &	stindex,
		const OptionDescriptor &	opt_desc,
		const std::string &	opt_space,
		const Optional< SubnetID > &	subnet_id,
		const HostID &	host_id
	)

Inserts a single DHCP option into the database.

Parameters

ctx	Context
stindex	Index of a statement being executed.
opt_desc	Option descriptor holding information about an option to be inserted into the database.
opt_space	Option space name.
subnet_id	Subnet identifier.
host_id	Host identifier.

Definition at line 3097 of file mysql_host_data_source.cc.

References addStatement().

Referenced by addOptions().

Here is the call graph for this function:

◆ addOptions()

void isc::dhcp::MySqlHostDataSourceImpl::addOptions	(	MySqlHostContextPtr &	ctx,
		const StatementIndex &	stindex,
		const ConstCfgOptionPtr &	options_cfg,
		const uint64_t	host_id
	)

Inserts multiple options into the database.

Parameters

ctx	Context
stindex	Index of a statement being executed.
options_cfg	An object holding a collection of options to be inserted into the database.
host_id	Host identifier retrieved using `mysql_insert_id`.

Definition at line 3109 of file mysql_host_data_source.cc.

References addOption().

Here is the call graph for this function:

◆ addResv()

void isc::dhcp::MySqlHostDataSourceImpl::addResv	(	MySqlHostContextPtr &	ctx,
		const IPv6Resrv &	resv,
		const HostID &	id
	)

Inserts IPv6 Reservation into ipv6_reservation table.

Parameters

ctx	Context
resv	IPv6 Reservation to be added
id	ID of a host owning this reservation

Definition at line 3087 of file mysql_host_data_source.cc.

References addStatement(), INSERT_V6_RESRV_NON_UNIQUE, INSERT_V6_RESRV_UNIQUE, and ip_reservations_unique_.

Here is the call graph for this function:

◆ addStatement()

void isc::dhcp::MySqlHostDataSourceImpl::addStatement	(	MySqlHostContextPtr &	ctx,
		MySqlHostDataSourceImpl::StatementIndex	stindex,
		std::vector< MYSQL_BIND > &	bind
	)

Executes statements which inserts a row into one of the tables.

Parameters

ctx	Context
stindex	Index of a statement being executed.
bind	Vector of MYSQL_BIND objects to be used when making the query.

Exceptions

isc::db::DuplicateEntry Database throws duplicate entry error

Definition at line 3036 of file mysql_host_data_source.cc.

References checkError(), isc_throw, and isc::db::MysqlExecuteStatement().

Referenced by addOption(), and addResv().

Here is the call graph for this function:

◆ checkError()

void isc::dhcp::MySqlHostDataSourceImpl::checkError	(	MySqlHostContextPtr &	ctx,
		const int	status,
		const StatementIndex	index,
		const char *	what
	)		const

Check Error and Throw Exception.

This method invokes db::MySqlConnection::checkError.

Parameters

ctx	Context
status	Status code: non-zero implies an error
index	Index of statement that caused the error
what	High-level description of the error

Exceptions

isc::dhcp::DbOperationError An operation on the open database has failed.

Definition at line 3133 of file mysql_host_data_source.cc.

Referenced by addStatement(), delStatement(), and getHostCollection().

◆ checkReadOnly()

void isc::dhcp::MySqlHostDataSourceImpl::checkReadOnly ( MySqlHostContextPtr & ctx ) const

Throws exception if database is read only.

This method should be called by the methods which write to the database. If the backend is operating in read-only mode this method will throw exception.

Parameters

ctx Context

Exceptions

DbReadOnly if backend is operating in read only mode.

Definition at line 3250 of file mysql_host_data_source.cc.

References isc_throw.

◆ createContext()

MySqlHostContextPtr isc::dhcp::MySqlHostDataSourceImpl::createContext ( ) const

Create a new context.

The database is opened with all the SQL commands pre-compiled.

Returns: A new (never null) context.

Exceptions

isc::dhcp::NoDatabaseName	Mandatory database name not given.
isc::db::DbOperationError	An operation on the open database has failed.

Definition at line 2895 of file mysql_host_data_source.cc.

References dbReconnect(), isc::dhcp::DHCPSRV_DBG_TRACE, isc::dhcp::dhcpsrv_logger, isc::dhcp::DHCPSRV_MYSQL_HOST_DB_READONLY, isc::dhcp::DHCPSRV_MYSQL_NO_TLS, isc::dhcp::DHCPSRV_MYSQL_TLS_CIPHER, isc::db::DatabaseConnection::getIOService(), LOG_DEBUG, LOG_ERROR, LOG_INFO, parameters_, timer_name_, and WRITE_STMTS_BEGIN.

Referenced by isc::dhcp::MySqlHostDataSource::MySqlHostContextAlloc::MySqlHostContextAlloc(), and MySqlHostDataSourceImpl().

Here is the call graph for this function:

◆ dbReconnect()

bool isc::dhcp::MySqlHostDataSourceImpl::dbReconnect ( ReconnectCtlPtr db_reconnect_ctl )

static

Attempts to reconnect the server to the host DB backend manager.

This is a self-rescheduling function that attempts to reconnect to the server's host DB backends after connectivity to one or more have been lost. Upon entry it will attempt to reconnect via HostDataSourceFactory::add. If this is successful, DHCP servicing is re-enabled and server returns to normal operation.

If reconnection fails and the maximum number of retries has not been exhausted, it will schedule a call to itself to occur at the configured retry interval. DHCP service remains disabled.

If the maximum number of retries has been exhausted an error is logged and the server shuts down.

This function is passed to the connection recovery mechanism. It will be invoked when a connection loss is detected.

Parameters

db_reconnect_ctl pointer to the ReconnectCtl containing the configured reconnect parameters.

Returns: true if connection has been recovered, false otherwise.

Definition at line 2953 of file mysql_host_data_source.cc.

References isc::dhcp::HostMgr::addBackend(), dbReconnect(), isc::dhcp::HostMgr::delBackend(), isc::dhcp::dhcpsrv_logger, isc::dhcp::DHCPSRV_MYSQL_HOST_DB_RECONNECT_ATTEMPT_FAILED, isc::dhcp::DHCPSRV_MYSQL_HOST_DB_RECONNECT_ATTEMPT_SCHEDULE, isc::dhcp::DHCPSRV_MYSQL_HOST_DB_RECONNECT_FAILED, isc::dhcp::CfgMgr::getCurrentCfg(), isc::dhcp::CfgMgr::instance(), isc::dhcp::TimerMgr::instance(), isc::db::DatabaseConnection::invokeDbFailedCallback(), isc::db::DatabaseConnection::invokeDbLostCallback(), isc::db::DatabaseConnection::invokeDbRecoveredCallback(), LOG_ERROR, LOG_INFO, isc::asiolink::IntervalTimer::ONE_SHOT, and isc::db::DatabaseConnection::parse().

Referenced by MySqlHostDataSourceImpl(), createContext(), dbReconnect(), and getVersion().

Here is the call graph for this function:

◆ delStatement()

bool isc::dhcp::MySqlHostDataSourceImpl::delStatement	(	MySqlHostContextPtr &	ctx,
		StatementIndex	stindex,
		MYSQL_BIND *	bind
	)

Executes statements that delete records.

Parameters

ctx	Context
stindex	Index of a statement being executed.
bind	Vector of MYSQL_BIND objects to be used when making the query.

Returns: true if any records were deleted, false otherwise

Definition at line 3066 of file mysql_host_data_source.cc.

References checkError(), and isc::db::MysqlExecuteStatement().

Here is the call graph for this function:

◆ getHost()

ConstHostPtr isc::dhcp::MySqlHostDataSourceImpl::getHost	(	MySqlHostContextPtr &	ctx,
		const SubnetID &	subnet_id,
		const Host::IdentifierType &	identifier_type,
		const uint8_t *	identifier_begin,
		const size_t	identifier_len,
		StatementIndex	stindex,
		boost::shared_ptr< MySqlHostExchange >	exchange
	)		const

Retrieves a host by subnet and client's unique identifier.

This method is used by both MySqlHostDataSource::get4 and MySqlHOstDataSource::get6 methods.

Parameters

ctx	Context
subnet_id	Subnet identifier.
identifier_type	Identifier type.
identifier_begin	Pointer to a beginning of a buffer containing an identifier.
identifier_len	Identifier length.
stindex	Statement index.
exchange	Pointer to the exchange object used for the particular query.

Returns: Pointer to const instance of Host or null pointer if no host found.

Definition at line 3205 of file mysql_host_data_source.cc.

References getHostCollection(), and isc::db::MLM_TRUE.

Here is the call graph for this function:

◆ getHostCollection()

void isc::dhcp::MySqlHostDataSourceImpl::getHostCollection	(	MySqlHostContextPtr &	ctx,
		StatementIndex	stindex,
		MYSQL_BIND *	bind,
		boost::shared_ptr< MySqlHostExchange >	exchange,
		ConstHostCollection &	result,
		bool	single
	)		const

Creates collection of Host objects with associated information such as IPv6 reservations and/or DHCP options.

This method performs a query which returns host information from the 'hosts' table. The query may also use LEFT JOIN clause to retrieve information from other tables, e.g. ipv6_reservations, dhcp4_options and dhcp6_options. Whether IPv6 reservations and/or options are assigned to the Host objects depends on the type of the exchange object.

Parameters

	ctx	Context
	stindex	Statement index.
	bind	Pointer to an array of MySQL bindings.
	exchange	Pointer to the exchange object used for the particular query.
[out]	result	Reference to the collection of hosts returned.
	single	A boolean value indicating if a single host is expected to be returned, or multiple hosts.

Definition at line 3141 of file mysql_host_data_source.cc.

References checkError(), isc_throw, isc::db::MLM_MYSQL_FETCH_FAILURE, isc::db::MLM_MYSQL_FETCH_SUCCESS, isc::db::MysqlExecuteStatement(), and isc::Exception::what().

Referenced by getHost().

Here is the call graph for this function:

◆ getVersion()

std::pair< uint32_t, uint32_t > isc::dhcp::MySqlHostDataSourceImpl::getVersion ( const std::string & timer_name = std::string() ) const

Returns backend version.

The method is called by the constructor before opening the database to verify that the schema version is correct.

Parameters

timer_name The DB reconnect timer name.

Returns: Version number stored in the database, as a pair of unsigned integers. "first" is the major version number, "second" the minor number.

Exceptions

isc::dhcp::DbOperationError An operation on the open database has failed.

Definition at line 3026 of file mysql_host_data_source.cc.

References dbReconnect(), isc::dhcp::DHCPSRV_DBG_TRACE_DETAIL, isc::dhcp::dhcpsrv_logger, isc::dhcp::DHCPSRV_MYSQL_HOST_DB_GET_VERSION, isc::db::DatabaseConnection::getIOService(), isc::db::MySqlConnection::getVersion(), LOG_DEBUG, and parameters_.

Here is the call graph for this function:

Member Data Documentation

◆ ip_reservations_unique_

bool isc::dhcp::MySqlHostDataSourceImpl::ip_reservations_unique_

Holds the setting whether the IP reservations must be unique or may be non-unique.

Definition at line 2327 of file mysql_host_data_source.cc.

Referenced by addResv().

◆ parameters_

DatabaseConnection::ParameterMap isc::dhcp::MySqlHostDataSourceImpl::parameters_

The parameters.

Definition at line 2323 of file mysql_host_data_source.cc.

Referenced by createContext(), and getVersion().

◆ pool_

MySqlHostContextPoolPtr isc::dhcp::MySqlHostDataSourceImpl::pool_

The pool of contexts.

Definition at line 2330 of file mysql_host_data_source.cc.

Referenced by isc::dhcp::MySqlHostDataSource::MySqlHostContextAlloc::MySqlHostContextAlloc(), and MySqlHostDataSourceImpl().

◆ timer_name_

std::string isc::dhcp::MySqlHostDataSourceImpl::timer_name_

Timer name used to register database reconnect timer.

Definition at line 2337 of file mysql_host_data_source.cc.

Referenced by MySqlHostDataSourceImpl(), and createContext().

◆ unusable_

bool isc::dhcp::MySqlHostDataSourceImpl::unusable_

Indicates if there is at least one connection that can no longer be used for normal operations.

Definition at line 2334 of file mysql_host_data_source.cc.

◆ WRITE_STMTS_BEGIN

const StatementIndex isc::dhcp::MySqlHostDataSourceImpl::WRITE_STMTS_BEGIN = INSERT_HOST_NON_UNIQUE_IP

static

Index of first statement performing write to the database.

This value is used to mark border line between queries and other statements and statements performing write operation on the database, such as INSERT, DELETE, UPDATE.

Definition at line 2124 of file mysql_host_data_source.cc.

Referenced by createContext().

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

mysql_host_data_source.cc

Public Types

Public Member Functions

Static Public Member Functions

Public Attributes

Static Public Attributes

Detailed Description

Member Enumeration Documentation

◆ StatementIndex

Constructor & Destructor Documentation

◆ MySqlHostDataSourceImpl()

◆ ~MySqlHostDataSourceImpl()

Member Function Documentation

◆ addOption()

◆ addOptions()

◆ addResv()

◆ addStatement()

◆ checkError()

◆ checkReadOnly()

◆ createContext()

◆ dbReconnect()

◆ delStatement()

◆ getHost()

◆ getHostCollection()

◆ getVersion()

Member Data Documentation

◆ ip_reservations_unique_

◆ parameters_

◆ pool_

◆ timer_name_

◆ unusable_

◆ WRITE_STMTS_BEGIN