21 #ifndef DBServer_MySQL_H_
22 #define DBServer_MySQL_H_
24 #include <unordered_map>
26 #include "UniSetTypes.h"
27 #include "MySQLInterface.h"
161 static std::shared_ptr<DBServer_MySQL>
init_dbserver(
int argc,
const char*
const* argv,
const std::string& prefix =
"mysql" );
164 static void help_print(
int argc,
const char*
const* argv );
166 inline std::shared_ptr<LogAgregator> logAggregator()
170 inline std::shared_ptr<DebugStream> log()
176 typedef std::unordered_map<int, std::string> DBTableMap;
178 virtual void initDBServer()
override;
179 virtual void initDB(
const std::unique_ptr<MySQLInterface>& db ) {};
180 virtual void initDBTableMap(DBTableMap& tblMap) {};
187 virtual std::string getMonitInfo(
const std::string& params )
override;
189 bool writeToBase(
const std::string& query );
192 inline std::string tblName(
int key )
194 return tblMap[
key].c_str();
204 std::unique_ptr<MySQLInterface> db;
205 int PingTime = { 15000 };
206 int ReconnectTime = { 30000 };
207 bool connect_ok = {
false };
211 typedef std::queue<std::string> QueryBuffer;
214 size_t qbufSize = { 200 };
215 bool lastRemove = {
false };
Definition: MessageType.h:237
Definition: DBServer_MySQL.h:154
static void help_print(int argc, const char *const *argv)
Definition: DBServer_MySQL.cc:466
Timers
Definition: DBServer_MySQL.h:198
@ PingTimer
Definition: DBServer_MySQL.h:199
@ ReconnectTimer
Definition: DBServer_MySQL.h:200
static std::shared_ptr< DBServer_MySQL > init_dbserver(int argc, const char *const *argv, const std::string &prefix="mysql")
Definition: DBServer_MySQL.cc:443
bool activate
Definition: DBServer_MySQL.h:209
Definition: DBServer.h:45
Definition: MySQLInterface.h:39
Definition: MessageType.h:127
Definition: MessageType.h:171
Definition: MessageType.h:280
Definition: MessageType.h:214
Definition: CommonEventLoop.h:15
KeyType key(const uniset::ObjectId id, const uniset::ObjectId node)
Definition: UniSetTypes.cc:746
long ObjectId
Definition: UniSetTypes_i.idl:30