Mysql_connection Class Reference

Mysql client connection wrapper class to connect MySQL, execute SQL query and fetch query results. More...

#include <rpl_mysql_connect.h>

Public Member Functions
	Mysql_connection (THD *thd, Master_info *mi, std::string host, uint port, std::string network_namespace, bool is_io_thread=false)
	Mysql_connection class constructor. More...
	~Mysql_connection ()
	Mysql_connection class destructor. More...
bool	is_connected ()
	Determine if its connected to mysql server. More...
bool	reconnect ()
	Re-connect to mysql server. More...
MYSQL *	get_mysql ()
	Get Mysql client connection object. More...
MYSQL_RES_TUPLE	execute_query (std::string query) const
	Execute given sql query on connected mysql server. More...
bool	version_compatible () const
	Checks whether the connected source server's version is compatible with the replica's version. More...

Private Member Functions
bool	safe_connect (THD *thd, Master_info *mi, std::string host, uint port, std::string network_namespace)
	To connect to mysql server. More...
bool	safe_reconnect (THD *thd, Master_info *mi, bool suppress_warnings, std::string host, uint port)
	To re-connect to mysql server. More...

Private Attributes
MYSQL *	m_conn {nullptr}
bool	m_connected {false}
bool	m_init {false}
THD *	m_thd {nullptr}
Master_info *	m_mi {nullptr}
std::string	m_host
uint	m_port {0}
std::string	m_network_namespace
bool	m_is_io_thread {false}

Detailed Description

Mysql client connection wrapper class to connect MySQL, execute SQL query and fetch query results.

Constructor & Destructor Documentation

Mysql_connection()

Mysql_connection::Mysql_connection	(	THD *	thd,
		Master_info *	mi,
		std::string	host,
		uint	port,
		std::string	network_namespace,
		bool	is_io_thread = false
	)

Mysql_connection class constructor.

Parameters

[in]	thd	The thread object.
[in]	mi	the pointer to the Master_info object.
[in]	host	the host or ip address for mysql client connection.
[in]	port	the port for mysql client connection.
[in]	network_namespace	the network_namespace for mysql client connection.
[in]	is_io_thread	to determine its IO or Monitor IO thread.

~Mysql_connection()

Mysql_connection::~Mysql_connection

(

)

Mysql_connection class destructor.

Member Function Documentation

execute_query()

MYSQL_RES_TUPLE Mysql_connection::execute_query

(

std::string

query

)

const

Execute given sql query on connected mysql server.

Parameters

[in]

query

sql query to execute.

Returns

result of executed query in rows<cols<result>> format where rows and cols both are std::vector and result is std::string. So other then character strings need to be converted.

get_mysql()

MYSQL * Mysql_connection::get_mysql ( )

inline

Get Mysql client connection object.

Returns

Mysql client connection object.

is_connected()

bool Mysql_connection::is_connected

(

)

Determine if its connected to mysql server.

Returns

true if connected, false otherwise.

reconnect()

bool Mysql_connection::reconnect

(

)

Re-connect to mysql server.

Returns

true if successfully reconnected, false otherwise.

safe_connect()

bool Mysql_connection::safe_connect ( THD *  thd, Master_info *  mi, std::string  host, uint  port, std::string  network_namespace  )

private

To connect to mysql server.

Parameters

[in]	thd	The thread object.
[in]	mi	the pointer to the Master_info object.
[in]	host	the host or ip address for mysql client connection.
[in]	port	the port for mysql client connection.
[in]	network_namespace	the network_namespace for mysql client connection.

safe_reconnect()

bool Mysql_connection::safe_reconnect ( THD *  thd, Master_info *  mi, bool  suppress_warnings, std::string  host, uint  port  )

private

To re-connect to mysql server.

Parameters

[in]	thd	The thread object.
[in]	mi	the pointer to the Master_info object.
[in]	suppress_warnings	Suppress reconnect warning
[in]	host	the host or ip address for mysql client connection.
[in]	port	the port for mysql client connection.

version_compatible()

bool Mysql_connection::version_compatible

(

)

const

Checks whether the connected source server's version is compatible with the replica's version.

Return values

true	The source and replica versions are compatible. false The versions are incompatible or the connection is not initialized.

Member Data Documentation

m_conn

MYSQL* Mysql_connection::m_conn {nullptr}

private

m_connected

bool Mysql_connection::m_connected {false}

private

m_host

std::string Mysql_connection::m_host

private

m_init

bool Mysql_connection::m_init {false}

private

m_is_io_thread

bool Mysql_connection::m_is_io_thread {false}

private

m_mi

Master_info* Mysql_connection::m_mi {nullptr}

private

m_network_namespace

std::string Mysql_connection::m_network_namespace

private

m_port

uint Mysql_connection::m_port {0}

private

m_thd

THD* Mysql_connection::m_thd {nullptr}

private

---

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

• sql/rpl_mysql_connect.h
• sql/rpl_mysql_connect.cc