2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
42#ifndef DATABASE_MARIADB_MARIADBLIBRARY
43#define DATABASE_MARIADB_MARIADBLIBRARY
47 class MariaDBLibrary
final {
51 MariaDBLibrary&
operator=(
const MariaDBLibrary&) =
delete;
void setTimeout(const utils::Timeval &timeout)
EventReceiver(const std::string &name)
void connectionVanished()
MariaDBCommandSequence()=default
MariaDBCommandSequence & execute_async(MariaDBCommand *mariaDBCommand) final
MariaDBConnection * mariaDBConnection
void onEvent(const utils::Timeval ¤tTime) override
virtual std::string commandInfo()
virtual int commandContinue(int status)=0
void setMariaDBConnection(MariaDBConnection *mariaDBConnection)
virtual void commandError(const std::string &errorString, unsigned int errorNumber)=0
virtual int commandStart()=0
virtual bool commandCompleted()=0
void unobservedEvent() override
MariaDBCommandStartEvent commandStartEvent
void writeTimeout() override
void outOfBandTimeout() override
MariaDBConnection(MariaDBClient *mariaDBClient, const MariaDBConnectionDetails &connectionDetails, const std::function< void(const MariaDBState &)> &onStateChanged)
void outOfBandEvent() override
void writeEvent() override
MariaDBCommand * currentCommand
MariaDBCommandSequence & execute_async(MariaDBCommandSequence &&commandSequence)
~MariaDBConnection() override
const std::string connectionName
void readTimeout() override
void commandContinue(int status)
void commandStart(const utils::Timeval ¤tTime)
void execute_sync(MariaDBCommand *mariaDBCommand)
MariaDBClient * mariaDBClient
void readEvent() override
void checkStatus(int status)
MariaDBLibrary(const MariaDBLibrary &)=delete
static void ensureInitialized()
MariaDBLibrary & operator=(const MariaDBLibrary &)=delete
static Timeval currentTime()
static const utils::Timeval DISABLE
static const utils::Timeval DEFAULT
std::string connectionName