The DBServer_PostgreSQL class Реализация работы с PostgreSQL. Т.к. основная работа сервера - это частая запись данных, то сделана следующая оптимизация: Создаётся insert-буфер настраиваемого размера (ibufMaxSize). Как только буфер заполняется, он пишется в БД одним "оптимизированным" запросом. Помимо этого буфер скидывается, если прошло ibufSyncTimeout мсек или если пришёл запрос на UPDATE данных. Подробнее...

#include <DBServer_PostgreSQL.h>

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

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

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

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

Открытые члены
	DBServer_PostgreSQL (uniset::ObjectId id, xmlNode *cnode, const std::string &prefix)
std::shared_ptr< LogAgregator >	logAggregator ()
std::shared_ptr< DebugStream >	log ()
bool	isConnectOk () const
Открытые члены унаследованные от 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_PostgreSQL >	init_dbserver (int argc, const char const argv, const std::shared_ptr< uniset::SharedMemory > &ic=nullptr, const std::string &prefix="pgsql")
static void	help_print (int argc, const char const argv)
Открытые статические члены унаследованные от uniset::DBServer
static std::string	help_print ()

Статические открытые данные
static constexpr std::string_view	tblcols = { "date,time,time_usec,sensor_id,value,node" }

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

Защищенные члены
virtual void	initDBServer () override
virtual void	onReconnect (std::unique_ptr< PostgreSQLInterface > &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 bool	deactivateObject () override
	Деактивация объекта (переопределяется для необходимых действий при завершении работы).
virtual std::string	getMonitInfo (const std::string &params) override
bool	writeToBase (const std::string &query)
std::string	tblName (int key)
void	flushBuffer ()
void	flushInsertBuffer ()
virtual void	addRecord (const PostgreSQLInterface::Record &&rec)
virtual bool	writeInsertBufferToDB (const std::string &table, std::string_view colname, const InsertBuffer &ibuf)
Защищенные члены унаследованные от 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
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< PostgreSQLInterface >	db
Защищенные данные унаследованные от 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

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

The DBServer_PostgreSQL class Реализация работы с PostgreSQL. Т.к. основная работа сервера - это частая запись данных, то сделана следующая оптимизация: Создаётся insert-буфер настраиваемого размера (ibufMaxSize). Как только буфер заполняется, он пишется в БД одним "оптимизированным" запросом. Помимо этого буфер скидывается, если прошло ibufSyncTimeout мсек или если пришёл запрос на UPDATE данных.

В случае если буфер переполняется (например нет связи с БД), то он чистится. При этом сколько записей удалять определяется коэффициентом ibufOverflowCleanFactor={0...1}. А также флаг lastRemove определяет удалять с конца или начала очереди.

Предупреждения: Следует иметь ввиду, что чтобы не было постоянных "перевыделений памяти" буфер сделан на основе vector и в начале работы в памяти сразу(!) резервируется место под буфер. Во первых надо иметь ввиду, что буфер - это то, что потеряется если вдруг произойдёт сбой по питанию или программа вылетит. Поэтому если он большой, то будет потеряно много данных. И второе, т.к. это vector - то идёт выделение "непрерывного куска памяти", поэтому у ОС могут быть проблемы найти "большой непрерывный кусок". Тем не менее реализация сделана на vector-е чтобы избежать лишних "перевыделений" (и сегментации) памяти во время работы.; Временно, для обратной совместимости поле 'time_usec' в таблицах оставлено с таким названием, хотя фактически туда сейчас сохраняется значение в наносекундах!

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

◆ Timers

enum uniset::DBServer_PostgreSQL::Timers

protected

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

Методы

◆ confirmInfo()

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

overrideprotectedvirtual

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

◆ deactivateObject()

bool DBServer_PostgreSQL::deactivateObject ( )

overrideprotectedvirtual

Деактивация объекта (переопределяется для необходимых действий при завершении работы).

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

◆ getMonitInfo()

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

overrideprotectedvirtual

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

◆ help_print()

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

static

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

◆ init_dbserver()

std::shared_ptr< DBServer_PostgreSQL > DBServer_PostgreSQL::init_dbserver	(	int	argc,
		const char const	argv,
		const std::shared_ptr< uniset::SharedMemory > &	ic = nullptr,
		const std::string &	prefix = "pgsql" )

static

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

◆ initDBServer()

void DBServer_PostgreSQL::initDBServer ( )

overrideprotectedvirtual

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

◆ onTextMessage()

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

overrideprotectedvirtual

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

◆ sensorInfo()

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

overrideprotectedvirtual

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

◆ sysCommand()

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

overrideprotectedvirtual

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

◆ timerInfo()

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

overrideprotectedvirtual

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

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

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

Статические открытые данные

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

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

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

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

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

◆ Timers

Методы

◆ confirmInfo()

◆ deactivateObject()

◆ getMonitInfo()

◆ help_print()

◆ init_dbserver()

◆ initDBServer()

◆ onTextMessage()

◆ sensorInfo()

◆ sysCommand()

◆ timerInfo()