?????????? ????????? - ??????????????? - /home/agenciai/.local/lib/python3.9/site-packages/mysql/connector/__pycache__/cursor_cext.cpython-39.pyc
???????
a ��Jh � � @ s� d Z ddlmZ ddlZddlZddlmZmZmZm Z m Z m Z m Z m Z mZmZmZmZ ddlmZ ddlmZ ddlmZmZmZmZmZm Z m Z m Z m Z dd l m!Z! dd l"m#Z#m$Z$ dd l%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z. dd l/m0Z0m1Z1m2Z2m3Z3m4Z4 e�rdd l5m6Z6 dZ7G dd� d�Z8G dd� de$�Z9G dd� de9�Z:G dd� de9�Z;G dd� de:�Z<G dd� de9�Z=G dd � d e:�Z>G d d � d e9�Z?G d d � d e=e?�Z@dS )!z%Cursor classes using the C Extension.� )� annotationsN) � TYPE_CHECKING�Any�Dict� Generator�Iterator�List�NoReturn�Optional�Sequence�Tuple�Union�cast)�MySQLInterfaceError� )� deprecated) �CextEofPacketType�CextResultType�DescriptionType�ParamsSequenceOrDictType�ParamsSequenceType� RowItemType�RowType� StrOrBytesAny� WarningType)�split_multi_statement)�CMySQLPrepStmt�MySQLCursorAbstract) � 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�_bytestr_format_dict)�Error�InterfaceError�NotSupportedError�ProgrammingError�get_mysql_exception)�CMySQLConnectionzNo result set to fetch fromc @ 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/ � r3 �P/home/agenciai/.local/lib/python3.9/site-packages/mysql/connector/cursor_cext.py�__init__g s z_ParamSubstitutor.__init__�object�bytes)�matchobjr0 c C sB | j }| j d7 _ z | j| W S ty< td�d �Y n0 d S )Nr z+Not enough parameters for the SQL statement)r1 r/ � IndexErrorr* )r2 r8 r1 r3 r3 r4 �__call__k s ��z_ParamSubstitutor.__call__�int�r0 c C s t | j�| j S )z8Returns number of parameters remaining to be substituted)�lenr/ r1 �r2 r3 r3 r4 � remainingu s z_ParamSubstitutor.remainingN)�__name__� __module__� __qualname__�__doc__r5 r: �propertyr? r3 r3 r3 r4 r- b s r- c s e Zd ZdZddd�� fdd� Zd`ddd �� fd d � Zdadddd �dd�Zedd�dd��Zej ddd�dd��Zedd�dd��Z e j ddd�dd��Z dd�dd�Z d d�d d �Z dd�d d �Z d!dd"�d#d$�Zdd�d%d&�Zdd�d'd(�Zdbd*d+ddd,�d-d.�Zd*d/d0d1�d2d3�Zd*d/dd1�d4d5�Zed6d�d7d8��Zedd�d9d:��Zdd�d;d<�Zdcd*d=d>d?�d@dA�ZdBd�dCdD�ZdEd�dFdG�ZddddEdI�dJdK�ZdLd�dMdN�ZdOd�dPdQ�Z e dR�dSd�dTdU��Z dVd�dWdX�Z edYd�dZd[��Z edd�d\d]��Z!d*d�d^d_�Z"� Z#S )e� CMySQLCursorz;Default cursor for interacting with MySQL using C Extensionr, r. �� connectionr0 c s0 t � �|� d| _d| _d| _td| j�| _dS )� Initialize���Fr, N)�superr5 �_affected_rows�_raw_as_string� _bufferedr � _connection�r2 rG �� __class__r3 r4 r5 ~ s zCMySQLCursor.__init__T�bool��freer0 c sX d| _ d | _d| _d| _d| _d | _d | _d| _d | _|rJ| jrJ| j�� t � � � d S )NrI r ) � _rowcount�_nextrowrK �_last_insert_id�_warning_count� _warnings� _descriptionrN � free_resultrJ �reset�r2 rT rP r3 r4 r\ � s zCMySQLCursor.resetF)rT �preserve_last_executed_stmtr0 c C s2 |s"d| _ g | _d| _d| _d| _| j|d� dS )a� Resets the cursor to default. This method is similar to `reset()`. Unlike `reset()`, this hidden method allows to customize the reset. Args: free: If `True`, the result will be freed. preserve_last_executed_stmt: If `False`, the last executed statement value is reset. Otherwise, such a value is preserved. NF�rT )� _executed�_executed_list�_stmt_partitions�_stmt_partition�_stmt_map_resultsr\ )r2 rT r^ r3 r3 r4 � _reset_result� s zCMySQLCursor._reset_resultzOptional[float]r< c C s t d��d S )Nz� The use of read_timeout after the connection has been established is unsupported in the C-Extension �r* r> r3 r3 r4 � read_timeout� s �zCMySQLCursor.read_timeoutr; )�timeoutr0 c C s t d��d S )Nz� Changes in read_timeout after the connection has been established is unsupported in the C-Extension rf �r2 rh r3 r3 r4 rg � s �c C s t d��d S )Nz� The use of write_timeout after the connection has been established is unsupported in the C-Extension rf r> r3 r3 r4 � write_timeout� s �zCMySQLCursor.write_timeoutc C s t d��d S )Nz� Changes in write_timeout after the connection has been established is unsupported in the C-Extension rf ri r3 r3 r4 rj � s �c C s | j du rtt��dS )zsCheck if the statement has been executed. Raises an error if the statement has not been executed. N)r` r( �ERR_NO_RESULT_TO_FETCHr> r3 r3 r4 �_check_executed� s z CMySQLCursor._check_executedzOptional[List[WarningType]]c C s� g }z8| j �� | j �d�}| j j| jd�d }| j �� W n� ty� } z:t|d�rlt|j|j |j d�|�t t |��|�W Y d}~n<d}~0 t y� } z t d|� ��d�W Y d}~n d}~0 0 |r�|S dS )a Fetch 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 Error (or subclass) on errors. Returns list of tuples or None. z SHOW WARNINGS��rawr �errno��msg�sqlstateNzFailed getting warnings; )rN Zconsume_results� cmd_query�get_rows�_rawr �hasattrr+ ro rq rr r( �str� Exception)r2 Zwarns�_�errr3 r3 r4 �_fetch_warnings� s& ��"&z CMySQLCursor._fetch_warningsc C sf | j jr| jr| �� | _| js"dS t| jd dd� d| j j i�}| j jrP|�tjt |�dd� dS )z�Handle possible warnings after all results are consumed. Raises: Error: Also raises exceptions if raise_on_warnings is set. Nr r � �warning� )� stacklevel) rN Z get_warningsrX r{ rY r+ Zraise_on_warnings�warnings�warnrw �r2 rz r3 r3 r4 �_handle_warnings� s ��z CMySQLCursor._handle_warningsz(Union[CextEofPacketType, CextResultType])�resultr0 c C sR d|v r"|d | _ d| _| �� n,|d | _|d | _|d | _d| _| �� dS )z,Handles the result after statement execution�columnsr Z insert_id� warning_countZ affected_rowsrI N)rZ rU �_handle_resultsetrW rX rK r� �r2 r� r3 r3 r4 �_handle_result s zCMySQLCursor._handle_resultc C s dS )�Handle a result setNr3 r> r3 r3 r4 r� s z CMySQLCursor._handle_resultsetc C s( | j j| _| �� | j js$| j �� dS )zMHandle end of reading the result Raises an Error on errors. N)rN r� rX r� � more_resultsr[ r> r3 r3 r4 � _handle_eof" s zCMySQLCursor._handle_eofr3 rw r �� operationr/ � map_resultsr0 c C s |sd S z| j r| j �� r t�W n4 ttfyT } ztdd�|�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,| j �|�}t|t�r�t||�}n8t|ttf��r,t|�}t�||�}|jdk�r,td��|�dd�}t||d�| _t| j�| _|| _ | jd | _ |�rx| jd � � n| jd | _ z*| � | j j!| jd | j"| j#| j$d �� W nV t%�y } z<t&|d ��r�t'|j(|j)|j*d �|�t+t|��|�W Y d }~n d }~0 0 d S )N�Cursor is not connected� � r �1Not all parameters were used in the SQL statements %%s� %s)Zsql_coder� � single_stmts� mappable_stmt�rn Zbuffered� raw_as_stringro rp ),rN � is_closedr* �ReferenceError�handle_unread_resultr\ � isinstancerw �encode�python_charsetr r7 �UnicodeDecodeError�UnicodeEncodeError�prepare_for_mysql�dictr& �list�tupler- r �subr? �replacer rb �nextrc rd ra �popleftr` r� rs ru rM rL r rv r+ ro rq rr r( )r2 r� r/ r� rz �stmt�prepared�psubr3 r3 r4 �execute, sp " $ � � ���� ��$zCMySQLCursor.executez"Sequence[ParamsSequenceOrDictType]zOptional[bytes]�r� � seq_paramsr0 c C s| ddd�dd�}t �tdt �t||��}t �t|�}|s@td��|�d��| j j �}g }z�|�| j j �}|D ]n} |}| j � | �} t | t �r�ttt|�| �}n4t | ttf�r�t| �} t�| |�}| jd kr�td ��|�|� ql||v �r|�|d �|�d�}|| _|W S W d S tt f�yB } ztt | ��| �W Y d } ~ n>d } ~ 0 t �yv } z td | � ��d �W Y d } ~ n d } ~ 0 0 d S )zImplements multi row insertzre.Matchrw )�matchr0 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� r3 r3 r4 �remove_commentsz s z3CMySQLCursor._batch_insert.<locals>.remove_commentsr� zAFailed rewriting statement for multi-row INSERT. Check SQL syntaxr r r� � ,N� Failed executing the operation; ) �rer� r# r �searchr" r( r� r� rN r� r� r� r� r& r r7 r� r� r- r r? r* �appendr� �joinr` r� r� rw rx ) r2 r� r� r� �tmp�matches�fmt�valuesr� r/ r� r� rz r3 r3 r4 � _batch_inserts sJ � � � "zCMySQLCursor._batch_insertc C sB |r|s dS z| j st�W n2 ttfyL } ztd�|�W Y d}~n d}~0 0 | j �� t|ttf�sntd��t�t |�r�|s�d| _ dS | � ||�}|dur�|| _ | � tt|��S d}zF|D ]<}| � ||� | jr�| j jr�| �� || jr�| j n| j7 }q�W n: ttf�y6 } 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. Nr� z+Parameters for query must be list or tuple.r r� )rN r* r� r� r� r� r� r� r� r! rU r� r` r� r rw � with_rows� unread_result�fetchall� descriptionrK � ValueError� TypeErrorr( )r2 r� r� rz r� �rowcntr/ r3 r3 r4 � executemany� s: &zCMySQLCursor.executemanyz Optional[List[DescriptionType]]c C s | j S )z*Returns description of columns in a result)rZ r> r3 r3 r4 r� � s zCMySQLCursor.descriptionc C s | j dkr| jS | j S )z/Returns the number of rows produced or affectedrI )rU rK r> r3 r3 r4 �rowcount� s zCMySQLCursor.rowcountc C s$ | j s dS | j �� d| _d| _ dS )z<Close the cursor The result will be freed. FNT)rN r� rY r> r3 r3 r4 �close� s zCMySQLCursor.closer z0Optional[Union[Dict[str, RowItemType], RowType]]��procname�argsr0 c C sV |rt |t�std��t |ttf�s,td��d}g | _�z�g }g }|�d�d }|r�g }t|�D ]n\}} |j||d d�} |� | � t | t�r�|� d| � d | d � d �� |� | d � q`|� | � |� | � q`d � d d� |D ��} | � d| � �|� d|� dd � |�� d �} | j j | | j| jd�} g }| j j�r�| j �� } t | ttf��rRt}n| j�r`t}nt}|| j �� �}d| � d �|_|�| � |� |� | j �� �q(|| _| �� |�r | �� dd� t |dd� |D ��D �}dd � |�� �}| � |� | � � W S t� W S t �y � Y n6 t �yP } z t d|� ��d�W Y d}~n d}~0 0 dS )z1Calls a stored procedure with the given argumentszprocname must be a stringzargs must be a sequencez@_{name}_arg{index}�.rI r )�namer1 z CAST(� AS �)r �,c s s | ]}|� d �V qdS )z=%sNr3 ��.0�argr3 r3 r4 � <genexpr>, r� z(CMySQLCursor.callproc.<locals>.<genexpr>zSET zCALL �()rn r� z (a result of c S s g | ]\}}|� d |� ��qS )r� r3 )r� r� �aliasr3 r3 r4 � <listcomp>K s �z)CMySQLCursor.callproc.<locals>.<listcomp>c S s g | ]}|� d ��qS )z@_)�lstripr� r3 r3 r4 r� N r� zSELECT z Failed calling stored routine; N)!r� rw r� r� r� �_stored_results�split� enumerate�formatr� r� r� rN rs ru rL �result_set_available�fetch_eof_columns�CMySQLCursorDict�CMySQLCursorBufferedDict�CMySQLCursorBufferedRaw�CMySQLCursorBufferedZget_selfr` r� � next_resultr� r\ �zip�fetchoner' rx r( )r2 r� r� Zargfmt�argnames�argtypesZ procname_absZ argvalues�idxr� �argnameZ placeholders�callr� �resultsZ cursor_class�cur�selectrz r3 r3 r4 �callproc sp � �� zCMySQLCursor.callproczOptional[bool]c C sR | j �� r|| jddd� | j js2| �| j �� � n| �| j �� � | jd urx| jrx| j d sht � d� n| j d � � | _ dS | jd u�rBzt| j�| _ W n ty� Y n�0 | j d � � | _ z*| �| j j| j d | j| j| jd�� W nV t�y< } z<t|d��rt|j|j|jd �|�tt|��|�W Y d }~n d }~0 0 dS | jdd � d S ) NFT)rT r^ r� zOMappingWarning: Number of result sets greater than number of single statements.r� r� ro rp r_ ) rN r� re r� r� Zfetch_eof_statusr� rb rd rc r� r� r� r` r� � StopIterationrs ru rM rL r rv r+ ro rq rr r( rw r� r3 r3 r4 �nextset\ sL � �� ��$ zCMySQLCursor.nextset� List[RowType]c C s� | � � | jjsg S | jj| jd�}| jrJ| jd rJ|d �d| jd � |d s^| �� g S | jt |d �7 _| �� |d S )��Return all rows of a query result set. Returns: list: A list of tuples with all rows of a query result set. rm r ) rl rN r� rt ru rV �insertr� rU r= �r2 �rowsr3 r3 r4 r� � s zCMySQLCursor.fetchallr ��sizer0 c C s� | � � | jr.| jd r.| jd g}|d8 }ng }|rZ| jjrZ|�| jj|| jd�d � |r�| jjr�| j�� | _| jr�| jd s�| jjs�| j� � nd| _|s�| � � g S | j t |�7 _ |S )�< 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 rm �NN) rl rV rN r� �extendrt ru �get_rowr� r[ r� rU r= )r2 r� r� r3 r3 r4 � fetchmany� s. ��� zCMySQLCursor.fetchmany�Optional[RowType]c C s| | � � | j}|s$| jjr$| j�� }|rZ|d rZ| j�� | _| jd sf| jjsf| j�� n | �� dS | jd7 _|d S )�yReturn next row of a query result set. Returns: tuple or None: A row from query result set. r Nr ) rl rV rN r� r� r� r[ r� rU �r2 �rowr3 r3 r4 r� � s zCMySQLCursor.fetchonezIterator[RowType]c C s t | jd�S )z�Iteration over the result set Iteration over the result set which calls self.fetchone() and returns the next row. N)�iterr� r> r3 r3 r4 �__iter__� s zCMySQLCursor.__iter__zmThe property counterpart 'stored_results' will be added in a future release, and this method will be removed.z#Generator[CMySQLCursor, None, None]c c s | j D ] }|V qg | _ dS )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. N)r� r� r3 r3 r4 �stored_results� s zCMySQLCursor.stored_resultsr c C s4 z | � � }W n ty$ td�Y n0 |s0td�|S )z�Iteration 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. N)r� r( r� r� r3 r3 r4 �__next__ s zCMySQLCursor.__next__zTuple[str, ...]c C s | j s dS tdd� | j D ��S )ztReturns column names This property returns the columns names as a tuple. Returns a tuple. r3 c s s | ]}|d V qdS )r Nr3 )r� �dr3 r3 r4 r� r� z,CMySQLCursor.column_names.<locals>.<genexpr>)r� r� r> r3 r3 r4 � column_names s zCMySQLCursor.column_namesc C s | j r 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. TF)r� r> r3 r3 r4 r� s zCMySQLCursor.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_namer� )r` �decode�AttributeErrorr= r� rQ r@ )r2 r� Zexecutedr3 r3 r4 �__str__- s zCMySQLCursor.__str__)T)TF)r3 F)r3 )r )$r@ rA rB rC r5 r\ re rD rg �setterrj rl r{ r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r r r� r � __classcell__r3 r3 rP r4 rE { s\ �! �G:C �S='� rE c s� e Zd ZdZdd�� fdd� Zdd�dd �Zd d dd �� fd d� Zdd�dd�Zdd�dd�Zd ddd�dd�Z dd�dd�Z e d d�d d ��Z � Z S ) r� z*Cursor using C Extension buffering resultsr, �rG c s t � �|� d| _d| _dS )rH Nr )rJ r5 �_rows� _next_rowrO rP r3 r4 r5 ? s z CMySQLCursorBuffered.__init__r. r< c C s4 | j j| jd�d | _d| _t| j�| _| �� dS )r� rm r N)rN rt ru r r r= rU r� r> r3 r3 r4 r� I s z&CMySQLCursorBuffered._handle_resultsetTrR rS c s d | _ d| _t� j|d� d S )Nr r_ )r r rJ r\ r] rP r3 r4 r\ P s zCMySQLCursorBuffered.resetr� c C s< d}z| j | j }W n ty( Y dS 0 | jd7 _|S )�QReturns the next row in the result set Returns a tuple or None. Nr )r r r9 r� r3 r3 r4 � _fetch_rowU s z CMySQLCursorBuffered._fetch_rowr� c C s6 | � � | jdu rg S | j| jd� }t| j�| _|S )r� N)rl r r r= �r2 �resr3 r3 r4 r� b s z CMySQLCursorBuffered.fetchallr r; r� c C sF | � � g }|p| j}|dkrB|d8 }| �� }|rB|�|� qqBq|S �r� r r )rl � arraysizer r� �r2 r� r Zcntr r3 r3 r4 r� o s z CMySQLCursorBuffered.fetchmanyc C s | � � | �� S )r� �rl r r> r3 r3 r4 r� � s z CMySQLCursorBuffered.fetchonec C s | j duS )z�Returns whether the cursor could have rows returned This property returns True when rows are available, which will need to be fetched. Returns True or False. N)r r> r3 r3 r4 r� � s z CMySQLCursorBuffered.with_rows)T)r )r@ rA rB rC r5 r� r\ r r� r� r� rD r� r r3 r3 rP r4 r� < s r� c s( e Zd ZdZddd�� fdd� Z� ZS )�CMySQLCursorRawz+Cursor using C Extension return raw resultsr, r. rF c s t � �|� d| _d S �NT�rJ r5 ru rO rP r3 r4 r5 � s zCMySQLCursorRaw.__init__�r@ rA rB rC r5 r r3 r3 rP r4 r � s r c s& e Zd ZdZdd�� fdd� Z� ZS )r� z.Cursor using C Extension buffering raw resultsr, r c s t � �|� d| _d S r r rO rP r3 r4 r5 � s z CMySQLCursorBufferedRaw.__init__r r3 r3 rP r4 r� � s r� c sN e Zd ZdZdd�� fdd� Zdddd �� fd d � Zdd�� fd d � Z� ZS )r� z7Cursor using C Extension returning rows as dictionaries� Optional[Dict[str, RowItemType]]r< c s" t � �� }|r tt| j|��S dS )zyReturn next row of a query result set. Returns: dict or None: A dict from query result set. N)rJ r� r� r� r r� rP r3 r4 r� � s zCMySQLCursorDict.fetchoner r; � List[Dict[str, RowItemType]]r� c s t � j|d�}� fdd�|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. )r� c s g | ]}t t� j|���qS r3 �r� r� r �r� r r> r3 r4 r� � r� z.CMySQLCursorDict.fetchmany.<locals>.<listcomp>)rJ r� )r2 r� r rP r> r4 r� � s zCMySQLCursorDict.fetchmanyc s t � �� }� fdd�|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 | ]}t t� j|���qS r3 r r r> r3 r4 r� � r� z-CMySQLCursorDict.fetchall.<locals>.<listcomp>�rJ r� r rP r> r4 r� � s zCMySQLCursorDict.fetchall)r )r@ rA rB rC r� r� r� r r3 r3 rP r4 r� � s r� c s8 e Zd ZdZdd�� fdd� Zdd�� fdd� Z� ZS ) r� zECursor using C Extension buffering and returning rows as dictionariesr r< c s" t � �� }|r tt| j|��S d S �N)rJ r r� r� r r� rP r3 r4 r � s z#CMySQLCursorBufferedDict._fetch_rowr c s t � �� }� fdd�|D �S )r� c s g | ]}t t� j|���qS r3 r r r> r3 r4 r� � r� z5CMySQLCursorBufferedDict.fetchall.<locals>.<listcomp>r! r rP r> r4 r� � s z!CMySQLCursorBufferedDict.fetchall)r@ rA rB rC r r� r r3 r3 rP r4 r� � s r� c s� e Zd ZdZdd�� fdd� Zdd�dd �Zd/d d d �dd�Zd0dddd�dd�Zdd�� fdd� Zd1d dd�� fdd� Z d2d d d dd �d d �Z d!d"dd#�d$d%�Z d d�d&d'�Z d3d(d)d*�d+d,�Z d)d�d-d.�Z� ZS )4�CMySQLCursorPreparedz&Cursor using MySQL Prepared Statementsr, r c s. t � �|� d | _d| _d| _d| _d | _d S )Nr T)rJ r5 r rU r �_binary�_stmtrO rP r3 r4 r5 � s z CMySQLCursorPrepared.__init__r. r< c C s d| _ | �� dS )zHandle EOF packetr� N)rV r� r> r3 r3 r4 r� � s z CMySQLCursorPrepared._handle_eofFrR r� )rn r0 c C s� | j r| j jsdS d}| jdkr@| jj| j| j|| j d�\}}n | j\}}|r�| jj| j| j|| j d�| _| jd }|dur�|d | _| �� | j dkr�d| _ n| j d7 _ |r�|d | _| �� |S )r Nr� )�binaryr� rn � prep_stmtr r� rI ) r% �have_result_setrV rN r� r$ r� rX r� rU )r2 rn r �eofr3 r3 r4 r � s: � � z CMySQLCursorPrepared._fetch_rowNr r r� c C s t � �dS )zRCalls a stored procedue Not supported with CMySQLCursorPrepared. N)r) )r2 r� r� r3 r3 r4 r� # s z CMySQLCursorPrepared.callprocc s0 | j r"| �� | j�| j � d| _ t� �� dS )zzClose the cursor This method will try to deallocate the prepared statement and close the cursor. N)r% r\ rN �cmd_stmt_closerJ r� r> rP r3 r4 r� * s zCMySQLCursorPrepared.closeTrS c s& | j r| j�| j � t� j|d� dS )aF Resets the prepared statement. Args: free: If `True`, the result will be freed. preserve_last_executed_stmt: If `False`, the last executed statement value is reset. Otherwise, such a value is preserved. r_ N)r% rN �cmd_stmt_resetrJ r\ r] rP r3 r4 r\ 6 s zCMySQLCursorPrepared.resetr z"Optional[ParamsSequenceOrDictType]r� c s� |r t d��|sdS z| jr&| j�� r*t �W n4 t tfy` } zt dd�|�W Y d}~n d}~0 0 | jjdd� | jj}|dkr�d}t|t�s�z|�|�}W n2 t y� } zt t|��|�W Y d}~n d}~0 0 |� d d �}t� t ��rNt � t|�}zt� fd d �|D ��� W n0 t�y> } zt d �|�W Y d}~n d}~0 0 t �td|�}|| ju�r| j�rp| j�| j� || _z|�|�}W n4 t�y� } zt t|��|�W Y d}~n d}~0 0 d|v �r�t �td|�}z| j�|�| _W n" t�y d| _d| _� Y n0 | j�| j� | jj dk�r.� �s.dS � �r�t� tt f��sdt ddt � �j � d� � d�d��| jj t � �k�r�t ddd��� du �r�d� | jj!| jg� �R � }|�r�| �"|� dS )a) Prepare and execute a MySQL Prepared Statement This method will prepare the given operation and execute it using the given parameters. If the cursor instance already had a prepared statement, it is first closed. Note: argument "multi" is unused. z@Multi statement execution not supported for prepared statements.Nr� r� T)r� Zutf8mb4�utf8z%%sz%sc 3 s | ]}� | V qd S r" r3 )r� �key�r/ r3 r4 r� s r� z/CMySQLCursorPrepared.execute.<locals>.<genexpr>z6Not all placeholders were found in the parameters dict�?r� � ?r i� z Incorrect type of argument: r� zP), it must be of type tuple or list the argument given to the prepared statement)ro rq z:Incorrect number of arguments executing prepared statementr3 )#r* rN r� r� r� �charsetr� rw r r� r� r� r� �findallr$ r� �KeyErrorr� r% r` r% r* r� r� r Zcmd_stmt_preparer' r+ Z param_countr� �typer@ r= Zcmd_stmt_executer� )r2 r� r/ r� rz r1 Zreplacement_keysr r3 r. r4 r� C s� �" $ �� $ �� z CMySQLCursorPrepared.executerw z Sequence[ParamsSequenceType]r� c C sz d}z2|D ](}| � ||� | jr(| �� || j7 }q W n8 ttfyn } z td|� ��|�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. r r� N)r� r� r� rU r� r� r( )r2 r� r� r� r/ rz r3 r3 r4 r� � s &z CMySQLCursorPrepared.executemanyc C s | � � | �� pdS )r� Nr r> r3 r3 r4 r� � s z CMySQLCursorPrepared.fetchonez Optional[int]r� r� c C sJ | � � g }|p| j}|dkrF| jjrF|d8 }| �� }|r|�|� q|S r )rl r r% r( r r� r r3 r3 r4 r� � s z CMySQLCursorPrepared.fetchmanyc C s� | � � | jjsg S | jj| jd�}| jrJ| jd rJ|d �d| jd � |d s^| �� g S | jt |d �7 _| �� |d S )r� )r' r ) rl r% r( rN rt rV r� r� rU r= r� r3 r3 r4 r� � s z CMySQLCursorPrepared.fetchall)F)N)T)NF)N)r@ rA rB rC r5 r� r r� r� r\ r� r� r� r� r� r r3 r3 rP r4 r# � s ( �e r# c @ s e Zd ZdZdS )�CMySQLCursorPreparedDicta� This class is a blend of features from CMySQLCursorDict and CMySQLCursorPrepared 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. CMySQLCursorPreparedDict (current class) 2. CMySQLCursorDict (left parent class) 3. CMySQLCursorPrepared (right parent class) 4. CMySQLCursor (base class) N)r@ rA rB rC r3 r3 r3 r4 r5 � s r5 )ArC � __future__r r� r� �typingr r r r r r r r r r r r Z_mysql_connectorr Z _decoratingr �typesr r r r r r r r r Z _scriptingr Z abstractsr r �cursorr r r r! r" r# r$ r% r& �errorsr' r( r) r* r+ Zconnection_cextr, rk r- rE r� r r� r� r� r# r5 r3 r3 r3 r4 �<module> s< 8 , , F^ %
| ver. 1.6 |
Github
|
.
| PHP 8.2.30 | ??????????? ?????????: 0 |
proxy
|
phpinfo
|
???????????