#include <MySQLConnection.h>

Inheritance diagram for MySQLConnection:

Public Member Functions
	MySQLConnection (MySQLConnectionInfo &connInfo)

	MySQLConnection (ProducerConsumerQueue< SQLOperation * > *queue, MySQLConnectionInfo &connInfo)
	Constructor for synchronous connections.

virtual	~MySQLConnection ()
	Constructor for asynchronous connections.

virtual uint32	Open ()

void	Close ()

bool	PrepareStatements ()

bool	Execute (char const *sql)

bool	Execute (PreparedStatementBase *stmt)

ResultSet *	Query (char const *sql)

PreparedResultSet *	Query (PreparedStatementBase *stmt)

bool	_Query (char const sql, MySQLResult pResult, MySQLField pFields, uint64 pRowCount, uint32 *pFieldCount)

bool	_Query (PreparedStatementBase stmt, MySQLPreparedStatement mysqlStmt, MySQLResult pResult, uint64 pRowCount, uint32 *pFieldCount)

void	BeginTransaction ()

void	RollbackTransaction ()

void	CommitTransaction ()

int	ExecuteTransaction (std::shared_ptr< TransactionBase > transaction)

size_t	EscapeString (char to, const char from, size_t length)

void	Ping ()

uint32	GetLastError ()

Protected Types
typedef std::vector< std::unique_ptr< MySQLPreparedStatement > >	PreparedStatementContainer

Protected Member Functions
bool	LockIfReady ()

void	Unlock ()
	Called by parent databasepool. Will let other threads access this connection.

uint32	GetServerVersion () const

MySQLPreparedStatement *	GetPreparedStatement (uint32 index)

void	PrepareStatement (uint32 index, std::string const &sql, ConnectionFlags flags)

virtual void	DoPrepareStatements ()=0

Protected Attributes
PreparedStatementContainer	m_stmts

bool	m_reconnecting
	PreparedStatements storage.

bool	m_prepareError
	Are we reconnecting?

Private Member Functions
bool	_HandleMySQLErrno (uint32 errNo, uint8 attempts=5)
	Was there any error while preparing statements?

	MySQLConnection (MySQLConnection const &right)=delete

MySQLConnection &	operator= (MySQLConnection const &right)=delete

Private Attributes
ProducerConsumerQueue< SQLOperation * > *	m_queue

std::unique_ptr< DatabaseWorker >	m_worker
	Queue shared with other asynchronous connections.

MySQLHandle *	m_Mysql
	Core worker task.

MySQLConnectionInfo &	m_connectionInfo
	MySQL Handle.

ConnectionFlags	m_connectionFlags
	Connection info (used for logging)

std::mutex	m_Mutex
	Connection flags (for preparing relevant statements)

Friends
template<class T >
class	DatabaseWorkerPool

class	PingOperation

Detailed Description

Definition at line 55 of file MySQLConnection.h.

Member Typedef Documentation

◆ PreparedStatementContainer

typedef std::vector<std::unique_ptr<MySQLPreparedStatement> > MySQLConnection::PreparedStatementContainer

protected

Definition at line 100 of file MySQLConnection.h.

Constructor & Destructor Documentation

◆ MySQLConnection() [1/3]

MySQLConnection::MySQLConnection ( MySQLConnectionInfo & connInfo )

Definition at line 50 of file MySQLConnection.cpp.

◆ MySQLConnection() [2/3]

MySQLConnection::MySQLConnection	(	ProducerConsumerQueue< SQLOperation * > *	queue,
		MySQLConnectionInfo &	connInfo
	)

Constructor for synchronous connections.

Definition at line 58 of file MySQLConnection.cpp.

◆ ~MySQLConnection()

MySQLConnection::~MySQLConnection ( )

virtual

Constructor for asynchronous connections.

Definition at line 69 of file MySQLConnection.cpp.

Here is the call graph for this function:

◆ MySQLConnection() [3/3]

MySQLConnection::MySQLConnection ( MySQLConnection const & right )

