?????????? ????????? - ??????????????? - /home/agenciai/.local/lib/python3.9/site-packages/mysql/connector/__pycache__/cursor.cpython-39.pyc
???????
a ��Jh�� � @ sl d Z ddlmZ ddlZddlZddlmZ ddlmZm Z m Z m Z m Z m Z mZmZmZmZmZ ddlmZ ddlmZ dd lmZ dd lmZ dd lm Z m Z 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*m+Z+m,Z,m-Z- er�dd l.m/Z/ dZ0e�1de0� de0� d�ej2ej3B ej4B �Z5e�1dej2ej3B ej4B �Z6e�1de0� de0� d�ej2ej3B ej4B �Z7e�1dej2ej3B ej4B �Z8e�1d�Z9e�1dej:�Z;e�1d�Z<e�1d�Z=e�1d�Z>e�1d�Z?d Z@d ZAG d d � d �ZBd d!d d"�d#d$�ZCG d%d&� d&e�ZDG d'd(� d(eD�ZEG d)d*� d*eD�ZFG d+d,� d,eE�ZGG d-d.� d.eD�ZHG d/d0� d0eD�ZIG d1d2� d2eIeE�ZJG d3d4� d4eIeH�ZKdS )5zCursor classes.� )� annotationsN)�Decimal) � TYPE_CHECKING�Any�Dict�Iterator�List�NoReturn�Optional�Sequence�Tuple�Union�cast� )� deprecated)�split_multi_statement)�MySQLCursorAbstract)� ServerFlag)�Error�InterfaceError�NotSupportedError�ProgrammingError�ReadTimeoutError�WriteTimeoutError�get_mysql_exception) �DescriptionType� EofPacketType�ParamsDictType�ParamsSequenceOrDictType�ParamsSequenceType� ResultType� RowItemType�RowType� StrOrBytes� WarningType)�MySQLConnectionz \/\*.*?\*\/�(z)|(["'`][^"'`]*?(z)[^"'`]*?["'`])z<\s*ON\s+DUPLICATE\s+KEY(?:[^"'`]*["'`][^"'`]*["'`])*[^"'`]*$z |\s)*INSERT(z[|\s)*(?:IGNORE\s+)?INTO\s+[`'\"]?.+[`'\"]?(?:\.[`'\"]?.+[`'\"]?){0,2}\s+VALUES\s*(\(.+\)).*z.*VALUES\s*(\(.+\)).*s ((?<!%)%s)sV % \((?P<mapping_key>[^)]+)\) (?P<conversion_type>[diouxXeEfFgGcrs%]) s4 ;(?=(?:[^"'`]*(?:"[^"]*"|'[^']*'|`[^`]*`))*[^"'`]*$)s+ %s(?=(?:[^"'`]*["'`][^"'`]*["'`])*[^"'`]*$)z %\(.*?\)sz %\((.*?)\)szNo result set to fetch froml �� c @ sB e Zd ZdZddd�dd�Zddd �d d �Zed d �dd��ZdS )�_ParamSubstitutorz4 Substitutes parameters into SQL statement. zSequence[bytes]�None��params�returnc C s || _ d| _d S �Nr )r* �index)�selfr* � r/ �K/home/agenciai/.local/lib/python3.9/site-packages/mysql/connector/cursor.py�__init__| s z_ParamSubstitutor.__init__�re.Match�bytes��matchobjr+ c C sF | j }| j d7 _ zt| j| �W S ty@ td�d �Y n0 d S )Nr z+Not enough parameters for the SQL statement)r- r3 r* � IndexErrorr )r. r5 r- r/ r/ r0 �__call__� s ��z_ParamSubstitutor.__call__�int�r+ c C s t | j�| j S )z8Returns number of parameters remaining to be substituted)�lenr* r- �r. r/ r/ r0 � remaining� s z_ParamSubstitutor.remainingN)�__name__� __module__� __qualname__�__doc__r1 r7 �propertyr< r/ r/ r/ r0 r' w s r' r3 zDict[bytes, bytes])�bytestr� value_dictr+ c s$ ddd�� fdd� }t �|| �}|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' r2 r3 r4 c sV d}| � � }|d dkr d}|d dkr8|d }� | }|du rRtd|d � ���|S )zReplace pattern.NZconversion_type� %� sZ mapping_keyz Unsupported conversion_type: )� groupdict� ValueError)r5 �value�groups�key�rC r/ r0 �replace� s �z%_bytestr_format_dict.<locals>.replace)�RE_PY_MAPPING_PARAM�sub)rB rC rL �stmtr/ rK r0 �_bytestr_format_dict� s rP c s� e Zd ZdZdbddddd�� fdd� Zd d �d d �Zdcddd�dd�Zdd �dd�Zdd �dd�Zdd �dd�Z dd �dd�Z dd d �d d �Z d d!d �d"d#�Z d$dd%�d&d'�Z dd �d(d)�Zd$dd*�d+d,�Zddd-d.ddd/�d0d1�Zd-d2d3d4�d5d6�Zd-d2dd4�d7d8�Zed9�d:d �d;d<��Zded-d>d?d@�dAdB�ZdCd �dDdE�Zdd �dFdG�ZdHddI�dJdK�ZdfddLdM�dNdO�ZdLd �dPdQ�ZdgddRdS�dTdU�ZdRd �dVdW�Z dXd �dYdZ�Z e d[d �d\d]��Z e dd �d^d_��Z d-d �d`da�Z!� Z"S )h� MySQLCursora� Default 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) N�Optional[MySQLConnection]� Optional[int]r( �� connection� read_timeout� write_timeoutr+ c s" t � �|||� td| j�| _dS )Z Initializer% N)�superr1 r � _connection�r. rU rV rW �� __class__r/ r0 r1 � s zMySQLCursor.__init__zIterator[RowType]r9 c C s t | jd�S )zm Iteration over the result set which calls self.fetchone() and returns the next row. N)�iter�fetchoner; r/ r/ r0 �__iter__� s zMySQLCursor.__iter__F�bool)�preserve_last_executed_stmtr+ c C sR d| _ d| _g | _d| _d| _d| _|sFd| _g | _d| _d| _ d| _ | � � dS )a Reset the cursor to default. Args: preserve_last_executed_stmt: If it is False, the last executed statement value is reset. Otherwise, such a value is preserved. ����NNNr F) � _rowcount�_nextrow�_stored_results� _warnings�_warning_count� _description� _executed�_executed_list�_stmt_partitions�_stmt_partition�_stmt_map_results�reset)r. ra r/ r/ r0 � _reset_result� s zMySQLCursor._reset_resultc C s$ z | j jW S ty Y dS 0 dS )z'Check whether there is an unread resultFN)rY � unread_result�AttributeErrorr; r/ r/ r0 �_have_unread_result� s z MySQLCursor._have_unread_resultc C s | j du rtt��dS )zsCheck if the statement has been executed. Raises an error if the statement has not been executed. N)rj r �ERR_NO_RESULT_TO_FETCHr; r/ r/ r0 �_check_executed� s zMySQLCursor._check_executedr" c C s2 z | � � }W n ty$ td�Y n0 |s.t�|S )zm Used for iterating over the result set. Calles self.fetchone() to get the next row. N)r^ r � StopIteration�r. �rowr/ r/ r0 �__next__� s zMySQLCursor.__next__c C s* | j du rdS | j �� | �� d| _ dS )zQClose the cursor Returns True when successful, otherwise False. NFT)rY �handle_unread_resultrp r; r/ r/ r0 �close s zMySQLCursor.closer z"Dict[bytes, Union[bytes, Decimal]]r) c C s� i }zp| j j}| j jj}| j jj}| j jj}|�� D ]<\}}|} || �} || |�} t|t�sd|| �} | ||� � < q4W n4 t y� } z t d| � ��| �W Y d} ~ n d} ~ 0 0 |S )z,Process query parameters given as dictionaryz'Failed processing pyformat-parameters; N) rY �sql_mode� converter�to_mysql�escape�quote�items� isinstancer �encode� Exceptionr ) r. r* �resr| r~ r r� rJ rH �conv�errr/ r/ r0 �_process_params_dict s( ��z MySQLCursor._process_params_dictr z!Tuple[Union[bytes, Decimal], ...]c s� �dd� }zh| j j�| j jj�| j jj� | j jj��fdd�|D �}� �fdd�|D �}��fdd�t|�D �}W n4 ty� } z td|� ��|�W Y d}~n d}~0 0 t |�S )zProcess query parameters.Nc s g | ] }� |��qS r/ r/ ��.0rH )r~ r/ r0 � <listcomp>2 � z/MySQLCursor._process_params.<locals>.<listcomp>c s g | ]}� |���qS r/ r/ r� )r r| r/ r0 r� 3 r� c s* g | ]"\}}t � | t�s"�|�n|�qS r/ )r� r )r� �irH )r* r� r/ r0 r� 4 s �z%Failed processing format-parameters; ) rY r| r} r~ r r� � enumerater� r �tuple)r. r* r� r� r/ )r r* r� r| r~ r0 �_process_params( s$ � ��zMySQLCursor._process_paramsr �r� r+ c C sh z"|d | _ |d | _|d | _W n8 ttfyZ } z td|� ��d�W Y d}~n d}~0 0 | �� dS )z7Handles result of execute() when there is no result set� affected_rowsZ insert_id� warning_countz Failed handling non-resultset; N)rd Z_last_insert_idrh �KeyError� TypeErrorr �_handle_warnings)r. r� r� r/ r/ r0 �_handle_noresultset> s &z MySQLCursor._handle_noresultsetc C s dS )z�Handles 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. Nr/ r; r/ r/ r0 �_handle_resultsetI s z MySQLCursor._handle_resultset��resultr+ c C s^ t |t�std��d|v r6|d | _d| j_| �� n$d|v rRd| j_| �|� ntd��dS )z� Handle 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()�columnsTr� FzInvalid resultN)r� �dictr ri rY rq r� r� �r. r� r/ r/ r0 �_handle_resultQ s zMySQLCursor._handle_result�str�"Optional[ParamsSequenceOrDictType]�� operationr* � map_resultsr+ c C s� |sd S z| j st�W n2 ttfyH } ztd�|�W Y d }~n d }~0 0 | j �� | �� d}z(t|t�r||�| j j�}n t t |�}W n6 t t fy� } ztt|��|�W Y d }~n d }~0 0 |�r>t|t �r�t|| �|��}n\t|ttf��r"t| �|��}t�||�}|jdk�r>td��n tdt|�j� d|� d���|�dd �}t||d �| _t | j�| _ || _ | j d | _ |�r�| j d � � n| j d | _!| �"| j j#| j d | j$| j%d �� d S )NzCursor is not connectedr� r �1Not all parameters were used in the SQL statementz Could not process parameters: r& z)), it must be of type list, tuple or dict� %%s� %s)Zsql_coder� � single_stmts� mappable_stmt�rV rW )&rY r �ReferenceErrorrz rp r� r� r� �python_charsetr r3 �UnicodeDecodeError�UnicodeEncodeErrorr� rP r� �listr� r' r� � RE_PY_PARAMrN r< �typer= rL r rl �nextrm rn rk �popleftrj r� � cmd_query� _read_timeout�_write_timeout)r. r� r* r� r� rO �psubr/ r/ r0 �executeh s` $ �� � ����zMySQLCursor.executez"Sequence[ParamsSequenceOrDictType]zOptional[bytes]�r� � seq_paramsr+ c C sz ddd�dd�}t �tdt �t||��}t �t|�}|s@td��|�d��| j j �}g }z�|�| j j �}|D ]Z} |}t | t �r�t || �| ��}n,t| �| ��} t�| |�}| jd kr�td ��|�|� ql||v r�|�|d �|�d�}|| _|W S W d S ttf�y, } ztt| ��| �W Y d } ~ nRd } ~ 0 t�y@ � Y n6 t �yt } z td | � ��d �W Y d } ~ n d } ~ 0 0 d S )zImplements multi row insertr2 r� )�matchr+ c S s | � d�rdS | � d�S )a Remove 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 � � )�group)r� r/ r/ r0 �remove_comments� s z2MySQLCursor._batch_insert.<locals>.remove_commentsr� zAFailed rewriting statement for multi-row INSERT. Check SQL syntaxr r r� � ,N� Failed executing the operation; ) �rerN �RE_SQL_ON_DUPLICATE�RE_SQL_COMMENT�search�RE_SQL_INSERT_VALUESr r� r� rY r� r� r� rP r� r' r� r� r< r �appendrL �joinrj r� r� r� r r� ) r. r� r� r� �tmp�matches�fmt�valuesrO r* r� r� r/ r/ r0 � _batch_insert� sJ � � � "zMySQLCursor._batch_insertc C s |r|s dS | j �� z t|�}W n. tyP } ztd�|�W Y d}~n d}~0 0 t�t|�r�|sld| _dS | � ||�}|dur�|| _ | � |�S d}z:|D ]0}| � ||� | j r�| � � r�| �� || j7 }q�W n: ttf�y } z td|� ��d�W Y d}~n d}~0 0 || _dS )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)" cursor.executemany(stmt, data) INSERT statements are optimized by batching the data, that is using the MySQL multiple rows syntax. Results are discarded. If they are needed, consider looping over data using the execute() method. Nz(Parameters for query must be an Iterabler r� )rY rz r] r� r r� r� �RE_SQL_INSERT_STMTrd r� rj r� � with_rowsrs �fetchallrG r )r. r� r� �_r� rO �rowcntr* r/ r/ r0 � executemany� s4 &zMySQLCursor.executemanyzmThe property counterpart 'stored_results' will be added in a future release, and this method will be removed.zIterator[MySQLCursor]c C s t | j�S )z�Returns 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. )r] rf r; r/ r/ r0 �stored_results s zMySQLCursor.stored_resultsr/ r z0Optional[Union[Dict[str, RowItemType], RowType]]��procname�argsr+ c C sh |rt |t�std��t |ttf�s,td��d}g | _g }�z�g }g }|�d�d }|r�g }t|�D ]n\} } |j|| d d�} |� | � t | t�r�|� d| � d | d � d �� |� | d � qd|� | � |� | � qdd � d d� |D ��} | � d| � �|� d|� dd � |�� d �} | j j }| j j| | j| jd�D ]�}d| j _ t | ttf��rRt}n| j�r`t}nt}|| j �� �}d| � d �|_|�|� |jdu�r�|j| _d|v �r0|� |� �q0|| j _ |�r dd� t|dd� |D ��D �}dd � |�� �}| � |� || _| � � W S || _t� W S t �y. � Y n6 t �yb } z t d|� ��d�W Y d}~n d}~0 0 dS ) a� Calls a stored procedure with the given arguments The arguments will be set during this session, meaning they will be called like _<procname>__arg<nr> where <nr> 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 cursor.callproc('multiply', args) print(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')) 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 sequencez@_{name}_arg{index}�.rb r )�namer- z CAST(� AS �)r �,c s s | ]}|� d �V qdS )z=%sNr/ �r� �argr/ r/ r0 � <genexpr>o r� z'MySQLCursor.callproc.<locals>.<genexpr>zSET zCALL r& r� Fz (a result of Nr� c S s g | ]\}}|� d |� ��qS )r� r/ )r� r� �aliasr/ r/ r0 r� � s �z(MySQLCursor.callproc.<locals>.<listcomp>c S s g | ]}|� d ��qS )z@_)�lstripr� r/ r/ r0 r� � r� zSELECT z Failed calling stored routine; ) r� r� rG r� r� rf �splitr� �formatr� r� r� rY �can_consume_resultsZcmd_query_iterr� r� �MySQLCursorDict�MySQLCursorBufferedDict�_raw�MySQLCursorBufferedRaw�MySQLCursorBufferedZget_selfrj r� �warningsrg �zipr^ r r� r )r. r� r� Zargfmt�results�argnames�argtypesZ procname_absZ argvalues�idxr� �argnameZ placeholders�callr� r� Z cursor_class�cur�selectr� r/ r/ r0 �callproc) st ( � �� zMySQLCursor.callproczOptional[List[WarningType]]c C sz g }z4| j jd| j| jd�}|�d� |�� }|�� W n4 tyl } z td|� ��d�W Y d}~n d}~0 0 |rv|S dS )z� Fetch warnings doing a SHOW WARNINGS. Can be called after getting the result. Returns a result set or None when there were no warnings. F)�rawrV rW z SHOW WARNINGSzFailed getting warnings; N) rY �cursorr� r� r� r� r{ r� r )r. r� r� r� r/ r/ r0 �_fetch_warnings� s � &zMySQLCursor._fetch_warningsc C sh | j jr| jr| �� | _| js"dS t| jd d | jd d | j j d�}| j jrV|�tj|dd� dS )z�Handle possible warnings after all results are consumed. Raises: Error: Also raises exceptions if raise_on_warnings is set. Nr r r� )�warning� )� stacklevel) rY Z get_warningsrh r� rg r Zraise_on_warningsr� �warn)r. r� r/ r/ r0 r� � s �z MySQLCursor._handle_warningsr ��eofr+ c C s$ d| j _d| _|d | _| �� dS )zHandle EOF packetFrc r� N)rY rq re rh r� �r. r� r/ r/ r0 � _handle_eof� s zMySQLCursor._handle_eof�Optional[RowType]�r� r+ c C s� | � � s dS d}| jdkr:| jj| j| j|| jd�\}}n | j\}}|r�| jj| j| j|| jd�| _| jd }|dur�| �|� | jdkr�d| _n| jd7 _|r�| �|� |S )zQReturns the next row in the result set Returns a tuple or None. Nrc )�binaryr� r� rV r rb ) rs re rY Zget_row�_binary� descriptionr� r� rd )r. r� rx r� r/ r/ r0 � _fetch_row� s6 � � zMySQLCursor._fetch_rowc C s | � � | �� S ��yReturn next row of a query result set. Returns: tuple or None: A row from query result set. �ru r r; r/ r/ r0 r^ � s zMySQLCursor.fetchone� List[RowType]��sizer+ c C sJ | � � g }|p| j}|dkrF| �� rF|d8 }| �� }|r|�|� q|S �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. r r )ru � arraysizers r^ r� �r. r r� Zcntrx r/ r/ r0 � fetchmany s zMySQLCursor.fetchmanyc C s� | � � | �� sg S | jj| jd�\}}| jd rD|�d| jd � | �|� t|�}|dkrn| j dkrnd| _ | j |7 _ |S )��Return all rows of a query result set. Returns: list: A list of tuples with all rows of a query result set. �rV r rb ) ru rs rY �get_rowsr� re �insertr� r: rd �r. �rowsr� Zrowcountr/ r/ r0 r� s zMySQLCursor.fetchallzOptional[bool]c C s� | j jrx| j �� | jdd� | �| j �| j jj| jd��� | jd urt| j rt| j d sdt � d� n| j d � � | _dS | jd ur�zt| j�| _ W n ty� Y n80 | j d � � | _| �| j j| j d | j| jd�� dS | �� d S )NT)ra r r� zOMappingWarning: Number of result sets greater than number of single statements.r� r� )rY Z_have_next_resultrz rp r� �_socket�recvr� rl rn rm r� r� r� rj r� rv r� r� r; r/ r/ r0 �nextset0 s> �� � ��zMySQLCursor.nextsetzTuple[str, ...]c C s | j s t� S tdd� | j D ��S )ztReturns column names This property returns the columns names as a tuple. Returns a tuple. c s s | ]}|d V qdS )r Nr/ )r� �dr/ r/ r0 r� q r� z+MySQLCursor.column_names.<locals>.<genexpr>)r r� r; r/ r/ r0 � column_namesg s zMySQLCursor.column_namesc C s | j s dS dS )z�Returns 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. FT)r r; r/ r/ r0 r� s s zMySQLCursor.with_rowsc C sh d}| j rRz| j �d�}W n ty2 | j }Y n0 t|�dkrV|d d� d }nd}|j| jj|d�S )Nz{class_name}: {stmt}zutf-8�( z..z(Nothing executed yet))� class_namerO )rj �decoderr r: r� r\ r= )r. r� Zexecutedr/ r/ r0 �__str__� s zMySQLCursor.__str__)NNN)F)NF)r/ )F)N)#r= r> r? r@ r1 r_ rp rs ru ry r{ r� r� r� r� r� r� r� r� r r� r� r� r� r� r r^ r r� r rA r r� r � __classcell__r/ r/ r[ r0 rQ � sP � �C87� �x& 7 rQ c s� e Zd ZdZd ddddd�� fdd� Zdd �d d �Zd!d dd�dd�Zd"d dd�dd�Zdd �dd�Zdd �dd�Z d#ddd�d d �Z e d d �d d ��Z � Z S )$r� z*Cursor which fetches rows within execute()NrR rS r( rT c s t � �|||� d | _d| _d S r, )rX r1 �_rows� _next_rowrZ r[ r/ r0 r1 � s z MySQLCursorBuffered.__init__r9 c C sV | j j| jd�\| _}t| j�| _| �|� d| _z d| j _W n t yP Y n0 d S )Nr r F) rY r r� r r: rd r� r rq rr r� r/ r/ r0 r� � s z%MySQLCursorBuffered._handle_resultsetTr` ��freer+ c C s d | _ d S �N�r �r. r" r/ r/ r0 ro � s zMySQLCursorBuffered.resetFr� r c C s@ d }z| j | j }W n ttfy, Y d S 0 | jd7 _|S )Nr )r r r6 r� )r. r� rx r/ r/ r0 r � s z MySQLCursorBuffered._fetch_rowc C s | � � | �� S r r r; r/ r/ r0 r^ � s z MySQLCursorBuffered.fetchoner c C s@ | j du s| jdu r tt��g }| j| jd� }t| j�| _|S �r N)rj r r rt r r: �r. r� r/ r/ r0 r� � s z MySQLCursorBuffered.fetchallr c C sB | � � g }|p| j}|dkr>|d8 }| �� }|r|�|� q|S r )ru r r^ r� r r/ r/ r0 r � s z MySQLCursorBuffered.fetchmanyc C s | j d uS r# r$ r; r/ r/ r0 r� � s z MySQLCursorBuffered.with_rows)NNN)T)F)N)r= r> r? r@ r1 r� ro r r^ r� r rA r� r r/ r/ r[ r0 r� � s � r� c sJ e Zd ZdZdddddd�� fdd� Zd d �d d �Zd d �dd�Z� ZS )�MySQLCursorRawzS Skips conversion from MySQL datatypes to Python types when fetching rows. NrR rS r( rT c s t � �|||� d| _d S �NT�rX r1 r� rZ r[ r/ r0 r1 � s zMySQLCursorRaw.__init__r� r9 c C s | � � | j| jd�S )r )r� )ru r r� r; r/ r/ r0 r^ � s zMySQLCursorRaw.fetchoner c C s� | � � | �� sg S | jj| j| jd�\}}| jd rH|�d| jd � | �|� t |�}|dkrr| j dkrrd| _ | j |7 _ |S )r �r� rV r rb ) ru rs rY r r� r� re r r� r: rd r r/ r/ r0 r� � s � zMySQLCursorRaw.fetchall)NNN)r= r> r? r@ r1 r^ r� r r/ r/ r[ r0 r( � s � r( c sj e Zd ZdZdddddd�� fdd� Zdd �d d �Zd d �d d�Zdd �dd�Zedd �dd��Z � Z S )r� z� Cursor which skips conversion from MySQL datatypes to Python types when fetching rows and fetches rows within execute(). NrR rS r( rT c s t � �|||� d| _d S r) r* rZ r[ r/ r0 r1 s z MySQLCursorBufferedRaw.__init__r9 c C sZ | j j| j| jd�\| _}t| j�| _| �|� d| _z d| j _ W n t yT Y n0 d S )Nr+ r F) rY r r� r� r r: rd r� r rq rr r� r/ r/ r0 r� s � z(MySQLCursorBufferedRaw._handle_resultsetr� c C s | � � | �� S r r r; r/ r/ r0 r^ ) s z MySQLCursorBufferedRaw.fetchoner c C s* | � � | jdu rg S t| j| jd� �S r& )ru r r� r r; r/ r/ r0 r� 2 s z MySQLCursorBufferedRaw.fetchallr` c C s | j d uS r# r$ r; r/ r/ r0 r� = s z MySQLCursorBufferedRaw.with_rows)NNN) r= r> r? r@ r1 r� r^ r� rA r� r r/ r/ r[ r0 r� s � r� c s e Zd ZdZd=dddd�� fdd� Zd>d d d �d d �Zdd d�� fdd� Zdd d�dd�Zdd d�� fdd� Zd?ddd d �d d �Z d d �� fd!d"� Z d@dddd#�d$d%�Z dd d&�d'd(�Z dAd*d+d d d,�d-d.�Z d/d0d d1�d2d3�Zd4d �d5d6�ZdBdd7d8�d9d:�Zd7d �d;d<�Z� ZS )C�MySQLCursorPreparedz&Cursor using MySQL Prepared StatementsNrR rS )rU rV rW c s> t � �|||� d | _d| _d | _d| _d | _d| _d| _d S )Nr TF) rX r1 r r � _preparedr � _have_result�_last_row_sent�_cursor_existsrZ r[ r/ r0 r1 E s z MySQLCursorPrepared.__init__Tr` r( r! c C sV | j r@z | jj| j d | j| jd� W n ty8 Y n0 d | _ d | _d| _d| _d S )N� statement_idr� F) r- rY �cmd_stmt_closer� r� r rj r/ r0 r% r/ r/ r0 ro T s � zMySQLCursorPrepared.resetr r� c s* | � |�d|�dd��� t� �|� d S �N� status_flag� server_statusr )�_handle_server_status�getrX r� r' r[ r/ r0 r� d s z'MySQLCursorPrepared._handle_noresultsetr8 )�flagsr+ c C s$ |t j@ dk| _|t j@ dk| _dS )zoCheck for SERVER_STATUS_CURSOR_EXISTS and SERVER_STATUS_LAST_ROW_SENT flags set by the server. r N)r ZSTATUS_CURSOR_EXISTSr0 ZSTATUS_LAST_ROW_SENTr/ )r. r8 r/ r/ r0 r6 h s z)MySQLCursorPrepared._handle_server_statusr r� c s* | � |�d|�dd��� t� �|� d S r3 )r6 r7 rX r� r� r[ r/ r0 r� o s z MySQLCursorPrepared._handle_eofr/ r r r� c C s t � �dS )zQCalls a stored procedue Not supported with MySQLCursorPrepared. N)r )r. r� r� r/ r/ r0 r� s s z MySQLCursorPrepared.callprocr9 c s | � � t� �� dS )zzClose the cursor This method will try to deallocate the prepared statement and close the cursor. N)ro rX r{ r; r[ r/ r0 r{ z s zMySQLCursorPrepared.close��rowdata�descr+ c C s dS )z�Convert row data from MySQL to Python types The conversion is done while reading binary data in the protocol module. Nr/ �r. r: r; r/ r/ r0 �_row_to_python� s z"MySQLCursorPrepared._row_to_pythonr� c C s~ t |t�r$d| j_d| _| �|� nV|d | _d| j_d| _d|d v r\| �|d d � n d|d v rz| �|d d � dS )z Handle result after executionFr Tr4 r� r5 N)r� r� rY rq r. r� ri r6 r� r/ r/ r0 r� � s z"MySQLCursorPrepared._handle_resultFr# r� r� c s� |r t d��| jj}|dkr d}t|t�slz|�|�}W n2 tyj } zt t|��|�W Y d}~n d}~0 0 t� t�r�t� t |�}zt � fdd�|D ��� W n. t y� } zt d�|�W Y d}~n d}~0 0 t� td|�}|| ju�r�| j�r | jj| jd | j| jd � || _z|�|�}W n4 t�yR } zt t|��|�W Y d}~n d}~0 0 |�d d �}d |v �rxt� td |�}z | jj|| j| jd �| _W n t�y� d| _� Y n0 | jj| jd | j| jd � | jd �r� �s�dS � �r>t� t tf��st ddt � �j � d� � d�d��t | jd �t � �k�r>t ddd��� du �rLd� z4| jj | jd � | jd | j| jd�}| � |� W n6 t!t"f�y� } z| �#� |�W Y d}~n d}~0 0 dS )a Prepare 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. *Argument "map_results" is unused as multi statement execution is not supported for prepared statements*. Raises: ProgrammingError: When providing a multi statement operation or setting *map_results* to True. z@Multi statement execution not supported for prepared statements.Zutf8mb4�utf8Nc 3 s | ]}� | V qd S r# r/ )r� rJ �r* r/ r0 r� � r� z.MySQLCursorPrepared.execute.<locals>.<genexpr>z6Not all placeholders were found in the parameters dict�?r1 r� r� r� � ?� parametersi� z Incorrect type of argument: r& zP), it must be of type tuple or list the argument given to the prepared statement)�errno�msgz:Incorrect number of arguments executing prepared statementr/ )�datarB rV rW )$r rY �charsetr� r� r r� r� r� �findall� RE_SQL_PYTHON_CAPTURE_PARAM_NAMEr� r� rN �RE_SQL_PYTHON_REPLACE_PARAMrj r- r2 r� r� r� r� rL �RE_SQL_FIND_PARAMZcmd_stmt_preparer Zcmd_stmt_resetr� r� r= r: Zcmd_stmt_executer� r r ro )r. r� r* r� rF r� Zreplacement_keysr� r/ r? r0 r� � s� � $ �� �$ � ��� �zMySQLCursorPrepared.executer� z Sequence[ParamsSequenceType]r� c C s� d}z:|D ]0}| � ||� | jr0| �� r0| �� || j7 }q W n8 ttfyv } z td|� ��d�W Y d}~n d}~0 0 || _dS )aD Prepare 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(). r r� N)r� r� rs r� rd rG r� r )r. r� r� r� r* r� r/ r/ r0 r� s &z MySQLCursorPrepared.executemanyr� c C s6 | � � | jr*| jj| jd | j| jd� | �� p4dS )r r1 r� N)ru r0 rY �cmd_stmt_fetchr- r� r� r r; r/ r/ r0 r^ ' s �z MySQLCursorPrepared.fetchoner r c C sJ | � � g }|p| j}|dkrF| �� rF|d8 }| �� }|r|�|� q|S r )ru r rs r r� r r/ r/ r0 r 6 s z MySQLCursorPrepared.fetchmanyc C s� | � � g }| jd r&|�| jd � | �� r�| jrR| jj| jd t| j | j d� | jj | j | j | j d�\}}|�|� | �|� q&t|�| _|S )r r r1 r� )r r� rV )ru re r� rs r0 rY rK r- � MAX_RESULTSr� r� r r r �extendr� r: rd )r. r r� r� r/ r/ r0 r� J s* �� z MySQLCursorPrepared.fetchall)NNN)T)r/ )N)NF)N)r= r> r? r@ r1 ro r� r6 r� r� r{ r= r� r� r� r^ r r� r r/ r/ r[ r0 r, B s( � �sr, c sL e Zd ZdZddddd�dd�Zdd �� fd d � Zd d �� fd d� Z� ZS )r� z� 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 } Nr" z Optional[List[DescriptionType]]� Optional[Dict[str, RowItemType]]r9 c C s |rt t| j|��S dS )zWConvert a MySQL text result row to Python types Returns a dictionary. N)r� r� r r< r/ r/ r0 r= s s z MySQLCursorDict._row_to_pythonr9 c s | � t� �� | j�S )zyReturn next row of a query result set. Returns: dict or None: A dict from query result set. )r= rX r^ r r; r[ r/ r0 r^ ~ s zMySQLCursorDict.fetchone�&List[Optional[Dict[str, RowItemType]]]c s � fdd�t � �� D �S )z�Return 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. c s g | ]}|r� � |� j��qS r/ �r= r �r� rx r; r/ r0 r� � s �z,MySQLCursorDict.fetchall.<locals>.<listcomp>)rX r� r; r[ r; r0 r� � s �zMySQLCursorDict.fetchall)N)r= r> r? r@ r= r^ r� r r/ r/ r[ r0 r� g s � r� c @ s, e Zd ZdZdd�dd�Zdd�dd�Zd S ) r� z8 Buffered Cursor fetching rows as dictionaries. rN r9 c C s& | � � | �� }|r"| �|| j�S dS )r N)ru r r= r rw r/ r/ r0 r^ � s z MySQLCursorBufferedDict.fetchonerO c C sZ | j du s| jdu r tt��g }| j| jd� D ]}|�| �|| j�� q0t| j�| _|S r& ) rj r r rt r r� r= r r: )r. r� rx r/ r/ r0 r� � s z MySQLCursorBufferedDict.fetchallN)r= r> r? r@ r^ r� r/ r/ r/ r0 r� � s r� c s* e Zd ZdZdddd�� fdd� Z� ZS ) �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) NrS z List[Dict[str, RowItemType]]r c s � fdd�t � j|d�D �S )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 represented as a list of dictionaries where column names are used as keys. c s g | ]}|r� � |� j��qS r/ rP rQ r; r/ r0 r� � s �z5MySQLCursorPreparedDict.fetchmany.<locals>.<listcomp>)r )rX r )r. r r[ r; r0 r � s �z!MySQLCursorPreparedDict.fetchmany)N)r= r> r? r@ r r r/ r/ r[ r0 rR � s rR )Lr@ � __future__r r� r� �decimalr �typingr r r r r r r r r r r Z _decoratingr Z _scriptingr Z abstractsr � constantsr �errorsr r r r r r r �typesr r r r r r r! r" r# r$ rU r% Z SQL_COMMENT�compile�I�M�Sr� r� r� r� r� �XrM ZRE_SQL_SPLIT_STMTSrJ rI rH rt rL r' rP rQ r� r( r� r, r� r� rR r/ r/ r/ r0 �<module> sr 4 $ 0 ��� �� cS-4 '-
| ver. 1.6 |
Github
|
.
| PHP 8.2.30 | ??????????? ?????????: 0 |
proxy
|
phpinfo
|
???????????