Ë
|
^iÒ ã óh d dl Z d dlZd dlZd dlZd dlZd dlZd dlZddlmZ ddl m
|
Z
|
m Z ddl m Z mZmZmZmZmZ ddlmZ ddlmZ ddlmZ dd lmZmZmZm Z m Z m Z dd
|
lm Z m Z d dl!Z!d Z" d dl$Z$ e$jJ « Z&[$d Z)dZ*ejV ejX ejZ ej\ ej^ ej` ejb ejd ejf h Z4d Z5dZ6d Z7d Z8 G d d« Z9 G d d« Z: G d d« Z;y# e#$ r dZ!d Z"Y ´w xY w# e#e'e(f$ r dZ&Y w xY w)é Né )Ú_auth)Úcharset_by_nameÚ charset_by_id)ÚCLIENTÚCOMMANDÚCRÚERÚ
|
FIELD_TYPEÚ SERVER_STATUS)Ú
|
converters)ÚCursor)ÚParser)Ú dump_packetÚ MysqlPacketÚFieldDescriptorPacketÚOKPacketWrapperÚEOFPacketWrapperÚLoadLocalPacketWrapper)ÚerrÚVERSION_STRINGTFÚutf8mb4iÿÿÿ c ó4 t j d| « d d S )Nú<Ié )ÚstructÚpack)Úns õf H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\pymysql/connections.pyÚ _pack_int24r F s Ü ;;tQÓ Ð #Ð#ó c ó, | dk rt d| z « | dk r t | g« S | dk rdt j d| « z S | dk r dt j d | « d d
|
z S | d k rd t j d | « z S t d| ddd dd« )Nr zFEncoding %d is less than 0 - no representation in LengthEncodedIntegeréû i ó üú<Hé ó ýr r l ó þz<Qz Encoding Úxz is larger than z, - no representation in LengthEncodedInteger)Ú
|
ValueErrorÚbytesr r )Úis r Ú _lenenc_intr- K s· Ø1uÜØ TÐWXÑ Xó
|
ð
|
ð
|
TÜaSzÐØ
|
g Ø T¨1Ó-Ñ-Ð-Ø
|
g Ø T¨1Ó-¨b¨qÐ1Ñ1Ð1Ø
|
g Ø T¨1Ó-Ñ-Ð-äØ!uÐ ,¨W°Q¨KÐ7cÐ dó
|
ð
|
r! c ) ó e Zd ZdZdZdZdZdZdZddddddddddddde ddddddddddddddddddddddddddd (d
|
Z
|
d Z d Z d Z d Zed « Zd ZeZd Zd Zd Zd Zd Zd Zd Zd Zd Zd7dZ d Z d Z d Z d7d Z d8d Z!d8d Z"d! Z#d" Z$d9d#Z%d$ Z&d7d%Z'd7d&Z(d' Z)e*fd(Z+d) Z,d* Z-d8d+Z.d, Z/d- Z0d. Z1d/ Z2d0 Z3d1 Z4d2 Z5d3 Z6d4 Z7d5 Z8d6 Z9e:jv Z;e:jx Z<e:jz Z=e:j| Z>e:j~ Z?e:j Z@e:j ZAe:j ZBe:j ZCe:j ZDy):Ú
|
Connectionaê
|
Representation of a socket with a mysql server.
|
|
The proper way to get an instance of this class is to call
|
connect().
|
|
Establish a connection to the MySQL database. Accepts several
|
arguments:
|
|
:param host: Host where the database server is located.
|
:param user: Username to log in as.
|
:param password: Password to use.
|
:param database: Database to use, None to not use a particular one.
|
:param port: MySQL port to use, default is usually OK. (default: 3306)
|
:param bind_address: When the client has multiple network interfaces, specify
|
the interface from which to connect to the host. Argument can be
|
a hostname or an IP address.
|
:param unix_socket: Use a unix socket rather than TCP/IP.
|
:param read_timeout: The timeout for reading from the connection in seconds.
|
(default: None - no timeout)
|
:param write_timeout: The timeout for writing to the connection in seconds.
|
(default: None - no timeout)
|
:param str charset: Charset to use.
|
:param str collation: Collation name to use.
|
:param sql_mode: Default SQL_MODE to use.
|
:param read_default_file:
|
Specifies my.cnf file to read these parameters from under the [client] section.
|
:param conv:
|
Conversion dictionary to use instead of the default one.
|
This is used to provide custom marshalling and unmarshalling of types.
|
See converters.
|
:param use_unicode:
|
Whether or not to default to unicode strings.
|
This option defaults to true.
|
:param client_flag: Custom flags to send to MySQL. Find potential values in constants.CLIENT.
|
:param cursorclass: Custom cursor class to use.
|
:param init_command: Initial SQL statement to run when connection is established.
|
:param connect_timeout: The timeout for connecting to the database in seconds.
|
(default: 10, min: 1, max: 31536000)
|
:param ssl: A dict of arguments similar to mysql_ssl_set()'s parameters or an ssl.SSLContext.
|
:param ssl_ca: Path to the file that contains a PEM-formatted CA certificate.
|
:param ssl_cert: Path to the file that contains a PEM-formatted client certificate.
|
:param ssl_disabled: A boolean value that disables usage of TLS.
|
:param ssl_key: Path to the file that contains a PEM-formatted private key for
|
the client certificate.
|
:param ssl_key_password: The password for the client certificate private key.
|
:param ssl_verify_cert: Set to true to check the server certificate's validity.
|
:param ssl_verify_identity: Set to true to check the server's identity.
|
:param read_default_group: Group to read from in the configuration file.
|
:param autocommit: Autocommit mode. None means use server default. (default: False)
|
:param local_infile: Boolean to enable the use of LOAD DATA LOCAL command. (default: False)
|
:param max_allowed_packet: Max size of packet sent to server in bytes. (default: 16MB)
|
Only used to limit size of "LOAD LOCAL INFILE" data packet smaller than default (16KB).
|
:param defer_connect: Don't explicitly connect on construction - wait for connect call.
|
(default: False)
|
:param auth_plugin_map: A dict of plugin names to a class that processes that plugin.
|
The class will take the Connection object as the argument to the constructor.
|
The class needs an authenticate method taking an authentication packet as
|
an argument. For the dialog plugin, a prompt(echo, prompt) method can be used
|
(if no authenticate method) for returning a string from the user. (experimental)
|
:param server_public_key: SHA256 authentication plugin public key value. (default: None)
|
:param binary_prefix: Add _binary prefix on bytes and bytearray. (default: False)
|
:param compress: Not supported.
|
:param named_pipe: Not supported.
|
:param db: **DEPRECATED** Alias for database.
|
:param passwd: **DEPRECATED** Alias for password.
|
|
See `Connection <https://www.python.org/dev/peps/pep-0249/#connection-objects>`_ in the
|
specification.
|
NÚ Fr Té
|
r& )(ÚuserÚpasswordÚhostÚdatabaseÚ unix_socketÚportÚcharsetÚ collationÚsql_modeÚread_default_fileÚconvÚ use_unicodeÚ client_flagÚ cursorclassÚ init_commandÚconnect_timeoutÚread_default_groupÚ
|
autocommitÚ local_infileÚmax_allowed_packetÚ defer_connectÚauth_plugin_mapÚ read_timeoutÚ write_timeoutÚ bind_addressÚ binary_prefixÚ program_nameÚserver_public_keyÚsslÚssl_caÚssl_certÚ ssl_disabledÚssl_keyÚssl_key_passwordÚssl_verify_certÚssl_verify_identityÚcompressÚ
|
named_pipeÚpasswdÚdbc ( ó . |(||(}|'|s|'}|%s|&r t d« t |« | _ | j r| t j z } r&|
|
s$t
|
j j d« rd}
|
nd}
|
|
|
rÒsdt « ..j t j j |
|
« « .fd}) |)d|« } |)d|« } |)d |« } |)d
|
|« } |)d |« }t |)d |« « } |)d |« } |)d|« }| si } t | t « r+dD ]& }* |)d|*z | j |*« « }+|+s"|+| |*< ( d| _ | su| s| s|!s|#s|$r(| t |$« |#|#ndd} | | | d< |!|!| d< |"|"| d< | rAt$ s t d« d| _ | t j& z } | j) | « | _ |xs d| _ |xs d| _ t1 | j. « t ur t3 d« |xs t4 | _ |xs d| _ t | j8 t: « r | j8 j= d« | _ || _ || _ || _! d |cxk rd k st3 d « t3 d « |xs d | _" ||d k r t3 d « || _# ||d k r t3 d « || _$ |xs tJ | _& || _' | | _( tS | jL « jT | _* | t jV z } | j> r| t jX z } | | _- || _. d | _/ d | _0 d!| _1 || _2 | tf jh } | jk « D ,-ci c] \ },}-t1 |,« t us|,|- c}-},| _6 | jk « D ,-ci c] \ },}-t1 |,« t u s|,|- c}-},| _7 | | _8 || _9 || _: |xs i | _; || _< | | _= d"t| t; t j~ « « d#| _@ |r|| j d$< |rd | _A y | j
« y c c}-},w c c}-},w )%Nz3compress and named_pipe arguments are not supportedÚwinz c:\my.iniz /etc/my.cnfÚclientc óT |r|S j | « S # t $ r |cY S w xY w©N)ÚgetÚ Exception)ÚkeyÚargÚcfgrB s r Ú_configz$Connection.__init__.<locals>._configû s6 ø ÙØ Jð Ø 77Ð#5°sÓ;Ð;øÜ ò Ø Jð ús '¦'r2 r3 r4 r5 Úsocketr7 z bind-addresszdefault-character-set)ÚcaÚcapathÚcertra r3 Úcipherzssl-F)rf Úcheck_hostnameÚ verify_moderh ra zssl module not foundTÚ localhostiê zport should be of type intr! Úlatin1r i3áz+connect_timeout should be >0 and <=31536000zread_timeout should be > 0zwrite_timeout should be > 0z Not connectedÚpymysql)Ú _client_nameÚ_client_versionÚ_pidrL )CÚNotImplementedErrorÚboolÚ _local_infiler Ú LOCAL_FILESÚsysÚplatformÚ
|
startswithr ÚreadÚosÚpathÚ
|
expanduserÚintÚ
|
isinstanceÚdictr_ rN Ú SSL_ENABLEDÚSSLÚ_create_ssl_ctxÚctxr4 r7 Útyper* Ú DEFAULT_USERr2 r3 ÚstrÚencoderY r6 rJ rA Ú _read_timeoutÚ_write_timeoutÚDEFAULT_CHARSETr8 r9 r= r ÚencodingÚ CAPABILITIESÚCONNECT_WITH_DBr> r? Ú_resultÚ_affected_rowsÚ host_infoÚautocommit_moder Ú conversionsÚitemsÚencodersÚdecodersr: r@ rE Ú_auth_plugin_mapÚ_binary_prefixrM r ÚgetpidÚ_connect_attrsÚ_sockÚconnect)/Úselfr2 r3 r4 r5 r6 r7 r8 r9 r: r; r< r= r> r? r@ rA rB rC rD rE rF rG rH rI rJ rK rL rM rN rO rP rQ rR rS rT rU rV rW rX rY rd ra ÚvalueÚkÚvrc s/ ` @r Ú__init__zConnection.__init__¬ s} ù ðX >hÐ .ð HØ Ð ¡hð Há zÜ%ØEóð ô " ,Ó /ÔØ × Ò Ø 6×-Ñ-Ñ -Ká Ñ&7Ü||×&Ñ& uÔ-Ø$0Ñ!à$1Ð!á Ù%Ø%-Ð"ä(CØ HHRWW×'Ñ'Ð(9Ó:Ô ;õ ñ 6 4Ó(DÙ z¨8Ó4HÙ6 4Ó(DÙ z¨8Ó4HÙ! (¨KÓ8KÜwv tÓ,Ó-DÙ" >°<Ó@LÙ Ð 5°wÓ?GÙØÜ#tÔ$ØPò )CÙ # F¨S¡L°'°#·'±'¸#³,Ó ?EÚ Ø#(Cð)ð
|
ÙÙ¡W±ÑCVà Ü&*Ð+>Ó&?à&Ð2ñ $3à ñ ð Ð'Ø"*CKØÐ&Ø!(CJØ#Ð/Ø&6C
|
OÙÝ"Ü-Ð.DÓEÐEØ ØvzzÑ) Ø ×/Ñ/°Ó4àÒ'K ØLD Ü ?¤#Ñ %Ü Ð 9Ó:Ð :ØÒ(L Ø C Ü dmm¤SÔ )Ø MM× 0Ñ 0°Ó :DMØØ&ÔØ (ÔØOÔ/ xÒ/Ü Ð JÓKÐ Kð 0Ü Ð JÓKÐ KØ .Ò 6°$Ô Ø Ð #¨ ¸Ò(9Ü Ð 9Ó:Ð :Ø )ÔØ Ð $¨ ¸!Ò);Ü Ð :Ó;Ð ;Ø +Ôà Ò1¤/ Ø"Ø&Ôä'¨¯ © Ó5×>Ñ> àv×*Ñ*Ñ* Ø 77Ø 6×1Ñ1Ñ 1Kà&Ôà&Ôà Ø ÔØ(ð *Ô à <Ü ×)Ñ)Dð -1¯J©J«L×O¡& 1 a¼DÀ»GÌ3Ò<NAÓO Ø,0¯J©J«L×K¡& 1 a¼DÀ»GÄsºNAÓK Ø Ø (ÔØ"4Ô Ø /Ò 5°2Ô Ø +ÔØ!2Ô ð &Ü -Ü Ó$ñ
|
Ôñ Ø2>D× Ñ Ñ /á Ø DJà LLNùó+ PùÛKs Î Q4Î'Q4ÏQ:Ï"Q:c ó | S r^ © ©r s r Ú __enter__zConnection.__enter__o s Ø r! c ó& ~| j « y r^ )Úclose)r Úexc_infos r Ú__exit__zConnection.__exit__r s Ø Ø
|
|
r! c ó t |t j « r|S |j d« }|j d« }|d u xr |d u }t j ||¬« }|xj
|
t j z c_ | xr |j dd« |_ |j d« }|(|rt j nt j |_
|
nÎt |t « r(|rt j nt j |_
|
nt |t « r|j « }|dv rt j |_
|
n\|dk( rt j |_
|
nA|d v rt j |_
|
n'|rt j nt j |_
|
d
|
|v r5|j |d
|
|j d « |j d « ¬ « d|v r|j! |d « |xj" t j$ z c_ |xj" t j& z c_ |S )Nrf rg )Úcafilerg rj Trk )ÚnoneÚ0ÚfalseÚnoÚoptional)ÚrequiredÚ1ÚtrueÚyesrh ra r3 )Úkeyfiler3 ri )r~ rN Ú
|
SSLContextr_ Úcreate_default_contextÚ verify_flagsÚVERIFY_X509_STRICTrj Ú CERT_NONEÚ CERT_REQUIREDrk rs r ÚlowerÚ CERT_OPTIONALÚload_cert_chainÚ set_ciphersÚoptionsÚ OP_NO_SSLv2Ú OP_NO_SSLv3)r Ússlprf rg Úhasnocar Úverify_mode_values r r zConnection._create_ssl_ctxv s¼ Ü dCNNÔ +ØKØ XXd^Ø(Ó#Ø*Ò/ ¨4 Ü×(Ñ(°¸6ÔBð
|
×ÒS× 3Ñ 3Ð 3Ñ3Õà!([Ò M¨T¯X©XÐ6FÈÓ-MÔØ HH ]Ó 3ÐØ Ð $Ù/6cmm¼C×<MÑ<MCOÜ Ð)¬4Ô 0Ù3Dc× /Ò /Ì#Ï-É-COäÐ+¬SÔ1Ø$5×$;Ñ$;Ó$=Ð!Ø Ð$@Ñ@Ü"%§-¡-Ø" jÒ0Ü"%×"3Ñ"3Ø"Ð&FÑFÜ"%×"3Ñ"3á3:¤#§-¢-Ä×@QÑ@QØ T>Ø × Ñ ØV d§h¡h¨u£oÀÇÁÈÓ@Tð ô ð tÑ Ø OOD NÔ +Ø sÑ& Ø sÑ& Ø
|
r! c óD | j rt j d« d| _ | j yt j
|
ddt j « } | j |« | j « y# t $ r Y w xY w# | j « w xY w)z÷
|
Send the quit message and close the socket.
|
|
See `Connection.close() <https://www.python.org/dev/peps/pep-0249/#Connection.close>`_
|
in the specification.
|
|
:raise Error: If the connection is already closed.
|
úAlready closedTNú<iBr ) Ú_closedr ÚErrorr r r r ÚCOM_QUITÚ _write_bytesr` Ú _force_close)r Ú send_datas r r¦ zConnection.close s ð <<Ü))Ð ,Ó-Ð -Ø Ø ::Ð Ø ÜKK q¬'×*:Ñ*:Ó; ð Ø × Ñ iÔ (ð × Ñ Õ øô ò Ù ð ûð × Ñ Õ ús$ Á A> Á> B
|
ÂB Â B
|
Â
|
B Â B c ó | j duS )z&Return True if the connection is open.N)r r£ s r ÚopenzConnection.open´ s ð zz Ð%Ð%r! c óÈ | j r| j j « | j r | j j « d| _ d| _ y# Y xY w)z&Close connection without QUIT message.N)Ú_rfiler¦ r r£ s r rÌ zConnection._force_close¹ sO à ;;Ø KK× Ñ Ô Ø ::ð Ø
|
|
× Ñ Ô"ð
|
Ø øð Ùús ´A Á A!c óp t |« | _ | j « }||k7 r| j « y y r^ )rs r Úget_autocommitÚ_send_autocommit_mode)r r Úcurrents r rC zConnection.autocommitÇ s5 Ü # E{Ô Ø×%Ñ%Ó'Ø GÒ Ø × &Ñ &Õ (ð r! c óN t | j t j z « S r^ )rs Ú server_statusr ÚSERVER_STATUS_AUTOCOMMITr£ s r rÓ zConnection.get_autocommitÍ s ÜD×&Ñ&¬ ×)OÑ)OÑOÓPÐPr! c óÆ | j « }|j « s$t j t j
|
d« t |« }|j | _ |S )NzCommand Out of Sync)Ú _read_packetÚ is_ok_packetr ÚOperationalErrorr ÚCR_COMMANDS_OUT_OF_SYNCr r× )r ÚpktÚoks r Ú_read_ok_packetzConnection._read_ok_packetÐ sZ Ø× Ñ Ó!Ø× Ñ Ô!Ü×&Ñ&Ü×*Ñ*Ø%óð ô SÓ !Ø × -Ñ -ÔØ r! c ó | j t j d| j | j « z « | j « y)z3Set whether or not to commit after every execute().zSET AUTOCOMMIT = %sN)Ú_execute_commandr Ú COM_QUERYÚescaper rà r£ s r rÔ z Connection._send_autocommit_modeÛ s> à × Ñ Ü × Ñ Ð 4°t·{±{À4×CWÑCWÓ7XÑ Xô
|
ð × Ñ Õ r! c ód | j t j d« | j « y)zBegin transaction.ÚBEGINN©râ r rã rà r£ s r ÚbeginzConnection.beginâ s$ à × Ñ g× /Ñ /°Ô9Ø × Ñ Õ r! c ód | j t j d« | j « y)z¨
|
Commit changes to stable storage.
|
|
See `Connection.commit() <https://www.python.org/dev/peps/pep-0249/#commit>`_
|
in the specification.
|
ÚCOMMITNrç r£ s r ÚcommitzConnection.commitç s& ð × Ñ g× /Ñ /°Ô:Ø × Ñ Õ r! c ód | j t j d« | j « y)z
|
Roll back the current transaction.
|
|
See `Connection.rollback() <https://www.python.org/dev/peps/pep-0249/#rollback>`_
|
in the specification.
|
ÚROLLBACKNrç r£ s r ÚrollbackzConnection.rollbackñ s& ð × Ñ g× /Ñ /°Ô<Ø × Ñ Õ r! c ó | j t j d« t | « }|j « |j
|
S )z%Send the "SHOW WARNINGS" SQL command.z SHOW WARNINGS)râ r rã Ú MySQLResultry Úrows)r Úresults r Ú show_warningszConnection.show_warningsû s5 à × Ñ g× /Ñ /° ÔAÜ TÓ"Ø Ø{{Ðr! c ód | j t j |« | j « y)zI
|
Set current db.
|
|
:param db: The name of the db.
|
N)râ r Ú COM_INIT_DBrà )r rY s r Ú select_dbzConnection.select_db s& ð × Ñ g× 1Ñ 1°2Ô6Ø × Ñ Õ r! c ó t |t « rd| j |« z dz S t |t t f« r$| j |« }| j rd|z }|S t j || j |¬« S )zxEscape whatever value is passed.
|
|
Non-standard, for internal use; do not use this in your applications.
|
ú'Ú_binary)Úmapping)
|
r~ r Ú escape_stringr+ Ú bytearrayÚ _quote_bytesr r Ú escape_itemr8 )r Úobjrú Úrets r rä zConnection.escape sx ô
|
c3Ô Ø×+Ñ+¨CÓ0Ñ0°3Ñ6Ð 6Ü cE¤9Ð-Ô .Ø×#Ñ# CÓ(CØ×"Ò"Ø #oØJÜ×%Ñ% c¨4¯<©<ÀÔIÐIr! c ó: | j || j « S )zkAlias for escape().
|
|
Non-standard, for internal use; do not use this in your applications.
|
)rä r )r rÿ s r ÚliteralzConnection.literal s ð
|
{{3 § ¡ Ó.Ð.r! c ó | j t j z r|j dd« S t j
|
|« S )Nrø z'')r× r Ú"SERVER_STATUS_NO_BACKSLASH_ESCAPESÚreplacer rû ©r Úss r rû zConnection.escape_string s8 Ø × Ñ ¤ × PÑ PÒ PØ99S $Ó'Ð 'Ü×'Ñ'¨Ó*Ð*r! c óÈ | j t j z r1dj |j dd« j dd« « S t j |« S )Nz'{}'ó 's ''ÚasciiÚsurrogateescape)r× r r Úformatr Údecoder Ú escape_bytesr s r rý zConnection._quote_bytes% sV Ø × Ñ ¤ × PÑ PÒ PØ==Ø $ Ó&×-Ñ-¨gÐ7HÓIóð ô ×&Ñ& qÓ)Ð)r! c ó8 |r || « S | j | « S )a
|
Create a new cursor to execute queries with.
|
|
:param cursor: The type of cursor to create. None means use Cursor.
|
:type cursor: :py:class:`Cursor`, :py:class:`SSCursor`, :py:class:`DictCursor`,
|
or :py:class:`SSDictCursor`.
|
)r? )r Úcursors r r zConnection.cursor, s" ñ Ù$<Ð Ø× Ñ Ó%Ð%r! c óà t |t « r |j | j d« }| j t
|
j |« | j |¬« | _ | j S )Nr ©Ú
|
unbuffered) r~ r r r râ r rã Ú_read_query_resultr )r Úsqlr s r ÚqueryzConnection.query9 s[ ô c3Ô Ø**T]]Ð,=Ó>CØ × Ñ g× /Ñ /°Ô5Ø "× 5Ñ 5ÀÐ 5Ó LÔØ×"Ñ"Ð"r! c óH | j |¬« | _ | j S )Nr )r r )r r s r Ú next_resultzConnection.next_resultB s$ Ø "× 5Ñ 5ÀÐ 5Ó LÔØ×"Ñ"Ð"r! c ó | j S r^ )r r£ s r Ú affected_rowszConnection.affected_rowsF ó Ø×"Ñ"Ð"r! c ód t |t « s t d« | j d|d« y )Nz thread_id must be an integerzKILL Úd)r~ r} Ú TypeErrorr )r Ú thread_ids r ÚkillzConnection.killI s- Ü)¤SÔ)ÜÐ :Ó;Ð ;Ø
|
|
U9 Q-Ð(Õ)r! c ó8 | j *|r| j « d}nt j d« | j t
|
j d« | j « y# t $ r' |r#| j « | j d« Y y w xY w)zÛ
|
Check if the server is alive.
|
|
:param reconnect: If the connection is closed, reconnect.
|
:type reconnect: boolean
|
|
:raise Error: If the connection is closed and reconnect=False.
|
NFrÆ r0 )
|
r r r rÉ râ r ÚCOM_PINGrà r` Úping)r Ú reconnects r r# zConnection.pingN s ð ::Ð ÙØ Ø ! äiiÐ 0Ó1Ð1ð Ø × !Ñ !¤'×"2Ñ"2°BÔ 7Ø × Ñ Õ "øÜò ÙØ Ø %Ö àð ús ¸0A) Á),BÂBc ó& | j |« y)z,Deprecated. Use set_character_set() instead.N)Úset_character_set)r r8 s r Ú set_charsetzConnection.set_charsetg s ð × Ñ wÕ'r! c óØ t |« j }|r d| d| }nd| }| j t j |« | j « || _ || _ || _ y)z
|
Set charaset (and collation)
|
|
Send "SET NAMES charset [COLLATE collation]" query.
|
Update Connection.encoding based on charset.
|
z
|
SET NAMES z COLLATE N)r r râ r rã rÚ r8 r9 )r r8 r9 r r s r r& z Connection.set_character_seto sl ô # 7Ó+×4Ñ4á Ø ¨°9°+Ð>Eà Ð*EØ × Ñ g× /Ñ /°Ô7Ø ×ÑÔØ Ø Ø"r! c ó6 d| _ || j rt j t j t j « }|j | j « |j | j « d| _ d| _ t rôt d« nèi }| j | j df|d< t j | j | j f| j fi |¤} d| j | j fz | _ t r t d« |j' t j( t j* d « |j' t j, t j. d « |j d « || _ |j3 d
|
« | _ d| _ | j9 « | j; « | j= | j> | j@ « | jB =| jE « }|jG d | jB f« |jI « | jJ ;| jE « }|jG | jJ « |jI « | jL | jO | jL « y y # t $ r)}|j" t" j$ k( rY d }~) d }~ww xY w# tP $ r}| jS « tU |t tV f« rrtY jZ t\ j^ d | j d | d« }||_0 tc jd « |_1 t rt |jb « | d }~ww xY w)NFzLocalhost via UNIX socketTzconnected using unix_socketr Úsource_addressz socket %s:%dzconnected using socketr ÚrbzSET sql_mode=%sz!Can't connect to MySQL server on z (ú))3rÈ r6 re ÚAF_UNIXÚ SOCK_STREAMÚ
|
settimeoutrA r r Ú_secureÚDEBUGÚprintrJ Úcreate_connectionr4 r7 ÚOSErrorÚerrnoÚEINTRÚ
|
setsockoptÚ IPPROTO_TCPÚ TCP_NODELAYÚ
|
SOL_SOCKETÚ SO_KEEPALIVEr ÚmakefilerÑ Ú _next_seq_idÚ_get_server_informationÚ_request_authenticationr& r8 r9 r: r Úexecuter¦ r@ r rC Ú BaseExceptionrÌ r~ ÚIOErrorr rÜ r ÚCR_CONN_HOST_ERRORÚoriginal_exceptionÚ tracebackÚ
|
format_exc)r ÚsockÚkwargsÚeÚcÚexcs r r zConnection.connect sÖ Ø ðS Ø|Ø×#Ò#Ü!==¬¯ © ¼×9KÑ9KÓLDØOO D×$8Ñ$8Ô9ØLL ×!1Ñ!1Ô2Ø%@DNØ#'DLÝ Ü Ð ;Õ<à FØ×(Ñ(Ð4Ø48×4EÑ4EÀqÐ3IÐ /Ñ0Ø ð"Ü#)×#;Ñ#;Ø!%§¡¨D¯I©IÐ 6¸×8LÑ8Lñ$ ØPVñ$ Dð "ð
|
&4°t·y±yÀ$Ç)Á)Ð6LÑ%LDNÝ Ü Ð 6Ô7ØOO¤F×$6Ñ$6¼×8JÑ8JÈAÔNØOO¤F×$5Ñ$5´v×7JÑ7JÈAÔNØ Ô%à DJØ --¨Ó-DKØ !DÔ à × (Ñ (Ô *Ø × (Ñ (Ô *ð × "Ñ " 4§<¡<°· ± Ô @à}}Ð(ØKKMØ Ð+¨d¯m©mÐ-=Ô>Ø à× Ñ Ð,ØKKMØ $×+Ñ+Ô,Ø à×#Ñ#Ð/Ø × 4Ñ 4Õ5ð 0øôW 'ò "Ø ww¬%¯+©+Ò 5Ý (Ø !ûð"ûôZ ò Ø × Ñ Ô ä!g¤wÐ /Ô0Ü×*Ñ*Ü×)Ñ)Ø7¸¿ ¹ °}ÀBÀqÀcÈÐKóð
|
*+Ô&Ü )× 4Ñ 4Ó 6 ÝÜ#--Ô(Ø ð
|
ûð% úsJ B7K1 Ã7J< Ã8GK1 Ê< K.Ë K)Ë"K1 Ë(K)Ë)K.Ë.K1 Ë1 NË:BNÎNc óÒ t t |« « t | j g« z |z }t r t |« | j |« | j dz dz | _ y)zvWrites an entire "mysql packet" in its entirety to the network
|
adding its length and sequence number.
|
r é N)r Úlenr+ r= r1 r rË )r ÚpayloadÚdatas r Ú write_packetzConnection.write_packetÚ s[ ô 3w<Ó(¬5°$×2CÑ2CÐ1DÓ+EÑEÈÑOÝ Ü Ô Ø ×Ñ$Ô Ø !× .Ñ .°Ñ 2°cÑ 9Õr! c óÎ t « } | j d« }t j d|« \ }}}||dz z }|| j k7 r]| j « |dk( r$t j t j d« t j d|| j fz « | j dz d z | _ | j |« }t r t |« ||z }|t k rnè |t |« | j « } | j! « rE| j" )| j" j$ du rd
|
| j" _ | j' « | S ) a! Read an entire "mysql packet" in its entirety from the network
|
and return a MysqlPacket type that represents the results.
|
|
:raise OperationalError: If the connection to the MySQL server is lost.
|
:raise InternalError: If the packet sequence number is wrong.
|
Té z<HBBé r ú,Lost connection to MySQL server during queryz1Packet sequence number wrong - got %d expected %dr rM F)rü Ú _read_bytesr Úunpackr= rÌ r rÜ r ÚCR_SERVER_LOSTÚ InternalErrorr1 r ÚMAX_PACKET_LENr+ r Úis_error_packetr Úunbuffered_activeÚraise_for_error)
|
r Ú packet_typeÚbuffÚ packet_headerÚbtrlÚbtrhÚ packet_numberÚ bytes_to_readÚ recv_dataÚpackets
|
r rÚ zConnection._read_packetæ sZ ô {ØØ × ,Ñ ,¨QÓ /Mô )/¯ © °f¸mÓ(LÑ %D$ Ø D¨B¡JÑ /MØ × 1Ñ 1Ò1Ø×!Ñ!Ô#Ø AÒ%ä ×.Ñ.Ü×)Ñ)ØFóð ô ×'Ñ'ØGØ$ d×&7Ñ&7Ð8ñ9óð ð "&×!2Ñ!2°QÑ!6¸#Ñ =DÔ à ×(Ñ(¨ Ó7IÝÜIÔ&Ø IÑ Dà ~Ò-Øð5 ñ8 U 4[¨$¯-©-Ó8Ø × !Ñ !Ô #Ø||Ð'¨D¯L©L×,JÑ,JÈdÑ,RØ16 Ô.Ø × "Ñ "Ô $Ø r! c ó | j j | j « | j j |« } t |« |k r4| j « t j t j d« |S # t
|
$ r_}|j t j k( rY d }~| j « t j t j d| d« d }~wt $ r | j « w xY w)Nz.Lost connection to MySQL server during query (r, rU )r r/ r rÑ ry r4 r5 r6 rÌ r rÜ r rX rA rN )r Ú num_bytesrP rI s r rV zConnection._read_bytes së Ø
|
|
× Ñ d× 0Ñ 0Ô1Øð Ø{{×'Ñ'¨ Ó2Øô t9yÒ Ø × Ñ Ô Ü×&Ñ&Ü×!Ñ!Ð#Qóð ð øô# ò Ø77ekkÒ)Ü Ø×!Ñ!Ô#Ü×*Ñ*Ü×%Ñ%ØDÀQÀCÀqÐIóð ûô !ò à×!Ñ!Ô#Øð ús ¨B  D  C+Â38C+Ã+ D c ó | j j | j « | j j |« y # t $ r=}| j « t j t j d|d« d }~ww xY w)Nz MySQL server has gone away (r, )
|
r r/ r Úsendallr4 rÌ r rÜ r ÚCR_SERVER_GONE_ERROR)r rP rI s r rË zConnection._write_bytes* su Ø
|
|
× Ñ d× 1Ñ 1Ô2ð Ø JJ× Ñ tÕ $øÜò Ø × Ñ Ô Ü×&Ñ&Ü×'Ñ'Ð+GÈÀuÈAÐ)Nóð ûð ús §A Á B Á 8BÂB c óÌ d | _ t | « }|r|j « n|j « || _ |j |j | _ |j
|
S r^ )r rð Úinit_unbuffered_queryry r× r )r r rò s r r z Connection._read_query_result4 sX Ø Ü TÓ"Ù Ø × (Ñ (Õ *à KKMØ Ø × Ñ Ð +Ø!'×!5Ñ!5DÔ Ø×#Ñ#Ð#r! c óH | j r| j j S y©Nr )r Ú insert_idr£ s r rp zConnection.insert_id@ s Ø <<Ø<<×)Ñ)Ð )àr! c ó8 | j st j dd« | j | j j r/t j d« | j j « | j j r'| j « | j j r'd| _ t |t « r|j | j « }t t t! |« dz « }t# j$ d||« }||d|dz
|
z }| j' |« t( r t+ |« d| _ |t k ry||dz
|
d } t t t! |« « }| j/ |d| « ||d }|s
|
|t k ry?)z~
|
:raise InterfaceError: If the connection is closed.
|
:raise ValueError: If no username was specified.
|
r r0 Nz.Previous unbuffered result was left incompleter rÇ )r r ÚInterfaceErrorr r\ ÚwarningsÚwarnÚ_finish_unbuffered_queryÚhas_nextr r~ r r r ÚminrZ rN r r rË r1 r r= rQ )r Úcommandr Ú packet_sizeÚpreluderf s r râ zConnection._execute_commandF s` ð
|
zzÜ×$Ñ$ Q¨Ó+Ð +ð <<Ð #Ø||×-Ò-Ü Ð NÔOØ ×5Ñ5Ô7Ø,,×'Ò'Ø× Ñ Ô"ð ,,×'Ó'à DLä c3Ô Ø**T]]Ó+Cä.¬#¨c«(°Q©,Ó7 ô ++e [°'Ó:Ø3Ð 0 ¨q¡ Ð1Ñ1Ø ×Ñ&Ô!Ý Ü Ô Ø Ôà Ò 'Ø à+ /Ð#Ð$ØÜ n¬c°#«hÓ7KØ × Ñ c , ;Ð /Ô 0ØklÐ#CÙ;¬ Ò7Øð r! c ó t | j j dd« d « dk\ r#| xj t j
|
z c_ | j t d« t | j « j }t | j t « r*| j j | j « | _ t j d| j t" |d« }| j$ r| j& t j( z rn| j+ |« | j, j/ | j0 | j2 ¬« | _ | j0 j5 d « | _ d
|
| _ || j z d z }d}d }| j: d k( r.d}t= j> | j@ | jB « }n| j: d k( r-d}t= j> | j@ | jB « }nÆ| j: dk( r\d}| j@ r<tD r tG d« t= jH | j@ | jB « }nmtD rgtG d« n[| j: dk( rLd}| j$ r-| j& t j( z r| j@ d z }n| j@ rd}nd }| j& t jJ z r|tM tO |« « |z z }nK| j& t jP z r&|t j dtO |« « |z z }n||d z z }| jR rs| j& t jT z rVt | jR t « r*| jR j | j « | _) || jR d z z }| j& t jV z r ||xs dd z z }| j& t jX z rd}| jZ j] « D ][ \ }}|j d« }|tM tO |« « |z z }|j d« }|tM tO |« « |z z }] |tM tO |« « |z z }| j+ |« | j_ « } | ja « rxtD r tG d« | jc « | je « }| j& t jV z r|| jg || « } n¢ti jj d« | jm « r}tD r tG d« | j: dk( rt= jn | | « } nF| j: dk( rt= jp | | « } n ti jj d| j: « tD r tG d « y y ) Nú.r r é zDid not specify a usernamez<iIB23sr! )Úserver_hostnamer+ Tó r0 Úmysql_native_passwordó mysql_native_passwordÚcaching_sha2_passwordó caching_sha2_passwordz caching_sha2: trying fast pathz caching_sha2: empty passwordÚsha256_passwordó sha256_passwordó ÚBúutf-8zreceived auth switchz$received unknown auth switch requestzreceived extra dataz(Received extra packet for auth method %rzSucceed to auth)9r} Úserver_versionÚsplitr> r Ú MULTI_RESULTSr2 r* r r8 Úidr~ r r r r r rZ rN Úserver_capabilitiesr rQ r Ú wrap_socketr r4 r< rÑ r0 Ú_auth_plugin_namer Úscramble_native_passwordr3 Úsaltr1 r2 Úscramble_caching_sha2Ú PLUGIN_AUTH_LENENC_CLIENT_DATAr- rN ÚSECURE_CONNECTIONrY r Ú PLUGIN_AUTHÚ CONNECT_ATTRSr r rÚ Úis_auth_switch_requestÚ
|
read_uint8Ú read_stringÚ _process_authr rÜ Úis_extra_auth_dataÚcaching_sha2_password_authÚsha256_password_auth)
|
r Ú
|
charset_idÚ data_initrP ÚauthrespÚ plugin_nameÚ connect_attrsr r Ú auth_packets
|
r r? z"Connection._request_authenticationq sÉ ä t×"Ñ"×(Ñ(¨¨aÓ0°Ñ3Ó 4¸Ò 9Ø × Ò ¤× 4Ñ 4Ñ 4Õ à 99Ð Ü Ð 9Ó:Ð :ä$ T§\¡\Ó2×5Ñ5
|
Ü dii¤Ô %Ø ×(Ñ(¨¯ © Ó7DIäKKØ t×'Ñ'¬ ¸ÀSó
|
ð 88×0Ñ0´6·:±:Ò=Ø × Ñ iÔ (à ×-Ñ-¨d¯j©jÈ$Ï)É)Ð-ÓTDJØ **×-Ñ-¨dÓ3DKØ DLà499Ñ$ uÑ,àØ à × !Ñ ! RÒ 'Ø KÜ ×5Ñ5°d·m±mÀTÇYÁYÓOHØ × #Ñ #Ð'>Ò >Ø2KÜ ×5Ñ5°d·m±mÀTÇYÁYÓOHØ × #Ñ #Ð'>Ò >Ø2KØ}}ÝÜÐ:Ô;Ü ×6Ñ6°t·}±}ÀdÇiÁiÓPåÜÐ8Õ9Ø × #Ñ #Ð'8Ò 8Ø,KØxxD× 4Ñ 4´v·z±zÒ AØ ==¨5Ñ0Ø Ø à à × #Ñ #¤f×&KÑ&KÒ KØ K¤ H£ Ó.°Ñ9Ñ 9DØ × %Ñ %¬×(@Ñ(@Ò @Ø FKK ¤S¨£]Ó3°hÑ>Ñ >Dà HuÑ$Ñ $Dà 77t×/Ñ/´&×2HÑ2HÒHÜ$''¤3Ô'Ø ''..¨¯ © Ó7Ø DGGeOÑ #Dà × #Ñ #¤f×&8Ñ&8Ò 8Ø [Ò' C¨5Ñ0Ñ 0Dà × #Ñ #¤f×&:Ñ&:Ò :Ø MØ ×+Ñ+×1Ñ1Ó3ò 91ØHHWÓ%Ø ¤¬S°«VÓ!4°qÑ!8Ñ8 ØHHWÓ%Ø ¤¬S°«VÓ!4°qÑ!8Ñ8 ð 9ð
|
K¤ MÓ 2Ó3°mÑCÑ CDà ×Ñ$Ô Ø×'Ñ'Ó) ð × -Ñ -Ô /ÝÜÐ,Ô-à × "Ñ "Ô $Ø%×1Ñ1Ó3Kà×(Ñ(¬6×+=Ñ+=Ò=Ø Ð+à "× 0Ñ 0°¸kÓ J ä×*Ñ*Ð+QÓRÐRØ × +Ñ +Ô -ÝÜÐ+Ô,à×%Ñ%Ð)@Ò@Ü #× >Ñ >¸tÀ[Ó Q Ø×'Ñ'Ð+<Ò<Ü #× 8Ñ 8¸¸{Ó K ä×*Ñ*Ø>À×@VÑ@Vóð õ Ü Ð#Õ $ð r! c ó | j |« }|r |j |« S |dk( rt j | |« S |dk( rt j | |« S |dk( r0t j | j |j « « }n|dk( r0t j | j |j « « }n[|d k( r3t j | j |j « « d
|
z }n#|d k( r| j d
|
z }n |dk( rá|} |j! « }|d z d k( }|dz dk( }|j « } | dk( r | j# | j d
|
z « nT|r*d}
|
|j% || « }
|
| j# |
|
d
|
z « n(t j t
|
j d| d« | j+ « }|j- « |j/ « s|r |S Þt j t
|
j d|z « | j# |« | j+ « }|j- « |S # t $ r= |dk7 r4t j t
|
j d| dt |« d« Y sw xY w# t $ r, t j t
|
j d| d|d« t& $ r1 t j t
|
j( d| d|d|
|
d| « w xY w)Ns dialogúAuthentication plugin 'ú' not loaded: - z missing authenticate methodr r
r s client_ed25519s mysql_old_passwordr s mysql_clear_passwordé é r s
|
Password: z3no response - TypeError within plugin.prompt methodz missing prompt methodz' z' didn't respond with string. Returned 'z ' to prompt z' not configuredz)Authentication plugin '%s' not configured)Ú_get_auth_plugin_handlerÚ authenticateÚAttributeErrorr rÜ r ÚCR_AUTH_PLUGIN_CANNOT_LOADr r r r r r3 Úread_allÚed25519_passwordÚscramble_old_passwordr rQ Úpromptr ÚCR_AUTH_PLUGIN_ERRrÚ Ú check_errorrÛ ) r r¡ r£ ÚhandlerrP rÞ ÚflagÚechoÚlastr° Úresps r r zConnection._process_authß s9 Ø×/Ñ/° Ó<Ù ð Ø ×+Ñ+¨KÓ8Ð8ð Ð2Ò 2Ü×3Ñ3°D¸+ÓFÐ FØ Ð .Ò .Ü×-Ñ-¨d°KÓ@Ð @Ø Ð 4Ò 4Ü×1Ñ1°$·-±-À×AUÑAUÓAWÓXDØ Ð -Ò -Ü×)Ñ)¨$¯-©-¸×9MÑ9MÓ9OÓPDØ Ð 1Ò 1ä×+Ñ+¨D¯M©M¸;×;OÑ;OÓ;QÓRØñò ð Ð 3Ò 3à== 5Ñ(DØ IÒ %Ø CØØ~~Ó'Ø t ¨Ñ,Ø t ¨Ñ,Ø à]Ò*Ø×%Ñ% d§m¡m°eÑ&;Õ<Ù ØPDðØ &~~¨d°FÓ ;Ø ×)Ñ)¨$°©,Õ7ô ×.Ñ.Ü×5Ñ5Ø1°+° Ð>NÐOóð ð ×'Ñ'Ó)ØÔ!Ø×#Ñ#Ô%©ØØJðE ôH ×&Ñ&Ü×-Ñ-Ø;¸kÑIóð ð
|
×Ñ$Ô Ø× Ñ Ó!Ø ÔØ
|
øôK "ò Ø )Ò+Ü ×.Ñ.Ü×5Ñ5Ø1°+° ð ?*Ü*.¨w«-Ð):Ð:VðXóð ò ,ð ûôL *ò Ü !× 2Ñ 2Ü × 9Ñ 9Ø 5°k°]ð C.Ø.5¨[Ð8Nð Pó ð ô
|
%ò Ü !× 2Ñ 2Ü × 1Ñ 1Ø 5°k°]ð C Ø '{Ð*QÐRVÐQYÐYeÐflÐeoð qó ð ðús I Å5&J ÉAJÊJÊ A-L
|
c óB | j j |« }|s:t |t « r*| j j |j d« « }|r || « }|S d }|S # t
|
$ r, t j t j d| d|d« w xY w)Nr
|
r¥ r¦ z- cannot be constructed with connection object)
|
r r_ r~ r+ r r r rÜ r r¬ )r r¡ Ú plugin_classr³ s r r© z#Connection._get_auth_plugin_handler+ s² Ø×,Ñ,×0Ñ0°Ó= Ù¤
|
¨;¼Ô >Ø ×0Ñ0×4Ñ4°[×5GÑ5GÈÓ5PÓQLÙ ð Ù& tÓ,ð ð GØøô ò Ü×*Ñ*Ü×1Ñ1Ø-¨k¨]ð ;&Ø&2Ð%5Ð5bðdóð ð ús ÁA) Á)5B c ó | j d S ro )Úserver_thread_idr£ s r r zConnection.thread_id= s Ø×$Ñ$ QÑ'Ð'r! c ó | j S r^ )r8 r£ s r Úcharacter_set_namez Connection.character_set_name@ s Ø||Ðr! c ó | j S r^ )r r£ s r Ú get_host_infozConnection.get_host_infoC s Ø~~Ð r! c ó | j S r^ )Úprotocol_versionr£ s r Úget_proto_infozConnection.get_proto_infoF s Ø×$Ñ$Ð$r! c ó d}| j « }|j « }|| | _ |dz }|j d|« }||| j d« | _ |dz }t j d|||dz « | _ |dz }|||dz | _ |dz }t j d |||d
|
z « d | _
|
|d
|
z }t |« |d z k\ rt j d |||d z « \ }}}}|d z }|| _ t |« j | _ || _ t$ rt' d |z « | xj |dz z c_
|
t$ r t' d|« t) d|dz
|
« }|dz }t |« |z k\ r | xj ||||z z c_ ||z }|dz }| j t* j, z rXt |« |k\ rJ|j d|« }|dk r||d j d« | _ n||| j d« | _ t0 t0 | _ y y # t $ r d | _ Y *w xY w)Nr r r rm r rS é é r% r¨ r§ z<BHHBzserver_status: %xrT z salt_len:é r1 r )rÚ Ú get_all_datarÁ Úfindr r r rW r» r r rN Úserver_languager ÚnameÚserver_charsetÚKeyErrorr× r1 r2 Úmaxr r r Ú_DEFAULT_AUTH_PLUGIN) r r, rf rP Ú
|
server_endÚlangÚstatÚcap_hÚsalt_lens r r> z"Connection._get_server_informationI s\ Ø Ø×"Ñ"Ó$Ø×"Ñ"Ó$à $ Q¡Ô Ø QàYYu aÓ(
|
Ø " 1 ZÐ 0× 7Ñ 7¸Ó AÔØ Nä &§ ¡ ¨d°D¸¸QÀ¹U°OÓ DÔ Ø QàQ UO Ø Qä#)§=¡=°°t¸AÀÀAÁ°Ó#GÈÑ#JÔ Ø Qä t9AÒ Ü*0¯-©-¸ÀÀaÈ!ÈaÉ%À Ó*QÑ 'D$xØ FAð $(DÔ ð +Ü&3°DÓ&9×&>Ñ&>Ô#ð
|
"&DÔ ÝÜÐ)¨DÑ0Ô1à × $Ò $¨°© Ñ 3Õ $ÝÜk 8Ô,Ü2x¨!|Ó,Hð
|
Rä t9H Ò $à IIa ! h¡,Ð/Ñ /IØ MAà Qà × #Ñ #¤f×&8Ñ&8Ò 8¼SÀ»YÈ!º^ð 5¨!Ó,JØA~à)-¨a¨b¨¯ © ¸Ó)AÕ&à)-¨a°
|
Ð);×)BÑ)BÀ7Ó)KÔ&ä Ð +Ü%9DÕ "ð ,øôI ò +à&*×#ð +ús ÄH3 È3IÉIc ó | j S r^ )r r£ s r Úget_server_infozConnection.get_server_info r r! r^ )F)T)EÚ__name__Ú
|
__module__Ú __qualname__Ú__doc__r rÑ r rÈ r0 r r r¤ r¨ r r¦ ÚpropertyrÏ rÌ Ú__del__rC rÓ rà rÔ rè rë rî ró rö rä r rû rý r r r r r r# r' r& r rQ r rÚ rV rË r rp râ r? r r© r r½ r¿ r r> rÕ r ÚWarningrÉ rr Ú DatabaseErrorÚ DataErrorrÜ ÚIntegrityErrorrY ÚProgrammingErrorÚNotSupportedErrorr¢ r! r r/ r/ ^ s ñEðN EØ FØÐØGØGð
|
ØØ ØØØ ØØØØ Ø ØØØØØØ ØØØ+ØØ ØØØØØØ Ø ØØØØØ Ø Ø ØØØØ ôUAòFòò&òP ð, ñ&ó ð&ò
|
ð Gò)ò Qò ò ò ò
|
ò òò ó Jò /ò+ò
|
*ó
|
&ó#ó#ò#ò*ó
|
ò2(ó#ó(Uòn
|
:ð (3ó )òVò2ó
|
$òò )òVl%ò\JòXò$(ò ò ò%òB:òH#ð kkGØ IIEØ×'Ñ'NØ×%Ñ%MØ IØ×+Ñ+ÐØ×'Ñ'NØ×%Ñ%MØ×+Ñ+ÐØ×-Ñ-Ñr! r/ c óZ e Zd Zd Zd Zd Zd Zd Zd Zd Z d Z
|
d Z d
|
Z d Z d Zd Zy)rð c ó || _ d| _ d| _ d| _ d| _ d| _ d| _ d| _ d| _ d| _ d| _
|
y)z.
|
:type connection: Connection
|
Nr F) Ú
|
connectionr rp r× Ú warning_countÚmessageÚ field_countÚ descriptionrñ rv r\ )r rä s r r zMySQLResult.__init__ sW ð %Ø !ÔØ Ø !ÔØ ÔØ Ø ÔØ ÔØ Ø Ø!&Õ r! c ó> | j r| j « y y r^ )r\ ru r£ s r rÛ zMySQLResult.__del__ s Ø × !Ò !Ø × )Ñ )Õ +ð "r! c ó
|
| j j « }|j « r| j |« n3|j « r| j |« n| j |« d | _ y # d | _ w xY wr^ )rä rÚ rÛ rà Úis_load_local_packetÚ_read_load_local_packetÚ_read_result_packet©r Ú first_packets r ry zMySQLResult.read± sj ð
|
#Ø ??×7Ñ7Ó9Là×(Ñ(Ô*Ø×$Ñ$ \Õ2Ø ×2Ñ2Ô4Ø×,Ñ,¨\Õ:à×(Ñ(¨ Ô6à "DOødDOús A/A9 Á9 Bc ó\ | j j « }|j « rd| _ | j |« y|j « r | j |« d| _ y|j « | _ | j « d| _ d| _
|
y# d| _ w xY w)zw
|
:raise OperationalError: If the connection to the MySQL server is lost.
|
:raise InternalError:
|
Nl ÿÿÿÿ T) rä rÚ rÛ rà rë rì Úread_length_encoded_integerrç Ú_get_descriptionsr r\ rî s r rm z!MySQLResult.init_unbuffered_query¾ s ð
|
×3Ñ3Ó5 à × $Ñ $Ô &Ø "DOØ × Ñ Õ .Ø × .Ñ .Ô 0ð 'Ø×,Ñ,¨\Ô:à"&à +× GÑ GÓ IDÔ Ø × "Ñ "Ô $ð
|
"6DÔ Ø%)DÕ "øð #'ús ÁB" Â" B+c óæ t |« }|j | _ |j | _ |j | _ |j | _ |j
|
| _ |j | _ y r^ )r r rp r× rå ræ rv )r rï Ú ok_packets r rà zMySQLResult._read_ok_packet× s] Ü# LÓ1 Ø &× 4Ñ 4ÔØ"×,Ñ,Ø &× 4Ñ 4ÔØ &× 4Ñ 4ÔØ ×(Ñ( Ø!×*Ñ* r! c ó¼ | j j s t d« t |« }t |j
|
| j « } |j « | j j « }|j « s$t j t j d« | j |« y # | j j « xY w)NzF**WARN**: Received LOAD_LOCAL packet but local_infile option is false.zCommands Out of Sync)rä rt Ú RuntimeErrorr Ú LoadLocalFileÚfilenamerÍ rÚ rÛ r rÜ r rÝ rà )r rï Ú load_packetÚsenderrô s r rì z#MySQLResult._read_load_local_packetà s» Ø×,Ò,Ü ØXóð ô -¨\Ó: Ü {× 3Ñ 3°T·_±_ÓEð Ø × Ñ Ô ð
|
OO×0Ñ0Ó2 à×&Ñ&Ô(ä×&Ñ&Ü×*Ñ*Ø&óð ð × Ñ YÕ'øð Ø OO× (Ñ (Ô *Ø ús ÁB> Â> Cc ó |j « syt |« }|j | _ |j | _ y)NFT)Ú is_eof_packetr rå rv )r rf Úwps r Ú_check_packet_is_eofz MySQLResult._check_packet_is_eof÷ s9 Ø×#Ñ#Ô%Øô fÓ %Ø × -Ñ -ÔØ Ør! c ón |j « | _ | j « | j « y r^ )rñ rç rò Ú_read_rowdata_packetrî s r rí z MySQLResult._read_result_packet s+ Ø'×CÑCÓEÔØ × Ñ Ô Ø ×!Ñ!Õ#r! c óâ | j sy | j j « }| j |« rd| _ d | _ d | _ y | j |« }d| _ |f| _ |S )NFr )r\ rä rÚ rþ rñ Ú_read_row_from_packetr )r rf Úrows r Ú _read_rowdata_packet_unbufferedz+MySQLResult._read_rowdata_packet_unbuffered so à×%Ò%Ø ð ×-Ñ-Ó/Ø × $Ñ $ VÔ ,Ø%*DÔ "Ø "DOØ DIØ à×(Ñ(¨Ó0Ø ÔØF Ø
|
r! c óh | j rH | j j « }| j |« rd| _ d | _ | j rGy y # t j $ rH}|j
|
d t j t j fv rd| _ d | _ Y d }~y d }~ww xY w)Nr F)
|
r\ rä rÚ r rÜ Úargsr
|
Ú QUERY_TIMEOUTÚSTATEMENT_TIMEOUTrþ )r rf rI s r ru z$MySQLResult._finish_unbuffered_query s¤ ð ×$Ò$ð Ø ×5Ñ5Ó7ð ×(Ñ(¨Ô0Ø).Ô&Ø"&ð# ×$Õ$øô ×'Ñ'ò
|
Ø66!9Ü×$Ñ$Ü×(Ñ(ð!ñ ð
|
.3DÔ*Ø&*DOÜàûð
|
ús A ÁB1Á)=B,Â+B,Â,B1c óò g } | j j « }| j |« rd| _ n!|j | j |« « Tt |« | _ t |« | _ y)z:Read a rowdata packet for each data row in the result set.N) rä rÚ rþ Úappendr rN r Útuplerñ )r rñ rf s r r z MySQLResult._read_rowdata_packet2 si àØØ__×1Ñ1Ó3FØ×(Ñ(¨Ô0Ø"&ØØ KK×2Ñ2°6Ó:Ô ;ð ô ! YÔÜ$K r! c ó g }| j D ]X \ }} |j « }|/||j |« }t r t d|« | ||« }|j |« Z t |« S # t $ r Y t |« S w xY w)NzDEBUG: DATA = )r Úread_length_coded_stringÚ
|
IndexErrorr r1 r2 r
|
r )r rf r r Ú converterrP s r r z!MySQLResult._read_row_from_packet? s¥ ØØ#'§?¡?ò Ñ Hið Ø ×6Ñ6Ó8ð
|
Ð ØÐ'Ø ;; xÓ0DÝÜÐ*¨DÔ1Ø Ð(Ù$ T?DØ JJtÕ ð ô SzÐøô ò ñ ô SzÐð ús A5Á5 B Â B c óN g | _ g | _ | j j }| j j }g }t | j « D ] }| j j t « }| j j |« |j |j « « |j }|r6|t j k( r|}n"|t v r|j dk( rd}n|}nd}nd}| j j j# |« }|t j$ u rd}t& rt) d| d| « | j j ||f« | j j « } | j+ « sJ d« t- |« | _
|
y)z>Read a column descriptor packet for each column in the result.é? Nr
|
z DEBUG: field=z , converter=z Protocol error, expecting EOF)Úfieldsr rä r= r Úrangerç rÚ r r
|
rè Ú type_coder ÚJSONÚ
|
TEXT_TYPESÚ charsetnrr r_ Úthroughr1 r2 rü r )
|
r r= Ú conn_encodingrè r, ÚfieldÚ
|
field_typer r Ú
|
eof_packets
|
r rò z MySQLResult._get_descriptionsR si à Ø Øoo×1Ñ1 Ø ×0Ñ0 Ø ät×'Ñ'Ó(ó :AØOO×0Ñ0Ô1FÓGEØ KK× Ñ uÔ %Ø × Ñ u× 0Ñ 0Ó 2Ô 3Ø JÙØ ¤§ ¡ Ò0ð -HØ ¤:Ñ-Ø ¨"Ò,à#'à#0ð 'Hà Ø ×0Ñ0×4Ñ4°ZÓ@IØJ× .Ñ .Ñ.Ø ÝÜ e W¨L¸¸ ÐDÔEØ OO× "Ñ " H¨iÐ#8Ö 9ð; :ð> __×1Ñ1Ó3
|
Ø×'Ñ'Ô)ÐJÐ+JÓJÐ)Ü Ó-Õr! N)rÖ r× rØ r rÛ ry rm rà rì rþ rí r ru r r rò r¢ r! r rð rð sC ò'ò ,ò #ò*ò2+ò(ò. ò$ò
|
ò$'ò. òó&).r! rð c ó e Zd Zd Zd Zy)r÷ c ó || _ || _ y r^ )rø rä )r rø rä s r r zLoadLocalFile.__init__ s Ø Ø$r! c óH | j j st j dd« | j } t | j
|
d« 5 }t |j d« } |j |« }|sn|j |« & ddd« |j s|j d« yy# 1 sw Y (xY w# t $ r3 t j t j d| j
|
d« w xY w# |j s|j d« w w xY w) z3Send data packets from the local file to the serverr r0 r+ i @ NzCan't find file 'rø r! )rä r r rr rÏ rø rw rE ry rQ r4 rÜ r
|
ÚFILE_NOT_FOUNDrÈ )r ÚconnÚ open_filery Úchunks r rÍ zLoadLocalFile.send_data s à×$Ò$Ü×$Ñ$ Q¨Ó+Ð +Ø ??ð 'Üdmm TÓ*ð -¨iÜ !Ø×+Ñ+¨Yó ð Ø %NN¨;Ó 7EÙ Ø Ø×%Ñ% eÔ,ð ð ÷ -ð <<à×!Ñ! #Õ&ð ÷ -ð -ûô ò Ü×&Ñ&Ü×!Ñ!Ø# D§M¡M ?°!Ð4óð ð ûð <<à×!Ñ! #Õ&ð ús/ ºC Á>B6ÂC Â6B?Â;C Ã<C>Ã>D Ä D!N)rÖ r× rØ r rÍ r¢ r! r r÷ r÷ ~ s ò%ó'r! r÷ )<r5 rz re r rv rE rs r0 r r8 r r Ú constantsr r r r
|
r r r Úcursorsr Ú
|
optionfiler Úprotocolr r r r r r r r rN r Ú ImportErrorÚgetpassÚgetuserr
rÌ r4 r1 rÎ ÚBITÚBLOBÚ LONG_BLOBÚ MEDIUM_BLOBÚSTRINGÚ TINY_BLOBÚ
|
VAR_STRINGÚVARCHARÚGEOMETRYr r rZ r r- r/ rð r÷ r¢ r! r ú<module>r4 s= ðó
|
Û Û Û Û
|
Û Û å ç 3ß I× IÝ Ý Ý ÷÷ ÷ "ðÛàKð
|
Ûà"7??Ó$LØð ØÐ ð NNØOOØ×ÑØ×ÑØ×ÑØ×ÑØ×ÑØ×ÑØ×Ñð
|
|
ð àò$ò
|
|
÷&{.ñ {.÷|!_.ñ _.÷D 'ò 'øðy* ò Ø
|
CØKðûð XwÐ'ò ð Lð ús$ Á&D Á-D$ Ä D!Ä D!Ä$
|
D1Ä0D1
|
