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

1. DatabaseTransactionBegin関数の概要と実務での活用法

MQL5におけるDatabaseTransactionBeginは、SQLiteデータベースへの操作を「トランザクション」として開始するための関数です。簡単に言えば、複数のデータ追加（INSERT）や更新（UPDATE）を一つのグループとしてまとめ、一括で処理を確定させるための「宣言」の役割を果たします。

実務開発において、初心者が最も陥りやすい罠が「大量のデータを1件ずつデータベースに書き込んでしまうこと」です。例えば、1,000件の取引履歴を保存しようとした際、トランザクションを使わずに処理すると、1件ごとにディスクへの書き込み（I/O操作）が発生し、EAの動作が数秒間フリーズするほど低速になります。

DatabaseTransactionBeginを活用することで、全ての処理をメモリ上で一時的にまとめ、最後に一括で書き込むことが可能になります。これにより、処理速度は数十倍〜数百倍に向上します。また、「全ての処理が成功したときだけ保存し、一つでも失敗したら元に戻す（ロールバック）」というデータの整合性を保つためにも必須の関数です。

2. 構文と戻り値

DatabaseTransactionBegin関数の構成は非常にシンプルです。

bool DatabaseTransactionBegin(
   int  database      // DatabaseOpenで取得したデータベースハンドル
);

パラメーター

• database: DatabaseOpen() 関数によって返されたデータベースのハンドル（ID）を指定します。

戻り値

• 処理が成功した場合は true、失敗した場合は false を返します。
• 失敗した原因を確認するには、GetLastError() 関数を使用します。

3. 具体的な使い方・実践サンプルコード

以下のサンプルは、複数のカスタムログ（取引記録など）をデータベースに高速に一括保存するEAのコード例です。

// データベースのファイル名
string db_filename = "TradeLog.mqd";

void OnStart()
{
   // 1. データベースを開く（または作成する）
   int db_handle = DatabaseOpen(db_filename, DATABASE_OPEN_READWRITE | DATABASE_OPEN_CREATE);

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

   // 2. テーブルの作成（存在しない場合）
   DatabaseExecute(db_handle, "CREATE TABLE IF NOT EXISTS TradeHistory("
                              "ID INTEGER PRIMARY KEY AUTOINCREMENT,"
                              "Time DATETIME,"
                              "Symbol TEXT,"
                              "Profit REAL);");

   // --- トランザクションの開始 ---
   // これを呼び出すことで、ループ内のDatabaseExecuteが高速化されます
   if(!DatabaseTransactionBegin(db_handle)) {
      Print("トランザクション開始失敗: ", GetLastError());
      DatabaseClose(db_handle);
      return;
   }

   bool success = true;
   for(int i = 0; i < 100; i++) {
      string sql = StringFormat("INSERT INTO TradeHistory (Time, Symbol, Profit) VALUES ('%s', '%s', %f);",
                                TimeToString(TimeCurrent()), _Symbol, MathRand() / 100.0);

      if(!DatabaseExecute(db_handle, sql)) {
         Print("データ挿入失敗: ", GetLastError());
         success = false;
         break;
      }
   }

   // 3. 処理結果に応じて確定（Commit）または破棄（Rollback）
   if(success) {
      // 全て成功したなら、ディスクに一括書き込み
      DatabaseTransactionCommit(db_handle);
      Print("100件のデータを正常に保存しました。");
   } else {
      // 一つでも失敗したなら、このトランザクション中の操作を全て取り消す
      DatabaseTransactionRollback(db_handle);
      Print("エラーが発生したため、変更をロールバックしました。");
   }

   // 4. データベースを閉じる
   DatabaseClose(db_handle);
}

4. 使用上の注意点とよくあるエラー

• Commitの忘れ: DatabaseTransactionBeginを呼び出した後、最後にDatabaseTransactionCommitを呼び出さない限り、データはディスクに保存されません。プログラムを終了すると、その間の操作はすべて消えてしまいます。
• 二重開始の禁止: すでにトランザクションが開始されている状態で、再度 DatabaseTransactionBegin を呼び出すとエラーになります。必ず Commit または Rollback で一度閉じてから次のトランザクションを開始してください。
• データベースのロック: トランザクション実行中は、そのデータベースファイルがロックされます。他のプログラムやツールから同時に書き込みを行おうとすると、競合エラーが発生する可能性があるため注意が必要です。
• エラーハンドリング: ループ内で一つでもクエリが失敗した場合は、不整合なデータが残らないよう必ず DatabaseTransactionRollback を実行する癖をつけましょう。

5. 【重要】自動売買における約定スピードと環境の罠

アルゴリズムトレードにおいて、ロジックの優位性と同じ、あるいはそれ以上に重要なのが「実行環境」です。どれほど優れたEAを開発し、データベース操作をミリ秒単位で高速化したとしても、自宅のPC環境で運用している限り、ネットワークの遅延（レイテンシ）という物理的な壁に突き当たります。

自宅のインターネット回線は、プロバイダーを経由する際の揺らぎ（ジッター）や、家庭内デバイスの負荷、Windowsの予期せぬアップデートなど、不安定要素の塊です。FXの注文が数ミリ秒遅れるだけで、スリッページによって期待利益は削られ、本来利益になるはずのトレードが損失に変わることも珍しくありません。極限まで約定スピードを高め、24時間365日安定したトレードを継続するには、証券会社のサーバーに物理的に近い場所に位置する「専用VPS（仮想専用サーバー）」の導入が必須です。プロのクオンツエンジニアにとって、VPSは単なるツールではなく、トレードの勝率を支えるインフラの一部なのです。