如何将 MetaTrader 5 与 PostgreSQL 连接

WSL 是什么

WSL 代表 Windows Subsystem For Linux。

自 2016 年以来，您就可以在 Windows 机器上运行 Linux 发行版作为子系统，您或许尚未接触它。 不用担心！ 这里没有隐秘后门。 WSL 由微软公司开发，内置于 Windows 当中。 您只需要启用它，我们将在下面看到。

为什么选 WSL

为什么不简单地在另一台 Windows 机器上安装 Postgres，甚至最终安装虚拟机呢？

因为 Postgres 是一个 Unix 原生系统，在 *nix 系统中创建和开发。 在 Linux 上，您可轻松地安装、更新、以及维护它。 所有官方文档都是针对 Unix 系统。 您可以在 Web 上找到的大多数示例代码、片段和一般帮助都反映出这一事实。

因此，您将可以轻松地在 Linux 系统中进行开发。 WSL 正是为了这个目的而由微软开发的。

安装 WSL

来自微软文档中的先决需求：

如果系统满足此先决需求，只需以管理员身份打开 Power Shell，然后输入以下命令即可安装/启用 WSL：

此命令将在 WSL 上安装 Ubuntu，因为它是默认发行版。 

重启 Windows。

这应该是一个直截了当的过程。 如果不对，您应在上面链接的 MS 官方文档中找到一个包含最常见安装问题的部分。

重新启动后，您应该看到类似这样的内容。 继续，创建一个新的 UNIX 用户名和密码。

现在，您已经安装并运行了 WSL/Ubuntu，我们在上面安装 Postgres。

在 WSL 上，安装 Postgres

输入以下命令。

此命令将安装 Ubuntu 存储库中可用的 PostgreSQL 软件包的最后一个稳定版本。 它包括服务器，pgsql 客户端，对应的二进制文件，和一些实用程序。 这些就是您开始所需的所有内容。

如果您想安装最新的稳定版 Postgres — 通常与 Ubuntu 仓储库中的最后一个稳定版本不同 — 您可以在软件包管理器的源代码清单中包含 Postgres 的官方仓储库。 您可以在 Postgres 官方文档中找到详细说明。

如果一切正常，输入命令

应当返回所安装 Postgres 数据库的版本。

启动服务器

键入此命令来启动服务器。

默认情况下，新的 Postgres 安装仅接受来自“本地主机”的连接。 我们需要改变一下。

找到 Postgres 配置文件。

编辑配置文件，以便接受本地主机之外的连接。更改 listen_addresses 行。

找到 pg_hba 配置文件。

编辑 pg_hba.conf 文件，从而允许在 IPv4 和 IPv6 上通过密码进行身份验证。

现在，以安装时创建的默认 Postgres 用户身份访问 psql 实用程序。 其名为 'postgres'。

创建拥有 CREATEDB 权限的数据库正式用户。 到目前为止，安装时只创建了用户 “postgres”。

为 mt5_user 授权架构的所有公开权限。 如果您的 Postgres 版本低于 15，则不需要这样做。

创建一个数据库 my_remote_db，并授予 mt5_user 对其的所有权限。

连接到 Postgres

到目前为止，您应当已在远程机器上运行数据库服务器，其 IP 与 Windows 本地主机不同，并准备好接受经由网络的连接。 我们可以通过套接字或 HTTP 连接。 由于我们将与 REST API 交互，因此在本例中我们将使用后者。

我们看看是否可以在 WSL 主机上按照用户名：mt5_user，密码：123 ，连接到 my_remote_db。

输入此命令以获取 WSL 主机名（IP）。

检查 Postgres 服务器状态。 如果处于停机，则启动它。 您可以使用此命令启动、重启、或停止服务器。

在 MetaTrader 5 终端上，转到 “工具 > 选项 > 智能系统” 选项卡，并将 WSL 主机 IP 包含在允许的 IP 列表之中。

MetaTrader 5 终端分别只接受端口 80 和 443 上的 HTTP 和 HTTPS 连接。 仅限端口 80 和 443。如果您要开发自己的 API，则应考虑此安全特点。 通常，在移动到生产中的真实服务器之前，开发服务器也许会侦听非特权端口，如 3000 或 5000。 因此，为了能够将请求发送到您在上述终端设置中声明的 IP，您需要把开发时的服务器自定义端口流量重定向到 HTTP 请求的端口 80 和/或 HTTPS 请求的 443。

为保持简单起见，您将在附加的 Python 应用的自述文件中找到有关如何在 WSL 上执行此重定向的说明。

启动演示应用

鉴于本文是关于 MQL5 的，因此我不会讨论 API 实现的细节。 取而代之，我做了一个演示应用程序，您可以作为为 Python 软件包下载并安装，以便测试您的 MQL5 代码与 API 的交互。

若要启动演示应用，您只需在 WSL 上安装 Python。 它应该已在那里准备就绪了。

强烈建议您创建一个 Python 虚拟环境（'venv'）来安装该应用程序。 这将确保您系统的 Python 安装不会混乱。 体验过该应用程序之后，您只需删除虚拟环境即可。

