ɧ-iUddlZddlmZddlmZedeZeddZ ee d<da ee e d<ej d ej d d Zej d ej d dZej dej ddZej dej ddZej dej ddZeej ddZeej ddZeej ddZGddZd Zd!Zd"Zd#Zd$ZdS)%N) ContextVar)Optionallogging db_connection)default_db_connection_connection_poolDB_NAMEMYSQL_DBeatance_website_builderDB_USER MYSQL_USERroot DB_PASSWORDMYSQL_PASSWORDDB_HOST MYSQL_HOST localhostDB_PORT MYSQL_PORT3306DB_POOL_MIN_SIZE5DB_POOL_MAX_SIZE20DB_POOL_RECYCLE3600c\eZdZdZdefdZdZddZdZdZ d Z d Z d Z d Z d ZdZdS)AsyncDBAdapterzAsync adapter that exposes execute(), executemany(), cursor(), commit(), and fetch helpers for underlying async connections from aiomysql. backendc0||_||_d|_dSN)_connr! _last_cursor)selfconnr!s 7/var/www/html/web-builder-api.evdpl.com/src/utils/db.py__init__zAsyncDBAdapter.__init__s   cK|jdkr|jd{VS|jd{VS)Nmysql)r!r$cursorr&s r(r-zAsyncDBAdapter.cursor#s_ <7 " "**,,,,,,,, ,Z&&(((((((((r*Nc K|d{V}|}|}|5|jdvr, d|vr|dd}n#t$rYnwxYw|%t |t t tfs|f} |||d{Vn|||d{V||_ |S#t$r}t|} t d|jd|n#t$rYnwxYw|pt |t t frT t d|D}|||d{V||_ |cYd}~S#t$rYnwxYw t d|jd|d |d |n#t$rYnwxYwd}~wwxYw) N)postgresr,?z%sz6DB execute failed, attempting tolerant retry: backend=z; error=c3<K|]}|dnt|VdSr#)str).0xs r( z)AsyncDBAdapter.execute..Is0II! s1vvIIIIIIr*zDB execute error (backend=z): z; query=z ; params=)r-r!replace Exception isinstancelisttupledictexecuter%r3loggerdebugerror) r&queryparamscurqpemsgalts r(r=zAsyncDBAdapter.execute)s{KKMM!!!!!!   =T\-BBB !88 #t,,A     =AeT/B!C!C=A ykk!nn$$$$$$$$kk!Q''''''''' #D J   a&&C  qVZVbqqloqqrrrr    }Ae}!=!=}IIqIIIIIC++a---------(+D%JJJJJJ D  e$,ee1eeVWeebceeffff     + sA AAAC G G%DG D GD!G2=E5/G5 F?GFG+F21G2 F?<G>F??GGcK|d{V}|||d{V}||_|Sr#)r- executemanyr%)r&rA seq_of_paramsrCress r(rJzAsyncDBAdapter.executemanyVsWKKMM!!!!!!OOE=99999999 r*cK|j4|d{V}|d{VS|jd{VSr#)r%r-fetchoner&rCs r(rNzAsyncDBAdapter.fetchone\u   $ %%%%%%C'''''' '&//111111111r*cK|j4|d{V}|d{VS|jd{VSr#)r%r-fetchallrOs r(rRzAsyncDBAdapter.fetchallbrPr*clK |jd{VdS#t$rYdSwxYwr#)r$commitr8r.s r(rTzAsyncDBAdapter.commithsY *##%% % % % % % % % % %    DD  % 33clK |jd{VdS#t$rYdSwxYwr#)r$closer8r.s r(rWzAsyncDBAdapter.closensY *""$$ $ $ $ $ $ $ $ $ $    DD rUc K|Sr#r.s r( __aenter__zAsyncDBAdapter.__aenter__ts  r*cK |3 |jd{VdS#t$rYdSwxYw |jd{VdS#t$rYdSwxYw#t$rYdSwxYwr#)r$rTr8rollback)r&exc_typeexctbs r( __aexit__zAsyncDBAdapter.__aexit__ws *++----------- DD*--/////////// DD    DD sDA,( 6A,6A,A A)%A,(A))A,, A:9A:c,t|j|Sr#)getattrr$)r&names r( __getattr__zAsyncDBAdapter.__getattr__stz4(((r*r#)__name__ __module__ __qualname____doc__r3r)r-r=rJrNrRrTrWrZr`rdrYr*r(r r s!c!!!! ))) ++++Z 222 222    )))))r*r c dKttS ddl}n-#t$r }tdd}~wwxYwt t ttdtttdd }tr) tt|d<n#t$rYnwxYw |jdi|d{Vatdtd t d td td td n0#t$r#}td|d}~wwxYwtS)z7Create a global connection pool for better performance.Nr;aiomysql is required for mysql backend but is not installedutf8mb4F) hostuserpassworddbcharsetminsizemaxsize pool_recycle autocommitportzCreated MySQL connection pool: @:z (min=z, max=)z"Failed to create connection pool: rY)r aiomysqlr8r>r@rr rr POOL_MIN_SIZE POOL_MAX_SIZE POOL_RECYCLErint create_poolinfo)ryrF conn_infos r(_create_connection_poolrs|#  RSSS    $  I  #G If      D !5!5!B!B !B!BBBBBBB ~g~~~~'~~Yf~~n{~~~  =!==>>>  s= A<A;B B B $AC;; D(D##D(cZK ddl}n-#t$r }tdd}~wwxYwt}||St d{V}|d{V}t|d}t ||S)zGet a connection from the pool.rNrjr,) ryr8r>r@rgetracquirer set)ryrF existing_connpoolr'adapters r(_connect_mysqlrs  RSSS  #&&((M )** * * * * * *D      DT7++Gw Ns 3.3c.Ktd{VS)z+Return an async DB connection (MySQL only).N)rrYr*r(get_connectionrs$!! ! ! ! ! ! !!r*cK t}|Btt|jtddSdS#t $rYdSwxYw)z$Release connection back to the pool.N)rrr releaser$rr8)r's r(close_connectionrs !!##  + ((444   t $ $ $ $ $        sAA## A10A1c0K tVttd{VdatddSdS#t $r(}td|Yd}~dSd}~wwxYw)zKClose the entire connection pool. Should be called on application shutdown.NzConnection pool closedzError closing connection pool: )r rW wait_closedr>rr8r@)rFs r( close_poolrs<  '  " " $ $ $"..00 0 0 0 0 0 0 0#  KK0 1 1 1 1 1 ( ' <<< :q::;;;;;;;;;r__annotations__r anygetenvr r rrrr}rzr{r|r rrrrrrYr*r(rs """""" I   ( ( 2 2(ZFFF FFF#'(3-&&& ")Iyry5NOO P P ")Iyryv>> ? ?bi yry1A2'F'FGG ")Iyry{CC D D ")Iyryv>> ? ?IBI0#6677 IBI0$7788 s929.7788 o)o)o)o)o)o)o)o)d&&&P0"""     < < < <