DatabaseWorkerPool.cpp File Reference

#include "DatabaseWorkerPool.h"
#include "AdhocStatement.h"
#include "CharacterDatabase.h"
#include "Errors.h"
#include "Log.h"
#include "LoginDatabase.h"
#include "MySQLPreparedStatement.h"
#include "MySQLWorkaround.h"
#include "PCQueue.h"
#include "PreparedStatement.h"
#include "QueryCallback.h"
#include "QueryHolder.h"
#include "QueryResult.h"
#include "SQLOperation.h"
#include "Transaction.h"
#include "WorldDatabase.h"
#include <limits>
#include <mysqld_error.h>
#include <sstream>
#include <vector>

Go to the source code of this file.

Classes
class	PingOperation

Functions
bool	DatabaseIncompatibleVersion (std::string const mysqlVersion)
	Returns true if the version string given is incompatible. More...

Variables
template class AC_DATABASE_API	DatabaseWorkerPool< LoginDatabaseConnection >
template class AC_DATABASE_API	DatabaseWorkerPool< WorldDatabaseConnection >
template class AC_DATABASE_API	DatabaseWorkerPool< CharacterDatabaseConnection >

Function Documentation

DatabaseIncompatibleVersion()

bool DatabaseIncompatibleVersion

(

std::string const

mysqlVersion

)

Returns true if the version string given is incompatible.

Intended to be used with mysql_get_server_info()'s output as the source

DatabaseIncompatibleVersion("8.0.35") => false DatabaseIncompatibleVersion("5.6.6") => true

Adapted from stackoverflow response https://stackoverflow.com/a/2941508

Parameters

mysqlVersion

The output from GetServerInfo()/mysql_get_server_info()

Returns

Returns true if the Server version is incompatible

{
    // anon func to turn a version string into an array of uint8
    // "1.2.3" => [1, 2, 3]
    auto parse = [](std::string const& input)
    {
        std::vector<uint8> result;
        std::istringstream parser(input);
        result.push_back(parser.get());
        for (int i = 1; i < 3; i++)
        {
            // Skip period
            parser.get();
            // Append int from parser to output
            result.push_back(parser.get());
        }
        return result;
    };
 
    // default to values for MySQL
    uint8 offset = 0;
    std::string minVersion = MIN_MYSQL_SERVER_VERSION;
 
    auto parsedMySQLVersion = parse(mysqlVersion.substr(offset));
    auto parsedMinVersion = parse(minVersion);
 
    return std::lexicographical_compare(parsedMySQLVersion.begin(), parsedMySQLVersion.end(),
                                        parsedMinVersion.begin(), parsedMinVersion.end());
}

References MIN_MYSQL_SERVER_VERSION.

Referenced by DatabaseWorkerPool< T >::OpenConnections().

Variable Documentation

DatabaseWorkerPool< CharacterDatabaseConnection >

template class AC_DATABASE_API DatabaseWorkerPool< CharacterDatabaseConnection >

DatabaseWorkerPool< LoginDatabaseConnection >

template class AC_DATABASE_API DatabaseWorkerPool< LoginDatabaseConnection >

DatabaseWorkerPool< WorldDatabaseConnection >

template class AC_DATABASE_API DatabaseWorkerPool< WorldDatabaseConnection >