Ë
|
^i@ ã óâ d dl Z d dlZddlmZ e j de j
|
e j z « Z G d d« Z G d d« Z G d d
|
e e« Z
|
G d d e« Z G d de e « Z y)é Né )Úerrz|\s*((?:INSERT|REPLACE)\b.+\bVALUES?\s*)(\(\s*(?:%s|%\(.+\)s)\s*(?:,\s*(?:%s|%\(.+\)s)\s*)*\))(\s*(?:ON DUPLICATE.*)?);?\s*\Zc óÂ e Zd ZdZdZd Zd Zd Zd Zd Z d Z
|
d Z d
|
Z d Z d d Zd Zd Zd dZd dZd Zd Zd!dZd Zd dZd Zd"dZd Zd Zd Z d Z d Z d Z y)#Ú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 ó || _ d| _ d | _ d| _ d| _ d| _ d | _ d | _ d | _ y )Nr éÿÿÿÿr ) Ú
|
connectionÚ warning_countÚ descriptionÚ rownumberÚrowcountÚ arraysizeÚ _executedÚ_resultÚ_rows)Úselfr s õb H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\pymysql/cursors.pyÚ__init__zCursor.__init__" sC Ø$Ø ÔØ ÔØØ ØØ Ø Ø
|
ó c ó | j }|y | j « r | j « rd| _ y# d| _ w xY w)zD
|
Closing a cursor just exhausts all remaining data.
|
N)r Únextset©r Úconns r Úclosez Cursor.close- sB ð Ø <Ø ð #Ø,,.Øð ,,.ð #DOødDOús !; » Ac ó | S ©N© ©r s r Ú __enter__zCursor.__enter__: ó Ø r c ó& ~| j « y r )r )r Úexc_infos r Ú__exit__zCursor.__exit__= s Ø Ø
|
|
r c ó\ | j st j d« | j S )Nz Cursor closed)r r ÚProgrammingErrorr s r Ú_get_dbzCursor._get_dbA s$ ØÜ×&Ñ& Ó7Ð 7ØÐ r c óF | j st j d« y )Nzexecute() first)r r r% r s r Ú_check_executedzCursor._check_executedF s Ø~~Ü×&Ñ&Ð'8Ó9Ð 9ð r c ó |S r r ©r Úrows r Ú _conv_rowzCursor._conv_rowJ ó Ø
|
r c ó y©z!Does nothing, required by DB API.Nr ©r Úargss r Ú setinputsizeszCursor.setinputsizesM ó r c ó yr/ r r0 s r ÚsetoutputsizeszCursor.setoutputsizesP r3 r c óê | j « }| j }|||j ury|j syd| _ | j « |j |¬« | j « y)zGet the next query set.N©Ú
|
unbufferedT)r& r Úhas_nextÚ _clear_resultÚ next_resultÚ_do_get_result)r r8 r Úcurrent_results r Ú_nextsetzCursor._nextsetS si à||~Ø Ø Ð ! ^¸4¿<¹<Ñ%GØØ ×&Ò&ØØ Ø ×ÑÔ Ø ×Ñ JÐÔ/Ø ×ÑÔ Ør c ó$ | j d« S )NF©r> r s r r zCursor.nextseta s Ø}}UÓ#Ð#r c ó t |t t f« rt fd|D « « S t |t « r3|j « D ci c] \ }}|j |« c}}S j |« S c c}}w )Nc 3 ó@ K | ] }j |« y wr )Úliteral)Ú.0Úargr s r ú <genexpr>z&Cursor._escape_args.<locals>.<genexpr>f s øè ø Ò;¨s c×*Ñ;ùs )Ú
|
isinstanceÚtupleÚlistÚdictÚitemsrC Úescape)r r1 r ÚkeyÚvals ` r Ú _escape_argszCursor._escape_argsd sl ø Ü dU¤DMÔ *ÜÓ;°dÔ;Ó;Ð ;Ü dÔ #Ø=A¿Z¹Z»\×J©z°°SC cÓ*Ñ*ÓJÐ Jð ;;tÓ$Ð $ùó Ks Á B Nc óT | j « }||| j ||« z }|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.
|
)r& rO )r Úqueryr1 r s r ÚmogrifyzCursor.mogrifyn s1 ð ||~à Ð ØD× -Ñ -¨d°DÓ 9Ñ9Eà r c ó | j « r | j « r| j ||« }| j |« }|| _ |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 rR Ú_queryr )r rQ r1 Úresults r ÚexecutezCursor.execute
sG ð llnØ ð llnð U DÓ)àUÓ#Ø Ø r c óª |syt j « }|r|j d« dz }|j d« j « }|j d« xs d}|d dk( r|d d
|
k( sJ j |||| j
|
j « j « S t fd |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 óB K | ] }j |« y wr )rV )rD rE rQ r s r rF z%Cursor.executemany.<locals>.<genexpr>¿ s øè ø ÒE¸DLL¨°× 4ÑEùs )
|
ÚRE_INSERT_VALUESÚmatchÚgroupÚrstripÚ_do_execute_manyÚmax_stmt_lengthr& ÚencodingÚsumr )r rQ r1 ÚmÚq_prefixÚq_valuesÚ q_postfixs `` r Ú executemanyzCursor.executemany sÉ ù ñ Ø ä × "Ñ " 5Ó )Ù Øwwqz BHØwwqz×(Ñ(Ó*HØ
|
Ò( bIØA; #Ò%¨(°2©,¸#Ò*=Ð =Ð=Ø×(Ñ(ØØØØØ×$Ñ$Ø ×'Ñ'ó ð ô ÔEÀÔEÓE Ø}}Ð r c ó¼ | j « }| j }t |t « r|j |« }t |t « r|j |« }t |« } t |« }| |t |« |« z }
|
t |
|
t « r|
|
j |d« }
|
| |
|
z } d} |D ] } | || |« z }
|
t |
|
t « r|
|
j |d« }
|
t | « t |
|
« z t |« z dz |kD r#| | j | |z « z } t |« } n| dz } | |
|
z } | | j | |z « z } | | _
|
| S )NÚsurrogateescaper r ó ,) r& rO rG ÚstrÚencodeÚ bytearrayÚiterÚnextÚlenrV r ) r ÚprefixÚvaluesÚpostfixr1 rc rd r rL ÚsqlÚvÚrowsrE s r rb zCursor._do_execute_many sQ ð ||~Ø×"Ñ"Ü fcÔ "Ø]] 8Ó,FÜ gsÔ #Ø nn XÓ.GÜÓ ÜDzØ VD J¨Ó-Ñ -Ü aÔ ØÐ#4Ó5AØ qØØò CØ TÓ*Ñ*AÜ!SÔ!ØHHXÐ'8Ó9Ü3x#a&Ñ ¤3 w£<Ñ/°!Ñ3°oÒEØ S¨7¡]Ó3Ñ3Ü Ó'àt Ø 1HCð ð S 7]Ó+Ñ+Ø Ø r c ó | j « |rLd| d| j ddj fdt |« D « « z « | j « dj |dj t t |« « D cg c] }d||fz c}« « }| j |« || _ |S c c}w )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 óP K | ] \ }}|j |« fz y wr )rL )rD ÚindexrE r Úfmts r rF z"Cursor.callproc.<locals>.<genexpr> s- øè ø ò Ù8B¸¸sC5 $§+¡+¨cÓ"2Ð3Õ3ñùs #&z CALL {}({})z@_%s_%d) r& rT ÚjoinÚ enumerater ÚformatÚrangers r )r Úprocnamer1 ÚiÚqr r~ s @@r ÚcallproczCursor.callprocà s¹ ù ð< ||~Ù Øxj Ð'CØ KKØØ((ô ÜFOÐPTÃoôó ñô ð LLNà × Ñ Ø Ø HH¼¼sÀ4»yÓ9IÖJ°Ai 8¨Q -Ó/ÒJÓ Kó
|
ð AØØ ùò Ks ÂCc óà | j « | j "| j t | j « k\ ry| j | j }| xj dz c_ |S )zFetch the next row.Nr ©r( r r rs ©r rU s r ÚfetchonezCursor.fetchone sS à × Ñ Ô Ø ::Ð § ¡ ´3°t·z±z³?Ò!BØØDNNÑ+Ø !ÑØ r c óô | j « | j y| j |xs | j z }| j | j | }t |t | j « « | _ |S )zFetch several rows.r )r( r r r Úminrs )r ÚsizeÚendrU s r Ú fetchmanyzCursor.fetchmany sc à × Ñ Ô Ø ::Ð ð Ønn Ò 6¨¯©Ñ7ØDNN¨SÐ1Ü S¤# d§j¡j£/Ó2Ø r c óÚ | j « | j g S | j r| j | j d }n | j }t | j « | _ |S )zFetch all the rows.Nr r s r ÚfetchallzCursor.fetchall& sV à × Ñ Ô Ø ::Ð ØIØ >>ØZZ §¡Ð 0Ð1FàZZFÜ TZZ Ø r c ó | j « |dk( r| j |z }n |dk( r|}nt j d|z « d|cxk r"t | j
|
« k st d« t d« || _ y )NÚrelativeÚabsoluteúunknown scroll mode %sr z out of range)r( r r r% rs r Ú
|
IndexError)r ÚvalueÚmodeÚrs r Úscrollz Cursor.scroll2 s Ø × Ñ Ô Ø :Ò Ø Ñ&AØ ZÒ ØAä×&Ñ&Ð'?À$Ñ'FÓGÐ GàQÔ(TZZ Ò(Ü ^Ó,Ð ,ð )Ü ^Ó,Ð ,Ør c ó | j « }| j « |j |« | j « | j S r ©r& r: rQ r< r ©r r
r s r rT z Cursor._query? s: Ø||~Ø ×ÑÔ Ø
|
|
1 Ø ×ÑÔ Ø}}Ð r c óf d| _ d | _ d| _ d| _ d | _ d | _ d | _ y )Nr )r r r r
|
r Ú lastrowidr r s r r: zCursor._clear_resultF s5 ØØ à Ø ÔØ ÔØ Ø
|
r c óô | j « }|j x| _ }|j | _ |j | _ |j
|
| _ |j | _ |j | _ y r )
|
r& r Ú affected_rowsr r
|
r Ú insert_idr ry r )r r rU s r r< zCursor._do_get_resultP s^ Ø||~à $§ ¡ Ð, và ×,Ñ, Ø #× 1Ñ 1ÔØ!×-Ñ-ÔØ ×)Ñ)Ø[[
|
r c ó | S r r r s r Ú__iter__zCursor.__iter__[ r r c ó6 | j « }|t |S r )r Ú StopIterationr* s r Ú__next__zCursor.__next__^ s ØmmoØ ;Ü Ð Ø
|
r c óx |dv r,t j dt d¬« t t |« S t |« )N)
|
ÚWarningÚErrorÚInterfaceErrorÚ DatabaseErrorÚ DataErrorÚOperationalErrorÚIntegrityErrorÚ InternalErrorr% ÚNotSupportedErrorz7PyMySQL errors hould be accessed from `pymysql` packagerX )Ú
|
stacklevel)ÚwarningsÚwarnÚDeprecationWarningÚgetattrr ÚAttributeError)r Únames r Ú __getattr__zCursor.__getattr__d sB ð ð
|
ñ
|
ô MMØIÜ"Ø õ ô
|
3 Ó%Ð %Ü TÓ"Ð"r )Fr )r ©r ) Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__rc r r r r# r& r( r, r2 r5 r> r rO rR rV rj rb r r r r r rT r: r< r¤ r§ r¹ r r r r r s ñð Oò ò #òòò ò
|
:òò0ò0ó ò $ò%óó.ò0# òJ ó</òbó
|
ò
|
ó ò òò !òòó #r r c ó( e Zd ZeZ fdZd Z xZS )ÚDictCursorMixinc ón t | « g }| j rU| j j D ]5 }|j
|
}||v r|j dz |z }|j |« 7 || _ |r<| j r/| j D cg c] }| j |« c}| _ y y y c c}w )Nú.) Úsuperr< r r Úfieldsr¸ Ú
|
table_nameÚappendÚ_fieldsr r, )r rÄ Úfr¸ r Ú __class__s r r< z DictCursorMixin._do_get_result s ø Ü Ñ Ô ØØ × Ò Ø\\×(Ñ(ò $ØvvØ6>Ø <<¨#Ñ-°Ñ4DØ dÕ#ð $ð
|
"DLá djjØ59·Z±ZÖ@°$..¨Õ+Ò@DJð !6ùÚ@s ÂB2c óR |y | j t | j |« « S r )Ú dict_typeÚziprÇ r* s r r, zDictCursorMixin._conv_row s$ Ø ;ØØ~~c $§,¡,°Ó 4Ó5Ð5r )r» r¼ r½ rJ rË r< r, Ú __classcell__)rÉ s @r rÀ rÀ } s ø àIô Aö 6r rÀ c ó e Zd ZdZy)Ú
|
DictCursorz.A cursor which returns results as a dictionaryN©r» r¼ r½ r¾ r r r rÏ rÏ s Ú8r rÏ c óT e Zd ZdZd Zd ZeZd Zd Zd Z d Z
|
d Z d Z d d Z dd Zy
|
)Ú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 ó |S r r r* s r r, zSSCursor._conv_row© r- r c ó
|
| j }|y | j 2| j |j u r| j j « | j « r | j « rd | _ y # d | _ w xY wr )r r Ú_finish_unbuffered_queryr r s r r zSSCursor.close¬ si ØØ <Ø à <<Ð #¨¯ © ¸¿ ¹ Ñ(DØ LL× 1Ñ 1Ô 3ð #Ø,,.Øð ,,.ð #DOødDOús Á!A9 Á9 Bc ó | j « }| j « |j |d¬« | j « | j S ©NTr7 r r s r rT zSSCursor._query¼ s? Ø||~Ø ×ÑÔ Ø
|
|
1
|
Ô&Ø ×ÑÔ Ø}}Ð r c ó& | j d¬« S r× r@ r s r r zSSCursor.nextsetà s Ø}}¨}Ó-Ð-r c óT | j | j j « « S )zRead next row.)r, r Ú _read_rowdata_packet_unbufferedr s r Ú read_nextzSSCursor.read_nextÆ s à~~dll× JÑ JÓ LÓMÐMr c ó¬ | j « | j « }| | j j | _ y| xj dz c_ |S )zFetch next row.Nr )r( rÛ r r
|
r r* s r r zSSCursor.fetchoneÊ sG à × Ñ Ô ØnnÓ Ø ;Ø!%§ ¡ ×!;Ñ!;DÔ ØØ !ÑØ
|
r c ó4 t | j « « 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.
|
)rI Úfetchall_unbufferedr s r r zSSCursor.fetchallÔ s ô D×,Ñ,Ó.Ó/Ð/r c ó. t | j d« S )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.
|
N)rq r r s r rÞ z SSCursor.fetchall_unbufferedÜ s ô DMM 4Ó(Ð(r Nc ó | j « | | j }g }t |« D ]W }| j « }| | j j
|
| _ n(|j |« | xj dz c_ Y |sy|S )z Fetch many.r r )r( r r rÛ r r
|
rÆ r )r r ry r r+ s r r zSSCursor.fetchmanyä s à × Ñ Ô Ø <Ø>>DàÜtò AØ..Ó"CØ{Ø%)§\¡\×%?Ñ%?Ô"ÙØ KKÔ Ø NNaÑ Nð ñ ð Ø r c ó¼ | j « |dk( rP|dk rt j d« t |« D ] }| j « | xj
|
|z c_ y |dk( r[|| j
|
k rt j d« || j
|
z
|
}t |« D ] }| j « || _ y t j d|z « )Nr r z0Backwards scrolling not supported by this cursorr r )r( r r± r rÛ r r% )r r r Ú_r s r r zSSCursor.scrollø sÕ Ø × Ñ Ô à :Ò ØqyÜ×+Ñ+ØFóð ô 5\ò !ØÕ ð !à NNeÑ #NØ ZÒ Øt~~Ò%Ü×+Ñ+ØFóð ð $..Ñ(CÜ3Zò !ØÕ ð !à "DNä×&Ñ&Ð'?À$Ñ'FÓGÐ Gr r rº )r» r¼ r½ r¾ r, r Ú__del__rT r rÛ r r rÞ r r r r r rÒ rÒ sB ñ ò ò #ð Gò ò.òNòò0ò)óô(Hr rÒ c ó e Zd ZdZy)Ú SSDictCursorz;An unbuffered cursor, which returns results as a dictionaryNrÐ r r r rå rå s ÚEr rå ) Úrer³ rZ r ÚcompileÚ
|
IGNORECASEÚDOTALLr^ r rÀ rÏ rÒ rå r r r ú<module>rê s~ ðÛ Û Ý ð 2::ð)ð MMBIIÑ ó Ð ÷i#ñ i#÷X 6ñ 6ô09 &ô 9ôvHvô vHôrF? Hõ Fr
|
