【MQL5】DatabaseExecute関数の使い方と自動売買実装コード

bool DatabaseExecute(
   int           database,      // DatabaseOpenで取得したデータベースハンドル
   const string  sql            // 実行するSQLリクエスト
);

//+------------------------------------------------------------------+
//| データベース操作のサンプルEA                                           |
//+------------------------------------------------------------------+
#property strict

int db_handle = INVALID_HANDLE;

int OnInit()
{
   // データベースファイルを開く（存在しない場合は作成される）
   db_handle = DatabaseOpen("TradeLog.sqlite", DATABASE_OPEN_READWRITE | DATABASE_OPEN_CREATE | DATABASE_OPEN_COMMON);

   if(db_handle == INVALID_HANDLE)
   {
      Print("データベースのオープンに失敗。エラーコード: ", GetLastError());
      return(INIT_FAILED);
   }

   // 1. テーブルの作成 (CREATE TABLE)
   // 取引時刻、シンボル、ロット数を保存するテーブル
   string sql_create = "CREATE TABLE IF NOT EXISTS TRADE_HISTORY("
                       "ID INTEGER PRIMARY KEY AUTOINCREMENT,"
                       "TIME TEXT NOT NULL,"
                       "SYMBOL TEXT NOT NULL,"
                       "LOT REAL NOT NULL);";

   if(!DatabaseExecute(db_handle, sql_create))
   {
      Print("テーブル作成失敗: ", GetLastError());
      DatabaseClose(db_handle);
      return(INIT_FAILED);
   }

   Print("データベースの準備が完了しました。");
   return(INIT_SUCCEEDED);
}

void OnDeinit(const int reason)
{
   // ハンドルを閉じる（忘れるとファイルがロックされる原因になる）
   if(db_handle != INVALID_HANDLE)
   {
      DatabaseClose(db_handle);
   }
}

void OnTick()
{
   // 何らかの条件でデータを挿入する例（デモ用に一度だけ実行）
   static bool inserted = false;
   if(!inserted)
   {
      string time_now = TimeToString(TimeCurrent(), TIME_DATE | TIME_SECONDS);
      string symbol = _Symbol;
      double lot = 0.1;

      // 2. データの挿入 (INSERT)
      // 文字列データはシングルクォーテーションで囲む必要があることに注意
      string sql_insert = StringFormat(
         "INSERT INTO TRADE_HISTORY (TIME, SYMBOL, LOT) VALUES ('%s', '%s', %f);",
         time_now, symbol, lot
      );

      if(DatabaseExecute(db_handle, sql_insert))
      {
         Print("データ挿入成功: ", sql_insert);
         inserted = true;
      }
      else
      {
         Print("データ挿入失敗: ", GetLastError());
      }
   }
}