b?i/:SSKrSSKJr SSKJr SSKJr SSKJr SSK J r SSK J r J r JrJr S S KJrJr S r"S S 5rSrg)N) ClauseElement) UpdateBase) DDLElement)exc)create_result_proxy)RootTransaction TransactionNestedTransactionTwoPhaseTransaction)_TransactionContextManager_SAConnectionContextManagercU$N)ks Z/var/www/html/livechat/backend/venv/lib/python3.13/site-packages/aiomysql/sa/connection.pynooprs Hc\rSrSrS SjrSrSrSrSrSr \ S 5r \ S 5r S r S rS rSrSrSrS SjrSrSrS SjrSrSrSS.SjrSS.Sjr\ S5rSrSrSrSrg)! SAConnectionNcXlSUlSUl[R"5UlX lURUlX0l g)Nr) _connection _transaction_savepoint_seqweakrefWeakSet _weak_results_enginedialect_dialect_compiled_cache)self connectionenginecompiled_caches r__init__SAConnection.__init__s=% $__.  -rcDUR"U/UQ70UD6n[U5$)aXExecutes a SQL query with optional parameters. query - a SQL query string or any sqlalchemy expression. *multiparams/**params - represent bound parameter values to be used in the execution. Typically, the format is a dictionary passed to *multiparams: await conn.execute( table.insert(), {"id":1, "value":"v1"}, ) ...or individual key/values interpreted by **params:: await conn.execute( table.insert(), id=1, value="v1" ) In the case that a plain SQL string is passed, a tuple or individual values in *multiparams may be passed:: await conn.execute( "INSERT INTO table (id, value) VALUES (%d, %s)", (1, "v1") ) await conn.execute( "INSERT INTO table (id, value) VALUES (%s, %s)", 1, "v1" ) Returns ResultProxy instance with results of SQL query execution. )_executer)r%query multiparamsparamscoros rexecuteSAConnection.executes(J}}U;[;F;*400rcU(ax[U[[45(a]U(a@[URR U5VVs0sHupVUR U_M nnnO[R"S5eURU5nURnUV s0sH!n XRU [5"Xy5_M# sn /n URRU 5n U S$s snnfs sn f)z handle params z=Don't mix sqlalchemy SELECT clause with positional parametersr) isinstancelisttupleziptableckeyr ArgumentErrorconstruct_params_bind_processorsgetrr#execute_sequence_format) r%r-dpcompiled is_updater9pvalcompiled_params processorsr:r/post_processed_paramss r _base_paramsSAConnection._base_paramsGs *R$//14U[[]]B1GH1GgaaeeTk1GH''! #33B7.. ' & T*?+?@ @&  !% E Ef M$Q''I s C-!(C3c # Sn[U[5(aURX5IShvN O[U[5(a[R "S5e[U[ 5(aURURS9n/n[U[5nUH&nURURUUUU55 M( UR[U5U5IShvN URnO[R "S5e[UUURU5IShvN n URRU 5 U $GN NgN&7f)z executemany N=Don't mix sqlalchemy DDL clause and execution with parametersr"Lsql statement should be str or SQLAlchemy data selection/modification clause)r4str executemanyrrr;rcompiler#rappendrG_result_columnsrr add) r%r-dpscursor result_maprAr/rBr@rets r _executemanySAConnection._executemany]sA eS ! !$$U0 0 0 z * *##4 } - -}}T]]};HF"5*5I %% ! $$S]F; ; ;!11J##0  (   MM     s# E 1& < s5,EEB:E)E*AE,E-"EEEc # URR5IShvN n[X#5n[U5S:aUR XU5IShvN $U(aUSnSn[ U[ 5(a$URX=(d S5IShvN GO[ U[5(GaTURbUnURRU5nU(drURURS9nU(a,UR5URR5:XdU(dUR(dXRU'OURURS9n[ U[5(d/UR!UUU[ U["55n UR$nO/U(a[&R("S5eUR+5n SnUR[ U5U 5IShvN O[&R("S5e[-XURU5IShvN n UR.R1U 5 U $GN<GN GNN`N,7f)NrrrKrJrL)rrT_distill_paramslenrWr4rMr1rr$r>rOr#keysr/rrGrrQrr;r<rr rR) r%r-r.r/rTr@rUr:rArFrVs rr,SAConnection._executes''..00 [ 1 r7Q;**5f== = AB eS ! !.. d3 3 3 } - -##///33C8$}}T]]}CHbggi8??+?+?+AA$&(//4<,,S1 ===?eZ00(,(9(9uj1 )% &55 ++-LMM(0(A(A(C%! ..X0EF F F##%DE E( $--   s# _1> 48 G  sYI)I3I)IAI)I"E*I)I%5I):I';"I)I)"I)%I)'I)c~# UR"U/UQ70UD6IShvN nUR5IShvN $NN7f)z0Executes a SQL query and returns a scalar value.N)r1scalar)r%r-r.r/ress rr_SAConnection.scalars8LL????jjl"#@"s=9=;==cXURSL=(d URR$)zAThe readonly property that returns True if connections is closed.N)rclosedr%s rrcSAConnection.closeds&4'B4+;+;+B+BBrcUR$r)rrds rr&SAConnection.connectionsrc8UR5n[U5$)aBegin a transaction and return a transaction handle. The returned object is an instance of Transaction. This object represents the "scope" of the transaction, which completes when either the .rollback or .commit method is called. Nested calls to .begin on the same SAConnection instance will return new Transaction objects that represent an emulated transaction within the scope of the enclosing transaction, that is:: trans = await conn.begin() # outermost transaction trans2 = await conn.begin() # "nested" await trans2.commit() # does nothing await trans.commit() # actually commits Calls to .commit only have an effect when invoked via the outermost Transaction object, though the .rollback method of any of the Transaction objects will roll back the transaction. See also: .begin_nested - use a SAVEPOINT .begin_twophase - use a two phase/XA transaction )_beginr)r%r0s rbeginSAConnection.begins6{{})$//rc# URc4[U5UlUR5IShvN UR$[XR5$N%7fr)rr _begin_implr rds rriSAConnection._beginsR    $ / 5D ""$ $ $$$ $t%6%67 7 %s1AA&Ac# URR5IShvN nURS5IShvN UR5IShvN gN7NN !UR5IShvN f=f7f)NBEGIN)rrTr1closer%curs rrmSAConnection._begin_impls\$$++-- ++g& & &))+   . & #))+  sSA<AA<AAAA<AA<AA<A92A53A99A<c# URR5IShvN nURS5IShvN UR5IShvN SUlgN>N&N!UR5IShvN SUlf=f7f)NCOMMITrrTr1rqrrrs r _commit_implSAConnection._commit_implsl$$++-- %++h' ' '))+   $D  . ' #))+   $D SB AB A%A!A%B A# B !A%#B %B9A<: BB c# URR5IShvN nURS5IShvN UR5IShvN SUlgN>N&N!UR5IShvN SUlf=f7f)NROLLBACKrwrrs r_rollback_implSAConnection._rollback_implsl$$++-- %++j) ) )))+   $D  . ) #))+   $D rzc.# URc4[U5UlUR5IShvN UR$[XR5UlUR 5IShvN URlUR$N]N!7f)aBegin a nested transaction and return a transaction handle. The returned object is an instance of :class:`.NestedTransaction`. Nested transactions require SAVEPOINT support in the underlying database. Any transaction in the hierarchy may .commit() and .rollback(), however the outermost transaction still controls the overall .commit() or .rollback() of the transaction of a whole. N)rr rmr _savepoint_impl _savepointrds r begin_nestedSAConnection.begin_nesteds    $ / 5D ""$ $ $   !2$8I8I JD 151E1E1G+GD   (   %,Hs!1BB=B1B2 BBcL# U=RS- slSUR-nURR5IShvN nURSU-5IShvN UUR 5IShvN $N;N N !UR 5IShvN f=f7f)Nrzaiomysql_sa_savepoint_%sz SAVEPOINT )rrrTr1rq)r%namerss rrSAConnection._savepoint_impls q )D,?,??$$++-- ++lT12 2 2))+   . 2 #))+  sZAB$BB$ B!B"B'B$:B;B$BB$B!BB!!B$c# URR5IShvN nURSU-5IShvN UR5IShvN X lgN@N%N!UR5IShvN f=f7f)NzROLLBACK TO SAVEPOINT rwr%rparentrss r_rollback_to_savepoint_impl(SAConnection._rollback_to_savepoint_impl"sh$$++-- ++6=> > >))+  " . > #))+  TBA!BA'A#A'BA% B#A'%B'B;A><BBc# URR5IShvN nURSU-5IShvN UR5IShvN X lgN@N%N!UR5IShvN f=f7f)NzRELEASE SAVEPOINT rwrs r_release_savepoint_impl$SAConnection._release_savepoint_impl*sh$$++-- ++2T9: : :))+  " . : #))+  rc# URb[R"S5eUcURR 5n[ X5UlUR SU5IShvN UR$N7f)aGBegin a two-phase or XA transaction and return a transaction handle. The returned object is an instance of TwoPhaseTransaction, which in addition to the methods provided by Transaction, also provides a TwoPhaseTransaction.prepare() method. xid - the two phase transaction id. If not supplied, a random id will be generated. NzOCannot start a two phase transaction when a transaction is already in progress.z XA START %s)rrInvalidRequestErrorr# create_xidr r1r%xids rbegin_twophaseSAConnection.begin_twophase2sv    ())*+ + ;--**,C/:ll=#...    /sA&A;(A9)A;c# URSU-5IShvN URSU-5IShvN gN!N7f)N XA END '%s'zXA PREPARE '%s'r1rs r_prepare_twophase_impl#SAConnection._prepare_twophase_implIs<ll=3.///ll,s2333 03sA<A>AAct# URS5IShvN nUVs/sHo"SPM sn$Ns snf7f)z3Return a list of prepared twophase transaction ids.z XA RECOVER;Nrr)r%resultrows rrecover_twophaseSAConnection.recover_twophaseMs5||M22"()&3A&))3)s818388T) is_preparedc# U(dURSU-5IShvN URSU-5IShvN gN!N7f)z'Rollback prepared twophase transaction.rNzXA ROLLBACK '%s'rr%rrs rrollback_preparedSAConnection.rollback_preparedRs?,,}s23 3 3ll-3444 44AAAAAAc# U(dURSU-5IShvN URSU-5IShvN gN!N7f)z%Commit prepared twophase transaction.rNzXA COMMIT '%s'rrs rcommit_preparedSAConnection.commit_preparedXs?,,}s23 3 3ll+c1222 42rcXURSL=(a URR$)z,Return True if a transaction is in progress.N)r is_activerds rin_transactionSAConnection.in_transaction^s&  ,L1B1B1L1LLrc# URcgURb)URR5IShvN SUlURR U5 SUlSUlgN57f)aClose this SAConnection. This results in a release of the underlying database resources, that is, the underlying connection referenced internally. The underlying connection is typically restored back to the connection-holding Pool referenced by the Engine that produced this SAConnection. Any transactional state present on the underlying connection is also unconditionally released via calling Transaction.rollback() method. After .close() is called, the SAConnection is permanently in a closed state, and will allow no further operations. N)rrrollbackr!releaserds rrqSAConnection.closecsj    #     (##,,. . . $D  T" /s9A3A16A3c# U$7frrrds r __aenter__SAConnection.__aenter__}s  sc@# UR5IShvN gN7fr)rq)r%exc_typeexc_valexc_tbs r __aexit__SAConnection.__aexit__sjjls )r$rr#r!rrr r) __name__ __module__ __qualname____firstlineno__r)r1rGrWr,r_propertyrcr&rjrirmrxr}rrrrrrrrrrrqrr__static_attributes__rrrrrs.&1P(,(T0d$ CC  0<8%%!& ##!.4* ;?5 9=3 MM4rrcxU(d U(aU/$/$[U5S:XalUSn[U[[45(a4U(a([ USS5(a[ USS5(dU$U/$[ US5(aU/$U//$[ USS5(a[ USS5(dU$U/$)zGiven arguments from the calling form *multiparams, **params, return a list of bind parameter structures, usually a list of dictionaries. In the case of 'raw' execution which accepts positional parameters, it may be a list of tuples or lists. rr__iter__stripr\)r[r4r5r6hasattr)r.r/zeros rrZrZs  8OI [ Q 1~ dT5M * *747J77Q11 v T6 " "6MF8O KNJ / /KNG44 = r)rsqlalchemy.sqlrsqlalchemy.sql.dmlrsqlalchemy.sql.ddlrrrr transactionr r r r utilsrrrrrZrrrrs?())'BBK mm` %!r