#include <DBServer_MySQL.h>

Граф наследования:uniset::DBServer_MySQL:

Граф связей класса uniset::DBServer_MySQL:

[см. легенду]

Открытые члены
	DBServer_MySQL (uniset::ObjectId id, xmlNode *cnode, const std::string &prefix)
	DBServer_MySQL (const std::string &prefix)
std::shared_ptr< LogAgregator >	logAggregator ()
std::shared_ptr< DebugStream >	log ()
Открытые члены унаследованные от uniset::DBServer
	DBServer (uniset::ObjectId id, const std::string &prefix="db")
	DBServer (const std::string &prefix="db")
virtual uniset::SimpleInfo *	getInfo (const char *userparam="") override
Открытые члены унаследованные от uniset::UniSetObject
	UniSetObject (const std::string &name, const std::string &section)
	UniSetObject (uniset::ObjectId id)
virtual CORBA::Boolean	exist () override
virtual uniset::ObjectId	getId () override
const uniset::ObjectId	getId () const
std::string	getName () const
virtual uniset::ObjectType	getType () override
const std::string	getStrType ()
virtual uniset::SimpleInfo *	apiRequest (const char *query) override
virtual void	push (const uniset::TransportMessage &msg) override
	поместить сообщение в очередь
virtual void	pushMessage (const char *msg, ::CORBA::Long mtype, const ::uniset::Timespec &tm, const ::uniset::ProducerInfo &pi, ::CORBA::Long priority, ::CORBA::Long consumer) override
	поместить текстовое сообщение в очередь
virtual Poco::JSON::Object::Ptr	httpRequest (const UHttp::HttpRequestContext &ctx) override
virtual Poco::JSON::Object::Ptr	httpHelp (const Poco::URI::QueryParameters &p) override
uniset::ObjectPtr	getRef () const
std::shared_ptr< UniSetObject >	get_ptr ()
virtual timeout_t	askTimer (uniset::TimerId timerid, timeout_t timeMS, clock_t ticks=-1, uniset::Message::Priority p=uniset::Message::High) override
Открытые члены унаследованные от uniset::LT_Object
timeout_t	checkTimers (UniSetObject *obj)
timeout_t	getTimeInterval (uniset::TimerId timerid) const
timeout_t	getTimeLeft (uniset::TimerId timerid) const

Открытые статические члены
static std::shared_ptr< DBServer_MySQL >	init_dbserver (int argc, const char const argv, const std::string &prefix="mysql")
static void	help_print (int argc, const char const argv)
Открытые статические члены унаследованные от uniset::DBServer
static std::string	help_print ()

Защищенные типы
enum	Timers { PingTimer , ReconnectTimer , lastNumberOfTimer }
typedef std::unordered_map< int, std::string >	DBTableMap
typedef std::queue< std::string >	QueryBuffer
Защищенные типы унаследованные от uniset::LT_Object
typedef std::deque< TimerInfo >	TimersList

Защищенные члены
virtual void	initDBServer () override
virtual void	onReconnect (const std::unique_ptr< MySQLInterface > &db)
virtual void	timerInfo (const uniset::TimerMessage *tm) override
virtual void	sysCommand (const uniset::SystemMessage *sm) override
virtual void	sensorInfo (const uniset::SensorMessage *sm) override
virtual void	confirmInfo (const uniset::ConfirmMessage *cmsg) override
virtual void	onTextMessage (const uniset::TextMessage *msg) override
virtual std::string	getMonitInfo (const std::string &params) override
bool	writeToBase (const std::string &query)
std::string	tblName (int key)
void	flushBuffer ()
Защищенные члены унаследованные от uniset::DBServer
virtual void	processingMessage (const uniset::VoidMessage *msg) override
virtual bool	activateObject () override
	Активизация объекта (переопределяется для необходимых действий после активизации).
Защищенные члены унаследованные от uniset::UniSetObject
VoidMessagePtr	receiveMessage ()
VoidMessagePtr	waitMessage (timeout_t msec=UniSetTimer::WaitUpTime)
void	termWaiting ()
size_t	countMessages ()
size_t	getCountOfLostMessages () const
virtual bool	deactivateObject ()
	Деактивация объекта (переопределяется для необходимых действий при завершении работы).
