ixTddlZddlZddlmZddlmZmZmZmZddl m Z ddl Z dZ dZ dZdZdZdZdZd ZdZdZdZd Zd Zd Zd ZdZdZGddejjZdS)N)Number)CURSORSTATUS CAPABILITY INDICATOR)SequencercJeZdZdZdZfdZdZdZdZd%de d e fd Z d&d e ffd Z fdZ d'd e d e fdZdZfdZfdZdZd(deffd ZfdZdZd)defdZdefdZdefdZdZd Zefd!Zed"Zed#Zed$Z xZ!S)*Cursorz0 MariaDB Connector/Python Cursor Object c|j|jjkrtjd|jrtjd|jdS)NzGCursor cannot be used anymore (the connection aborted and reconnected).z=Cursor cannot be used anymore (it was already closed before).) _thread_id connection thread_idmariadbProgrammingError_closed _connection _check_closedselfs G/srv/django_bis/venv311/lib/python3.11/site-packages/mariadb/cursors.py check_closedzCursor.check_closed8s^ ?do7 7 7*+uvv v < l*+jkk k &&(((((c d|_d|_d|_||_t|_d|_d|_d|_d|_ d|_ d|_ d|_ d|_ d|_|j|_d|_|st%jd|r|dd}|r t*|_n$|dd}|r t,|_|dd}||_ |d d|_|d d|_ |d d|_t1j|fi|dS) z initialization FNrTz!Invalid or no connection provided named_tuple dictionarybufferedpreparedbinary cursor_type)_bulk _dictionary _named_tupler RESULT_TUPLE _resulttype _description_transformed_statement _prepared _prev_stmt _force_binary _rowcountr& _parseinfo_datarrrrrpopRESULT_NAMEDTUPLERESULT_DICTIONARY _cursor_typesuper__init__)rrkwargsrtyper& __class__s r r<zCursor.__init__?so  !%' &*#!  $.  P*+NOO O  =JJ}e44E 9#4   <779'8D$zz*d33H$DM#ZZ E::DN!'He!((00 ? ?1c$/2233 ? ? #':::*TZ]3CC*Q-C;$GG!#y'>??-).00&,G)"333&/G#C00 -"%++--%cE9+=>>-&,t/L/L # H = =0?0?'?GG'-t/L/L # 0/0/'/G*-gnnW.E.E*F*F #G +-Koa(<7#DSD>GOO,=,=,D,DV,L,LLSUVV$%G q 0; >> r"cPt|tr6t|dvr%tjdt|dt|t jr@|dvr*tjd|ddS)a) Internal use only Checks for unsupported parameters. The following parameters are not supported by MariaDB/MySQL (but also not part of the SQL Standard) - float("nan" | "inf" | "-inf") - Decimal("NaN" | "sNaN" | "Infinity" | "-Infinity") )naninfz-infz Float value 'z' is not supported.)NaNsNaNInfinityz -InfinityzDecimal value 'N)rNfloatreprrNotSupportedErrordecimalDecimalrP)rrYs r _check_decimal_parameterzCursor._check_decimal_parameters c5 ! ! bd3ii3I&I&I+,ZDII,Z,Z,Z[[ [ W_ - - b#++--Ck2k2k+,`ckkmm,`,`,`aa atr"cd}|jttfvr*+<== = >Y & &' &$* & GGNN9 % % %'DO"DOO#DO&*n#   0 0 0DJ  ""$$$$$r"cl|tS)z Will make the cursor skip to the next available result set, discarding any remaining rows from the current set. )r!r;_nextsetrr?s r nextsetzCursor.nextsets- ww!!!r"Nc|jjr|jj|_||js|||j_d}d|_|||_ |j r| |jr|j r |j }d}|r| ||d|_|pd}t|r||_n)d|_|jt$kr|jdkrd|_|jrd|_|r|dkrd|_|jr`|jdkr||_n |j |_||j|n||_||d|_dS)a Prepare and execute a SQL statement. Parameters may be provided as sequence or mapping and will be bound to variables in the operation. Variables are specified as question marks (paramstyle ='qmark'), however for compatibility reasons MariaDB Connector/Python also supports the 'format' and 'pyformat' paramstyles with the restriction, that different paramstyles can't be mixed within a statement. A reference to the operation will be retained by the cursor. If the cursor was created with attribute prepared =True the statement string for following execute operations will be ignored. This is most effective for algorithms where the same operation is used, but different parameters are bound to it (many times). By default execute() method generates an buffered result unless the optional parameter buffered was set to False or the cursor was generated as an unbuffered cursor. TrNFrj)rrxrrr!r1ry_last_executed_statementr4r& field_count _clear_resultrFrr/rJr6_commandSQL_CALLr:rr3_check_text_types paramcountr\r0 _execute_text _readresponse_execute_binary _initresultr*)rrFrsr&do_parses r rzzCursor.execute s* ? ) 7!_6DO ~  KKMMM3<0  $DM   !     > dn IH  3    D 2 2 2 zr t99 "DJJDJ}((T->!-C-C!   DJ  D**,,44DJ : #!##.2.I.I.K.K++.2n+   t: ; ; ;    DJ  " " "  r"c\|jjr|jj|_|||rt |stjd||j_ |j r| |jj tjdz zs0d}|D]"}|||||jz }#||_dS|||dd||_d|_d|_|d|_dS) a! Prepare a database operation (INSERT,UPDATE,REPLACE or DELETE statement) and execute it against all parameter found in sequence. Exactly behaves like .execute() but accepts a list of tuples, where each tuple represents data of a row within a table. .executemany() only supports DML (insert, update, delete) statements. If the SQL statement contains a RETURNING clause, executemany() returns a result set containing the values for columns listed in the RETURNING clause. zNo data provided rT)rFr N)rrxrrr!ryrJrrrrrextended_server_capabilitiesrBULK_OPERATIONSrzrowcountr4rr6is_text _execute_bulkr*)rrF parameterscountrows r executemanyzCursor.executemanygs? ? ) 7!_6DO   ?Z ?*+=>> >3<0   !    <+r13 E! ' ' Y,,,&"DNNN    :a=$  G G G#DJ DLDN    DJJJr"c|js||jstjdt S)zl Internal use only fetches row and converts values, if connection has a converter. Cursor doesn't have a result set)r&r!rrrr;fetchoners r _fetch_rowzCursor._fetch_rowsW }       O*+MNN Nww!!!r"c|jr|`|jjs td|_dS)ap Closes the cursor. If the cursor has pending or unread results, .close() will cancel them so that further operations using the same connection can be executed. The cursor will be unusable from this point forward; an Error (or subclass) exception will be raised if any operation is attempted with the cursor." TN)r6rrr;closers r rz Cursor.closes= :  &  GGMMOOO r"cr|jr|js||}|S)a Fetch the next row of a query result set, returning a single sequence, or None if no more data is available. An exception will be raised if the previous call to execute() didn't produce a result set or execute() wasn't called before. )r&rr!r)rrs r rzCursor.fetchones=  $*      oo r"rsizec|jr|js||dkr|j}t |S)a Fetch the next set of rows of a query result, returning a sequence of sequences (e.g. a list of tuples). An empty sequence is returned when no more rows are available. The number of rows to fetch per call is specified by the parameter. If it is not given, the cursor's arraysize determines the number of rows to be fetched. The method should try to fetch as many rows as indicated by the size parameter. If this is not possible due to the specified number of rows not being available, fewer rows may be returned. An exception will be raised if the previous call to execute() didn't produce a result set or execute() wasn't called before. r)r&rr! arraysizer; fetchrows)rrr?s r fetchmanyzCursor.fetchmanysR   $*       199>Dww  &&&r"c|jr|js|tt S)a Fetch all remaining rows of a query result, returning them as a sequence of sequences (e.g. a list of tuples). An exception will be raised if the previous call to execute() didn't produce a result set or execute() wasn't called before. )r&rr!r;rROWS_EOFrs r fetchallzCursor.fetchallsB  $*      ww  ***r"c,t|jdS)N)iterrrs r __iter__zCursor.__iter__sDM4(((r"relativevaluecP|jr|js||jdkrt jd|jst jd|dkr|dkrt jd|dkr|dkrt jd|dkr@|j|zdks|j|z|jkrt jd|j|z}n'|dks ||jkrt jd|}||||_ d S) a Scroll the cursor in the result set to a new position according to mode. If mode is "relative" (default), value is taken as offset to the current position in the result set, if set to absolute, value states an absolute target position. rrzEThis method is available only for cursors with a buffered result set.absoluterz)Invalid or unknown scroll mode specified.zInvalid position value 0.zPosition value is out of range.N) r&rr!rrr rownumberr_seek _rownumber)rrmodenew_poss r scrollz Cursor.scrollsw  $*        q *+MNN N} :*,9:: : :  $*"4"4*,=>> > A::$*,,*+FGG G :  ~%))~% 55.0BCCCnu,GGqyyET]22.0BCCCG 7!r"cdSzO Required by PEP-249. Does nothing in MariaDB Connector/Python Nrjrrs r setinputsizeszCursor.setinputsizes r"cdSrrjrs r setoutputsizezCursor.setoutputsize#rr"c|S)zReturns a copy of the cursor.rjrs r __enter__zCursor.__enter__*s  r"c.|dS)zCloses cursor.N)r)rexc_typeexc_valexc_tbs r __exit__zCursor.__exit__/s r"c|js, |n#tj$rYdSwxYw|jdkr|jSt jS)a This read-only attribute specifies the number of rows that the last execute*() produced (for DQL statements like SELECT) or affected (for DML statements like UPDATE or INSERT). The return value is -1 in case no .execute*() has been performed on the cursor or the rowcount of the last operation cannot be determined by the interface. r r)r&r!rrr4r;rrs r rzCursor.rowcount3sr}  !!####+   rr  >A  > !wws 22cv|t|jjtjzS)z Indicates if the current result set contains in out or out parameter from a previous executed stored procedure )r!boolr server_statusr PS_OUT_PARAMSrs r sp_outparamszCursor.sp_outparamsKs1 DO1F4HHIIIr"cL||j}|dkr|SdS)a Returns the ID generated by a query on a table with a column having the AUTO_INCREMENT attribute or the value for the last usage of LAST_INSERT_ID(). If the last query wasn't an INSERT or UPDATE statement or if the modified table does not have a column with the AUTO_INCREMENT attribute and LAST_INSERT_ID was not used, the returned value will be None rN)r! insert_id)rids r lastrowidzCursor.lastrowidUs0  ^ 66Itr"c|jS)z Read-Only attribute which returns the reference to the connection object on which the cursor was created. )rrs r rzCursor.connectionhs r")rj)rjF)rjNr )r)"__name__ __module__ __qualname____doc__r!r<r\rhrqstrrr|rrrzrrrrintrrrrrrrrpropertyrrrr __classcell__)r?s@r rr3s)))(/(/(/(/(/T,,,\( 7 7 7D&&3&h&&&&8%%%%%%%%6"""""XXXHXXXXt///b " " " " "*   ''c''''''0 + + + + +)))("("C("("("("T##     X .JJXJX$  X     r"r) rdatetimenumbersrmariadb.constantsrrrrtypingrrfrkrlrLROWS_ALLr-r8r9SQL_NONE SQL_INSERT SQL_UPDATE SQL_REPLACE SQL_DELETErSQL_DO SQL_SELECT SQL_OTHERr_mariadbcursorrrjr"r rs (CCCCCCCCCCCC            | | | | | W  $| | | | | r"