zj'SSKJr SSKJr SSKJr SrSrSrSr Sr SS \ S \ S \ S \ S\ S\ S\ S\ S\ S\ S\ SS 4SjjrSS \ S\ S\\ S\\4SjjrSS\\ S\\4Sjjrg ))Optional)get_connection)_validate_table_namez SHOW TABLESz4SELECT id, name, type FROM instruments ORDER BY namez>SELECT id, name FROM instruments WHERE type = %s ORDER BY namezZSELECT COUNT(*) FROM information_schema.tables WHERE table_schema = %s AND table_name = %saV CREATE TABLE IF NOT EXISTS signal_log ( id INT AUTO_INCREMENT PRIMARY KEY, ts INT NOT NULL, ticker VARCHAR(20) NOT NULL, `signal` VARCHAR(10) NOT NULL DEFAULT 'NEUTRAL', p_long DECIMAL(6,4) DEFAULT 0, p_short DECIMAL(6,4) DEFAULT 0, threshold_long DECIMAL(4,2) DEFAULT 0, threshold_short DECIMAL(4,2) DEFAULT 0, confidence DECIMAL(6,4) DEFAULT 0, flat_filter VARCHAR(50) DEFAULT NULL, close_price DECIMAL(20,8) DEFAULT 0, model_type VARCHAR(20) DEFAULT 'moe_v12', INDEX idx_ticker_ts (ticker, ts), INDEX idx_ts (ts) ) CHARACTER SET utf8mb4; Ntstickersignalp_longp_shortthreshold_longthreshold_short confidence flat_filter close_price model_typereturnc [5n U R5n U R[5 U RS[ U5X[ U5[ U5[ U5[ U5[ U5U[ U 5U 4 5 U R 5 U R5 SSS5 g!,(df  g=f)uЗаписывает сигнал в signal_log таблицу (audit 2026-08-03). Используется для post-hoc анализа качества модели и debugging. Таблица создаётся автоматически при первом вызове. zINSERT INTO signal_log (ts, ticker, `signal`, p_long, p_short, threshold_long, threshold_short, confidence, flat_filter, close_price, model_type) VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s)N)rcursorexecuteSIGNAL_LOG_CREATE_SQLintfloatcommitclose) rrrr r r r r rrrconncurs +/home/ai/projects/AI_Strategy/db/queries.pyinsert_signal_logr"s  Tkkm )*  BWf 6]E'N > "E/$: :  ;   -   !   s B!B55 C timeframelimitc*[X5nSU-S-nSnU(aUS- n[U54n[5nURSS9nUR XE5 UR 5nUR 5 UsSSS5 $!,(df  g=f)NzFSELECT timestamp, `Date`, `Time`, Open, High, Low, Close, Volume FROM z ORDER BY timestampz LIMIT %sT dictionary)rrrrrfetchallr) rrrtablequeryparamsrrrowss r load_candlesr(?s  3E TW\ \_t tE F  e*  T-u%     s AB Binstrument_typec[5nURSS9nU(aUR[U45 OUR[5 UR 5nUR 5 UsSSS5 $!,(df  g=f)NTr!)rrrINSTRUMENTS_BY_TYPE_QUERYINSTRUMENTS_QUERYr#r)r)rrr's rget_instrumentsr-Ns`  T-  NN46H I NN, -     s A%A:: B)rrrrrNrmoe_v12)N)typingr db.connectionr data.loaderr TABLES_QUERYr,r+TABLE_EXISTS_QUERYrrstrrrlistdictr(r-rr9s(, J\q *<=KLAEAJ #sC$38',CH$)