您可以使用此命令创建虚拟环境。

故此，在您安装演示应用程序之后，为了启动您的 MQL5 开发代码，您将：

1. 启动 WSL
2. 启动 Postgres 服务器
3. 启动演示应用
4. 从演示应用的输出中获取主机名 IP
5. 将主机名 IP 添加到终端中允许的地址

WSL 和 Postgres 服务器都可以配置为在 Windows 启动时启动。

从 MQL5 插入数据

我们来尝试插入一些数据。 首先，我们的帐户信息。 在您的 MT5 终端上，创建一个新脚本，并添加以下代码。

//+------------------------------------------------------------------+
//|                                                post_acc_info.mq5 |
//|                                  Copyright 2023, MetaQuotes Ltd. |
//|                                             https://www.mql5.com |
//+------------------------------------------------------------------+
#property copyright "Copyright 2023, MetaQuotes Ltd."
#property link      "https://www.mql5.com"
#property version   "1.00"
#include <JAson.mqh> //--- include the JSON library
//+------------------------------------------------------------------+
//| Script program start function                                    |
//+------------------------------------------------------------------+
void OnStart()
  {
//--- gathering the data - Account Info
   CJAVal data;
   CJAVal acc_info;
//--- doubles
   data["balance"] =          AccountInfoDouble(ACCOUNT_BALANCE);
   data["credit"] =           AccountInfoDouble(ACCOUNT_CREDIT);
   data["profit"] =           AccountInfoDouble(ACCOUNT_PROFIT);
   data["equity"] =           AccountInfoDouble(ACCOUNT_EQUITY);
   data["margin"] =           AccountInfoDouble(ACCOUNT_MARGIN);
   data["margin_free"] =      AccountInfoDouble(ACCOUNT_MARGIN_FREE);
   data["margin_level"] =     AccountInfoDouble(ACCOUNT_MARGIN_LEVEL);
   data["margin_so_call"] =   AccountInfoDouble(ACCOUNT_MARGIN_SO_CALL);
   data["margin_so_so"] =     AccountInfoDouble(ACCOUNT_MARGIN_SO_SO);
//--- integers
   data["login"] =            AccountInfoInteger(ACCOUNT_LOGIN);
   data["leverage"] =         AccountInfoInteger(ACCOUNT_LEVERAGE);
   data["trade_allowed"] =    AccountInfoInteger(ACCOUNT_TRADE_ALLOWED);
   data["ea_allowed"] =       AccountInfoInteger(ACCOUNT_TRADE_EXPERT);
   data["trade_mode"] =       AccountInfoInteger(ACCOUNT_TRADE_MODE);
   data["margin_so_mode"] =   AccountInfoInteger(ACCOUNT_MARGIN_SO_MODE);
//-- strings
   data["company"] =          AccountInfoString(ACCOUNT_COMPANY);
   data["currency"] =         AccountInfoString(ACCOUNT_CURRENCY);
   data["name"] =             AccountInfoString(ACCOUNT_NAME);
   data["server"] =           AccountInfoString(ACCOUNT_SERVER);
   
//--- fill in the acc_info array with Account Info data
   acc_info["acc_info"].Add(data);
   
//--- WebRequest arguments
   string method = "POST";
   string url = "http://172.22.18.235/accs";
   string headers = "Content-Type: application/json";
   int timeout = 500;
   char post[], result[];
   string result_headers;
   
//--- prepare JSON data to send
   string json = acc_info.Serialize();
   ArrayResize(post, json.Length(), 0);
   StringToCharArray(json, post, 0, StringLen(json), CP_UTF8);
   ResetLastError();
   
//--- send the request
   int res = WebRequest(method, url, headers, timeout, post, result, result_headers);
   if(res == -1)
     {
      Print("Error in WebRequest  =", GetLastError());
      MessageBox("Add " + url + " to allowed URLs on MT5 terminal", "Unknown URL", MB_ICONINFORMATION);     }
   else
     {
      Print("Starting post...");
      
      if(res == 201)// HTTP result code 201 (created)
        {
         Print("posted accs");
        }
     }
  }

正如您从文件开头看到的那样，我们正在使用助手函数库来序列化/逆序列化我们的 JSON 数据。 它是由 MQL5 社区的一位成员开发的，您可以在他的 GitHub 存储库中找到该函数库。

现在，我们来插入 MetaTrader 5 历史记录中的交易。 创建新脚本，并添加以下代码。

