
    TjZ              
           S SK Jr  S SKJr  S SKJr  SrSrSrSr	SS	\
S
\
S\\   S\\   4S jjrSS\\
   S\\   4S jjrg)    )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 = %sNticker	timeframelimitreturnc                 *   [        X5      nSU-   S-   nS nU(       a  US-  n[        U5      4n[        5        nUR                  SS9nUR	                  XE5        UR                  5       nUR                  5         UsS S S 5        $ ! , (       d  f       g = f)NzFSELECT timestamp, `Date`, `Time`, Open, High, Low, Close, Volume FROM z ORDER BY timestampz	 LIMIT %sT
dictionary)r   intr   cursorexecutefetchallclose)	r   r   r   tablequeryparamsconnr   rowss	            +/home/ai/projects/AI_Strategy/db/queries.pyload_candlesr      s     3ETW\\_ttEFe*		T-u%  
		s   AB
Binstrument_typec                    [        5        nUR                  SS9nU (       a  UR                  [        U 45        OUR                  [        5        UR                  5       nUR                  5         UsS S S 5        $ ! , (       d  f       g = f)NTr   )r   r   r   INSTRUMENTS_BY_TYPE_QUERYINSTRUMENTS_QUERYr   r   )r   r   r   r   s       r   get_instrumentsr      s`    		T-NN46HINN,-  
		s   A%A::
B)N)typingr   db.connectionr   data.loaderr   TABLES_QUERYr   r   TABLE_EXISTS_QUERYstrr   listdictr   r        r   <module>r(      sl     ( , J \ q   Xc] dSWj 	Xc] 	d4j 	r'   