G)fPdZdgZddlZddlZddlmZddlmZddlm Z m Z m Z m Z m Z mZmZmZmZmZddlmZdd lmZmZmZmZmZmZmZmZmZmZm Z m!Z!dd l"m#Z#m$Z$m%Z%m&Z&m'Z'dd l(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2d d l3m4Z4m5Z5m6Z6dZ7GddZ8de9de e9e9fde9fdZ:Gdde6Z;Gdde;Z<Gdde;Z=Gdde<Z>Gdde;Z?Gdde;Z@Gd d!e?e<ZAGd"d#e@e<ZBGd$d%e;ZCGd&d'e?eCZDGd(d)e@eCZEGd*d+eCZFy),z0Implementation of cursor classes in pure Python. MySQLCursorN) namedtuple)Decimal) AnyAsyncGeneratorDictIteratorListNoReturnOptionalSequenceTupleUnion) ServerFlag) MAX_RESULTSRE_PY_MAPPING_PARAM RE_PY_PARAMRE_SQL_COMMENTRE_SQL_FIND_PARAMRE_SQL_INSERT_STMTRE_SQL_INSERT_VALUESRE_SQL_ON_DUPLICATE RE_SQL_PYTHON_CAPTURE_PARAM_NAMERE_SQL_PYTHON_REPLACE_PARAMis_eol_commentparse_multi_statement_query)ErrorInterfaceErrorNotSupportedErrorProgrammingErrorget_mysql_exception) DescriptionType EofPacketTypeParamsDictTypeParamsSequenceOrDictTypeParamsSequenceType ResultType RowItemTypeRowType StrOrBytes WarningType)NAMED_TUPLE_CACHEMySQLConnectionAbstractMySQLCursorAbstractzNo result set to fetch fromc`eZdZdZdeeddfdZdejdefdZ e de fdZ y) _ParamSubstitutorz+Substitute parameters into a SQL statement.paramsreturnNc ||_d|_yNr)r3index)selfr3s W/var/www/html/flask-app/venv/lib/python3.12/site-packages/mysql/connector/aio/cursor.py__init__z_ParamSubstitutor.__init___s'-  matchobjc|j}|xjdz c_ t|j|S#t$r t ddwxYw)Nr-z+Not enough parameters for the SQL statement)r7bytesr3 IndexErrorr!)r8r<r7s r9__call__z_ParamSubstitutor.__call__csS  a  U+, , "=  s ;AcFt|j|jz S)zr:reMatchr@propertyintrDr;r9r2r2\sN5x4e-3--r;r2bytestr value_dictr4cldtjdtffd }tj||}|S)ah >>> _bytestr_format_dict(b'%(a)s', {b'a': b'foobar'}) b'foobar >>> _bytestr_format_dict(b'%%(a)s', {b'a': b'foobar'}) b'%%(a)s' >>> _bytestr_format_dict(b'%%%(a)s', {b'a': b'foobar'}) b'%%foobar' >>> _bytestr_format_dict(b'%(x)s %(y)s', ... {b'x': b'x=%(y)s', b'y': b'y=%(x)s'}) b'x=%(y)s y=%(x)s' r<r4cd}|j}|ddk(rd}|ddk(r |d}|}|td|d|S)zReplace pattern.Nconversion_type%s mapping_keyzUnsupported conversion_type: ) groupdict ValueError)r<valuegroupskeyrOs r9replacez%_bytestr_format_dict..replacest!%##% # $ ,E # $ ,'CsOE =/7H0I/JK  r;)rIrJr>rsub)rNrOr[stmts ` r9_bytestr_format_dictr^ss3 "(( u   " "7G 4D Kr;c eZdZdZdefdZdefdZdede e e e e fffdZ dedee e e fdffdZd eed fdeed ffd Zd*d edeefd Zdedd fdZd+dZdedd fdZd+dZdedd fdZd+dZdefdZd+dZ d,de de e!e"e e#e"ffde fdZ$dee%e&fdZ'de#de!e(dee fdZ)de*efdZ+ d,de#d e!e"dee e e#e,feffd!Z- d-de de e!e"e e#e"ffd"edd fd#Z. d,de de e!e"e e#e"ffdeed ffd$Z/de#de!edd fd%Z0deefd&Z1de%efd'Z2d.d(ee3de%efd)Z4y )/raDefault cursor for interacting with MySQL. This cursor will execute statements and handle the result. It will not automatically fetch all rows. MySQLCursor should be inherited whenever other functionallity is required. An example would to change the fetch* member functions to return dictionaries instead of lists of values. Implements the Python Database API Specification v2.0 (PEP-249). r4cRK|jd{}||St7wN)fetchoneStopAsyncIterationr8ress r9 __anext__zMySQLCursor.__anext__s)MMO# ?J  $s '%'cK|jsy|jj||jjd{|jd{d|_y7$7w)NFT) _connection remove_cursorhandle_unread_result _reset_resultrCs r9closezMySQLCursor.closesd &&t,33555  """ 6"s$AA1A- A1 A/! A1/A1r3ci} |jjj}|jjj}|jjj}|j D]B\}}|}||}||}t |ts||}|||j<D |S#t$r} td| | d} ~ wwxYw)z-Process query parameters given as dictionary.z'Failed processing pyformat-parameters; N) rh converterto_mysqlescapequoteitems isinstancerencode Exceptionr!) r8r3rerorprqrZrXconverrs r9_process_params_dictz MySQLCursor._process_params_dicts!# ''11::H%%//66F$$..44E$lln ) U~d|!%1 ;D$(CJJL!  )  "9#?  sB5B<< CCC.c|dd} |jjj}|jjj}|jjj}|Dcgc] }|| }}|Dcgc] }|| }}t |Dcgc]"\}}t ||ts||n|$}}}t|Scc}wcc}wcc}}w#t$r}td||d}~wwxYw)zProcess query parameters.Nz%Failed processing format-parameters; ) rhrnrorprq enumeratersrrur!tuple) r8r3resultrorprqrXirws r9_process_paramszMySQLCursor._process_paramss ''11::H%%//66F$$..44E39:%huo:F:178fUm8F8!*& 1Au%/vay'$Be MFV};8 "7u=  sBA$C$+C:C$CC$'CC$C$$ D-C<<D query_iterNcKt|j}d|_|r|jnd}|23d{}|jd{|j |d{t |rF|j |_||jjdrd|vs|r|jnd}77~7g6yw)a Generator returns MySQLCursor objects for multiple statements This method is only used when multiple statements are executed by the `cursor.execute(multi_stmt_query, multi=True)` method. It matches the given `query_iter` (result of `MySQLConnection.cmd_query_iter()`) and the list of statements that were executed. How does this method work? To properly map each statement (stmt) to a result, the following facts must be considered: 1. Read operations such as `SELECT` produce a non-empty result (calling `next(query_iter)` gets a result that includes at least one column). 2. Write operatios such as `INSERT` produce an empty result (calling `next(query_iter)` gets a result with no columns - aka empty). 3. End-of-line (EOL) comments do not produce a result, unless is the last stmt in which case produces an empty result. 4. Calling procedures such as `CALL my_proc` produce a sequence `(1)*0` which means it may produce zero or more non-empty results followed by just one empty result. In other words, a callproc stmt always terminates with an empty result. E.g., `my_proc` includes an update + select + select + update, then the result sequence will be `110` - note how the write ops results get annulated, just the read ops results are produced. Other examples: * insert + insert -> 0 * select + select + insert + select -> 1110 * select -> 10 Observe how 0 indicates the end of the result sequence. This property is vital to know what result corresponds to what callproc stmt. In this regard, the implementation is composed of: 1. Parsing: the multi-statement is broken down into single statements, and then for each of these, leading white spaces are removed (including jumping line, vertical line, tab, etc.). Also, EOL comments are removed from the stream, except when the comment is the last statement of the multi-statement string. 2. Mapping: the facts described above as used as "game rules" to properly match statements and results. In case, if we run out of statements before running out of results we use a sentinel named "stmt_overflow!" to indicate that the mapping went wrong. Acronyms 1: a non-empty result 2: an empty result ) multi_stmtNsstmt_overflow!sCALLcolumns) r _executedpopleftrk_handle_resultrrstripupper startswith)r8r executed_listr]r|s r9 _execute_iterzMySQLCursor._execute_iters^4t~~N *7}$$&=N& W W&$$& & &%%f- - -d#![[]DNJ::<**73y7N2?},,.EV W & -'sP4CCCCCCC+C,A C:CCCCCrawclK|jjsyd}|jdk(r>|jj|j|j |d{\}}n|j\}}|r|jj|j|j |d{|_|jd}||j |d{|jdk(rd|_n|xjdz c_|r|j |d{|S77~7Q7 w)&Return the next row in the result set.NNN)binaryrrr-)rh unread_result_nextrowget_row_binary description _handle_eof _rowcount)r8rroweofs r9 _fetch_rowzMySQLCursor._fetch_rows -- ==L (#//77||T-=-=3 8 JS#JS# "&"2"2":":||T-=-=3#;#DM--"C&&s+++~~#!"!# ""3' ' ' ) , (sJAD4 D,!AD4/D.0.D4D0AD4%D2&D4.D40D42D4r|c,Kt|ts tdd|vr4|d|_d|j_|j d{yd|vr+d|j_|j|d{ytd7?7w)zHandle the result after a command was send. The result can be either an OK-packet or a dictionary containing column/eof information. Raises: InterfaceError: When result is not a dict() or result is invalid. zResult was not a dict()rTN affected_rowsFzInvalid result)rsdictr _descriptionrhr_handle_resultset_handle_noresultsetr8r|s r9rzMySQLCursor._handle_result6s&$' !:; ;   &y 1D -1D   *((* * *  &-2D   ***62 2 2 !12 2 + 3s$ABB.B?BBBc Kyw)Handle the result set. This method handles the result set and is called after reading and storing column information in _handle_result(). For non-buffering cursors, this method is usually doing nothing. NrMrCs r9rzMySQLCursor._handle_resultsetNssrecK |d|_|d|_|d|_|j d{y#ttf$r}t d|dd}~wwxYw7+w)zHandle result of execute() when there is no result set. Raises: ProgrammingError: When failing handling a non-resultset. r insert_id warning_countzFailed handling non-resultset; N)r_last_insert_id_warning_countKeyError TypeErrorr!_handle_warnings)r8rerws r9rzMySQLCursor._handle_noresultsetVsz  V 1DN#&{#3D "%o"6D ##%%%)$ V"%DSE#JKQU U V &s/A#;A#A!A#A AAA#cK|jjr)|jr|jd{|_|jsyt |jdd|jdd|jj }|jj r|tj|dy7w)zHandle possible warnings after all results are consumed. Raises: Error: Also raises exceptions if raise_on_warnings is set. Nrr-r)warning) stacklevel) rh get_warningsr_fetch_warnings _warningsr"raise_on_warningswarningswarn)r8rws r9rzMySQLCursor._handle_warningses    ( (T-@-@#'#7#7#99DN~~ ! NN1 a NN1 a ((:::     - -I ca(:s6CCB CrcKd|j_d|_|d|_|j d{y7w)zHandle EOF packet.FrrN)rhrrrrr8rs r9rzMySQLCursor._handle_eof|s:).&$ !/2##%%%s6A>AcKd|_d|_d|_d|_g|_g|_d|_d|_|jd{y7w)Reset the cursor to default.Nrrr) rrrr_executed_list_stored_resultsrrresetrCs r9rkzMySQLCursor._reset_resultsQ  !$ jjlsA AAAcN |jjS#t$rYywxYw)z(Check whether there is an unread result.F)rhrAttributeErrorrCs r9_have_unread_resultzMySQLCursor._have_unread_results+ ##11 1  s  $$c:|jtty)zCheck if the statement has been executed. Raises: InterfaceError: If the statement has not been executed. N)rrERR_NO_RESULT_TO_FETCHrCs r9_check_executedzMySQLCursor._check_executeds >> ! !78 8 "r; operationcF t|ttfr|n$|j|jj }|rt|trt||j|}|St|ttfrLt|j!|}t#j$||}|j&dk7r td|Stdt)|j*d|d|S#t tf$r}tt||d}~wwxYw)a'Prepare SQL statement for execution. Converts the SQL statement to bytes and replaces the parameters in the placeholders. Raises: ProgrammingError: On converting to bytes, missing parameters or invalid parameters type. Nr1Not all parameters were used in the SQL statementzCould not process parameters: (z)), it must be of type list, tuple or dict)rsr> bytearrayrtrhpython_charsetUnicodeDecodeErrorUnicodeEncodeErrorr!strrr^rxlistr{r2r~rr\rDtyperE)r8rr3r]rwpsubs r9_prepare_statementzMySQLCursor._prepare_statements# 6i%);<%%d&6&6&E&EF  &$'+D$2K2KF2ST FT5M2()=)=f)EF"tT2>>Q&*K '4T&\5J5J4K1VHU>>  '#$67 6"3s8,# 5 6s=C77D DD c4Kg}|jjdd{4d{}|jdd{|jd{}dddd{|r|SdS7T7M767 7#1d{7swY"xYww)z%Fetch warnings doing a SHOW WARNINGS.FrNz SHOW WARNINGS)rhcursorexecutefetchall)r8r|curs r9rzMySQLCursor._fetch_warningss))00U0;; * *s++o. . .<<>)F * * v)T)< * .) * * * *sx"BA9BA;BBA=BA?B# B.B/ B;B=B?BBB B BB seq_paramsc dtjdtfd}tjtdtjt ||}tj t|}|s td|jdj|jj}g} |j|jj}|D]} |}t| trt||j!| }nJt#|j%| } t'j| |}| j(dk7r t+d|j-|||vr+|j/|d j1|d}||_|Sy #t4t6f$r} t+t| | d } ~ wt8$rt:$r} td | d d } ~ wwxYw) zImplements multi row insertmatchr4cH|jdry|jdS)aRemove comments from INSERT statements. This function is used while removing comments from INSERT statements. If the matched string is a comment not enclosed by quotes, it returns an empty string, else the string itself. r-r)group)rs r9remove_commentsz2MySQLCursor._batch_insert..remove_commentss {{1~;;q> !r;rzAFailed rewriting statement for multi-row INSERT. Check SQL syntaxr-rr,N Failed executing the operation; )rIrJrr\rrsearchrrrrtrhrrsrr^rxr2r~rrDr!appendr[joinrrrrru) r8rrrtmpmatchesfmtvaluesr]r3rrws r9 _batch_insertzMySQLCursor._batch_inserts "288 " "ff   FF>?I >  ))0#6 S mmA%%d&6&6&E&EF U##D$4$4$C$CDD$ #fd+.sD4M4Mf4UVC,T-A-A&-IJD%//$4C~~*.O c" #d{||C6):A>!% "$67 6"3s8,# 5   U #CC5!IJPT T Us%-C#FG!F66G GGc,t|jS)zReturns an iterator for stored results. This method returns an iterator over results which are stored when callproc() is called. The iterator will provide MySQLCursorBuffered instances. )iterrrCs r9stored_resultszMySQLCursor.stored_resultss D(())r;procnameargsc K|rt|ts tdt|ttfs tdg|_g} g}g}|j dd}|rg}t|D]\}} d|d|dz} |j| t| tr0|jd| d | dd |j| d b|j| |j| d jd |D} |jd| |d{d|dd j|d } |jj} |jj| 23d{}d|j_ t|ttfrt}n6t|t t"frt"}n|j$rt&}nt(}||jj+}d| d |_|j/|d{|j0|j0|_d|vs|j|7377=6| |j_ |rt5||D cgc]} | j7dncc} wc} Dcgc] \}}|d |ncc}}w}}}dd j|}|j|d{7||_|j9d{7S||_tS#t:$rt<$r}t?d|dd}~wwxYww)aCalls a stored procedure with the given arguments The arguments will be set during this session, meaning they will be called like ___arg where is an enumeration (+1) of the arguments. Coding Example: 1) Defining the Stored Routine in MySQL: CREATE PROCEDURE multiply(IN pFac1 INT, IN pFac2 INT, OUT pProd INT) BEGIN SET pProd := pFac1 * pFac2; END 2) Executing in Python: args = (5, 5, 0) # 0 is to hold pprod await cursor.callproc('multiply', args) print(await cursor.fetchone()) For OUT and INOUT parameters the user should provide the type of the parameter as well. The argument should be a tuple with first item as the value of the parameter to pass and second argument the type of the argument. In the above example, one can call callproc method like: args = (5, 5, (0, 'INT')) await cursor.callproc('multiply', args) The type of the argument given in the tuple will be used by the MySQL CAST function to convert the values in the corresponding MySQL type (See CAST in MySQL Reference for more information) Does not return a value, but a result set will be available when the CALL-statement execute successfully. Raises exceptions when something is wrong. zprocname must be a stringzargs must be a sequence.rz@__argr-z CAST(z AS )r,c3&K|] }|d yw)z=%sNrM).0args r9 z'MySQLCursor.callproc..Us'H3%s 'HszSET NzCALL rFz (a result of rzSELECT zFailed calling stored routine; ) rsrrWr{rrsplitrzrrrrhcan_consume_resultscmd_query_iterMySQLCursorDictMySQLCursorBufferedDictMySQLCursorNamedTupleMySQLCursorBufferedNamedTuple_rawMySQLCursorBufferedRawMySQLCursorBufferedget_selfrrrrziplstriprbrrur)r8rrresultsargnamesargtypes procname_abs argvaluesidxrargname placeholderscallrr| cursor_classrnamealiasselectrws r9callproczMySQLCursor.callprocsCPz(C889 9$ .67 7!H THH $>>#.r2L )$.HC "<.S1WI>GOOG,!#u- & c!fXQ(GH!((Q0 0!((-. #xx'Hx'HH llT,#8)DDD8*Achhx&8%9;D#'"2"2"F"F  $ 0 0 ? ? E ( (f7<  4d_6M$NO#:L*,IJ$ALYY#9L#6L#4#3#3#<#<#>?"/vQ 7 ((000<<+%(\\DN&NN3'=E ($1%!F24GD   0(+ x"H3::d#3"H"H(#efD( #388D>"23ll6***'.$!]]_,,,#*D 7N   T #B3%!HIt S TsAM  CL"(I)A L"6I":I;I">B$L""I #%L" L"I" L""L"J L"(J:92L"+K.,L" L L"M L"!M "M4MMM multicK|js td|sy|r td|jjd{|jd{|j ||}||_ |j |jj|d{d{y7q7[77 #t$r(}|jjr td|d}~wwxYww)amExecutes the given operation. Executes the given operation substituting any markers with the given parameters. For example, getting all rows where id is 5: await cursor.execute("SELECT * FROM t1 WHERE id = %s", (5,)) If the `multi`` parameter is used a `ProgrammingError` is raised. The method for executing multiple statements is `executemulti()`. If warnings where generated, and connection.get_warnings is True, then self._warnings will be a list containing these warnings. Raises: ProgramingError: If multi parameter is used. Cursor is not connectedNzThe `multi` parameter cannot be used in the Connector/Python Asyncio implementation. Please use `executemulti()` for executing multiple statementsz7Use `executemulti()` when executing multiple statements) rhr!rjrkrrr cmd_queryrhave_next_result)r8rr3rr]rws r9rzMySQLCursor.executes,"#<= = "  33555  """&&y&9 %%D,<,<,F,Ft,L&LM M M 6" 'M M 00$M   slAC5B9C5B; C5>)C'B=( C3B?4C8C5;C5=C?C C2 #C--C22C5c~K|js td|st|jjd{|j d{|j ||}||_g|_|j|jj|23d{}|7u7_76yw)Execute multiple statements. Executes the given operation substituting any markers with the given parameters. rN) rhr!rcrjrkrrrrr)r8rr3r]r|s r9 executemultizMySQLCursor.executemultis"#<= =$ $33555  """&&y&9  ..t/?/?/N/Nt/TU  &L 6"  UsG=B=B5B=B7AB=&B;*B9+B;.B=7B=9B;;B=cK|r|sy|jjd{ t|}t j t|r>|sd|_y|j||}| ||_ |j|d{Sd} |D]_}|j||d{|jr(|jr|jd{||jz }a ||_y7#t$r}t d|d}~wwxYw77s7A#ttf$r}t d|dd}~wwxYww)aPrepare and execute a MySQL Prepared Statement many times. This method will prepare the given operation and execute with each tuple found the list seq_params. If the cursor instance already had a prepared statement, it is first closed. N(Parameters for query must be an Iterablerr)rhrjrrr!rIrrrrrr with_rowsrrrW)r8rr_rwr]rowcntr3s r9 executemanyzMySQLCursor.executemanysP 33555 XZ A 88& 2!"%%i>d&>&>&@--/))$..(  ) 5 6 X"#MNTW W X0 6)I& W"%EcU#KLRV V Ws#E C>E  DAE  D E D#+D,3D#D! D#6 E  D DDE D#!D##E2EEE ctK|jtt|jd{S7w)zReturn next row of a query result set. Raises: InterfaceError: If there is no result to fetch. Returns: tuple or None: A row from query result set. N)rrrrrCs r9rbzMySQLCursor.fetchones1 >> ! !78 8__&&&&s /868cK|jtt|jjsgS|jj d{\}}|j dr|jd|j d|j|d{t|}|dk\r|jdk(rd|_ |xj|z c_ |S77Cw)Return all rows of a query result set. Returns: list: A list of tuples with all rows of a query result set. Nrr) rrrrhrget_rowsrinsertrrBrr8rowsrrowcounts r9rzMySQLCursor.fetchalls >> ! !78 8--I**3355 c ==  KK4==+ ,s###t9 q=T^^r1DN (" 6 $s&AC#CA C#C!AC#!C#sizecK|jg}|xs |j}|dkDr6|dz}|jd{}|r|j||dkDr6|S7w)a<Return the next set of rows of a query result set. When no more rows are available, it returns an empty list. The number of rows returned can be specified using the size argument, which defaults to one. Returns: list: The next set of rows of a query result set. rr-N)r arraysizerbrr8r&recntrs r9 fetchmanyzMySQLCursor.fetchmany'sh $dnnAg 1HC 'C 3 Ag  (sAA$A"A$ A$Fr4NrM)rMFra)5rErFrGrHr*rfboolrlr%rr>rrrxr'rr~rr(r0rr rrrrrr$rrkrrr+r rrrr r,rr&rr rr)rrrrrbrrLr+rMr;r9rrs !! T$ eU5'>** +,( uUG^$c) **=W(T)9:=W +T1 2=W~DXg5F:3:3$30  &Z &D &).&]&t& T98:''hsmT#s(^34'  'R*x[0A'B*6U6U*23K*L6U %6Up*)< =*!yTyTsmyT %S+-.78 9 yT|8: 11hsmT#s(^341 1  1l8:hsmT#s(^34 +T1 2 6( ( /0(   ( T ' 1 'W .HSMT']r;ceZdZdZdeddffd ZddZddedee fdZ dd eddfd Z dee fd Z de e fd Zedefd ZxZS)rz+Cursor which fetches rows within execute(). connectionr4Nc@t||d|_d|_yr6)superr:_rows _next_rowr8r1 __class__s r9r:zMySQLCursorBuffered.__init__@s $.2 r;cK|jjd{\|_}t|j|_|j |d{d|_d|j_y7X7w)rNrF)rhr!r4rBrrr5rrs r9rz%MySQLCursorBuffered._handle_resultsetEsf!% 0 0 9 9 ;; CTZZs###).& <#s!A=A9:A=A;A=;A=rcKd} |j|j}|xjdz c_|S#ttf$rYywxYww)rNr-)r4r5r?r)r8rrs r9rzMySQLCursorBuffered._fetch_rowRsO **T^^,C ! I&  s%A 6A AA AA freecKd|_yw)rNr4r8r:s r9rzMySQLCursorBuffered.reset\s  s c^K|j|jd{S7wyReturn next row of a query result set. Returns: tuple or None: A row from query result set. NrrrCs r9rbzMySQLCursorBuffered.fetchone`s' __&&&&s $-+-cK|j |jttg}|j|jd}t |j|_|Swr N)rr4rrr5rBrds r9rzMySQLCursorBuffered.fetchallisU >> !TZZ%7 !78 8jj)*TZZ sAA!c|jduSrar<rCs r9rzMySQLCursorBuffered.with_rowsvzz%%r;r-r,T)rErFrGrHr/r:rr/r r*rrrbr rrKr __classcell__r7s@r9rr=s5 #: t /DXg5F' 1' W &4&&r;rcPeZdZdZdeddffd ZdeefdZde efdZ xZ S)MySQLCursorRawzHSkip conversion from MySQL datatypes to Python types when fetching rows.r1r4Nc2t||d|_y)NT)r3r:rr6s r9r:zMySQLCursorRaw.__init__~s $ r;cbK|j|jdd{S7w)r@TrNrArCs r9rbzMySQLCursorRaw.fetchones+ ___....s &/-/cK|j|jsgS|jjdd{\}}|jdr|j d|jd|j |d{t|}|dk\r|jdk(rd|_|xj|z c_|S77Cw)r TrNrr) rrrhr!rr"rrBrr#s r9rzMySQLCursorRaw.fetchalls '')I**333== c ==  KK4==+ ,s###t9 q=T^^r1DN (" > $s&ACCA CCACC) rErFrGrHr/r:r r*rbr rrGrHs@r9rJrJ{s;R#:t/ 1/W r;rJc6eZdZUdZdZeed<edefdZy)rz Cursor which skips conversion from MySQL datatypes to Python types when fetching rows and fetches rows within execute(). Trr4c|jduSrar<rCs r9rz MySQLCursorBufferedRaw.with_rowsrEr;N) rErFrGrHrr/__annotations__rKrrMr;r9rrs, D$ &4&&r;rc eZdZdZ ddedeeedeee e ffdZ deee e fffd Z deeee e fffd Z xZS) rz Cursor fetching rows as dictionaries. The fetch methods of this class will return dictionaries instead of tuples. Each row is a dictionary that looks like: row = { "col1": value1, "col2": value2 } rowdatadescr4cH|rtt|j|SdS)zWConvert a MySQL text result row to Python types Returns a dictionary. N)rr column_namesr8rRrSs r9_row_to_pythonzMySQLCursorDict._row_to_pythons$9@tC))734ITIr;cpK|jt| d{|jS7w)zyReturn next row of a query result set. Returns: dict or None: A dict from query result set. N)rWr3rbrr8r7s r9rbzMySQLCursorDict.fetchones0 "")9);#;T=M=MNN#;s 646cKt|d{Dcgc] }|r|j||j"c}S7.cc}ww)zReturn all rows of a query result set. Returns: list: A list of dictionaries with all rows of a query result set where column names are used as keys. Nr3rrWrr8rr7s r9rzMySQLCursorDict.fetchallsM#W-//    T%5%5 6  / A AA %AA A ra)rErFrGrHr*r r r#rrr)rWrbrrGrHs@r9rrs 15 J JtO,- J $sK'( ) JOc;.>)? @O  Xd3 3C.D%E F   r;rcteZdZdZ ddedeeedeefdZdeeffd Z deeeffd Z xZ S) rz Cursor fetching rows as named tuple. The fetch methods of this class will return namedtuples instead of tuples. Each row is returned as a namedtuple and the values can be accessed as: row.col1, row.col2 rRrSr4c|}|r$t|j} t|}||Sy#t$rt d|}|t|<Y&wxYw)zXConvert a MySQL text result row to Python types Returns a named tuple. RowN)r{rUr.rr)r8rRrSrr named_tuples r9rWz$MySQLCursorNamedTuple._row_to_pythonsc D--.G 9/8 $ $  9(8 -8!'* 9s *A  A cKt|d{}|syt|jdr|j ||j S|S7;w)r@Nrn)r3rbhasattrrhrWrr\s r9rbzMySQLCursorNamedTuple.fetchones] G$&&t''5   T%5%5 6  'sAA> !TZZ%7 !78 8::dnn./ CC JJt**30@0@A B CTZZ BBN) rErFrGrHr rrr)rbr rrMr;r9rrsB c;.>)? @  Xd3 3C.D%E F r;rc:eZdZdZdeefdZdeeefdZy)rz7 Buffered Cursor fetching rows as named tuple. r4cK|j|jd{}|r|j||jSy7#wr?rgrhs r9rbz&MySQLCursorBufferedNamedTuple.fetchone8rirjc&K|j |jttg}|j|jdD]-}|j |j ||j/t|j|_|SwrCrlrms r9rz&MySQLCursorBufferedNamedTuple.fetchallDrnroN) rErFrGrHr r*rbr rrMr;r9rr3s.  1  Xg%6 7 r;rc veZdZdZdeffd Zd"deddfdZdeddffd Z d e ddfd Z d e ddffd Z d#dededefdZ d#dedeeeeeeffdeedffdZd$fd Zd%dededefdZdeddfdZ d&dedeededdfdZdedeeddfdZ dee!fdZ"d%dee de#e!fd Z$de#e!fd!Z%xZ&S)'MySQLCursorPreparedz&Cursor using MySQL Prepared Statementsr1ct||d|_d|_d|_d|_d|_d|_d|_y)NrTF) r3r:r4r5 _preparedr _have_result_last_row_sent_cursor_existsr6s r9r:zMySQLCursorPrepared.__init__VsD $.2 QU! ,0$)$)r;r:r4NcK|jr8 |jj|jdd{d|_d|_d|_y7#t$rY#wxYww)N statement_idF)rvrhcmd_stmt_closerrxryr=s r9rzMySQLCursorPrepared.reset`se >> &&55dnn^6TUUU"DN## V  s8 A'+AAAA'A A$!A'#A$$A'rec K|j|jd|jddt| |d{y7wN status_flag server_statusr)_handle_server_statusgetr3r)r8rer7s r9rz'MySQLCursorPrepared._handle_noresultsetksC "" GGM377?A#> ? g)#...AAA Aflagscp|tjzdk7|_|tjzdk7|_yr6)rSTATUS_CURSOR_EXISTSrySTATUS_LAST_ROW_SENTrx)r8rs r9rz)MySQLCursorPrepared._handle_server_statusqs2#j&E&EEJ#j&E&EEJr;rc K|j|jd|jddt| |d{y7wr~)rrr3r)r8rr7s r9rzMySQLCursorPrepared._handle_eofusC "" GGM377?A#> ? g!#&&&rrrcKtw)zQCalls a stored procedue Not supported with MySQLCursorPrepared. r )r8rrs r9rzMySQLCursorPrepared.callproc{s  !! rr3cKtw)rr)r8rr3s r9rz MySQLCursorPrepared.executemultis !!rcrK|jd{t| d{y77w)zzClose the cursor This method will try to deallocate the prepared statement and close the cursor. N)rr3rlrYs r9rlzMySQLCursorPrepared.closes0 jjlgmo s737577rRrScy)zConvert row data from MySQL to Python types The conversion is done while reading binary data in the protocol module. NrMrVs r9rWz"MySQLCursorPrepared._row_to_pythonsr;r|cTKt|tr2d|j_d|_|j |d{y|d|_d|j_d|_d|dvr|j|ddyd|dvr|j|ddyy7fw)zHandle result after executionFNr-Trrr)rsrrhrrwrrrrs r9rz"MySQLCursorPrepared._handle_results fd #-2D   * %D **62 2 2 &q D -1D   * $D q )**6!9]+CD F1I-**6!9_+EF. 3s=B(B&A'B(rcK|js td|sy|jj}|dk(rd}t|ts |j |}ttrJtjt|} tfd|Dtjtd|}||jur|j r0|jj#|j dd{||_ |j%|}d |vrtjt(d |} |jj+|d{|_|jj/|j dd{|j d rsyrnttt0fs'td d t3j4ddt7|j d t7k7r td dd|jj9|j d|j d d{}|j;|d{y#t $r}tt ||d}~wwxYw#t$r}td|d}~wwxYw7#t&$r}tt ||d}~wwxYw7#t,$r d|_wxYw7i77w)a4Prepare and execute a MySQL Prepared Statement This method will prepare the given operation and execute it using the optionally given parameters. If the cursor instance already had a prepared statement, it is first closed. Note: argument "multi" is unused. rNutf8mb4utf8c3(K|] }| ywrarM)rrZr3s r9rz.MySQLCursorPrepared.execute..sGsvc{Gsz6Not all placeholders were found in the parameters dict?r{s%s? parametersizIncorrect type of argument: rzP), it must be of type tuple or list the argument given to the prepared statement)errnomsgz:Incorrect number of arguments executing prepared statementrM)datar)rhr!charsetrsrdecoderrrIfindallrr{rr\rrrvr|rtrrcmd_stmt_preparercmd_stmt_resetrrrErBcmd_stmt_executer)r8rr3rrrwreplacement_keysres ` r9rzMySQLCursorPrepared.executes "#<= =""** i G)S) :%,,W5  fd #!zz*JIV  G6FGG :CKI DNN *~~&&55dnn^6TUUU&DN :%,,W5  !FF#4dIF  '+'7'7'H'H'S!S --dnn^.LMMM >>, '  fudm4&6F|,,-Qvh7--4>>,/0CK?&T >F$$55 NN> *~~l36   !!#&&&{& :&s3x0c9 : &L V & :&s3x0c9 :"T !%  N* 'sAK= I2*K=JA K=<J5= K= J8K=:K!K K!"+K= K6CK=K9K=,K;-K=2 J;JJK= J2! J--J22K=8 KKKK=K!!K33K=9K=;K=rcK|r|sy|jjd{ t|}d} |D]_}|j ||d{|j r(|jr|jd{||jz }a ||_ y7#t$r}t d|d}~wwxYw7q7?#ttf$r}td|dd}~wwxYww)aDPrepare and execute a MySQL Prepared Statement many times This method will prepare the given operation and execute with each tuple found the list seq_params. If the cursor instance already had a prepared statement, it is first closed. executemany() simply calls execute(). Nrrr) rhrjrrr!rrrrrrWr)r8rrrrwrr3s r9rzMySQLCursorPrepared.executemanys 33555 XZ A U$ )ll9f555>>d&>&>&@--/))$..(  ) ! 6 X"#MNTW W X 6)I& U #CC5!IJPT T Usx#C/B&C/ B(C/C C3C CC  C/( C1 B==CC/C C C,C''C,,C/cK|j|jr0|jj|jdd{|j d{xsdS7 7 w)r@r{N)rryrhcmd_stmt_fetchrvrrCs r9rbzMySQLCursorPrepared.fetchone+s_    ""11$..2PQ Q Q__&&.$. R&s$AA/ A+ A/"A-# A/-A/r&c K|jg}|xs |j}|dkDrV|jrF|dz}|jd{}|r|j ||dkDr|jrF|S7/w)<Return the next set of rows of a query result set. When no more rows are available, it returns an empty list. The number of rows returned can be specified using the size argument, which defaults to one. Returns: list: The next set of rows of a query result set. rr-N)rr(rrrr)s r9r+zMySQLCursorPrepared.fetchmany6s $dnnAg$224 1HC))C 3 Ag$224  *sABB,BBcHK|jg}|jdr|j|jd|jr|jr5|j j |jdtd{|j j|j|jd{\}}|j||j|d{|jrt||_|S77V7+w)r rr{N)rr)rrrrryrhrrvrr!rrextendrrBrr8r$rrs r9rzMySQLCursorPrepared.fetchallJs  ==  KK a( )&&(""&&55NN>2K"--66||T-=-=7HC KK ""3' ' '&&(T  (s<B D"D8D"D,D"4D 5D" D"D" D"rFr.r-ra)NF)'rErFrGrHr/r:r/rr(rrLrr$rrr rr+rr rrrr0rrlrWrr r&rr'rr*rbr r+rrGrHs@r9rtrtSs0*#:* $ $ $/Z/D/ K3K4K']'t' "s"#"x"8: " "hsmT#s(^34 " +T1 2 " c   G: G$ G$6: Z'Z'12Z' Z'  Z'x! ! /0!   ! F / 1 /HSMT'](W r;rtcFeZdZdZ ddeedeeee fffd Z xZ S)MySQLCursorPreparedDicta This class is a blend of features from MySQLCursorDict and MySQLCursorPrepared Multiple inheritance in python is allowed but care must be taken when assuming methods resolution. In the case of multiple inheritance, a given attribute is first searched in the current class if it's not found then it's searched in the parent classes. The parent classes are searched in a left-right fashion and each class is searched once. Based on python's attribute resolution, in this case, attributes are searched as follows: 1. MySQLCursorPreparedDict (current class) 2. MySQLCursorDict (left parent class) 3. MySQLCursorPrepared (right parent class) 4. MySQLCursor (base class) r&r4cKt||d{Dcgc] }|r|j||j"c}S7.cc}ww)aReturn the next set of rows of a query result set. When no more rows are available, it returns an empty list. The number of rows returned can be specified using the size argument, which defaults to one. Returns: list: The next set of rows of a query result set represented as a list of dictionaries where column names are used as keys. r&Nr3r+rWrr8r&rr7s r9r+z!MySQLCursorPreparedDict.fetchmanytsR#W.D.99    T%5%5 6  9 A AA %AA A ra) rErFrGrHr rLr rrr)r+rGrHs@r9rrbs:$%) SM d3 #$ %  r;rc:eZdZdZddeedeeffd ZxZ S)MySQLCursorPreparedNamedTuplez^ This class is a blend of features from MySQLCursorNamedTuple and MySQLCursorPrepared r&r4cKt||d{Dcgc] }|r|j||j"c}S7.cc}ww)aReturn the next set of rows of a query result set. When no more rows are available, it returns an empty list. The number of rows returned can be specified using the size argument, which defaults to one. Returns: list: The next set of rows of a query result set represented as a list of named tuples where column names are used as names. rNrrs r9r+z'MySQLCursorPreparedNamedTuple.fetchmanysR#W.D.99    T%5%5 6  9 rra) rErFrGrHr rLr r*r+rGrHs@r9rrs( HSM T']  r;rcbeZdZUdZdZeed<deefdZ d dee de efdZ de efd Z y) MySQLCursorPreparedRawzW This class is a blend of features from MySQLCursorRaw and MySQLCursorPrepared Trr4cK|j|jr0|jj|jdd{|j |j d{xsdS7,7 w)r@r{Nr)rryrhrrvrrrCs r9rbzMySQLCursorPreparedRaw.fetchonesg    ""11$..2PQ Q Q___33;t; R3s$AA; A7 #A;.A9/ A;9A;Nr&c$K|jg}|xs |j}|dkDrb|jrR|dz}|j|jd{}|r|j ||dkDr|jrR|S7/w)rrr-rN)rr(rrrrr)s r9r+z MySQLCursorPreparedRaw.fetchmanys $dnnAg$224 1HCDII66C 3 Ag$224  7sABB,B Bc^K|jg}|jdr|j|jd|jr|jr5|j j |jdtd{|j j|j|j|jd{\}}|j||j|d{|jrt||_|S77V7+w)r rr{N)rrr)rrrrryrhrrvrr!rrrrrrBrrs r9rzMySQLCursorPreparedRaw.fetchalls   ==  KK a( )&&(""&&55NN>2K"--66IIdllDr^rrrJrrrrrrtrrrrMr;r9rsI>7 / "   #       WV6--.%T%,5GE@g %g T;&+;&|![!H &0 &* k* Z7 K7 to/B@$9;N@L+L^# o/B# L $9;N .;0;r;