{hf *ddlZddlmZmZmZmZmZmZddlm Z ddl m Z ddddd d d d Z eeeed feeed ffZdZdZddedeeed fdeeeeffdZ deddedededefdZ ddddedeeed fdedeeeeffdZy)N)AnyDictListOptionalTupleUnion)connect)errorsz6dev-rds-mysql.crs0e6k0ssxf.us-east-2.rds.amazonaws.comi agencycicz3fU(>C&~I[X5,}% imparablesT )hostportuserpassworddatabaseuse_pureconnection_timeout.icRKtditd{}|jd{} |jdd{|jdd{|j d{|S7i7S7;7$7#|j d{7wxYww)ul Conexión asíncrona a MySQL con ajustes de sesión para reducir bloqueos y esperas por locks. Nz6SET SESSION TRANSACTION ISOLATION LEVEL READ COMMITTEDz(SET SESSION innodb_lock_wait_timeout = 5)r DB_CONFIGcursorexecuteclose)cnxcurs W/var/www/dev.api.imparables.com.co/api_imparables/crm_asincrono/conexion_db/conexion.pyget_connectionrs $)$ $C CkkRSSSkkDEEEiik J % SEciiksxB'A?B'BB'B BB B!B %B'8B9B'B'B B B' B$B B$$B'sqlparamsreturncKtd{}|jdd{} |j||xsdd{|jd{}||j d{|j d{S77o7R7<7%7#|j d{7|j d{7wxYww)u$ SELECT → lista de dicts. NT) dictionaryr)rrrfetchallr)rr rrrowss rqueriesr&+s C d + +Ckk#v|,,,\\^#iikiik ! +,# iikiiksCBCBCB$ B B$!B"B$'C:B ;CB"CCB$B$ C"C$C8B;9CCCC) chunk_sizer'c Ktd{}|jd{} t|tsx|j ||xsdd{|j xsd}|j d{||jd{|jd{Sd}|xsg}|s2 |jd{|jd{ytdt|}tdt||D]}td||zdzd|d||zdz d||||z} d D]I} |j|| d{||j xsdz }|j d{nt%j&dd{||jd{|jd{S7777r7\7G7&777r#tj$rr} t!| d d} | d vrB| dk(r=|j#d{7t%j&d d{7Yd} ~ |j#d{7d} ~ wwxYw777#|jd{7|jd{7wxYww) u INSERT/UPDATE/DELETE. - Si 'params' es tupla -> execute - Si 'params' es lista de tuplas -> executemany con chunking y reintento 1× Devuelve el número total de filas afectadas. NrrzProcesando chunk z (registros z a ))r)errno)iig?)rr isinstancelistrrowcountcommitrmaxintrangelenprint executemany mysql_errors DatabaseErrorgetattrrollbackasynciosleep) rr r'rraffectedtotal_affecteddataichunkattemptecodes rrr:s C C.&$'++c6*E" //#u555"cll&7a7N**,&&  $--" " "/ #2iikiika !  1 P  -6&#11 "1gt4D|+1 !lln,,%mmC000 ,,.((  # iikiiks{K G(K G+K )JG.'J?G1JK G4K 0G71K 6 JK G:K ,G=-K 2AJH$H%*HHHJ/J 0J7K  J K "J#K +K .J1J4K 7K :K =K HHJ )JI JI! J$J*J=J >JJ  JK K K&J)'K?KKK i:c Ktd{}|jddd{} td|dddtjj }|j dd{|j d d{|j ||xsd d{g}d }d } |j|d{} | sn|d z }|t| z }|j| tjj |z } | d kDr|| z nd } td |dt| d|dd| dd tjd d{tjj |z } | d kDr|| z nd } td|dd| dd| dd||jd{|jd{S777v7`7E7(7717#t$r}td|d}~wwxYw#|jd{7|jd{7wxYww)un SELECT masivo optimizado para grandes volúmenes (reemplazo directo de queries). Procesa por chunks pero devuelve todas las filas como lista completa. Args: sql: Query SQL params: Parámetros de la query chunk_size: Tamaño del chunk para streaming Returns: Lista completa de todas las filas como dicts NTSSCursor)r# cursor_classu🚀 Ejecutando query masiva: dz...z!SET SESSION sql_buffer_result = 0z&SET SESSION read_buffer_size = 2097152rrr)u 📦 Chunk z: z filas | Total: ,z | Velocidad: z,.0fz filas/segu✅ Query masiva completada: z filas en z.2fzs | Promedio: u❌ Error en query masiva: ) rrr5r;get_event_looptimer fetchmanyr4extendr<r Exception)rr r'rr start_timeall_rows total_rows chunk_countrAelapsedrate total_time final_raterCs rqueries_masivosrWxs_$ C d D DC1 .s4Cyk=>++-224 kk=>>>kkBCCCkk#v|,,,  -- 33E 1 K #e* $J OOE ",,.335 BG+2Q;:'AD k]"SZL9$Q("4[ 4  --" " "%(++-224zA 0:QZ*,A  +Jq>JsCST#D) 5  iikiiki ! D ?C,4" #   +A3/0 iikiiksIG)IG,IAH9G/:HG2H0G51HG8BH(G;)AH8I G= I#G?$I,I/H2H5H8H;H=I?I H HHH!!I5H86IIII)N)r;typingrrrrrrmysql.connector.aior mysql.connectorr r7r ParamsType_DEFAULT_CHUNKrstrr&r2rrWrrr_s2::'2 E  !  eE#s(OT%S/-BBC D   s HU38_$= dSVX[S[nI] "<% < < < <  <@)-F F F U38_ %F F  $sCx. Fr^