Интеграция MetaTrader 5 с PostgreSQL через libpq.dll в MQL5

//+------------------------------------------------------------------+
//| PostgreSQL_Example.mq5 | 
//| Copyright 2023, Finfluct.com | 
//| https://finfluct.com | 
//+------------------------------------------------------------------+
#property copyright "Copyright 2023, Finfluct.com"
#property link "https://finfluct.com"
#property version "1.00"
#property description "Пример интеграции MT5 с PostgreSQL через libpq.dll"

//--- Включаем наш заголовочный файл с объявлениями функций libpq
#include 

//--- Входные параметры для подключения к базе данных
input string Inp_DBHost = "localhost"; // Хост базы данных
input int Inp_DBPort = 5432; // Порт базы данных
input string Inp_DBName = "mt5_data"; // Имя базы данных
input string Inp_DBUser = "mt5_user"; // Пользователь базы данных
input string Inp_DBPassword = "mt5_password"; // Пароль пользователя
input string Inp_TableName = "trade_history"; // Имя таблицы для записи данных

//--- Глобальная переменная для хранения указателя на соединение с БД
PGconn g_conn = 0;

//+------------------------------------------------------------------+
//| Инициализация эксперта | 
//+------------------------------------------------------------------+
int OnInit()
 {
  // Формируем строку подключения
  string conninfo = StringFormat("host=%s port=%d dbname=%s user=%s password=%s",
                                 Inp_DBHost, Inp_DBPort, Inp_DBName, Inp_DBUser, Inp_DBPassword);

  // Устанавливаем соединение с PostgreSQL
  g_conn = PQconnectdb(conninfo);

  // Проверяем успешность соединения
  if (g_conn == 0)
   {
    Print("Ошибка: Не удалось подключиться к PostgreSQL. Проверьте параметры и libpq.dll.");
    return INIT_FAILED;
   }

  // Проверяем статус соединения (PQstatus не импортирован, используем PQerrorMessage для проверки)
  // Если PQerrorMessage возвращает непустую строку, значит есть ошибка
  if (StringLen(PQerrorMessage(g_conn)) > 0)
   {
    Print("Ошибка подключения к PostgreSQL: ", PQerrorMessage(g_conn));
    PQfinish(g_conn);
    g_conn = 0;
    return INIT_FAILED;
   }

  Print("Успешно подключено к PostgreSQL.");

  // Создаем таблицу, если она не существует
  string create_table_sql = StringFormat(
    "CREATE TABLE IF NOT EXISTS %s (",
    Inp_TableName
    ) +
    "  id SERIAL PRIMARY KEY,"
    "  symbol VARCHAR(16) NOT NULL,"
    "  ticket BIGINT NOT NULL,"
    "  order_type VARCHAR(10) NOT NULL,"
    "  volume DOUBLE PRECISION NOT NULL,"
    "  price DOUBLE PRECISION NOT NULL,"
    "  time_open TIMESTAMP WITH TIME ZONE NOT NULL,"
    "  comment VARCHAR(255)"
    ");";

  PGresult res = PQexec(g_conn, create_table_sql);
  if (PQresultStatus(res) != PGRES_COMMAND_OK)
   {
    Print("Ошибка при создании таблицы: ", PQerrorMessage(g_conn));
    PQclear(res);
    PQfinish(g_conn);
    g_conn = 0;
    return INIT_FAILED;
   }
  Print("Таблица '", Inp_TableName, "' проверена/создана.");
  PQclear(res);

  // Пример записи данных (можно вызывать в OnTick или OnTrade)
  // Для демонстрации, запишем текущую цену BID/ASK в таблицу
  MqlTick tick;
  if (SymbolInfoTick(_Symbol, tick))
   {
    string insert_sql = StringFormat(
      "INSERT INTO %s (symbol, ticket, order_type, volume, price, time_open, comment) VALUES ('%s', %d, '%s', %f, %f, NOW(), '%s');",
      Inp_TableName,
      _Symbol,
      (long)TimeCurrent(), // Используем текущее время как 'ticket' для примера
      "DEMO_BUY",
      0.1,
      tick.bid,
      "Demo entry"
      );

    res = PQexec(g_conn, insert_sql);
    if (PQresultStatus(res) != PGRES_COMMAND_OK)
     {
      Print("Ошибка при вставке данных: ", PQerrorMessage(g_conn));
     }
    else
     {
      Print("Данные успешно вставлены в таблицу '", Inp_TableName, "'.");
     }
    PQclear(res);
   }

  // Пример чтения данных
  string select_sql = StringFormat("SELECT id, symbol, price, time_open FROM %s ORDER BY time_open DESC LIMIT 5;", Inp_TableName);
  res = PQexec(g_conn, select_sql);

  if (PQresultStatus(res) == PGRES_TUPLES_OK)
   {
    int rows = PQntuples(res);
    int cols = PQnfields(res);
    Print("--- Последние 5 записей из '", Inp_TableName, "' ---");
    for (int r = 0; r < rows; r++)
     {
      string row_data = "";
      for (int c = 0; c < cols; c++)
       {
        row_data += StringFormat("%s: %s ", PQfname(res, c), PQgetvalue(res, r, c));
       }
      Print(row_data);
     }
   }
  else
   {
    Print("Ошибка при чтении данных: ", PQerrorMessage(g_conn));
   }
  PQclear(res);

  return INIT_SUCCEEDED;
 }

//+------------------------------------------------------------------+
//| Деинициализация эксперта | 
//+------------------------------------------------------------------+
void OnDeinit(const int reason)
 {
  // Закрываем соединение с базой данных при деинициализации
  if (g_conn != 0)
   {
    PQfinish(g_conn);
    g_conn = 0;
    Print("Соединение с PostgreSQL закрыто.");
   }
 }

//+------------------------------------------------------------------+
//| OnTick функция | 
//+------------------------------------------------------------------+
void OnTick()
 {
  // В реальном приложении здесь можно записывать данные по каждому тику
  // или выполнять другие операции с БД. Для примера, мы сделали это в OnInit.
 }

//+------------------------------------------------------------------+
//| OnTrade функция | 
//+------------------------------------------------------------------+
void OnTrade()
 {
  // Здесь можно записывать информацию о каждой торговой операции в БД.
  // Например, для анализа эффективности алгоритмов, таких как описанный в статье 
  // MQL4: Алгоритм Частичного Закрытия Сетки для Снижения Просадки (Partial Grid Close),
  // или для сбора данных для мультивалютного тестирования, как в 
  // Мультивалютное тестирование в MT5: обход ограничений тестера.
 }