b?i[ZSSKrSSKrSSKrSSKrSSKJrJrJrJrJ r J r J r J r J r Jr SSKJr SSKJr \R&"S\R(\R*-5r"SS5r"S S 5r"S S \\5r"S S5r"SS\\5r"SS\5r"SS\\5rg)N) WarningErrorInterfaceError DataError DatabaseErrorOperationalErrorIntegrityError InternalErrorNotSupportedErrorProgrammingError)logger) FIELD_TYPEz|\s*((?:INSERT|REPLACE)\s.+\sVALUES?\s+)(\(\s*(?:%s|%\(.+\)s)\s*(?:,\s*(?:%s|%\(.+\)s)\s*)*\))(\s*(?:ON DUPLICATE.*)?);?\s*\Zc\rSrSrSrSrS)Sjr\S5r\S5r \S5r \S5r \S 5r \ RS 5r \S 5r\S 5r\S 5rSrSrSrSrSrSrSrSrS*SjrS*SjrSrSrS+SjrSrS*SjrSr S,Sjr!S r"S!r#S"r$S#r%\&r&\'r'\(r(\)r)\*r*\+r+\,r,\-r-\.r.\/r/S$r0S%r1S&r2S'r3S(r4g)-Cursorz-Cursor is used to interact with the database.icXlURRUlSUlSUlSUlSUlSUlSUlSUl SUl X l g)zVDo not create an instance of a Cursor yourself. Call connections.Connection.cursor(). Nrr ) _connectionloop_loop _description _rownumber _rowcount _arraysize _executed_result_rows _lastrowid_echo)self connectionechos T/var/www/html/livechat/backend/venv/lib/python3.13/site-packages/aiomysql/cursors.py__init__Cursor.__init__$s[&%%**     cUR$)zeThis read-only attribute return a reference to the Connection object on which the cursor was created.rr!s r$r"Cursor.connection4sr'cUR$)aBThis read-only attribute is a sequence of 7-item sequences. Each of these sequences is a collections.namedtuple containing information describing one result column: 0. name: the name of the column returned. 1. type_code: the type of the column. 2. display_size: the actual length of the column in bytes. 3. internal_size: the size in bytes of the column associated to this column on the server. 4. precision: total number of significant digits in columns of type NUMERIC. None for other types. 5. scale: count of decimal digits in the fractional part in columns of type NUMERIC. None for other types. 6. null_ok: always None as not easy to retrieve from the libpq. This attribute will be None for operations that do not return rows or if the cursor has not had an operation invoked via the execute() method yet. )rr*s r$ descriptionCursor.description:s,   r'cUR$)aReturns the number of rows that has been produced of affected. This read-only attribute specifies the number of rows that the last :meth:`execute` produced (for Data Query Language statements like SELECT) or affected (for Data Manipulation Language statements like UPDATE or INSERT). The attribute is -1 in case no .execute() has been performed on the cursor or the row count of the last operation if it can't be determined by the interface. )rr*s r$rowcountCursor.rowcountRs~~r'cUR$)zRow index. This read-only attribute provides the current 0-based index of the cursor in the result set or ``None`` if the index cannot be determined. )rr*s r$ rownumberCursor.rownumberar'cUR$)How many rows will be returned by fetchmany() call. This read/write attribute specifies the number of rows to fetch at a time with fetchmany(). It defaults to 1 meaning to fetch a single row at a time. rr*s r$ arraysizeCursor.arraysizelr5r'cXlg)r7Nr8)r!vals r$r9r:ws r'cUR$)aBThis read-only property returns the value generated for an AUTO_INCREMENT column by the previous INSERT or UPDATE statement or None when there is no such value available. For example, if you perform an INSERT into a table that contains an AUTO_INCREMENT column, lastrowid returns the AUTO_INCREMENT value for the new row. )rr*s r$ lastrowidCursor.lastrowidsr'cUR$)zReturn echo mode status.)r r*s r$r# Cursor.echoszzr'c,UR(dS$S$)z\The readonly property that returns ``True`` if connections was detached from current cursor TFr)r*s r$closed Cursor.closeds  ++t66r'c# URnUcgUR5IShvN (a UR5IShvN (aM SUlgN1N!SUlf=f7f)z2Closing a cursor just exhausts all remaining data.N)rnextsetr!conns r$close Cursor.closesZ <  $'''' $D ( $D s>A)AAAA AA)AA A&&A)cRUR(d [S5eUR$)Nz Cursor closed)rr r*s r$_get_dbCursor._get_dbs""?3 3r'c<UR(d [S5eg)Nzexecute() first)rr r*s r$_check_executedCursor._check_executeds~~"#45 5r'cU$Nr!rows r$ _conv_rowCursor._conv_rows r'cgz!Does nothing, required by DB API.NrSr!argss r$ setinputsizesCursor.setinputsizesr'cgrYrSrZs r$setoutputsizesCursor.setoutputsizesr^r'c"# UR5nURnUbX!RLagUR(dgSUlUR5 UR 5IShvN UR 5IShvN gNN7f)zGet the next query setNT)rLrhas_next _clear_result next_result_do_get_result)r!rHcurrent_results r$rFCursor.nextsetsy||~  !^<<%G &&      !!### !#s$A+B-B .BB B Bc&^[U[[45(a[U4SjU55$[U[5(a5UR 5VVs0sHup4UTR U5_M snn$TR U5$s snnf)Nc3F># UHnTRU5v M g7frR)escape).0argrHs r$ &Cursor._escape_args..s:TcS))Ts!) isinstancetuplelistdictitemsrk)r!r[rHkeyr<s ` r$ _escape_argsCursor._escape_argsst dUDM * *:T:: : d # #<@JJLILjsCS))LI I;;t$ $ JsB NcRUR5nUbXRX#5-nU$)aReturns the exact string that is sent to the database by calling the execute() method. This method follows the extension to the DB API 2.0 followed by Psycopg. :param query: ``str`` sql statement :param args: ``tuple`` or ``list`` of arguments for sql query )rLrvr!queryr[rHs r$mogrifyCursor.mogrifys-||~  --d99E r'c# UR5nUR5IShvN (a UR5IShvN (aM UbXRX#5-nURU5IShvN XlUR (a-[ R"U5 [ R"SU5 UR$NNNX7f)a~Executes the given operation Executes the given operation substituting any markers with the given parameters. For example, getting all rows where id is 5: cursor.execute("SELECT * FROM t1 WHERE id = %s", (5,)) :param query: ``str`` sql statement :param args: ``tuple`` or ``list`` of arguments for sql query :returns: ``int``, number of rows that has been produced of affected N%r) rLrFrv_queryrr rinforrys r$executeCursor.executes||~\\^## \\^##  --d99Ekk%    :: KK  KKd #~~$ !s:$CCCC C*C:C;ACCCc # U(dgUR(a.[R"SU5 [R"SU5 [R U5nU(aUR S5S-nUR S5R 5nUR S5=(d SnUS S :Xa US S :XdeURXEXbURUR5R5IShvN $S nUH*nURX5IShvN XpR- nM, Xpl UR$NHN*7f) a{Execute the given operation multiple times The executemany() method will execute the operation iterating over the list of parameters in seq_params. Example: Inserting 3 new employees and their phone number data = [ ('Jane','555-001'), ('Joe', '555-001'), ('John', '555-003') ] stmt = "INSERT INTO employees (name, phone) VALUES ('%s','%s')" await cursor.executemany(stmt, data) INSERT or REPLACE statements are optimized by batching the data, that is using the MySQL multiple rows syntax. :param query: `str`, sql statement :param args: ``tuple`` or ``list`` of arguments for sql query NCALL %sr~r rSr(r)) r rrRE_INSERT_VALUESmatchgrouprstrip_do_execute_manymax_stmt_lengthrLencodingrr) r!rzr[mq_prefixq_values q_postfixrowsrms r$ executemanyCursor.executemanys,  :: KK 5 ) KKd #  " "5 ) wwqzBHwwqz((*H (bIA;#%(2,#*= ==//IT5I5I '')) *Dll5...&"N~~) /s$C>E E E  E !)E  E c# UR5nURn[U[5(aUR U5n[U[5(aUR U5n[ U5n [ U5nX("[U5U5-n [U [5(aU R US5n X- n Sn UHn X("X5-n [U [5(aU R US5n [U 5[U 5-[U5-S-U:a+URX-5IShvN n X- n [ U5n OU S- n X- n M URX-5IShvN n X- n Xl U $NHN7f)Nsurrogateescaperr ,) rLrvrpstrencode bytearrayiternextlenrr)r!prefixvaluespostfixr[rrrHrksqlvrrmrs r$rCursor._do_execute_many$sa||~"" fc " "]]8,F gs # #nnX.GDz VDJ- - a  #45A C**A!S!!HHX'893x#a& 3w</!3oE,,s}55 't  HC,,s}- -  6 .s$D6F8F97F0F1FFc^# UR5nUR(a.[R"ST5 [R"SU5 [ U5HLupESTXCR U54-nUR U5IShvN UR5IShvN MN SRU4Sj[[U5555nSTSUS 3nUR U5IShvN X`l U$NwNaN7f) aExecute stored procedure procname with args Compatibility warning: PEP-249 specifies that any modified parameters must be returned. This is currently impossible as they are only available by storing them in a server variable and then retrieved by a query. Since stored procedures return zero or more result sets, there is no reliable way to get at OUT or INOUT parameters via callproc. The server variables are named @_procname_n, where procname is the parameter above and n is the position of the parameter (from zero). Once all result sets generated by the procedure have been fetched, you can issue a SELECT @_procname_0, ... query using .execute() to get any OUT or INOUT values. Compatibility warning: The act of calling a stored procedure itself creates an empty result set. This appears after any result sets generated by the procedure. This is non-standard behavior with respect to the DB-API. Be sure to use nextset() to advance through all result sets; otherwise you may get disconnected. :param procname: ``str``, name of procedure to execute on server :param args: `sequence of parameters to use with procedure :returns: the original args. rr~zSET @_%s_%d=%sN,c32># UH nSTU4-v M g7f)z@_%s_%dNrS)rliprocnames r$rn"Cursor.callproc..gsMr#rCrIrLrOrVr\r`rFrvr{rrrrrrrrrrdrfrrrrrrrr r r r rrrr__static_attributes__rSr'r$rrs7O   !!.  77 $ 600 % 8,\>(T .(<$ ,0G E#N!MI'#N!M')%r'rc:^\rSrSrU4SjrSrU4SjrSrU=r$)_DeserializationCursorMixinic># [TU]5IShvN UR(a1URVs/sHoRU5PM snUlggNGs snf7frR)superrfr_deserialization_row)r!r __class__s r$rf*_DeserializationCursorMixin._do_get_result sNg$&&& ::@D K 133A6 KDJ  'Ks A$A#A$A A$A$cUcg[U[5(aSnO [U5nSn[UR5HkuntpEnU[ R :XdMU(aUOUn[R"[[5 [R"X5X'SSS5 Mm U(aU$[U5$!,(df  M=f)NTF)rprsrrrrrJSON contextlibsuppress ValueError TypeErrorjsonloadsrq)r!rU dict_flagrname field_typenpoints r$r0_DeserializationCursorMixin._deserialization_rows ; c4 Is)CI-6t7H7H-I )E)DqZ__, )u((Y?!%CJ!7CJ@?.J J:  @?s C C cL>Ucg[TU]U5nURU5$rR)rrVrr!rUrs r$rV%_DeserializationCursorMixin._conv_row s+ ;g$((--r')r) rrrrrfrrVr __classcell__rs@r$rrsL $..r'rc\rSrSrSrSrg)DeserializationCursori'z6A cursor automatic deserialization of json type fieldsrSNrrrrrrrSr'r$rr's@r'rc8^\rSrSr\rU4SjrU4SjrSrU=r $)_DictCursorMixini+c># [TU]5IShvN /nUR(aWURRH7nUR nX1;aUR S-U-nURU5 M9 XlU(aCUR(a1URVs/sHo@RU5PM snUl gggNs snf7f)N.) rrfrrfieldsr table_nameappend_fieldsrrV)r!r"frrrs r$rf_DictCursorMixin._do_get_result/sg$&&&   \\((vv><<#-4D d# ) "L djj59ZZ@Z..+Z@DJ!6 'As"CCBC*C CCct>Ucg[TU]U5nUR[URU55$rR)rrV dict_typezipr%rs r$rV_DictCursorMixin._conv_row=s4 ;g$~~c$,,455r')r%r) rrrrrsr)rfrVrrrs@r$rr+sI A66r'rc\rSrSrSrSrg) DictCursoriDz.A cursor which returns results as a dictionaryrSNrrSr'r$r-r-Ds8r'r-cJ\rSrSrSrSrSrSrSrSr S S jr S S jr S r g)SSCursoriHaUnbuffered Cursor, mainly useful for queries that return a lot of data, or for connections to remote servers over a slow network. Instead of copying every row of data into a buffer, this will fetch rows as needed. The upside of this, is the client uses much less memory, and rows are returned much faster when traveling over a slow network, or if the result set is very big. There are limitations, though. The MySQL protocol doesn't support returning the total number of rows, so the only way to tell how many rows there are is to iterate over every row returned. Also, it currently isn't possible to scroll backwards, as only the current row is held in memory. cj# URnUcgURb;URURLa"URR5IShvN UR5IShvN (a UR5IShvN (aM SUlgNJN3N!SUlf=f7frR)rr_finish_unbuffered_queryrFrGs r$rISSCursor.closeWs <  << #  (D,,779 9 9 $'''' $D  :( $D sNAB3B!B3B'/B#0B' B% B' B3#B'%B'' B00B3c# UR5nXlURUSS9IShvN UR5IShvN UR$N(N7f)NT) unbuffered)rLrrzrfrrs r$rSSCursor._queryesP||~jjtj,,,!!###~~ -#s!*AAAAAAcx# URR5IShvN nURU5nU$N7f)zRead next row N)r_read_rowdata_packet_unbufferedrVrTs r$ _read_nextSSCursor._read_nextls3LL@@BBnnS! Cs :8:c# UR5 UR5IShvN nUcgU=RS- slU$N7f)zFetch next row Nr )rOr8rrTs r$rSSCursor.fetchoners@ OO%% ;  1 &s$AA Acv# /nUR5IShvN nUcU$URU5 M1N7f)zPFetch all, as per MySQLdb. Pretty useless for large queries, as it is buffered. N)rr$)r!rrUs r$rSSCursor.fetchall{s@ 'C{  KK  's 979Nc# UR5 Uc URn/n[U5HGnUR5IShvN nUc U$UR U5 U=R S- slMI U$N67f)rNr )rOrrr8r$r)r!rrrrUs r$rSSCursor.fetchmanysz  <??DtA))C{  KK  OOq O   *sAA>A<7A>c# UR5 US:XaQUS:a [S5e[U5HnUR5IShvN M U=RU- slgUS:XaYXR:a [S5eXR- n[U5HnUR5IShvN M Xlg[ SU-5eNN7f)aScroll the cursor in the result set to a new position according to mode . Same as :meth:`Cursor.scroll`, but move cursor on server side one by one row. If you want to move 20 rows forward scroll will make 20 queries to move cursor. Currently only forward scrolling is supported. :param int value: move cursor to next position according to mode. :param str mode: scroll mode, possible modes: `relative` and `absolute` rrz0Backwards scrolling not supported by this cursorNrr)rOr rr8rr )r!rr_rs r$rSSCursor.scrolls  : qy')9::5\oo'''" OOu $O Z &'FHH//)C3Zoo''' #O"#;d#BC C((s%A C C A-C9C:CC)rrrrRr) rrrrrrIrr8rrrrrrSr'r$r/r/Hs+  $  0Dr'r/c\rSrSrSrSrg) SSDictCursorizrKs ))) "::'MMBII kk\..>A7A6629!69vDvvDrG#XGr'