privatedelete

Member Function Documentation

◆ _HandleMySQLErrno()

bool MySQLConnection::_HandleMySQLErrno	(	uint32	errNo,
		uint8	attempts = `5`
	)

private

Was there any error while preparing statements?

Definition at line 531 of file MySQLConnection.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ _Query() [1/2]

bool MySQLConnection::_Query	(	char const *	sql,
		MySQLResult **	pResult,
		MySQLField **	pFields,
		uint64 *	pRowCount,
		uint32 *	pFieldCount
	)

Definition at line 333 of file MySQLConnection.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ _Query() [2/2]

bool MySQLConnection::_Query	(	PreparedStatementBase *	stmt,
		MySQLPreparedStatement **	mysqlStmt,
		MySQLResult **	pResult,
		uint64 *	pRowCount,
		uint32 *	pFieldCount
	)

Definition at line 263 of file MySQLConnection.cpp.

Here is the call graph for this function:

◆ BeginTransaction()

void MySQLConnection::BeginTransaction ( )

Definition at line 374 of file MySQLConnection.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Close()

void MySQLConnection::Close ( )

Definition at line 74 of file MySQLConnection.cpp.

Here is the caller graph for this function:

◆ CommitTransaction()

void MySQLConnection::CommitTransaction ( )

Definition at line 384 of file MySQLConnection.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ DoPrepareStatements()

virtual void MySQLConnection::DoPrepareStatements ( )

protectedpure virtual

Implemented in CharacterDatabaseConnection, LoginDatabaseConnection, and WorldDatabaseConnection.

Here is the caller graph for this function:

◆ EscapeString()

size_t MySQLConnection::EscapeString	(	char *	to,
		const char *	from,
		size_t	length
	)

Definition at line 440 of file MySQLConnection.cpp.

◆ Execute() [1/2]

bool MySQLConnection::Execute ( char const * sql )

Definition at line 189 of file MySQLConnection.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Execute() [2/2]

bool MySQLConnection::Execute ( PreparedStatementBase * stmt )

Definition at line 216 of file MySQLConnection.cpp.

Here is the call graph for this function:

◆ ExecuteTransaction()

int MySQLConnection::ExecuteTransaction ( std::shared_ptr< TransactionBase > transaction )

Definition at line 389 of file MySQLConnection.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ GetLastError()

uint32 MySQLConnection::GetLastError ( )

Definition at line 450 of file MySQLConnection.cpp.

Here is the caller graph for this function:

◆ GetPreparedStatement()

MySQLPreparedStatement * MySQLConnection::GetPreparedStatement ( uint32 index )

protected

Definition at line 470 of file MySQLConnection.cpp.

Here is the caller graph for this function:

◆ GetServerVersion()

uint32 MySQLConnection::GetServerVersion ( ) const

protected

Definition at line 465 of file MySQLConnection.cpp.

◆ LockIfReady()

bool MySQLConnection::LockIfReady ( )

protected

Tries to acquire lock. If lock is acquired by another thread the calling parent will just try another connection

Definition at line 455 of file MySQLConnection.cpp.

◆ Open()

uint32 MySQLConnection::Open ( )

virtual

Definition at line 88 of file MySQLConnection.cpp.

Here is the caller graph for this function:

◆ operator=()

MySQLConnection & MySQLConnection::operator= ( MySQLConnection const & right )

privatedelete

◆ Ping()

void MySQLConnection::Ping ( )

Definition at line 445 of file MySQLConnection.cpp.

Here is the caller graph for this function:

◆ PrepareStatement()

void MySQLConnection::PrepareStatement	(	uint32	index,
		std::string const &	sql,
		ConnectionFlags	flags
	)

protected

Definition at line 482 of file MySQLConnection.cpp.

Here is the caller graph for this function:

◆ PrepareStatements()

bool MySQLConnection::PrepareStatements ( )

Definition at line 183 of file MySQLConnection.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Query() [1/2]

ResultSet * MySQLConnection::Query ( char const * sql )

