DhdddZddlmZddlZddlZddlmZmZddlm Z m Z ddl m Z ddl mZdd lmZmZmZmZmZmZdd lmZGd d eZGd deZGddeZGddeZGddeZGddeZGddeZGddeZ GddeZ!GddeZ"y)z%Cursor classes using the C Extension ) namedtupleN)MySQLConnectionAbstractMySQLCursorAbstract)PY2 isunicode)errors)CR_NO_RESULT_SET) RE_PY_PARAMRE_SQL_INSERT_STMTRE_SQL_ON_DUPLICATERE_SQL_COMMENTRE_SQL_INSERT_VALUESRE_SQL_SPLIT_STMTS)MySQLInterfaceErrorc,eZdZdZdZdZedZy)_ParamSubstitutorz4 Substitutes parameters into SQL statement. c ||_d|_y)Nr)paramsindex)selfrs [/var/www/html/civilisation/venv/lib/python3.12/site-packages/mysql/connector/cursor_cext.py__init__z_ParamSubstitutor.__init__2s  c|j}|xjdz c_ |j|S#t$rtjdwxYw)Nrz+Not enough parameters for the SQL statement)rr IndexErrorr ProgrammingError)rmatchobjrs r__call__z_ParamSubstitutor.__call__6sQ  a  ?;;u% % ?))=? ? ?s 2AcFt|j|jz S)z8Returns number of parameters remaining to be substituted)lenrrrs r remainingz_ParamSubstitutor.remaining?s4;;$**,,rN)__name__ __module__ __qualname____doc__rrpropertyr#rrrr,s%?--rrceZdZdZdZdZdZdZdfd ZdZ dZ dZ dZ d Z d Zd d Zd Zd ZedZedZedZdZd!dZdZdZd"dZdZdZdZerdZdZ edZ!edZ"edZ#dZ$xZ%S)# CMySQLCursorz;Default cursor for interacting with MySQL using C ExtensionFc,tj|d|_d|_d|_d|_d|_d|_d|_g|_ g|_ t|tstjdtj ||_y) InitializerNierrno)rr _insert_id_warning_count _warnings_affected_rows _rowcount_nextrow _executed_executed_list_stored_results isinstancerr InterfaceErrorweakrefproxy_cnx)r connections rrzCMySQLCursor.__init__Ms$$T*   !*&=>''d3 3MM*- rcd|_d|_d|_d|_d|_d|_d|_d|_d|_d|_g|_|r&|jr|jjtt|7y)zXReset the cursor When free is True (default) the result will be freed. r.Nr)r5r6r4r1r2r3 _descriptionr7r8r> free_resultsuperr+resetrfree __class__s rrDzCMySQLCursor.reset_s}      DII II ! ! # lD')rcg} |jj|jjd}|jj}|jj|r|Sy#t$r;}t j |j|j|jd}~wt$r2}t jdjt|d}~wwxYw)aFetch warnings Fetch warnings doing a SHOW WARNINGS. Can be called after getting the result. Returns a result set or None when there were no warnings. Raises errors.Error (or subclass) on errors. Returns list of tuples or None. z SHOW WARNINGSmsgr0sqlstateNzFailed getting warnings; {0})r>consume_results cmd_queryget_rowsrr get_mysql_exceptionrJr0rK Exceptionr;formatstr)rwarnings_excerrs r_fetch_warningszCMySQLCursor._fetch_warningsss A II % % ' ##O4Ayy))+H II % % ' O# D,, 69llD D A''.55c#h?A A As$A)A22 C/;6B11 C/=-C**C/cz|jjdur#|jr|j|_yyy)z7Handle possible warnings after all results are consumedTN)r> get_warningsr2rWr3r"s r_handle_warningszCMySQLCursor._handle_warningss5 99 ! !T )d.A.A!113DN/B )rcHd|vr"|d|_d|_|jy |d|_|d|_|d|_d|_|j |jjdur/|jr"tj|jddd y y ) z,Handles the result after statement executioncolumnsr insert_id warning_count affected_rowsr.TrN) rAr5_handle_resultsetr1r2r4rZr>raise_on_warningsr3r rO)rresults r_handle_resultzCMySQLCursor._handle_results   &y 1D DN  " " $$[1DO"("9D "("9D DN  ! ! #yy**d2t~~00$..2CAa2HII8F2rcy)Handle a result setNr)r"s rrazCMySQLCursor._handle_resultsets rcH|jj|_|j|jjdur.|j r"t j|j ddd|jjs|jjyy)zTHandle end of reading the result Raises an errors.Error on errors. Trrr`N) r>r^r2rZrbr3r rO more_resultsrBr"s r _handle_eofzCMySQLCursor._handle_eofs} #ii55  99 & &$ .4>>,,dnnQ.?!.DE Eyy%% II ! ! #&rc#FKtj|j}d}|||_| |jst |dz }||j|_|:#t j $r}|jtk7rYd}~Nd}~wwxYww)aGenerator returns MySQLCursor objects for multiple statements Deprecated: use nextset() method directly. This method is only used when multiple statements are executed by the execute() method. It uses zip() to make an iterator from the given query_iter (result of MySQLConnection.cmd_query_iter()) and the list of statements that were executed. rNr) rsplitr7nextset StopIterationr r;r0r strip)r executed_listirUs r _execute_iterzCMySQLCursor._execute_iters+00@ &q)  ||~''& FA*1-335DNJ(( 99 001 s.1B!A- #B!-BBB!BB!c|sy|jstjd|jjd}|j  t |r&|j |jj}n|}|r|jj|}t|trp|jD]\\}}tr"|j!dj#||}.|j!dj#|j |}^n[t|t$t&frEt)|} t+j,| |}| j.dk7rtjd |jj1||j2|j4|j6} ||_!|jE| |r|jGSy#ttf$r#}tjt|d}~wwxYw#t8$r;} tj:| j<| j>| j@d} ~ wwxYw) zExecute given statement using given parameters Deprecated: The multi argument is not needed and nextset() should be used to handle multiple result sets. NCursor is not connected%({0})sr1Not all parameters were used in the SQL statement)rawbuffered raw_as_stringrI)$r>r rhandle_unread_resultrDrencodepython_charsetUnicodeDecodeErrorUnicodeEncodeErrorrRprepare_for_mysqlr:dictitemsrreplacerQlisttuplerr subr#rM_raw _buffered_raw_as_stringrrOrJr0rKr7rdrq) r operationrmultistmtrVpreparedkeyvaluepsubrcrUs rexecutezCMySQLCursor.executes  yy))*CD D &&(  4# '' (@(@A  yy226:H(D)"*.."23JC#||I,<,>Q& 11KMM DYY((49926..7;7J7J)LF F# %%' 'C#$67 4))#c(3 3 4.# D,, 69llD D Ds03G&>=H&H5HH I$6IIc ld}tjtdtjt||}tjt |}|st jd|jdj|jj}g} |j|jj}|D]} |}|jj| } t| trH| jD]4\} } |j!dj#| j| }6n[t| t$t&frEt)| } t+j| |}| j,dk7rt j.d|j1|||vr+|j!|dj3|d}||_|Sy #t6t8f$r#}t j.t;|d }~wt<$r}t jd |zd }~wwxYw) zImplements multi row insertcH|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. rrt)group)matchs rremove_commentsz3CMySQLCursor._batch_insert..remove_comments s {{1~{{1~%rrtzBFailed rewriting statement for multi-row INSERT. Check SQL syntax.rrurrv,Nz"Failed executing the operation; %s)rerr rsearchrr r;rr{r>charsetrr:rrrrQrrrr r#rappendjoinr7r}r~rRrP)rr seq_paramsrtmpmatchesfmtvaluesrrrrrrrVs r _batch_insertzCMySQLCursor._batch_insert s &ff("VVNOYGI))0#6''$ mmA%%dii&7&78 <##DII$5$56D$ #9966v>h-&.nn&6Q U!kk)*:*:3*?*F*F*H%PQ4-8,X6D%//$4C~~*$55OQQ c" #d{||C6):A>!% "$67 4))#c(3 3 <''4s:< < r rrzr:rrrrr r5rrrAr!rNr4rlrm ValueError TypeErrorrQ)rrrrrowcntrrVs r executemanyzCMySQLCursor.executemanyBso yy))*CD D &&(*tUm4))=? ? 88& 2!"%%i&??F"d&9&99F#||~!  " $ %I& C))5<>R && &>> !rc|jS)z8Returns the value generated for an AUTO_INCREMENT column)r1r"s r lastrowidzCMySQLCursor.lastrowid{srcn|jsy|jjd|_d|_y)zrzr3r"s rclosezCMySQLCursor.closes/ yy &&( rc*|rt|ts tdt|ttfs tdd}g|_g} g}g}|rt |D]\}}|j||dz} |j| t|trJ|jdj| |d|jdj| |df|j| |jdj| |fd j|d j|} |jj| |j|j } g}|jjr|jj!} |jr$t#|jj%} n#t'|jj%} d j| | _| j+| |j| |jj-|jjr||_|j/|rQ|j1d jd j|} |j| |j3StS#t4j6$rt8$r)}t5j:dj|d}~wwxYw)z1Calls a stored procedure with the given argumentszprocname must be a stringzargs must be a sequencez@_{name}_arg{index}r)namerz CAST({0} AS {1})z SET {0}=%srz CALL {0}({1}),)rwryz(a result of {0})z SELECT {0}z"Failed calling stored routine; {0}N)r:rRrrrr9 enumeraterQrrrr>rMrrresult_set_availablefetch_eof_columnsCMySQLCursorBufferedRaw _get_selfCMySQLCursorBufferedr7rd next_resultrirDfetchoner ErrorrPr;)rprocnameargsargfmtresultsargnamesargtypesidxargargnamecallrccurselectrVs rcallproczCMySQLCursor.callprocsz(C889 9$ .67 7&!1 BHH )$ KHC$mmqmIGOOG,!#u- (;(B(B7CFq6)KL \%8%8%ACF9M 0 \%8%8%AC6J K#))(CHHX4FGDYY((4997;7J7J)LFG))00446991$))2E2E2GHC.tyy/B/B/DEC 3 : :4 @ ""6*s# %%'))00$+D     %,,SXXh-?@ V$}}&w||   B''4;;C@B B Bs& H K A)K  K L)$L  Lc|jjs|jdy|jd|jjsE|jj }|j |t jt|j |jjy)z%Skip to the next available result setTrFNFr/) r>rrDrfetch_eof_statusrdr r;r r)reofs rrlzCMySQLCursor.nextsetsyy$$& JJDJ !  yy--)),,.C    $''.>? ? DII779:rcd|jjstjd|jj }|j r|j d|j |s|jgS|xjt|z c_|j|S)zRReturns all rows of a query result set Returns a list of tuples. No result set to fetch from.r) r> unread_resultr r;rNr6insertrir5r!)rrowss rfetchallzCMySQLCursor.fetchalls yy&&''(FG Gyy!!# == KK4== )    I #d)#  rc|jr|jg}|dz}ng}|r@|jjr*|j|jj ||r[|jj |_|js0|jj s|jj|s|jgS|xjt|z c_ |S)z,Returns the next set of rows of a result setr) r6r>rextendrNget_rowrhrBrir5r!)rsizers r fetchmanyzCMySQLCursor.fetchmanys ==MM?D AIDD DII++ KK **40 1  II--/DM==)?)? %%'    I #d)# rc|j}|s0|jjr|jj}|r\|jj|_|jsB|jjs,|jj n|j y|xjdz c_|S)z&Returns next row of a query result setNr)r6r>rrrhrBrir5rrows rrzCMySQLCursor.fetchonesmmtyy..))##%C  II--/DM==)?)? %%'     ! rc.t|jdS)zIteration over the result set Iteration over the result set which calls self.fetchone() and returns the next row. N)iterrr"s r__iter__zCMySQLCursor.__iter__s DMM4((rc#Ktt|jD]}|j|g|_yw)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. Returns a iterator. N)ranger!r9)rrps rstored_resultszCMySQLCursor.stored_resultssBs4//01 *A&&q) ) * "s=?c"|jS)z'Used for iterating over the result set.)__next__r"s rnextzCMySQLCursor.next,s==? "rcr |j}|st|S#tj$rtwxYw)zIteration over the result set Used for iterating over the result set. Calls self.fetchone() to get the next row. Raises StopIteration when no more rows are available. )rr r;rmrs rrzCMySQLCursor.__next__0s? --/C  $$   s6cr|jsyt|jDcgc]}|d c}Scc}w)ztReturns column names This property returns the columns names as a tuple. Returns a tuple. r)r)rr)rds r column_nameszCMySQLCursor.column_names?s3D$4$45qad5665s 4c |jjjdS#t$r|jjcYSwxYw)zReturns the executed statement This property returns the executed statement. When multiple statements were executed, the current statement in the iterator will be returned. utf8)r7rndecodeAttributeErrorr"s r statementzCMySQLCursor.statementKsG *>>'')008 8 *>>'') ) *s(+#AAc|jryy)zReturns whether the cursor could have rows returned This property returns True when column descriptions are available and possibly also rows, which will need to be fetched. Returns True or False. TF)rr"s r with_rowszCMySQLCursor.with_rowsXs   rc d}|jr3 |jjd}t|dkDr |dddz}nd}|j |j j |S#t$r|j}YWwxYw)Nz{class_name}: {stmt}zutf-8(z..z(Nothing executed yet)) class_namer)r7rrr!rQrGr$)rrexecuteds r__str__zCMySQLCursor.__str__es$ >> *>>0098}r!#CR=4//HzzT^^%<%<8zLL" *>> *sA++BBT)r)F)r)r)&r$r%r&r'rrrrrDrWrZrdrarirqrrrr(rrrrrrlrrrrrrrrrrrr __classcell__rGs@rr+r+EsE DIN.$*(>4 J  $86p4 rc|jj|_d|_t |j|_|j y)rfrN)r>rNrrr!r5rir"s rraz&CMySQLCursorBuffered._handle_resultsets8YY'') TZZ rcJd|_d|_tt||y)zReset the cursor to defaultNrr)rrrCrrDrEs rrDzCMySQLCursorBuffered.resets$  "D/T/:rcd} |j|j}|xjdz c_|S#t$rYywxYw)zQReturns the next row in the result set Returns a tuple or None. Nr)rrrrs r _fetch_rowzCMySQLCursorBuffered._fetch_rowsI  **T^^,C NNa N   s4 AAc|jtjd|j|jd}t |j|_|S)Nr)rr r;rr!)rress rrzCMySQLCursorBuffered.fetchallsF :: ''(FG Gjj)TZZ rcg}|xs |j}|dkDr2|dz}|j}|r|j|n |S|dkDr2|S)Nrr) arraysizerr)rrrcntrs rrzCMySQLCursorBuffered.fetchmanysW$dnnAg 1HC//#C 3 Ag rc"|jSN)rr"s rrzCMySQLCursorBuffered.fetchones  rrr) r$r%r&r'rrarDrrrrrrs@rrrts)4;  !rrceZdZdZdZy)CMySQLCursorRawz+Cursor using C Extension return raw resultsTNr$r%r&r'rr)rrr r s 5 Drr ceZdZdZdZy)rz.Cursor using C Extension buffering raw resultsTNr r)rrrrs 8 Drrc<eZdZdZdZfdZdfd ZfdZxZS)CMySQLCursorDictz7Cursor using C Extension returning rows as dictionariesFcltt| }|rtt |j |Syz/Returns all rows of a query result set N)rCr rrziprrrrGs rrzCMySQLCursorDict.fetchones3$d46 D--s34 4rc tt| |}|Dcgc]!}tt |j |#c}Scc}w)z0Returns next set of rows as list of dictionariesr)rCr rrrrrrrrrGs rrzCMySQLCursorDict.fetchmanys>$d545@=@AcS**C01AAAs&Ac tt| }|Dcgc]!}tt |j |#c}Scc}w)z>Returns all rows of a query result set as list of dictionaries)rCr rrrrrrrrGs rrzCMySQLCursorDict.fetchalls9$d46=@AcS**C01AAA&Ar) r$r%r&r'rrrrrrs@rr r s"A DB BBrr c0eZdZdZdZfdZfdZxZS)CMySQLCursorBufferedDictzECursor using C Extension buffering and returning rows as dictionariesFcltt| }|rtt |j |Syr)rCrrrrrrs rrz#CMySQLCursorBufferedDict._fetch_rows1,d>@ D--s34 4rc tt| }|Dcgc]!}tt |j |#c}Scc}wr)rCrrrrrrs rrz!CMySQLCursorBufferedDict.fetchalls9,d<>=@AcS**C01AAAr)r$r%r&r'rrrrrs@rrrsO DBBrrcBeZdZdZfdZfdZdfd ZfdZxZS)CMySQLCursorNamedTuplez7Cursor using C Extension returning rows as named tuplesc`tt| td|j|_y)rfRowN)rCrrarr named_tuplerrGs rraz(CMySQLCursorNamedTuple._handle_resultsets& $d=?%eT->->?rcLtt| }|r|j|Syr)rCrrr rs rrzCMySQLCursorNamedTuple.fetchones.*D:< #4##S) )rcptt| |}|Dcgc]}|j|c}Scc}w)z0Returns next set of rows as list of named tuplesr)rCrrr rs rrz CMySQLCursorNamedTuple.fetchmanys:*D;;F2563   #&666s3cltt| }|Dcgc]}|j|c}Scc}w)z>Returns all rows of a query result set as list of named tuples)rCrrr rs rrzCMySQLCursorNamedTuple.fetchalls5*D:<2563   #&6661r) r$r%r&r'rarrrrrs@rrrs A@7 77rrc6eZdZdZfdZfdZfdZxZS)CMySQLCursorBufferedNamedTuplezECursor using C Extension buffering and returning rows as named tuplesc`tt| td|j|_y)Nr)rCr'rarrr r!s rraz0CMySQLCursorBufferedNamedTuple._handle_resultsets& ,dEG%eT->->?rcLtt| }|r|j|Syr)rCr'rr rs rrz)CMySQLCursorBufferedNamedTuple._fetch_rows,2DDF #4##S) )rcltt| }|Dcgc]}|j|c}Scc}wr)rCr'rr rs rrz'CMySQLCursorBufferedNamedTuple.fetchalls52DBD2563   #&666r%)r$r%r&r'rarrrrs@rr'r' sO@ 77rr'c"eZdZdZfdZxZS)CMySQLCursorPreparedz#Cursor using Prepare Statement c@tt| |td)Nz/Alternative: Use connection.MySQLCursorPrepared)rCr,rNotImplementedErrorrs rrzCMySQLCursorPrepared.__init__&s# "D2:>! =? ?r)r$r%r&r'rrrs@rr,r,!s??rr,)#r' collectionsrrr< abstractsrrcatch23rrrtr errorcoder cursorr r r rrr_mysql_connectorrobjectrr+rr rr rrr'r,r)rrr6s0# C#' 1--2lM&lM^;!<;!|l2B|B4B3B$7\7>7%97,?<?r