U
|
·ý°dL= ã @ s| d dl Z ddlmZ e de je jB ¡ZG dd dZG dd dZG d d
|
d
|
eeZ G d d d eZ
|
G d d dee
|
Z dS )é Né )Úerrz|\s*((?:INSERT|REPLACE)\b.+\bVALUES?\s*)(\(\s*(?:%s|%\(.+\)s)\s*(?:,\s*(?:%s|%\(.+\)s)\s*)*\))(\s*(?:ON DUPLICATE.*)?);?\s*\Zc @ s. e Zd ZdZdZdd Zdd Zdd Zd d
|
Zd d Z d d Z
|
dd Z dd Z dd Z d;ddZdd Zd<dd Zd d Zd=d d Zd>d!d"Zd#d$ Zd%d& Zd?d(d)Zd*d+ Zd@d,d-Zd.d/ ZdAd1d2Zd3d4 Zd5d6 Z d7d8 Z d9d: Z e j Z e j!Z!e j"Z"e j#Z#e j$Z$e j%Z%e j&Z&e j'Z'e j(Z(e j)Z)dS )BÚCursora
|
This is the object used to interact with the database.
|
|
Do not create an instance of a Cursor yourself. Call
|
connections.Connection.cursor().
|
|
See `Cursor <https://www.python.org/dev/peps/pep-0249/#cursor-objects>`_ in
|
the specification.
|
i c C s4 || _ d | _d| _d| _d| _d | _d | _d | _d S )Nr éÿÿÿÿr )Ú
|
connectionÚ descriptionÚ rownumberÚrowcountÚ arraysizeÚ _executedÚ_resultÚ_rows)Úselfr © r úFd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\pymysql/cursors.pyÚ__init__! s zCursor.__init__c C s. | j }|dkrdS z| ¡ r qW 5 d| _ X dS )zD
|
Closing a cursor just exhausts all remaining data.
|
N)r Únextset©r Úconnr r r Úclose+ s z Cursor.closec C s | S ©Nr ©r r r r Ú __enter__8 s zCursor.__enter__c G s ~| ¡ d S r )r )r Úexc_infor r r Ú__exit__; s zCursor.__exit__c C s | j st d¡| j S )Nz Cursor closed)r r ÚProgrammingErrorr r r r Ú_get_db? s
|
zCursor._get_dbc C s | j st d¡d S )Nzexecute() first)r r r r r r r Ú_check_executedD s zCursor._check_executedc C s |S r r ©r Úrowr r r Ú _conv_rowH s zCursor._conv_rowc G s dS ©z!Does nothing, required by DB API.Nr ©r Úargsr r r Ú setinputsizesK s zCursor.setinputsizesc G s dS r! r r" r r r ÚsetoutputsizesN s zCursor.setoutputsizesFc C sT | ¡ }| j}|dks ||jk r$dS |js.dS d| _| ¡ |j|d | ¡ dS )zGet the next query set.N©Ú
|
unbufferedT)r r Zhas_nextÚ _clear_resultZ next_resultÚ_do_get_result)r r' r Zcurrent_resultr r r Ú_nextsetQ s zCursor._nextsetc C s
|
| d¡S )NF©r* r r r r r _ s zCursor.nextsetNc sD t |tr| ¡}n*t |ttfr@t| fdd|D }|S )Nc 3 s | ]}j | d V qdS ))ÚencodingN)Ú _ensure_bytes)Ú.0Úv©r, r r r Ú <genexpr>f s z'Cursor._ensure_bytes.<locals>.<genexpr>)Ú
|
isinstanceÚstrÚencodeÚtupleÚlistÚtype)r Úxr, r r0 r r- b s
|
|
zCursor._ensure_bytesc sR t |ttfr$t fdd|D S t |trD fdd| ¡ D S |¡S d S )Nc 3 s | ]} |¡V qd S r ©Úliteral©r. Úarg©r r r r1 k s z&Cursor._escape_args.<locals>.<genexpr>c s i | ]\}}| |¡qS r r9 )r. ÚkeyÚvalr= r r Ú
|
<dictcomp>m s z'Cursor._escape_args.<locals>.<dictcomp>)r2 r5 r6 ÚdictÚitemsÚescape)r r# r r r= r Ú _escape_argsi s
|
|
zCursor._escape_argsc C s$ | ¡ }|dk r || ||¡ }|S )a¾
|
Returns the exact string that would be sent to the database by calling the
|
execute() method.
|
|
:param query: Query to mogrify.
|
:type query: str
|
|
:param args: Parameters used with query. (optional)
|
:type args: tuple, list or dict
|
|
:return: The query with argument binding applied.
|
:rtype: str
|
|
This method follows the extension to the DB API 2.0 followed by Psycopg.
|
N)r rD )r Úqueryr# r r r r Úmogrifys s zCursor.mogrifyc C s* | ¡ r
|
q | ||¡}| |¡}|| _|S )a¡ Execute a query.
|
|
:param query: Query to execute.
|
:type query: str
|
|
:param args: Parameters used with query. (optional)
|
:type args: tuple, list or dict
|
|
:return: Number of affected rows.
|
:rtype: int
|
|
If args is a list or tuple, %s can be used as a placeholder in the query.
|
If args is a dict, %(name)s can be used as a placeholder in the query.
|
)r rF Ú_queryr )r rE r# Úresultr r r Úexecute s
|
zCursor.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 ) aÏ Run several data against one query.
|
|
:param query: Query to execute.
|
:type query: str
|
|
:param args: Sequence of sequences or mappings. It is used as parameter.
|
:type args: tuple or list
|
|
:return: Number of rows affected, if any.
|
:rtype: int or None
|
|
This method improves performance on multiple-row INSERT and
|
REPLACE. Otherwise it is equivalent to looping over args with
|
execute().
|
Nr r é é Ú r ú(r ú)c 3 s | ]} |¡V qd S r )rI r; ©rE r r r r1 Ä s z%Cursor.executemany.<locals>.<genexpr>) ÚRE_INSERT_VALUESÚmatchÚgroupÚrstripÚAssertionErrorÚ_do_execute_manyÚmax_stmt_lengthr r, Úsumr )r rE r# ÚmZq_prefixZq_valuesZ q_postfixr rO r Ú executemany¢ s$
|
ú zCursor.executemanyc C s | ¡ }| j}t|tr"| |¡}t|tr6| |¡}t|} t|}||t|| }
|
t|
|
trn|
|
|d¡}
|
| |
|
7 } d} |D ]t} ||| | }
|
t|
|
tr¦|
|
|d¡}
|
t| t|
|
t| d |krâ| | | | ¡7 } t|} n| d7 } | |
|
7 } q~| | | | ¡7 } | | _
|
| S )NÚsurrogateescaper r ó ,) r rD r2 r3 r4 Ú bytearrayÚiterÚnextÚlenrI r ) r ÚprefixÚvaluesZpostfixr# rV r, r rC Zsqlr/ Úrowsr< r r r rU Ç s2
|
|
|
|
|
|
|
|
zCursor._do_execute_manyr c s | ¡ |rHd d| dd fddt|D ¡ ¡ | ¡ dd fdd tt|D ¡f }| |¡ || _|S )
|
ab Execute stored procedure procname with args.
|
|
:param procname: Name of procedure to execute on server.
|
:type procname: str
|
|
:param args: Sequence of parameters to use with procedure.
|
:type args: tuple or list
|
|
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.
|
z@_z_%d=%szSET %sú,c 3 s$ | ] \}}| |¡f V qd S r )rC )r. Úindexr< )r Úfmtr r r1 s z"Cursor.callproc.<locals>.<genexpr>z CALL %s(%s)c s g | ]}d |f qS )z@_%s_%dr )r. Úi)Úprocnamer r Ú
|
<listcomp> s z#Cursor.callproc.<locals>.<listcomp>)r rG ÚjoinÚ enumerater Úranger_ r )r rg r# Úqr )r re rg r Úcallprocå s$ ÿÿÿ þ
|
zCursor.callprocc C sD | ¡ | jdks"| jt| jkr&dS | j| j }| jd7 _|S )zFetch the next row.Nr ©r r r r_ ©r rH r r r Úfetchone s zCursor.fetchonec C sL | ¡ | jdkrdS | j|p"| j }| j| j|
}t|t| j| _|S )zFetch several rows.Nr )r r r r
|
Úminr_ )r ÚsizeÚendrH r r r Ú fetchmany s
|
zCursor.fetchmanyc C sD | ¡ | jdkrdS | jr.| j| jd
}n| j}t| j| _|S )zFetch all the rows.Nr rn ro r r r Úfetchall) s
|
zCursor.fetchallÚrelativec C sf | ¡ |dkr | j| }n |dkr*|}nt d| ¡d| krRt| jk s\n td|| _d S )Nrv Úabsoluteúunknown scroll mode %sr z out of range)r r r r r_ r Ú
|
IndexError)r ÚvalueÚmodeÚrr r r Úscroll5 s z Cursor.scrollc C s( | ¡ }| ¡ | |¡ | ¡ | jS r ©r r( rE r) r ©r rl r r r r rG B s
|
|
z Cursor._queryc C s( d| _ d | _d| _d | _d | _d | _d S )Nr )r r r r Ú lastrowidr r r r r r( I s zCursor._clear_resultc C s8 | ¡ }|j | _}|j| _|j| _|j| _|j| _d S r ) r r Z affected_rowsr r Z insert_idr rb r )r r rH r r r r) R s zCursor._do_get_resultc C s t | jd S r ©r] rp r r r r Ú__iter__\ s zCursor.__iter__)F)N)N)N)r )N)rv )*Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__rV r r r r r r r r$ r% r* r r- rD rF rI rY rU rm rp rt ru r} rG r( r) r r ÚWarningÚErrorZInterfaceErrorZ DatabaseErrorZ DataErrorZOperationalErrorZIntegrityErrorZ InternalErrorr ÚNotSupportedErrorr r r r r sL
|
|
|
|
|
|
%
|
1
|
|
|
|
r c s( e Zd ZeZ fddZdd Z ZS )ÚDictCursorMixinc sv t t ¡ g } jrR jjD ]*}|j}||kr@|jd | }| |¡ q | _ |rr j
|
rr fdd j
|
D _
|
d S )NÚ.c s g | ]} |¡qS r )r )r. r| r r r rh { s z2DictCursorMixin._do_get_result.<locals>.<listcomp>) Úsuperr r) r r ÚfieldsÚnameZ
|
table_nameÚappendÚ_fieldsr )r r Úfr ©Ú __class__r r r) o s
|
z DictCursorMixin._do_get_resultc C s |d kr d S | t| j|¡S r )Ú dict_typeÚzipr r r r r r } s zDictCursorMixin._conv_row)r r r
rA r r) r Ú __classcell__r r r r r k s r c @ s e Zd ZdZdS )Ú
|
DictCursorz.A cursor which returns results as a dictionaryN©r r r
r r r r r r s r c @ sp e Zd ZdZdd Zdd ZeZdd Zdd Zd
|
d Z d d Z
|
dd Z dd Z dd Z dddZdddZdS ) ÚSSCursoraÃ
|
Unbuffered Cursor, mainly useful for queries that return a lot of data,
|
or for connections to remote servers over a slow network.
|
|
Instead of copying every row of data into a buffer, this will fetch
|
rows as needed. The upside of this is the client uses much less memory,
|
and rows are returned much faster when traveling over a slow network
|
or if the result set is very big.
|
|
There are limitations, though. The MySQL protocol doesn't support
|
returning the total number of rows, so the only way to tell how many rows
|
there are is to iterate over every row returned. Also, it currently isn't
|
possible to scroll backwards, as only the current row is held in memory.
|
c C s |S r r r r r r r s zSSCursor._conv_rowc C sN | j }|d krd S | jd k r2| j|jkr2| j ¡ z| ¡ r>q4W 5 d | _ X d S r )r r Z_finish_unbuffered_queryr r r r r r s
|
zSSCursor.closec C s, | ¡ }| ¡ |j|dd | ¡ | jS ©NTr& r~ r r r r rG ª s
|
zSSCursor._queryc C s | j ddS r r+ r r r r r ± s zSSCursor.nextsetc C s | | j ¡ ¡S )zRead next row.)r r Z _read_rowdata_packet_unbufferedr r r r Ú read_next´ s zSSCursor.read_nextc C s. | ¡ | ¡ }|dkr dS | jd7 _|S )zFetch next row.Nr )r r r r r r r rp ¸ s zSSCursor.fetchonec C s t | ¡ S )zÈ
|
Fetch all, as per MySQLdb. Pretty useless for large queries, as
|
it is buffered. See fetchall_unbuffered(), if you want an unbuffered
|
generator version of this method.
|
)r6 Úfetchall_unbufferedr r r r ru Á s zSSCursor.fetchallc C s t | jdS )zÛ
|
Fetch all, implemented as a generator, which isn't to standard,
|
however, it doesn't make sense to return everything in a list, as that
|
would use ridiculous memory for large result sets.
|
Nr r r r r r É s z SSCursor.fetchall_unbufferedc C s | ¡ S r )r r r r r r Ñ s zSSCursor.__iter__Nc C sX | ¡ |dkr| j}g }t|D ]0}| ¡ }|dkr: qT| |¡ | jd7 _q"|S )z Fetch many.Nr )r r
|
rk r r r )r rr rb rf r r r r rt Ô s
|
zSSCursor.fetchmanyrv c C s | ¡ |dkrH|dk r"t d¡t|D ] }| ¡ q*| j|7 _nR|dkr|| jk rdt d¡|| j }t|D ] }| ¡ qv|| _nt d| ¡d S )Nrv r z0Backwards scrolling not supported by this cursorrw rx )r r r rk r r r )r rz r{ Ú_rs r r r r} ã s& ÿ
|
|
ÿ
|
|
zSSCursor.scroll)N)rv )r r r
r r r Ú__del__rG r r rp ru r r rt r} r r r r r s
|
r c @ s e Zd ZdZdS )Ú SSDictCursorz;An unbuffered cursor, which returns results as a dictionaryNr r r r r r ý s r ) ÚrerL r ÚcompileÚ
|
IGNORECASEÚDOTALLrP r r r r r r r r r Ú<module> s
|
ü ]v
|
