Экспорт тиков в SQL из MQL5: Скрипт реального времени

#property copyright "Quant Developer"
#property link      "https://finfluct.com"
#property version   "1.00"
#property strict

// Входные параметры
input string DB_FileName = "TickData.db"; // Имя файла базы данных
input string DB_TableName = "ticks";     // Имя таблицы

int db_handle = INVALID_HANDLE;

//+------------------------------------------------------------------+
//| Expert initialization function                                   |
//+------------------------------------------------------------------+
int OnInit() {
    // Открываем или создаем базу данных в общей папке всех терминалов
    db_handle = DatabaseOpen(DB_FileName, DATABASE_OPEN_READWRITE | DATABASE_OPEN_CREATE | DATABASE_OPEN_COMMON);
    if(db_handle == INVALID_HANDLE) {
        Print("Ошибка открытия БД: ", GetLastError());
        return INIT_FAILED;
    }

    // Создаем таблицу для хранения тиков, если она не существует
    string query = "CREATE TABLE IF NOT EXISTS " + DB_TableName + " (" 
                   "id INTEGER PRIMARY KEY AUTOINCREMENT," 
                   "symbol TEXT," 
                   "time INT," 
                   "msec INT," 
                   "bid REAL," 
                   "ask REAL," 
                   "volume REAL" 
                   ");";

    if(!DatabaseExecute(db_handle, query)) {
        Print("Ошибка создания таблицы: ", GetLastError());
        DatabaseClose(db_handle);
        return INIT_FAILED;
    }

    // Создаем индекс для оптимизации будущих аналитических выборок
    string index_query = "CREATE INDEX IF NOT EXISTS idx_symbol_time ON " + DB_TableName + " (symbol, time);";
    if(!DatabaseExecute(db_handle, index_query)) {
        Print("Ошибка создания индекса: ", GetLastError());
    }

    Print("Экспорт тиков успешно запущен. БД: ", DB_FileName);
    return INIT_SUCCEEDED;
}

//+------------------------------------------------------------------+
//| Expert deinitialization function                                 |
//+------------------------------------------------------------------+
void OnDeinit(const int reason) {
    if(db_handle != INVALID_HANDLE) {
        DatabaseClose(db_handle);
        Print("Соединение с БД закрыто.");
    }
}

//+------------------------------------------------------------------+
//| Expert tick function                                             |
//+------------------------------------------------------------------+
void OnTick() {
    MqlTick last_tick;
    if(SymbolInfoTick(_Symbol, last_tick)) {
        // Формируем SQL-запрос на вставку данных
        string query = StringFormat(
            "INSERT INTO %s (symbol, time, msec, bid, ask, volume) VALUES ('%s', %lld, %d, %f, %f, %f);",
            DB_TableName, _Symbol, last_tick.time, last_tick.time_msc % 1000, last_tick.bid, last_tick.ask, (double)last_tick.volume_real
        );

        if(!DatabaseExecute(db_handle, query)) {
            Print("Ошибка записи тика: ", GetLastError());
        }
    }
}