?????????? ????????? - ??????????????? - /home/agenciai/.local/lib/python3.9/site-packages/mysql/connector/aio/__pycache__/cursor.cpython-39.pyc
???????
a ��Jh"� � @ s� d Z dgZddlZddlZddlmZ ddlmZmZm Z m Z m Z m Z m Z mZmZmZ ddlmZ ddlmZ dd lmZ dd lmZmZmZm 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( dd l)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3 d dlmZ d dl4m5Z5m6Z6 dZ7G dd� d�Z8e9e e9e9f e9d�dd�Z:G dd� de6�Z;G dd� de;�Z<G dd� de;�Z=G dd� de<�Z>G d d � d e;�Z?G d d � d e?e<�Z@G d d!� d!e;�ZAG d"d#� d#e?eA�ZBdS )$z0Implementation of cursor classes in pure Python.� MySQLCursor� N)�Decimal) �Any�AsyncGenerator�Dict�Iterator�List�NoReturn�Optional�Sequence�Tuple�Union� )� deprecated)�split_multi_statement)� ServerFlag) � MAX_RESULTS�RE_PY_MAPPING_PARAM� RE_PY_PARAM�RE_SQL_COMMENT�RE_SQL_FIND_PARAM�RE_SQL_INSERT_STMT�RE_SQL_INSERT_VALUES�RE_SQL_ON_DUPLICATE� RE_SQL_PYTHON_CAPTURE_PARAM_NAME�RE_SQL_PYTHON_REPLACE_PARAM)�Error�InterfaceError�NotSupportedError�ProgrammingError�get_mysql_exception) �DescriptionType� EofPacketType�ParamsDictType�ParamsSequenceOrDictType�ParamsSequenceType� ResultType� RowItemType�RowType� StrOrBytes� WarningType� )�MySQLConnectionAbstract�MySQLCursorAbstractzNo result set to fetch fromc @ sH e Zd ZdZee dd�dd�Zejed�dd�Z e e d �d d ��Z dS ) �_ParamSubstitutorz+Substitute parameters into a SQL statement.N��params�returnc C s || _ d| _d S �Nr )r0 �index)�selfr0 � r5 �O/home/agenciai/.local/lib/python3.9/site-packages/mysql/connector/aio/cursor.py�__init___ s z_ParamSubstitutor.__init__��matchobjr1 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)r3 �bytesr0 � IndexErrorr )r4 r9 r3 r5 r5 r6 �__call__c s ��z_ParamSubstitutor.__call__�r1 c C s t | j�| j S )z<Return the number of parameters remaining to be substituted.)�lenr0 r3 �r4 r5 r5 r6 � remainingm s z_ParamSubstitutor.remaining) �__name__� __module__� __qualname__�__doc__r r: r7 �re�Matchr< �property�intr@ r5 r5 r5 r6 r. \ s r. )�bytestr� value_dictr1 c s& t jtd�� 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' r8 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)r9 �value�groups�key�rJ r5 r6 �replace� s �z%_bytestr_format_dict.<locals>.replace)rE rF r: r �sub)rI rJ rS �stmtr5 rR r6 �_bytestr_format_dicts s rV c @ s\ e Zd ZdZed�dd�Zed�dd�Zee e e e e f f d�dd �Z eee e e f d f d�d d �ZdFeee d�dd�Zedd�dd�Zdd�dd�Zedd�dd�Zdd�dd�Zedd �d d �ZdGedd �d d!�Zed�d"d#�Zdd�d$d%�Z dHe e e e e e e f f e d'�d(d)�Z!ee"e# d�d*d+�Z$e e e% ee d,�d-d.�Z&e'd/�e(e) d�d0d1��Z*dIe e e ee e e e+f ef d2�d3d4�Z,dJe e e e e e e f f edd5�d6d7�Z-e.d8�dKe e e e e e e f f edd5�d9d:��Z/e e e dd,�d;d<�Z0ee d�d=d>�Z1e"e d�d?d@�Z2dLee3 e"e dA�dBdC�Z4ee d�dDdE�Z5dS )Mr a� 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). r= c � s" | � � I d H }|d ur|S t�d S �N)�fetchone�StopAsyncIteration�r4 �resr5 r5 r6 � __anext__� s zMySQLCursor.__anext__c � s> | j s dS | j �| � | j �� I d H | �� I d H d | _ dS )NFT)� _connectionZ remove_cursor�handle_unread_result� _reset_resultr? r5 r5 r6 �close� s zMySQLCursor.closer/ c � s� i }zx| j �� I dH }| j jj}| j jj}| j jj}|�� D ]<\}}|} || �} || |�} t|t�sl|| �} | ||� � < q<W n4 t y� } z t d| � ��| �W Y d} ~ n d} ~ 0 0 |S )z-Process query parameters given as dictionary.Nz'Failed processing pyformat-parameters; ) r] � get_sql_mode� converter�to_mysql�escape�quote�items� isinstancer �encode� Exceptionr ) r4 r0 r[ �sql_moderc rd re rQ rO �conv�errr5 r5 r6 �_process_params_dict� s( ��z MySQLCursor._process_params_dict.c � s� �dd� }zp| j �� I dH �| 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 r5 r5 ��.0rO )rc r5 r6 � <listcomp>� � z/MySQLCursor._process_params.<locals>.<listcomp>c s g | ]}� |���qS r5 r5 rn )rd rj r5 r6 rp � rq c s* g | ]"\}}t � | t�s"�|�n|�qS r5 )rg r )ro �irO )r0 re r5 r6 rp � s �z%Failed processing format-parameters; ) r] ra rb rc rd re � enumerateri r �tuple)r4 r0 �resultrl r5 )rd r0 re rj rc r6 �_process_params� s$ � ��zMySQLCursor._process_paramsF��rawr1 c � s� | j js dS d}| jdkr@| j j| j| j|| jd�I dH \}}n | j\}}|r�| j j| j| j|| jd�I dH | _| jd }|dur�| �|�I dH | jdkr�d| _n| jd7 _|r�| �|�I dH |S )�&Return the next row in the result set.N�NN)�binary�columnsrx � read_timeoutr+ ���) r] � unread_result�_nextrowZget_row�_binary� description� _read_timeout� _handle_eof� _rowcount)r4 rx �row�eofr5 r5 r6 � _fetch_row� s6 � � zMySQLCursor._fetch_rowN�ru r1 c � sj t |t�std��d|v r<|d | _d| j_| �� I dH n*d|v r^d| j_| �|�I dH 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()r| TN� affected_rowsFzInvalid result)rg �dictr � _descriptionr] r �_handle_resultset�_handle_noresultset�r4 ru r5 r5 r6 �_handle_result� s zMySQLCursor._handle_resultc � s dS )��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. Nr5 r? r5 r5 r6 r� s z MySQLCursor._handle_resultset�r[ r1 c � sn z"|d | _ |d | _|d | _W n8 ttfyZ } z td|� ��d�W Y d}~n d}~0 0 | �� I dH dS )z�Handle result of execute() when there is no result set. Raises: ProgrammingError: When failing handling a non-resultset. r� Z insert_id� warning_countz Failed handling non-resultset; N)r� Z_last_insert_id�_warning_count�KeyError� TypeErrorr �_handle_warnings)r4 r[ rl r5 r5 r6 r� s &z MySQLCursor._handle_noresultsetc � sn | j jr | jr | �� I dH | _| js(dS t| jd d | jd d | j j d�}| j jr\|�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) r] Z get_warningsr� �_fetch_warnings� _warningsr Zraise_on_warnings�warnings�warn)r4 rl r5 r5 r6 r� . s �z MySQLCursor._handle_warnings�r� r1 c � s* d| j _d| _|d | _| �� I dH dS )zHandle EOF packet.Frz r� N)r] r r� r� r� �r4 r� r5 r5 r6 r� E s zMySQLCursor._handle_eof)�preserve_last_executed_stmtr1 c � sX d| _ d| _d| _g | _d| _d| _|sFd| _g | _d| _d| _ d| _ | � � I dH 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. Nr r~ rz F) r� r� r� �_stored_resultsr� r� � _executed�_executed_list�_stmt_partitions�_stmt_partition�_stmt_map_results�reset)r4 r� r5 r5 r6 r_ L s zMySQLCursor._reset_resultc C s$ z | j jW S ty Y dS 0 dS )z(Check whether there is an unread result.FN)r] r �AttributeErrorr? r5 r5 r6 �_have_unread_resulte s z MySQLCursor._have_unread_resultc C s | j du rtt��dS )z�Check if the statement has been executed. Raises: InterfaceError: If the statement has not been executed. N)r� r �ERR_NO_RESULT_TO_FETCHr? r5 r5 r6 �_check_executedl s zMySQLCursor._check_executedr5 )� operationr0 r1 c � s� z$t |ttf�r|n |�| jj�}W n6 ttfyZ } ztt |��|�W Y d}~n d}~0 0 |r�t |t �r�t || � |�I dH �}n^t |t tf�r�t| �|�I dH �}t�||�}|jdkr�td��n tdt|�j� d|� d���|�dd�}|S ) 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. Nr �1Not all parameters were used in the SQL statementz Could not process parameters: �(z)), it must be of type list, tuple or dict� %%s� %s)rg r: � bytearrayrh r] �python_charset�UnicodeDecodeError�UnicodeEncodeErrorr �strr� rV rm �listrt r. rv r rT r@ �typerA rS )r4 r� r0 rU rl �psubr5 r5 r6 �_prepare_statementu s0 � �$ � �� z MySQLCursor._prepare_statementc � s~ g }| j jd| j| jd�I dH 4 I dH �4}|�d�I dH |�� I dH }W d �I dH qr1 I dH sh0 Y |rz|S dS )z%Fetch warnings doing a SHOW WARNINGS.F)rx r} � write_timeoutNz SHOW WARNINGS)r] �cursorr� �_write_timeout�execute�fetchall)r4 ru �curr5 r5 r6 r� � s �8zMySQLCursor._fetch_warnings�r� � seq_paramsr1 c � s� t jtd�dd�}t �tdt �t||��}t �t|�}|sBtd��|� d�� | j j �}g }z�|� | j j �}|D ]f} |}t | t�r�t|| �| �I dH �}n2t| �| �I dH �} t�| |�}| jdkr�td ��|�|� qn||v r�|�|d �|�d�}|| _|W S W dS ttf�y: } ztt| ��| �W Y d} ~ nRd} ~ 0 t �yN � Y n6 t �y� } z td | � ��d�W Y d} ~ n d} ~ 0 0 dS ) zImplements multi row insert)�matchr1 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+ � r )�group)r� r5 r5 r6 �remove_comments� s z2MySQLCursor._batch_insert.<locals>.remove_commentsr� zAFailed rewriting statement for multi-row INSERT. Check SQL syntaxr+ Nr r� � ,� Failed executing the operation; ) rE rF r� rT r r �searchr r r� rh r] r� rg r� rV rm r. rv r r@ r �appendrS �joinr� r� r� r ri ) r4 r� r� r� �tmp�matches�fmt�valuesrU r0 r� rl r5 r5 r6 � _batch_insert� sN � � � � "zMySQLCursor._batch_insertzmThe property counterpart 'stored_results' will be added in a future release, and this method will be removed.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. )�iterr� r? r5 r5 r6 �stored_results� s zMySQLCursor.stored_results��procname�argsr1 c � s� |rt |t�std��t |ttf�s,td��g | _g }�z g }g }|�d�d }|r�g }t|�D ]p\}} d|� d|d � �} |�| � t | t�r�|�d| � d | d � d �� |�| d � q`|�| � |�| � q`d � d d� |D ��} | � d| � �|�I dH d|� dd � |�� d �} | j j } | j j | | j| jd�2 z�3 dH W }d| j _ t | ttf��r^t}n| j�rlt}nt}|| j �� �}d| � d �|_|�|�I dH |jdu�r�|j| _d|v �r4|�|� �q46 | | j _ |�r,dd� t|dd� |D ��D �}dd � |�� �}| � |�I dH || _| �� I dH W S || _t� W S t �yN � Y n6 t �y� } 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 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�.r~ �@_Z_argr+ z CAST(� AS �)r �,c s s | ]}|� d �V qdS )z=%sNr5 �ro �argr5 r5 r6 � <genexpr>9 rq z'MySQLCursor.callproc.<locals>.<genexpr>zSET NzCALL r� �r} r� Fz (a result of r| c S s g | ]\}}|� d |� ��qS )r� r5 )ro �name�aliasr5 r5 r6 rp \ s �z(MySQLCursor.callproc.<locals>.<listcomp>c S s g | ]}|� d ��qS )r� )�lstripr� r5 r5 r6 rp _ rq zSELECT z Failed calling stored routine; ) rg r� rN rt r� r� �splitrs r� r� r� r] �can_consume_resultsZcmd_query_iterr� r� �MySQLCursorDict�MySQLCursorBufferedDict�_raw�MySQLCursorBufferedRaw�MySQLCursorBufferedZget_selfr� r� r� r� �ziprX r ri r )r4 r� r� �results�argnames�argtypesZ procname_absZ argvalues�idxr� �argnameZ placeholders�callr� ru Z cursor_classr� �selectrl r5 r5 r6 �callproc� sv ( � ��zMySQLCursor.callproc�r� r0 � map_resultsr1 c � s� | j std��|sd S | j �� I d H | �� I d H | �||�I d H }t||d�| _t| j�| _|| _ | jd | _ |r�| jd � � n| jd | _ | � | j j| jd | j| jd�I d H �I d H d S )N�Cursor is not connected)Zsql_coder� � single_stmts� mappable_stmtr� )r] r r^ r_ r� r r� �nextr� r� r� �popleftr� r� � cmd_queryr� r� )r4 r� r0 r� rU r5 r5 r6 r� n s2 � ��� � zMySQLCursor.execute�\executemulti() is deprecated and will be removed in a future release. Use execute() instead.c � s | j |||d�I d H S )N)r� r0 r� )r� �r4 r� r0 r� r5 r5 r6 � executemulti� s �zMySQLCursor.executemultic � s2 |r|s dS | j �� I dH z t|�}W n. tyV } ztd�|�W Y d}~n d}~0 0 t�t|�r�|srd| _dS | � ||�I dH }|dur�|| _ | � |�I dH S d}zF|D ]<}| � ||�I dH | j r�| � � r�| �� I dH || j7 }q�W n: ttf�y& } z td|� ��d�W Y d}~n d}~0 0 || _dS )a 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. N�(Parameters for query must be an Iterabler r� )r] r^ r� r� r rE r� r r� r� r� r� � with_rowsr� r� rN )r4 r� r� �_rl rU �rowcntr0 r5 r5 r6 � executemany� s2 &zMySQLCursor.executemanyc � s | j du rtt��| �� I dH S )z�Return 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)r� r r� r� r? r5 r5 r6 rX � s zMySQLCursor.fetchonec � s� | j du rtt��| jjs g S | jj| jd�I dH \}}| jd rT|�d| jd � | � |�I dH t |�}|dkr�| j dkr�d| _ | 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. N�r} r r~ ) r� r r� r] r �get_rowsr� r� �insertr� r> r� �r4 �rowsr� Zrowcountr5 r5 r6 r� � s zMySQLCursor.fetchall��sizer1 c � sH | � � g }|p| j}|dkrD|d8 }| �� I dH }|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+ N)r� � arraysizerX r� �r4 r r[ Zcntr� r5 r5 r6 � fetchmany� s zMySQLCursor.fetchmanyc � s | j jr�| j �� I d H | jdd�I d H | �| j �| j jj| jd�I d H �I d H �I d H | jd ur�| j r�| j d s�t � d� n| j d � � | _dS | jd u�rzt| j�| _ W n ty� Y nD0 | j d � � | _| �| j j| j d | j| jd�I d H �I d H dS | �� I d H d S )NT)r� r r� zOMappingWarning: Number of result sets greater than number of single statements.r� r� )r] Z_have_next_resultr^ r_ r� �_socket�readr� r� r� r� r� r� r� r� r� � StopIterationr� r� r? r5 r5 r6 �nextset s> �� � � � zMySQLCursor.nextset)F)F)r5 )r5 )r5 F)r5 F)N)6rA rB rC rD r( r\ �boolr` r# r r: r r rm r% r rv r r� r& r� r� r� r� r" r� r_ r� r� r) r r r� r� r r* r� r$ r� �deprecated_syncr r- r� r' r� r� r r� r rX r� rH r r r5 r5 r5 r6 r � s� � � # �� - � :� �� } �� '� �� � * c s� e Zd ZdZdeee ee dd�� fdd� Zdd�dd�Zde ee d �d d �Z de dd�dd�Z ee d�dd�Z ee d�dd�Zee d�dd��Z� ZS )r� z+Cursor which fetches rows within execute().N�� connectionr} r� r1 c s t � �|||� d | _d| _d S r2 )�superr7 �_rows� _next_row�r4 r r} r� �� __class__r5 r6 r7 A s z MySQLCursorBuffered.__init__r= c � sN | j j| j| jd�I dH \| _}t| j�| _| �|�I dH d| _d| j _ dS )r� �rx r} Nr F) r] r r� r� r r> r� r� r r r� r5 r5 r6 r� K s � z%MySQLCursorBuffered._handle_resultsetFrw c � s@ d}z| j | j }W n ttfy, Y dS 0 | jd7 _|S )ry Nr+ )r r r; r� )r4 rx r� r5 r5 r6 r� Z s z MySQLCursorBuffered._fetch_rowT��freer1 c � s d| _ dS )z Reset the cursor to default.N�r �r4 r r5 r5 r6 r� d s zMySQLCursorBuffered.resetc � s | � � | �� I dH S ��yReturn next row of a query result set. Returns: tuple or None: A row from query result set. N�r� r� r? r5 r5 r6 rX h s z MySQLCursorBuffered.fetchonec � sD | j du rtt��| jdu r g S g }| j| jd� }t| j�| _|S �r N)r� r r� r r r> rZ r5 r5 r6 r� q s z MySQLCursorBuffered.fetchallc C s | j d uS rW r r? r5 r5 r6 r� � s z MySQLCursorBuffered.with_rows)NN)F)T)rA rB rC rD r, r rH r7 r� r r( r� r� rX r r� rG r� � __classcell__r5 r5 r r6 r� > s �� r� c sZ e Zd ZdZd eee ee dd�� fdd� Zee d�dd�Z e e d�d d �Z � Z S ) �MySQLCursorRawzHSkip conversion from MySQL datatypes to Python types when fetching rows.Nr c s t � �|||� d| _d S �NT�r r7 r� r r r5 r6 r7 � s zMySQLCursorRaw.__init__r= c � s | � � | jdd�I dH S )r! T)rx Nr" r? r5 r5 r6 rX � s zMySQLCursorRaw.fetchonec � s� | � � | �� sg S | jjd| jd�I dH \}}| jd rL|�d| jd � | �|�I dH t|�}|dkr|| j dkr|d| _ | j |7 _ |S )r Tr Nr r~ ) r� r� r] r r� r� r r� r> r� r r5 r5 r6 r� � s � zMySQLCursorRaw.fetchall)NN) rA rB rC rD r, r rH r7 r( rX r r� r$ r5 r5 r r6 r% � s �� r% c sH e Zd ZdZd eee ee dd�� fdd� Zee d�dd��Z � Z S ) r� z� Cursor which skips conversion from MySQL datatypes to Python types when fetching rows and fetches rows within execute(). Nr c s t � �|||� d| _d S r& r' r r r5 r6 r7 � s z MySQLCursorBufferedRaw.__init__r= c C s | j d uS rW r r? r5 r5 r6 r� � s z MySQLCursorBufferedRaw.with_rows)NN) rA rB rC rD r, r rH r7 rG r r� r$ r5 r5 r r6 r� � s �� r� c s| e Zd ZdZd eeee eee e f d�dd�Z eee e f d�� fdd� Z eeee e f 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 } N��rowdata�descr1 c C s |rt t| j|��S dS )zWConvert a MySQL text result row to Python types Returns a dictionary. N)r� r� Z column_names�r4 r) r* r5 r5 r6 �_row_to_python� s z MySQLCursorDict._row_to_pythonr= c � s | � t� �� I dH | j�S )zyReturn next row of a query result set. Returns: dict or None: A dict from query result set. N)r, r rX r� r? r r5 r6 rX � s zMySQLCursorDict.fetchonec � s � fdd�t � �� I dH 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 r5 �r, r� �ro r� r? r5 r6 rp � s �z,MySQLCursorDict.fetchall.<locals>.<listcomp>N)r r� r? r r? r6 r� � s �zMySQLCursorDict.fetchall)N)rA rB rC rD r( r r r! r r� r' r, rX r� r$ r5 r5 r r6 r� � s � � r� c @ sH e Zd ZdZeeeef d�dd�Ze eeeef d�dd�Z dS )r� z8 Buffered Cursor fetching rows as dictionaries. r= c � s, | � � | �� I dH }|r(| �|| j�S dS r )r� r� r, r� )r4 r� r5 r5 r6 rX � s z MySQLCursorBufferedDict.fetchonec � sZ | j du s| jdu r tt��g }| j| jd� D ]}|�| �|| j�� q0t| j�| _|S r# ) r� r r r� r r� r, r� r> )r4 r[ r� r5 r5 r6 r� s z MySQLCursorBufferedDict.fetchallN) rA rB rC rD r r r� r' rX r r� r5 r5 r5 r6 r� � s r� c sp e Zd ZdZd1eee ee d�� fdd� Zd2edd�dd �Z e dd �� fd d � Z edd �dd�Z e dd�� fdd� Zd3eeed�dd�Zed�d4eeee eeef f eeedf d�dd��Zdd �� fd d � Zd5eeed �d d!�Ze dd"�d#d$�Z d6e ee edd�d%d&�Z eee dd'�d(d)�Z!ee" d �d*d+�Z#d7ee e$e" d,�d-d.�Z%e$e" d �d/d0�Z&� Z'S )8�MySQLCursorPreparedz&Cursor using MySQL Prepared StatementsN)r r} r� c s> t � �|||� d | _d| _d | _d| _d | _d| _d| _d S )Nr TF) r r7 r r � _preparedr� � _have_result�_last_row_sent�_cursor_existsr r r5 r6 r7 s z MySQLCursorPrepared.__init__Tr c � sV | j rFz&| jj| j d | j| jd�I d H W n ty> Y n0 d | _ d| _d| _d S )N� statement_idr� F)r0 r] �cmd_stmt_closer� r� r r2 r3 r r5 r5 r6 r� # s � zMySQLCursorPrepared.resetr� c � s0 | � |�d|�dd��� t� �|�I d H d S �N� status_flag� server_statusr )�_handle_server_status�getr r� rZ r r5 r6 r� 2 s �z'MySQLCursorPrepared._handle_noresultset)�flagsr1 c C s$ |t j@ dk| _|t j@ dk| _d S r2 )r ZSTATUS_CURSOR_EXISTSr3 ZSTATUS_LAST_ROW_SENTr2 )r4 r; r5 r5 r6 r9 8 s z)MySQLCursorPrepared._handle_server_statusr� c � s0 | � |�d|�dd��� t� �|�I d H d S r6 )r9 r: r r� r� r r5 r6 r� < s �z MySQLCursorPrepared._handle_eofr5 r� c � s t � �dS )zQCalls a stored procedue Not supported with MySQLCursorPrepared. N�r )r4 r� r� r5 r5 r6 r� B s z MySQLCursorPrepared.callprocr� Fr� c � s t � �dS )z�Execute multiple statements. Executes the given operation substituting any markers with the given parameters. Nr< r� r5 r5 r6 r� I s z MySQLCursorPrepared.executemultir= c � s" | � � I dH t� �� I dH dS )zzClose the cursor This method will try to deallocate the prepared statement and close the cursor. N)r� r r` r? r r5 r6 r` Z s zMySQLCursorPrepared.closer( 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. Nr5 r+ r5 r5 r6 r, c s z"MySQLCursorPrepared._row_to_pythonr� c � s� t |t�r*d| j_d| _| �|�I dH nV|d | _d| j_d| _d|d v rb| �|d d � n d|d v r�| �|d d � dS )z Handle result after executionFNr+ Tr7 r r8 )rg r� r] r r1 r� r� r9 r� r5 r5 r6 r� i s z"MySQLCursorPrepared._handle_resultc � s� |r t d��| jst d��|s"dS | jj}|dkr6d}t|t�s�z|�|�}W n2 ty� } 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 �I dH || _z|�|�}W n4 t�yn } zt t|��|�W Y d}~n d}~0 0 |�d d �}d |v �r�t� td|�}z"| jj|| j| jd �I dH | _W n t�y� d| _� Y n0 | jj| jd | j| jd �I dH | jd �r � �s dS � �rft� t tf��sBt ddt � �j � d� � d�d��t | jd �t � �k�rft ddd��� du �rtd� | jj | jd � | jd | j| jd�I dH }| � |�I dH 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.r� NZutf8mb4�utf8c 3 s | ]}� | V qd S rW r5 )ro rQ �r0 r5 r6 r� � rq z.MySQLCursorPrepared.execute.<locals>.<genexpr>z6Not all placeholders were found in the parameters dict�?r4 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 statementr5 )�datarA r} r� )!r r] �charsetrg r� �decoder� r� rE �findallr rt r� rT r r� r0 r5 r� r� rh r� rS r Zcmd_stmt_preparer Zcmd_stmt_resetr� r� rA r> Zcmd_stmt_executer� )r4 r� r0 r� rE rl Zreplacement_keysr[ r5 r> r6 r� x s� � $ �� � $ �� ���� � zMySQLCursorPrepared.executer� c � s� |r|s dS | j �� I dH z t|�}W n. tyV } ztd�|�W Y d}~n d}~0 0 d}zF|D ]<}| �||�I dH | jr�| �� r�| �� I dH || j 7 }qbW n8 t tfy� } z t d|� ��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(). Nr� r r� ) r] r^ r� r� r r� r� r� r� r� rN r )r4 r� r� r� rl r r0 r5 r5 r6 r � s" &z MySQLCursorPrepared.executemanyc � sB | � � | jr0| jj| jd | j| jd�I dH | �� I dH p@dS )r! r4 r� N)r� r3 r] �cmd_stmt_fetchr0 r� r� r� r? r5 r5 r6 rX s � z MySQLCursorPrepared.fetchoner c � sP | � � g }|p| j}|dkrL| �� rL|d8 }| �� I dH }|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+ N)r� r r� r� r� r r5 r5 r6 r s z MySQLCursorPrepared.fetchmanyc � s� | � � g }| jd r&|�| jd � | �� r�| jrX| jj| jd t| j | j d�I dH | jj | j | j | j d�I dH \}}|�|� | �|�I dH q&t|�| _|S )r r r4 r� N)r{ r| r} )r� r� r� r� r3 r] rH r0 r r� r� r r� r� �extendr� r> r� )r4 r r� r� r5 r5 r6 r� 4 s* � � z MySQLCursorPrepared.fetchall)NN)T)r5 )r5 F)N)NF)N)(rA rB rC rD r, r rH r7 r r� r& r� r9 r" r� r r r� r r� r r r r r- r� r` r, r� r) r$ r� r% r r( rX r r r� r$ r5 r5 r r6 r/ sT ��� � � �� x� #r/ c s: e Zd ZdZdee eeee f d�� fdd� Z � Z 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) Nr c � s" � fdd�t � j|d�I dH 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 r5 r- r. r? r5 r6 rp p s �z5MySQLCursorPreparedDict.fetchmany.<locals>.<listcomp>)r N)r r )r4 r r r? r6 r c s �z!MySQLCursorPreparedDict.fetchmany)N) rA rB rC rD r rH r r r� r' r r$ r5 r5 r r6 rJ Q s ��rJ )CrD �__all__rE r� �decimalr �typingr r r r r r r r r r Z _decoratingr r Z _scriptingr � constantsr r� r r r r r r r r r r �errorsr r r r r �typesr! r" r# r$ r% r& r' r( r) r* Z abstractsr, r- r� r. r: rV r r� r% r� r� r� r/ rJ r5 r5 r5 r6 �<module> s> 0 0 0 0G+- B
| ver. 1.6 |
Github
|
.
| PHP 8.2.30 | ??????????? ?????????: 0 |
proxy
|
phpinfo
|
???????????