//+------------------------------------------------------------------+
//|                                                   post_deals.mq5 |
//|                                  Copyright 2023, MetaQuotes Ltd. |
//|                                             https://www.mql5.com |
//+------------------------------------------------------------------+
#property copyright "Copyright 2023, MetaQuotes Ltd."
#property link      "https://www.mql5.com"
#property version   "1.00"
#include <JAson.mqh> //--- include the JSON library
//+------------------------------------------------------------------+
//| Script program start function                                    |
//+------------------------------------------------------------------+
void OnStart()
  {
//--- gathering the data - Deals
   CJAVal data;
   CJAVal deals;
//--- request trade history
   HistorySelect(0, TimeCurrent());
   int deals_total = HistoryDealsTotal();
//--- iterate over all deals to get data
//--- of each deal from its ticket number
   for(int i = 0; i < deals_total; i++)
     {
      //-- integers
      ulong deal_ticket =   HistoryDealGetTicket(i);
      data["ticket"] =     (int) deal_ticket;
      data["order"] =      (int) HistoryDealGetInteger(deal_ticket, DEAL_ORDER);
      data["position"] =   (int) HistoryDealGetInteger(deal_ticket, DEAL_POSITION_ID);
      data["time"] =       (int) HistoryDealGetInteger(deal_ticket, DEAL_TIME);
      data["type"] =       (int) HistoryDealGetInteger(deal_ticket, DEAL_TYPE);
      data["entry"] =      (int) HistoryDealGetInteger(deal_ticket, DEAL_ENTRY);
      data["magic"] =      (int) HistoryDealGetInteger(deal_ticket, DEAL_MAGIC);
      data["reason"] =     (int) HistoryDealGetInteger(deal_ticket, DEAL_REASON);
      //--- strings
      data["symbol"] =     (string) HistoryDealGetString(deal_ticket, DEAL_SYMBOL);
      //--- doubles
      data["volume"] =     (double) HistoryDealGetDouble(deal_ticket, DEAL_VOLUME);
      data["price"] =      (double) HistoryDealGetDouble(deal_ticket, DEAL_PRICE);
      data["profit"] =     (double) HistoryDealGetDouble(deal_ticket, DEAL_PROFIT);
      data["swap"] =       (double) HistoryDealGetDouble(deal_ticket, DEAL_SWAP);
      data["comission"] =  (double) HistoryDealGetDouble(deal_ticket, DEAL_COMMISSION);
 //--- fill in the deals array with each deal data
      deals["deals"].Add(data);
     }
 //--- WebRequest arguments
   string method = "POST";
   string url = "http://172.22.18.235/deals";
   string headers = "Content-Type: application/json";
   int timeout = 500;
   char post[], result[];
   string result_headers;
   
 //--- prepare JSON data to send
   string json = deals.Serialize();
   ArrayResize(post, json.Length(), 0);
   StringToCharArray(json, post, 0, StringLen(json), CP_UTF8);
   ResetLastError();
//--- send the request
   int res = WebRequest(method, url, headers, timeout, post, result, result_headers);
   
   if(res == -1)
     {
      Print("Error in WebRequest  =", GetLastError());
      MessageBox("Add " + url + " to allowed URLs on MT5 terminal", "Unknown URL", MB_ICONINFORMATION);     }
   else
     {
      Print("Starting post...");
      
      if(res == 201)// HTTP result code 201 (created)
        {
         Print("posted deals");
        }
     }
  }

从 MQL5 查询数据

现在，我们查询最近插入的数据。 在 MetaTrader 5 终端上，创建一个新脚本，并添加以下代码。

//+------------------------------------------------------------------+
//|                                                 get_endpoint.mq5 |
//|                                  Copyright 2023, MetaQuotes Ltd. |
//|                                             https://www.mql5.com |
//+------------------------------------------------------------------+
#property copyright "Copyright 2023, MetaQuotes Ltd."
#property link      "https://www.mql5.com"
#property version   "1.00"
#include <JAson.mqh> //--- include the JSON library
//+------------------------------------------------------------------+
//| Script program start function                                    |
//+------------------------------------------------------------------+
void OnStart()
  {
//--- choose the testing endpoint
   string endpoint = "accs"; // or "deals"
//--- WebRequest arguments
   string method = "GET";
   string url = "http://172.22.18.235/" + endpoint;
   string cookie = NULL, headers;
   int timeout = 500;
   char post[], result[];
   ResetLastError();
//--- send the request
   int res = WebRequest(method, url, cookie, NULL, timeout, post, 0, result, headers);
   if(res == -1)
     {
      Print("Error in WebRequest  =", GetLastError());
      MessageBox("Add " + url + " to allowed URLs on MT5 terminal", "Unknown URL", MB_ICONINFORMATION);
     }
   else
     {
      Print("Starting get...");
      if(res == 200)// HTTP result code 200 (OK)
        {
         PrintFormat("Server headers: %s", headers);
         ResetLastError();
         // save the returned JSON in a file
         string terminal_data_path = TerminalInfoString(TERMINAL_DATA_PATH);
         string subfolder = "TutoPostgres";
         string filename = endpoint + "_fromserver.json";
         int filehandle = FileOpen(subfolder + "\\" + filename, FILE_WRITE | FILE_BIN);
         if(filehandle != INVALID_HANDLE)
           {
            FileWriteArray(filehandle, result, 0, ArraySize(result));
            FileClose(filehandle);
            Print(filename + " created at " + terminal_data_path + "\\" + subfolder);
           }
         else
            Print("File open failed with error ", GetLastError());
        }
      else
         PrintFormat("Request to '%s' failed with error code %d", url, res);
     }
  }