j/ dZddlZddlZddlZddlmZmZmZddlm Z ddl m Z ddl m Z mZmZddlmZddlmZmZmZmZmZdd lmZd d lmZd d lmZgd Zej>dZ eedZ!dejDdeddfdZ#dejDde$ddfdZ%e&Z'GddeZ(ddddee)e fdeejTdede(fdZ+y)z* Core implementation of aiosqlite proxies N) AsyncIterator GeneratorIterable)partial)Path)EmptyQueue SimpleQueue)Thread)AnyCallableLiteralOptionalUnion)warn)contextmanager)Cursor)connect Connectionr aiosqlite)DEFERRED IMMEDIATE EXCLUSIVEfutresultreturncH|js|j|yy)z9Set the result of a future if it hasn't been set already.N)done set_result)rrs X/var/www/html/Fitness-lenito-AI-main/venv/lib/python3.12/site-packages/aiosqlite/core.pyr r s 88: v ecH|js|j|yy)zdegej fdedeejddffd Z dZ e dej fdZ d ed edeej fd Zd ed edeej fd Zd?d ZdZd@dZdeeddffdZd@dZd?dZedefdZd?dZd?dZd?dZ e d>d ed eeedefdZ!e d>d ed eeedeej fdZ"e d>d ed eeedeej fdZ#ed ed eeedefdZ$ededefdZ%d?dZ& dAdeded ed!e'ddf d"Z(e de'fd#Z)e deefd$Z*e*jVd%e,ddfd&Z*e dee-fd'Z.e.jVd(ee-ddfd)Z.e dee/geffd*Z0e0jVd(ee/gefddfd+Z0e defd,Z1d%e'ddfd-Z2d.efd/Z3d0egeefd1eddfd2Z4d0eddfd3Z5de6efd4Z7d5dd6d7d8d9e8dej fd:ed;eeeeegdfdedcursors r!_execute_insertzConnection._execute_insertMs2##C434  r"cZ|jj||}|jSN)r<r@fetchallrBs r!_execute_fetchallzConnection._execute_fetchallRs%##C4  r"c |jj}|tury|\}} tj d||}tj d||j j t||#t$rE}tj d||j j t||Yd}~Jd}~wwxYw)zV Execute function calls on a separate thread. :meta private: z executing %szoperation %s completedzreturning exception %sN) r0getr7LOGdebugget_loopcall_soon_threadsafer BaseExceptionr%)r3tx_itemfuturefunctionrr#s r!runzConnection.runVs  hhllnG00& FH Q .(3! 2H=!66z66R ! Q 2A6!66}faPP QsAB C ;C  CcK|jr |js tdt|g|i|}t j j }|jj||f|d{S7w)z8Queue a function with the given arguments for execution.zConnection closedN) r-r.r;rasyncioget_event_loop create_futurer0r6)r3fnargskwargsrRrQs r!_executezConnection._executepsm}}D$4$401 12///'')779 VX./||sA7B9A>:Bc*K|j[ tjj}|jj ||j f|d{|_|S|S7 #t$r|jd|_wxYww)z&Connect to the actual sqlite database.N) r.rUrVrWr0r6r/rOr9)r3rQs r!_connectzConnection._connect|s    #  //1??A##VT__$=>)/<  t $0  ""$#'  s/ BAA.A, A.(B,A.."BBc^|j|jjSrF)startr] __await__r8s r!r`zConnection.__await__s  }}((**r"c"K|d{S7wrFr8s r! __aenter__zConnection.__aenter__szzs  c@K|jd{y7wrF)close)r3exc_typeexc_valexc_tbs r! __aexit__zConnection.__aexit__sjjls c|Kt||j|jjd{S7w)zs r!execute_insertzConnection.execute_inserts2  J]]4#7#7jIIII %.,.c`K|g}|j|j||d{S7w)z2Helper to execute a query and return all the data.N)r[rHrus r!execute_fetchallzConnection.execute_fetchalls2  J]]4#9#93 KKKKrwcK|j|jj||d{}t||S7w)z;Helper to create a cursor and execute the given multiquery.N)r[r< executemanyrrBs r!r{zConnection.executemanys: }}TZZ%;%;S*MMdF##Ns+A>A sql_scriptcK|j|jj|d{}t||S7w)z4Helper to create a cursor and execute a user script.N)r[r< executescriptr)r3r|rCs r!r~zConnection.executescripts8}}TZZ%=%=zJJdF##Ks *?=?c>K|jjSw)zInterrupt pending queries.)r< interruptr8s r!rzConnection.interruptszz##%%sname num_paramsfunc deterministicctK|j|jj||||d{y7w)a/ Create user-defined function that can be later used within SQL statements. Must be run within the same thread that query executions take place so instead of executing directly against the connection, we defer this to `run` function. If ``deterministic`` is true, the created function is marked as deterministic, which allows SQLite to perform additional optimizations. This flag is supported by SQLite 3.8.3 or higher, ``NotSupportedError`` will be raised if used with older versions. )rN)r[r<create_function)r3rrrrs r!rzConnection.create_functions<mm JJ & &   '    s .868c.|jjSrF)r<in_transactionr8s r!rzConnection.in_transactionszz(((r"c.|jjSrFr<isolation_levelr8s r!rzConnection.isolation_levelszz)))r"valuec&||j_yrFrr3rs r!rzConnection.isolation_levels%* "r"c.|jjSrFr< row_factoryr8s r!rzConnection.row_factoryszz%%%r"factoryc&||j_yrFrr3rs r!rzConnection.row_factorys!( r"c.|jjSrFr< text_factoryr8s r!rzConnection.text_factoryszz&&&r"c&||j_yrFrrs r!rzConnection.text_factory s") r"c.|jjSrF)r< total_changesr8s r!rzConnection.total_changesszz'''r"clK|j|jj|d{y7wrF)r[r<enable_load_extensionrs r!rz Connection.enable_load_extensions$mmDJJ<.dumper.sh  JJ//1D))$/2%%d+  :;%%d+ s AA1A6Nziterdump completed unexpectedlyg{Gz?) r r[rU ensure_future get_nowaitrrrKwarningsleep)r3rrtaskrrs` @r!rzConnection.iterdump"s"G  mmF#$$S) *&0&;&;&=<   *99;KK ABmmD)))  * sX8B7A!B7A!B7B5B7!.B2B7B2)B,*B2/B71B22B7rmaing?pagesprogressrrtargetrrrcKt|tr |j}|j|jj|||||d{y7w)z Make a backup of the current database to the target database. Takes either a standard sqlite3 or aiosqlite Connection object as the target. rN) isinstancerr<r[backup)r3rrrrrs r!rzConnection.backupLsR fj )\\Fmm JJ       sA A AArF)rN)rr)F)<__name__ __module__ __qualname__r sqlite3rintrrUAbstractEventLoopr,r9propertyr<strr RowrDrrHrSr[r]rr`rcrirrrCrlrorer@rvryr{r~rboolrrrsetterIsolationLeveltyperbytesrrrrrrrrrfloatr __classcell__)r4s@r!rr-sy 59 B 2 223w001   &4  w))  !3!C!HW[[S!Q4  +9S$ %<=+DfDD/1 $>B$$$,Xc]$;$ $$>BJJ$,Xc]$;J '++ JJ>BLL$,Xc]$;L '++ LL$$$,Xc]$;$ $$$c$f$$ & QV  %( 08 IM  ,)))*#**+^+++&Xd^&&)8D>)d))'hw|4''*HeWc\$:*t**(s((EE$E==IHSM 12I7:I I DDTD( c 2(\>B lG$6$667   8S#sOT$9:;       r"r@)r(r)databaser)rZc p|tdtdtjffd }t||S)z.connectorvsG h $C % (//'*Ch-Cs-f--r")rr2rr)rr(r)rZr's` ` r!rrgs:  E  .w)). i 11r"),__doc__rUloggingrcollections.abcrrr functoolsrpathlibrqueuerr r threadingr typingr r rrrwarningsrcontextrrCr__all__ getLoggerrKrFuturer rOr%objectr7rrrrrbr"r!rs>>++::# -g $'"FGHGNNCD w~~-D  w w z 04 2CI2 7,, - 2  2  2r"