U
|
£ý°d> ã @ sÒ d Z ddlZddlmZ e d dddg¡ejejB ¡ZG d d
|
d
|
Z G d d d Z
|
G d d dZ G dd dZ G dd dZ G dd de
|
e e ZG dd de
|
e e ZG dd de e e ZG dd de e e ZdS )zyMySQLdb Cursors
|
|
This module implements Cursors of various types for MySQLdb. By
|
default, MySQLdb uses the Cursor class.
|
é Né )ÚProgrammingErrorÚ z'\s*((?:INSERT|REPLACE)\b.+\bVALUES?\s*)z6(\(\s*(?:%s|%\(.+\)s)\s*(?:,\s*(?:%s|%\(.+\)s)\s*)*\))z (\s*(?:ON DUPLICATE.*)?);?\s*\Zc @ s e Zd ZdZdZddlmZmZmZm Z m
|
Z
|
m Z m Z m Z mZmZmZ dZdd Zdd Zd
|
d Zd d Zdd Zdd Zdd Zdd Zdd Zdd Zdd Z d d Z d-d d Z d d! Z d"d# Z d.d%d&Z!d'd( Z"d/d)d*Z#d+d, Z$eZeZe Z e
|
Z
|
e Z e Z e Z eZeZeZdS )0Ú
|
BaseCursora A base for Cursor classes. Useful attributes:
|
|
description
|
A tuple of DB API 7-tuples describing the columns in
|
the last executed query; see PEP-249 for details.
|
|
description_flags
|
Tuple of column flags for last query, one entry per column
|
in the result set. Values correspond to those in
|
MySQLdb.constants.FLAG. See MySQL documentation (C API)
|
for more information. Non-standard extension.
|
|
arraysize
|
default number of rows fetchmany() will fetch
|
i r ) Ú
|
MySQLErrorÚWarningÚErrorÚInterfaceErrorÚ DatabaseErrorÚ DataErrorÚOperationalErrorÚIntegrityErrorÚ InternalErrorr ÚNotSupportedErrorNc C s@ || _ d | _d | _d| _d| _d | _d | _d | _d | _d | _ d S )Néÿÿÿÿr )
|
Ú
|
connectionÚ descriptionÚdescription_flagsÚrowcountÚ arraysizeÚ _executedÚ lastrowidÚ_resultÚ rownumberÚ_rows)Úselfr © r úFd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\MySQLdb/cursors.pyÚ__init__A s zBaseCursor.__init__c C s4 z | j dkrW ¢dS | ¡ r qW 5 d| _ d| _X dS )z6Close the cursor. No further queries will be possible.N)r r Únextset©r r r r ÚcloseN s
|
zBaseCursor.closec C s | S ©Nr r r r r Ú __enter__Y s zBaseCursor.__enter__c G s ~| ¡ d S r" )r! )r Úexc_infor r r Ú__exit__\ s zBaseCursor.__exit__c sz |j |j fddt|ttfrBtfdd|D }n0t|trffdd| ¡ D }n |}d |S )Nc sH t | tr| ¡S t | tr,tt| S t | trDtt| S | S r" )Ú
|
isinstanceÚstrÚencodeÚtupleÚmapÚlist)Úx)ÚencodingÚ ensure_bytesr r r. d s
|
|
|
|
z-BaseCursor._escape_args.<locals>.ensure_bytesc 3 s | ]} |V qd S r" r ©Ú.0Úarg©r. Úliteralr r Ú <genexpr>n s z*BaseCursor._escape_args.<locals>.<genexpr>c s" i | ]\}} | |qS r r )r0 ÚkeyÚvalr2 r r Ú
|
<dictcomp>p s ÿ z+BaseCursor._escape_args.<locals>.<dictcomp>)r- r3 r& r) r+ ÚdictÚitems)r ÚargsÚconnÚretr )r- r. r3 r Ú _escape_args` s
|
þ zBaseCursor._escape_argsc C s | j stdd S )Nzexecute() first)r r r r r r Ú_check_executed| s zBaseCursor._check_executedc C s@ | j r| ¡ | ¡ }| ¡ }|dkr*dS | |¡ | ¡ dS )z`Advance to the next result set.
|
|
Returns None if there are no more result sets.
|
r Nr )r ÚfetchallÚ_get_dbZ next_resultÚ_do_get_resultÚ_post_get_result)r ÚdbÚnrr r r r s
|
zBaseCursor.nextsetc C sV | ¡ | _}|d kr$d | _| _n| ¡ | _| ¡ | _| ¡ | _d| _| ¡ | _
|
d S ©Nr ) Ú _get_resultr r r ZdescribeZ field_flagsZ affected_rowsr r Z insert_idr )r rC Úresultr r r rA s
|
|
|
zBaseCursor._do_get_resultc C s d S r" r r r r r rB s zBaseCursor._post_get_resultc G s dS ©z!Does nothing, required by DB API.Nr ©r r: r r r Ú setinputsizes s zBaseCursor.setinputsizesc G s dS rH r rI r r r Úsetoutputsizes¢ s zBaseCursor.setoutputsizesc C s | j }|d krtd|S )Nz cursor closed)r r )r Úconr r r r@ ¥ s zBaseCursor._get_dbc
|
C sæ | ¡ r
|
q | ¡ }t|tr(| |j¡}|dk rÆt|trzi }| ¡ D ],\}}t|trd| |j¡}| |¡||< qF|}nt t
|
|j|}z || }W n. t k
|
rÄ } zt t|W 5 d}~X Y nX t|t tfsØt| |¡}|S )a Execute a query.
|
|
query -- string, query to execute on server
|
args -- optional sequence or mapping, parameters to use with query.
|
|
Note: If args is a sequence, then %s must be used as the
|
parameter placeholder in the query. If a mapping is used,
|
%(key)s must be used as the placeholder.
|
|
Returns integer represents rows affected, if any
|
N)r r@ r& r' r( r- r8 r9 r3 r) r* Ú TypeErrorr ÚbytesÚ bytearrayÚAssertionErrorÚ_query) r Úqueryr: rC Únargsr5 ÚitemÚmÚresr r r Úexecute« s*
|
|
|
|
zBaseCursor.executec s |sdS t ¡}|rx| d¡d }| d¡ ¡ }| d¡p>d}|d dkrX|d d
|
ks\t ||||j ¡ j¡S t fd d |D _
|
j
|
S ) ax Execute a multi-row query.
|
|
:param query: query to execute on server
|
:param args: Sequence of sequences or mappings. It is used as parameter.
|
:return: Number of rows affected, if any.
|
|
This method improves performance on multiple-row INSERT and
|
REPLACE. Otherwise it is equivalent to looping over args with
|
execute().
|
Nr r é é r r ú(r ú)c 3 s | ]} |¡V qd S r" )rW r/ ©rR r r r r4 ï s z)BaseCursor.executemany.<locals>.<genexpr>) ÚRE_INSERT_VALUESÚmatchÚgroupÚrstriprP Ú_do_execute_manyÚmax_stmt_lengthr@ r- Úsumr )r rR r: rU Zq_prefixZq_valuesZ q_postfixr r\ r Ú executemanyÑ s$
|
ú zBaseCursor.executemanyc C sø | ¡ }| j}t|tr"| |¡}t|tr6| |¡}t|trJ| |¡}t|} t|}||t|| }
|
| |
|
7 } d} |D ]^} ||| | }
|
t| t|
|
t| d |krÊ| | | | ¡7 } t|} n| d7 } | |
|
7 } q|| | | | ¡7 } | | _
|
| S )Nr r ó ,) r@ r= r& r' r( rO ÚiterÚnextÚlenrW r ) r ÚprefixÚvaluesZpostfixr: rb r- r; ÚescapeZsqlÚvÚrowsr1 r r r ra ò s.
|
|
|
|
|
|
|
|
zBaseCursor._do_execute_manyr c s | ¡ ttr j¡|rbd d dd fddt|D ¡ }| |¡ | ¡ dd fdd t t
|
|D ¡f }| |¡ |S )
|
a Execute stored procedure procname with args
|
|
procname -- string, name of procedure to execute on server
|
|
args -- Sequence of parameters to use with procedure
|
|
Returns the original args.
|
|
Compatibility warning: PEP-249 specifies that any modified
|
parameters must be returned. This is currently impossible
|
as they are only available by storing them in a server
|
variable and then retrieved by a query. Since stored
|
procedures return zero or more result sets, there is no
|
reliable way to get at OUT or INOUT parameters via callproc.
|
The server variables are named @_procname_n, where procname
|
is the parameter above and n is the position of the parameter
|
(from zero). Once all result sets generated by the procedure
|
have been fetched, you can issue a SELECT @_procname_0, ...
|
query using .execute() to get any OUT or INOUT values.
|
|
Compatibility warning: The act of calling a stored procedure
|
itself creates an empty result set. This appears after any
|
result sets generated by the procedure. This is non-standard
|
behavior with respect to the DB-API. Be sure to use nextset()
|
to advance through all result sets; otherwise you may get
|
disconnected.
|
s @_s _%d=%ss SET %sre c 3 s$ | ] \}}| |¡f V qd S r" )r3 )r0 Úindexr1 )rC Úfmtr r r4 / s z&BaseCursor.callproc.<locals>.<genexpr>s CALL %s(%s)c s g | ]}d |f qS )s @_%s_%dr )r0 Úi)Úprocnamer r Ú
|
<listcomp>7 s z'BaseCursor.callproc.<locals>.<listcomp>) r@ r& r' r( r- ÚjoinÚ enumeraterQ r Úrangerh )r rq r: Úqr )rC ro rq r Úcallproc s
|
ÿ
|
|
þ
|
zBaseCursor.callprocc C s6 | ¡ }d | _| |¡ | |¡ | ¡ || _| jS r" )r@ r rR rA rB r r )r rv rC r r r rQ < s
|
|
zBaseCursor._queryc C s | j s
|
dS | j || j¡S )Nr )r Z fetch_rowÚ _fetch_type)r Úsizer r r Ú
|
_fetch_rowE s zBaseCursor._fetch_rowc C s t | jd S r" )rf Úfetchoner r r r Ú__iter__J s zBaseCursor.__iter__)N)r )r )%Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__rb Ú _exceptionsr r r r r
|
r r r r r r r r r! r# r% r= r> r rA rB rJ rK r@ rW rd ra rw rQ rz r| r r r r r sB 4
|
&!
|
.
|
r c @ sL e Zd ZdZdd Zdd Zdd Zdd d
|
Zd d ZdddZ dd Z
|
dS )ÚCursorStoreResultMixIna This is a MixIn class which causes the entire result set to be
|
stored on the client side, i.e. it uses mysql_store_result(). If the
|
result set can be very large, consider adding a LIMIT clause to your
|
query, or using CursorUseResultMixIn instead.c C s | ¡ ¡ S r" )r@ Z store_resultr r r r rF _ s z"CursorStoreResultMixIn._get_resultc C s | d¡| _d | _d S rE )rz r r r r r r rB b s z'CursorStoreResultMixIn._post_get_resultc C s8 | ¡ | jt| jkr dS | j| j }| jd | _|S )z]Fetches a single row from the cursor. None indicates that
|
no more rows are available.Nr )r> r rh r ©r rG r r r r{ f s z CursorStoreResultMixIn.fetchoneNc C s> | ¡ | j|p| j }| j| j|
}t|t| j| _|S ©z
Fetch up to size rows from the cursor. Result set may be smaller
|
than size. If size is not defined, cursor.arraysize is used.)r> r r r Úminrh )r ry ÚendrG r r r Ú fetchmanyp s
|
z CursorStoreResultMixIn.fetchmanyc C s6 | ¡ | jr | j| jd
}n| j}t| j| _|S )ú+Fetches all available rows from the cursor.N)r> r r rh r r r r r? y s z CursorStoreResultMixIn.fetchallÚrelativec C sb | ¡ |dkr | j| }n |dkr*|}ntdt| |dk sP|t| jkrXtd|| _dS )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.r Úabsolutezunknown scroll mode %sr z out of rangeN)r> r r Úreprrh r Ú
|
IndexError)r ÚvalueÚmodeÚrr r r Úscroll s z CursorStoreResultMixIn.scrollc C s, | ¡ | jr | j| jd
p"| j}t|S r" )r> r r rf r r r r r| s z CursorStoreResultMixIn.__iter__)N)r ) r} r~ r r rF rB r{ r r? r r| r r r r r Y s
|
|
|
|
r c @ sF e Zd ZdZdd Zdd ZdddZd d
|
Zd d Zd d Z e Z
|
dS )ÚCursorUseResultMixIna This is a MixIn class which causes the result set to be stored
|
in the server and sent row-by-row to client side, i.e. it uses
|
mysql_use_result(). You MUST retrieve the entire result set and
|
close() the cursor before additional queries can be performed on
|
the connection.c C s | ¡ ¡ S r" )r@ Z
|
use_resultr r r r rF £ s z CursorUseResultMixIn._get_resultc C s. | ¡ | d¡}|sdS | jd | _|d S )z%Fetches a single row from the cursor.r Nr )r> rz r ©r r r r r r{ ¦ s
|
z CursorUseResultMixIn.fetchoneNc C s, | ¡ | |p| j¡}| jt| | _|S r )r> rz r r rh )r ry r r r r r ¯ s z CursorUseResultMixIn.fetchmanyc C s& | ¡ | d¡}| jt| | _|S )r r )r> rz r rh r r r r r? · s
|
z CursorUseResultMixIn.fetchallc C s | S r" r r r r r r| ¾ s z CursorUseResultMixIn.__iter__c C s | ¡ }|d krt|S r" )r{ Ú StopIteration)r Úrowr r r rg Á s zCursorUseResultMixIn.next)N) r} r~ r r rF r{ r r? r| rg Ú__next__r r r r r s
|
r c @ s e Zd ZdZdZdS )ÚCursorTupleRowsMixInzwThis is a MixIn class that causes all rows to be returned as tuples,
|
which is the standard form required by DB API.r N©r} r~ r r rx r r r r r Ê s r c @ s e Zd ZdZdZdS )ÚCursorDictRowsMixInznThis is a MixIn class that causes all rows to be returned as
|
dictionaries. This is a non-standard feature.r Nr r r r r r Ñ s r c @ s e Zd ZdZdS )ÚCursorzjThis is the standard Cursor class that returns rows as tuples
|
and stores the result set in the client.N©r} r~ r r r r r r r Ø s r c @ s e Zd ZdZdS )Ú
|
DictCursorzeThis is a Cursor class that returns rows as dictionaries and
|
stores the result set in the client.Nr r r r r r Ý s r c @ s e Zd ZdZdS )ÚSSCursorz_This is a Cursor class that returns rows as tuples and stores
|
the result set in the server.Nr r r r r r â s r c @ s e Zd ZdZdS )Ú SSDictCursorzeThis is a Cursor class that returns rows as dictionaries and
|
stores the result set in the server.Nr r r r r r ç s r )r Úrer r Úcompilers Ú
|
IGNORECASEÚDOTALLr] r r r r r r r r r r r r r Ú<module> s, ýÿ
|
ø AB/
|