void	uterminate ()
void	thread (bool create)
void	offThread ()
void	onThread ()
virtual void	callback ()
void	setID (uniset::ObjectId id)
void	setThreadPriority (Poco::Thread::Priority p)
void	setMaxSizeOfMessageQueue (size_t s)
size_t	getMaxSizeOfMessageQueue () const
bool	isActive () const
void	setActive (bool set)
virtual Poco::JSON::Object::Ptr	httpGetMyInfo (Poco::JSON::Object::Ptr root)
Poco::JSON::Object::Ptr	request_configure (const std::string &req, const Poco::URI::QueryParameters &p)
Poco::JSON::Object::Ptr	request_configure_get (const std::string &req, const Poco::URI::QueryParameters &p)
Poco::JSON::Object::Ptr	request_configure_by_name (const std::string &name, const std::string &props)
Poco::JSON::Object::Ptr	request_params (const std::string &req, const Poco::URI::QueryParameters &p)
virtual Poco::JSON::Object::Ptr	request_params_get (const std::string &req, const Poco::URI::QueryParameters &p)
virtual Poco::JSON::Object::Ptr	request_params_set (const std::string &req, const Poco::URI::QueryParameters &p)
Защищенные члены унаследованные от uniset::LT_Object
virtual std::string	getTimerName (int id) const
TimersList	getTimersList () const

Защищенные данные
std::unique_ptr< MySQLInterface >	db
int	PingTime = { 15000 }
int	ReconnectTime = { 30000 }
bool	connect_ok = { false }
bool	activate = { false }
QueryBuffer	qbuf
size_t	qbufSize = { 200 }
bool	lastRemove = { false }
uniset::uniset_rwmutex	mqbuf
Защищенные данные унаследованные от uniset::DBServer
std::shared_ptr< LogAgregator >	loga
std::shared_ptr< DebugStream >	dblog
std::shared_ptr< LogServer >	logserv
std::string	logserv_host = {""}
int	logserv_port = {0}
const std::string	prefix = { "db" }
Защищенные данные унаследованные от uniset::UniSetObject
std::shared_ptr< UInterface >	ui
std::string	myname
std::weak_ptr< UniSetManager >	mymngr
Защищенные данные унаследованные от uniset::LT_Object
timeout_t	sleepTime

Подробное описание

Реализация DBServer для MySQL

Перечисления

◆ Timers

enum uniset::DBServer_MySQL::Timers

protected

Элементы перечислений
PingTimer	таймер на пере одическую проверку соединения с сервером БД
ReconnectTimer	таймер на повторную попытку соединения с сервером БД (или восстановления связи)

Методы

◆ confirmInfo()

void DBServer_MySQL::confirmInfo ( const uniset::ConfirmMessage * cmsg )

overrideprotectedvirtual

Переопределяет метод предка uniset::DBServer.

◆ getMonitInfo()

std::string DBServer_MySQL::getMonitInfo ( const std::string & params )

overrideprotectedvirtual

Переопределяет метод предка uniset::DBServer.

◆ help_print()

void DBServer_MySQL::help_print	(	int	argc,
		const char const	argv )

static

глобальная функция для вывода help-а

◆ init_dbserver()

std::shared_ptr< DBServer_MySQL > DBServer_MySQL::init_dbserver	(	int	argc,
		const char const	argv,
		const std::string &	prefix = "mysql" )

static

глобальная функция для инициализации объекта

◆ initDBServer()

void DBServer_MySQL::initDBServer ( )

overrideprotectedvirtual

Переопределяет метод предка uniset::DBServer.

◆ onTextMessage()

void DBServer_MySQL::onTextMessage ( const uniset::TextMessage * msg )

overrideprotectedvirtual

Переопределяет метод предка uniset::UniSetObject.

◆ sensorInfo()

void DBServer_MySQL::sensorInfo ( const uniset::SensorMessage * sm )

overrideprotectedvirtual

Переопределяет метод предка uniset::UniSetObject.

◆ sysCommand()

void DBServer_MySQL::sysCommand ( const uniset::SystemMessage * sm )

overrideprotectedvirtual

Переопределяет метод предка uniset::DBServer.

◆ timerInfo()

void DBServer_MySQL::timerInfo ( const uniset::TimerMessage * tm )

overrideprotectedvirtual

Переопределяет метод предка uniset::UniSetObject.

Данные класса

◆ activate

bool uniset::DBServer_MySQL::activate = { false }

protected

признак наличия соединения с сервером БД

Открытые члены

Открытые статические члены

Защищенные типы

Защищенные члены

Защищенные данные

Подробное описание

Перечисления

◆ Timers

Методы

◆ confirmInfo()

◆ getMonitInfo()

◆ help_print()

◆ init_dbserver()

◆ initDBServer()

◆ onTextMessage()

◆ sensorInfo()

◆ sysCommand()

◆ timerInfo()

Данные класса

◆ activate