Definition at line 317 of file MySQLConnection.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Query() [2/2]

PreparedResultSet * MySQLConnection::Query ( PreparedStatementBase * stmt )

Definition at line 514 of file MySQLConnection.cpp.

Here is the call graph for this function:

◆ RollbackTransaction()

void MySQLConnection::RollbackTransaction ( )

Definition at line 379 of file MySQLConnection.cpp.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ Unlock()

void MySQLConnection::Unlock ( )

protected

Called by parent databasepool. Will let other threads access this connection.

Definition at line 460 of file MySQLConnection.cpp.

Friends And Related Symbol Documentation

◆ DatabaseWorkerPool

template<class T >

friend class DatabaseWorkerPool

friend

Definition at line 57 of file MySQLConnection.h.

◆ PingOperation

friend class PingOperation

friend

Definition at line 58 of file MySQLConnection.h.

Member Data Documentation

◆ m_connectionFlags

ConnectionFlags MySQLConnection::m_connectionFlags

private

Connection info (used for logging)

Definition at line 113 of file MySQLConnection.h.

◆ m_connectionInfo

MySQLConnectionInfo& MySQLConnection::m_connectionInfo

private

MySQL Handle.

Definition at line 112 of file MySQLConnection.h.

◆ m_Mutex

std::mutex MySQLConnection::m_Mutex

private

Connection flags (for preparing relevant statements)

Definition at line 114 of file MySQLConnection.h.

◆ m_Mysql

MySQLHandle* MySQLConnection::m_Mysql

private

Core worker task.

Definition at line 111 of file MySQLConnection.h.

◆ m_prepareError

bool MySQLConnection::m_prepareError

protected

Are we reconnecting?

Definition at line 104 of file MySQLConnection.h.

◆ m_queue

ProducerConsumerQueue<SQLOperation*>* MySQLConnection::m_queue

private

Definition at line 109 of file MySQLConnection.h.

◆ m_reconnecting

bool MySQLConnection::m_reconnecting

protected

PreparedStatements storage.

Definition at line 103 of file MySQLConnection.h.

◆ m_stmts

PreparedStatementContainer MySQLConnection::m_stmts

protected

Definition at line 102 of file MySQLConnection.h.

◆ m_worker

std::unique_ptr<DatabaseWorker> MySQLConnection::m_worker

private

Queue shared with other asynchronous connections.

Definition at line 110 of file MySQLConnection.h.

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

server/database/Database/MySQLConnection.h
server/database/Database/MySQLConnection.cpp

Public Member Functions

Protected Types

Protected Member Functions

Protected Attributes

Private Member Functions

Private Attributes

Friends

Detailed Description

Member Typedef Documentation

◆ PreparedStatementContainer

Constructor & Destructor Documentation

◆ MySQLConnection() [1/3]

◆ MySQLConnection() [2/3]

◆ ~MySQLConnection()

◆ MySQLConnection() [3/3]

Member Function Documentation

◆ _HandleMySQLErrno()

◆ _Query() [1/2]

◆ _Query() [2/2]

◆ BeginTransaction()

◆ Close()

◆ CommitTransaction()

◆ DoPrepareStatements()

◆ EscapeString()

◆ Execute() [1/2]

◆ Execute() [2/2]

◆ ExecuteTransaction()

◆ GetLastError()

◆ GetPreparedStatement()

◆ GetServerVersion()

◆ LockIfReady()

◆ Open()

◆ operator=()

◆ Ping()

◆ PrepareStatement()

◆ PrepareStatements()

◆ Query() [1/2]

◆ Query() [2/2]

◆ RollbackTransaction()

◆ Unlock()

Friends And Related Symbol Documentation

◆ DatabaseWorkerPool

◆ PingOperation

Member Data Documentation

◆ m_connectionFlags

◆ m_connectionInfo

◆ m_Mutex

◆ m_Mysql

◆ m_prepareError

◆ m_queue

◆ m_reconnecting

◆ m_stmts

◆ m_worker