§
    ¢”jºÙ  ã            	       ó"  — d dl Z d dlZd dlZd dlZd dlZd dlZd dlZddlmZ ddl	m
Z
mZ ddlmZmZmZmZmZmZ ddlmZ ddlmZ ddlmZ dd	lmZmZmZmZmZmZ dd
lmZm Z  	 d dl!Z!dZ"n# e#$ r dZ!dZ"Y nw xY w	 d dl$Z$ e$j%        ¦   «         Z&[$n# e#e'e(f$ r dZ&Y nw xY wdZ)dZ*ej+        ej,        ej-        ej.        ej/        ej0        ej1        ej2        ej3        h	Z4dZ5dZ6d„ Z7d„ Z8 G d„ d¦  «        Z9 G d„ d¦  «        Z: G d„ d¦  «        Z;dS )é    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                 ó<   — t          j        d| ¦  «        d d…         S )Nú<Ié   )ÚstructÚpack)Úns    úb/var/www/finuniver-perm.ru/html/portfolio/venv/lib/python3.11/site-packages/pymysql/connections.pyÚ_pack_int24r    F   s   € ÝŒ;�t˜QÑÔ   Ô#Ð#ó    c                 óR  — | dk     rt          d| z  ¦  «        ‚| dk     rt          | g¦  «        S | dk     rdt          j        d| ¦  «        z   S | dk     r dt          j        d	| ¦  «        d d
…         z   S | dk     rdt          j        d| ¦  «        z   S t          d| d›ddd›d�¦  «        ‚)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Ö   € Øˆ1‚u€uÝØTÐWXÑXñ
ô 
ð 	
ð 
ˆTŠˆÝ�a�S‰zŒzÐØ	
ˆgŠˆØ�œ T¨1Ñ-Ô-Ñ-Ð-Ø	
ˆgŠˆØ�œ T¨1Ñ-Ô-¨b¨q¨bÔ1Ñ1Ð1Ø	
ˆgŠˆØ�œ T¨1Ñ-Ô-Ñ-Ð-åØd˜ÐdÐdÐd¨WÐdÐdÐdÐdñ
ô 
ð 	
r!   c            )       ó<  — e Zd ZdZdZdZdZdZdZddddddddddddde	ddddddddddddddddddddddddddd	œ(d
„Z
d„ Zd„ Zd„ Zd„ Zed„ ¦   «         Zd„ ZeZd„ Zd„ Zd„ Zd„ Zd„ Zd„ Zd„ Zd„ Zd„ Zd7d„Zd„ Zd„ Zd„ Zd7d„Z d8d„Z!d8d „Z"d!„ Z#d"„ Z$d8d#„Z%d$„ Z&d7d%„Z'd7d&„Z(d'„ Z)e*fd(„Z+d)„ Z,d*„ Z-d8d+„Z.d,„ Z/d-„ Z0d.„ Z1d/„ Z2d0„ Z3d1„ Z4d2„ Z5d3„ Z6d4„ Z7d5„ Z8d6„ Z9e:j;        Z;e:j<        Z<e:j=        Z=e:j>        Z>e:j?        Z?e:j@        Z@e:jA        ZAe:jB        ZBe:jC        ZCe:jD        ZDdS )9Ú
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: An ssl.SSLContext, or a dict of arguments similar to mysql_ssl_set()'s parameters.
        Passing a dict is deprecated; use the individual ``ssl_*`` parameters or an
        ``ssl.SSLContext`` instead.
    :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. Unlike other SSL options,
        setting this to True explicitly prohibits the use of TLS, even if the server supports it.
    :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       (         ó¤	  ‡‡,— |(�|€t          j        dt          d¦  «         |(}|'�|st          j        dt          d¦  «         |'}|%s|&rt          d¦  «        ‚t	          |¦  «        | _        | j        r|t          j        z  }‰r&|
s$t          j	         
                    d¦  «        rd}
nd}
|
rù‰sdŠt          ¦   «         Š,‰,                     t          j                             |
¦  «        ¦  «         ˆ,ˆfd	„}) |)d
|¦  «        } |)d|¦  «        } |)d|¦  «        } |)d|¦  «        } |)d|¦  «        }t!           |)d|¦  «        ¦  «        } |)d|¦  «        } |)d|¦  «        }|si }t#          |t$          ¦  «        r)dD ]&}* |)d|*z    |j        |*¦  «        ¦  «        }+|+r|+||*<   Œ'd| _        d| _        | sµ|s|s|!s|#s|$r,|t	          |$¦  «        |#�|#nddœ}|�||d<   |!�|!|d<   |"�|"|d<   |rNt,          st          d¦  «        ‚d| _        d| _        |t          j        z  }|                      |¦  «        | _        n/t,          r(d| _        d| _        |                      i ¦  «        | _        |pd| _        |pd| _        t9          | j        ¦  «        t           urt;          d¦  «        ‚|pt<          | _        |pd| _         t#          | j         tB          ¦  «        r| j          "                    d¦  «        | _         || _#        || _$        || _%        d|cxk     rd k    sn t;          d!¦  «        ‚|pd | _&        |�|dk    rt;          d"¦  «        ‚|| _'        |�|dk    rt;          d#¦  «        ‚|| _(        |ptR          | _*        || _+        || _,        t[          | j*        ¦  «        j.        | _.        |t          j/        z  }| j#        r|t          j0        z  }|| _1        || _2        d | _3        d| _4        d$| _5        || _6        |€tn          j8        }d%„ | 9                    ¦   «         D ¦   «         | _:        d&„ | 9                    ¦   «         D ¦   «         | _;        |	| _<        || _=        || _>        |pi | _?        || _@        || _A        d't„          tC          t          jC        ¦   «         ¦  «        d(œ| _D        |r
|| jD        d)<   |r	d | _E        d S |  F                    ¦   «          d S )*Nz"'db' is deprecated, use 'database'r   z&'passwd' is deprecated, use 'password'z3compress and named_pipe arguments are not supportedÚwinz	c:\my.iniz/etc/my.cnfÚclientc                 ó^   •— |r|S 	 ‰                      ‰| ¦  «        S # t          $ r |cY S w xY w©N)ÚgetÚ	Exception)ÚkeyÚargÚcfgrB   s     €€r   Ú_configz$Connection.__init__.<locals>._configú   sN   ø€ Øð Ø�JðØŸ7š7Ð#5°sÑ;Ô;Ð;øÝ ð ð ð Ø�J�J�Jðøøøs   ‡ �,«,r2   r3   r4   r5   Úsocketr7   zbind-addresszdefault-character-set)ÚcaÚcapathÚcertra   r3   Úcipherzssl-F)rf   Úcheck_hostnameÚverify_moderh   ra   zssl module not foundTÚ	localhostiê  zport should be of type intr!   Úlatin1r   i€3áz+connect_timeout should be >0 and <=31536000zread_timeout should be > 0zwrite_timeout should be > 0zNot connectedc                 óF   — i | ]\  }}t          |¦  «        t          u¯||“ŒS © ©ÚtypeÚint©Ú.0ÚkÚvs      r   ú
<dictcomp>z'Connection.__init__.<locals>.<dictcomp>_  s.   € ÐOÐOÐO¡& 1 a½DÀ¹G¼GÍ3Ð<NÐ<N˜˜AÐ<NÐ<NÐ<Nr!   c                 óF   — i | ]\  }}t          |¦  «        t          u ¯||“ŒS ro   rp   rs   s      r   rw   z'Connection.__init__.<locals>.<dictcomp>`  s)   € ÐKÐKÐK¡& 1 a½DÀ¹G¼GÅs¸N¸N˜˜A¸N¸N¸Nr!   Úpymysql)Ú_client_nameÚ_client_versionÚ_pidrL   )GÚwarningsÚwarnÚDeprecationWarningÚNotImplementedErrorÚboolÚ_local_infiler   ÚLOCAL_FILESÚsysÚplatformÚ
startswithr   ÚreadÚosÚpathÚ
expanduserrr   Ú
isinstanceÚdictr_   rN   Ú_ssl_requiredÚSSL_ENABLEDÚSSLÚ_create_ssl_ctxÚctxr4   r7   rq   r*   Ú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   Úvaluerc   s-                    `                          @r   Ú__init__zConnection.__init__¯   sÇ  øø€ ðX ˆ>˜hÐ.ÝŒMÐ>Õ@RÐTUÑVÔVÐVØˆHØÐ hÐÝŒMØ8Õ:LÈañô ð ð ˆHàð 	�zð 	Ý%ØEñô ð õ " ,Ñ/Ô/ˆÔØÔð 	.Ø�6Ô-Ñ-ˆKàð 	2Ð&7ð 	2ÝŒ|×&Ò& uÑ-Ô-ð 2Ø$0Ð!Ð!à$1Ð!àð 	)Ø%ð .Ø%-Ð"å‘(”(ˆCØ�HŠH•R”W×'Ò'Ð(9Ñ:Ô:Ñ;Ô;Ð;ðð ð ð ð ð ð �7˜6 4Ñ(Ô(ˆDØ�w˜z¨8Ñ4Ô4ˆHØ�7˜6 4Ñ(Ô(ˆDØ�w˜z¨8Ñ4Ô4ˆHØ!˜' (¨KÑ8Ô8ˆKÝ�w�w˜v tÑ,Ô,Ñ-Ô-ˆDØ"˜7 >°<Ñ@Ô@ˆLØ�gÐ5°wÑ?Ô?ˆGØð Ø�Ý˜#�tÑ$Ô$ð )ØPð )ð )�CØ#˜G F¨S¡L°'°#´'¸#±,´,Ñ?Ô?�EØð )Ø#(˜˜C™øàˆŒØ"ˆÔØð 	4Øð 7˜ð 7 Wð 7°ð 7ÐCVð 7à Ý&*Ð+>Ñ&?Ô&?à&Ð2ð $3 ?àðð �ð Ð'Ø"*�C˜‘KØÐ&Ø!(�C˜‘JØ#Ð/Ø&6�C˜
‘OØð 4Ý"ð FÝ-Ð.DÑEÔEÐEØ�”Ø%)�Ô"Ø�vœzÑ)�Ø×/Ò/°Ñ4Ô4�”�Ýð 4ð  �”Ø%*�Ô"Ø×/Ò/°Ñ3Ô3�”àÐ'˜KˆŒ	Ø�L˜DˆŒ	Ý�”	‰?Œ?¥#Ð%Ð%ÝÐ9Ñ:Ô:Ð:ØÐ(�LˆŒ	Ø ˜ CˆŒÝ�d”m¥SÑ)Ô)ð 	;Ø œM×0Ò0°Ñ:Ô:ˆDŒMØˆŒØ&ˆÔØ(ˆÔØ�OÐ/Ð/Ò/Ð/ xÒ/Ð/Ð/Ð/ÝÐJÑKÔKÐKØ.Ð6°$ˆÔØÐ#¨¸Ò(9Ð(9ÝÐ9Ñ:Ô:Ð:Ø)ˆÔØÐ$¨¸!Ò);Ð);ÝÐ:Ñ;Ô;Ð;Ø+ˆÔàÐ1¥/ˆŒØ"ˆŒØ&ˆÔå'¨¬Ñ5Ô5Ô>ˆŒà•vÔ*Ñ*ˆØŒ7ð 	2Ø�6Ô1Ñ1ˆKà&ˆÔà&ˆÔàˆŒØˆÔØ(ˆŒð  *ˆÔàˆ<ÝÔ)ˆDð PÐO¨D¯JªJ©L¬LÐOÑOÔOˆŒØKÐK¨D¯JªJ©L¬LÐKÑKÔKˆŒØ ˆŒØ(ˆÔØ"4ˆÔØ /Ð 5°2ˆÔØ+ˆÔØ!2ˆÔð &Ý-Ý�œ	™œÑ$Ô$ð
ð 
ˆÔð ð 	?Ø2>ˆDÔ Ñ/àð 	ØˆDŒJˆJˆJà�LŠL‰NŒNˆNˆNˆNr!   c                 ó   — | S r^   ro   ©r©   s    r   Ú	__enter__zConnection.__enter__v  s   € Øˆr!   c                 ó0   — ~|                       ¦   «          d S r^   )Úclose)r©   Úexc_infos     r   Ú__exit__zConnection.__exit__y  s   € ØØ�
Š
‰Œˆˆˆr!   c                 óf  — t          |t          j        ¦  «        r|S |                     d¦  «        }|                     d¦  «        }|d u o|d u }t          j        ||¬¦  «        }|xj        t          j         z  c_        | o|                     dd¦  «        |_        |                     d¦  «        }|€ |rt          j        nt          j	        |_
        nÁt          |t          ¦  «        r |rt          j	        nt          j        |_
        nŒt          |t          ¦  «        r|                     ¦   «         }|dv rt          j        |_
        nM|dk    rt          j        |_
        n5|d	v rt          j	        |_
        n|rt          j        nt          j	        |_
        d
|v rD|                     |d
         |                     d¦  «        |                     d¦  «        ¬¦  «         d|v r|                     |d         ¦  «         |xj        t          j        z  c_        |xj        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   r�   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�   zConnection._create_ssl_ctx}  s
  € Ý�d�CœNÑ+Ô+ð 	ØˆKØ�XŠX�d‰^Œ^ˆØ—’˜(Ñ#Ô#ˆØ˜�*Ð/ ¨4 ˆÝÔ(°¸6ÐBÑBÔBˆð
 	ÐÔ�SÔ3Ð3Ñ3ÐÔà!(˜[ÐM¨T¯XªXÐ6FÈÑ-MÔ-MˆÔØ ŸHšH ]Ñ3Ô3ÐØÐ$Ø/6ÐM�cœm˜m½CÔ<MˆCŒOˆOÝÐ)­4Ñ0Ô0ð 	RØ3DÐW�cÔ/Ð/Í#Ì-ˆCŒOˆOåÐ+­SÑ1Ô1ð >Ø$5×$;Ò$;Ñ$=Ô$=Ð!Ø Ð$@Ð@Ð@Ý"%¤-�”�Ø" jÒ0Ð0Ý"%Ô"3�”�Ø"Ð&FÐFÐFÝ"%Ô"3�”�à3:Ð"Q¥#¤- -ÅÔ@Q�”Ø�Tˆ>ˆ>Ø×ÒØ�V” d§h¢h¨u¡o¤oÀÇÂÈÑ@TÔ@Tð  ñ ô ð ð �tÐÐØ�OŠO˜D œNÑ+Ô+Ð+ØˆŒ•s”Ñ&ˆŒØˆŒ•s”Ñ&ˆŒØˆ
r!   c                 óD  — | j         rt          j        d¦  «        ‚d| _         | j        €dS t	          j        ddt          j        ¦  «        }	 |                      |¦  «         n# t          $ r Y nw xY w|  
                    ¦   «          dS # |  
                    ¦   «          w xY 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°   zConnection.close¥  s·   € ð Œ<ð 	.Ý”)Ð,Ñ-Ô-Ð-ØˆŒØŒ:ÐØˆFÝ”K  q­'Ô*:Ñ;Ô;ˆ	ð	 Ø×Ò˜iÑ(Ô(Ð(Ð(øÝð 	ð 	ð 	ØˆDð	øøøð ×ÒÑÔÐÐÐøˆD×ÒÑÔÐÐøøøs*   ÁA# Á"B	 Á#
A0Á-B	 Á/A0Á0B	 Â	Bc                 ó   — | j         duS )z&Return True if the connection is open.N)r§   r­   s    r   ÚopenzConnection.open»  s   € ð Œz Ð%Ð%r!   c                 ó´   — | j         r| j                              ¦   «          | j        r"	 | j                             ¦   «          n#  Y nxY wd| _        d| _         dS )z&Close connection without QUIT message.N)Ú_rfiler°   r§   r­   s    r   rÖ   zConnection._force_closeÀ  sf   € àŒ;ð 	 ØŒK×ÒÑÔÐØŒ:ð 	ðØ”
× Ò Ñ"Ô"Ð"Ð"øðØ�øøøØˆŒ
ØˆŒˆˆs   ©A ÁAc                 óŽ   — t          |¦  «        | _        |                      ¦   «         }||k    r|                      ¦   «          d S d S r^   )r�   rž   Úget_autocommitÚ_send_autocommit_mode)r©   rª   Úcurrents      r   rC   zConnection.autocommitÎ  sL   € Ý# E™{œ{ˆÔØ×%Ò%Ñ'Ô'ˆØ�GÒÐØ×&Ò&Ñ(Ô(Ð(Ð(Ð(ð Ðr!   c                 óD   — t          | j        t          j        z  ¦  «        S r^   )r�   Úserver_statusr   ÚSERVER_STATUS_AUTOCOMMITr­   s    r   rÝ   zConnection.get_autocommitÔ  s   € Ý�DÔ&­Ô)OÑOÑPÔPÐPr!   c                 óÊ   — |                       ¦   «         }|                     ¦   «         st          j        t          j        d¦  «        ‚t          |¦  «        }|j        | _        |S )NzCommand Out of Sync)Ú_read_packetÚis_ok_packetr   ÚOperationalErrorr	   ÚCR_COMMANDS_OUT_OF_SYNCr   rá   )r©   ÚpktÚoks      r   Ú_read_ok_packetzConnection._read_ok_packet×  sd   € Ø×ÒÑ!Ô!ˆØ×ÒÑ!Ô!ð 	ÝÔ&ÝÔ*Ø%ñô ð õ ˜SÑ!Ô!ˆØÔ-ˆÔØˆ	r!   c                 ó¤   — |                       t          j        d|                      | j        ¦  «        z  ¦  «         |                      ¦   «          dS )z3Set whether or not to commit after every execute().zSET AUTOCOMMIT = %sN)Ú_execute_commandr   Ú	COM_QUERYÚescaperž   rê   r­   s    r   rÞ   z Connection._send_autocommit_modeâ  sQ   € à×ÒÝÔÐ4°t·{²{À4ÔCWÑ7XÔ7XÑXñ	
ô 	
ð 	
ð 	×ÒÑÔÐÐÐr!   c                 ón   — |                       t          j        d¦  «         |                      ¦   «          dS )zBegin transaction.ÚBEGINN©rì   r   rí   rê   r­   s    r   ÚbeginzConnection.beginé  s3   € à×Ò�gÔ/°Ñ9Ô9Ð9Ø×ÒÑÔÐÐÐr!   c                 ón   — |                       t          j        d¦  «         |                      ¦   «          dS )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   ÚcommitzConnection.commitî  s5   € ð 	×Ò�gÔ/°Ñ:Ô:Ð:Ø×ÒÑÔÐÐÐr!   c                 ón   — |                       t          j        d¦  «         |                      ¦   «          dS )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   ÚrollbackzConnection.rollbackø  s5   € ð 	×Ò�gÔ/°Ñ<Ô<Ð<Ø×ÒÑÔÐÐÐr!   c                 ó–   — |                       t          j        d¦  «         t          | ¦  «        }|                     ¦   «          |j        S )z%Send the "SHOW WARNINGS" SQL command.zSHOW WARNINGS)rì   r   rí   ÚMySQLResultr‡   Úrows)r©   Úresults     r   Úshow_warningszConnection.show_warnings  s=   € à×Ò�gÔ/°ÑAÔAÐAÝ˜TÑ"Ô"ˆØ�Š‰ŒˆØŒ{Ðr!   c                 ón   — |                       t          j        |¦  «         |                      ¦   «          dS )zI
        Set current db.

        :param db: The name of the db.
        N)rì   r   ÚCOM_INIT_DBrê   )r©   rY   s     r   Ú	select_dbzConnection.select_db	  s5   € ð 	×Ò�gÔ1°2Ñ6Ô6Ð6Ø×ÒÑÔÐÐÐr!   c                 ó  — t          |t          ¦  «        rd|                      |¦  «        z   dz   S t          |t          t          f¦  «        r#|                      |¦  «        }| j        rd|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î   zConnection.escape  s‘   € õ
 �c�3ÑÔð 	7Ø˜×+Ò+¨CÑ0Ô0Ñ0°3Ñ6Ð6Ý�c�E¥9Ð-Ñ.Ô.ð 	Ø×#Ò# CÑ(Ô(ˆCØÔ"ð &Ø #‘o�ØˆJÝÔ% c¨4¬<ÀÐIÑIÔIÐIr!   c                 ó8   — |                       || j        ¦  «        S )zkAlias for escape().

        Non-standard, for internal use; do not use this in your applications.
        )rî   r¡   )r©   r	  s     r   ÚliteralzConnection.literal   s   € ð
 �{Š{˜3 ¤Ñ.Ô.Ð.r!   c                 ó~   — | j         t          j        z  r|                     dd¦  «        S t	          j        |¦  «        S )Nr  z'')rá   r   Ú"SERVER_STATUS_NO_BACKSLASH_ESCAPESÚreplacer   r  ©r©   Úss     r   r  zConnection.escape_string'  s:   € ØÔ¥Ô PÑPð 	(Ø—9’9˜S $Ñ'Ô'Ð'ÝÔ'¨Ñ*Ô*Ð*r!   c                 óÌ   — | j         t          j        z  r=d                     |                     dd¦  «                             dd¦  «        ¦  «        S t          j        |¦  «        S )Nz'{}'ó   's   ''ÚasciiÚsurrogateescape)rá   r   r  Úformatr  Údecoder   Úescape_bytesr  s     r   r  zConnection._quote_bytes,  s`   € ØÔ¥Ô PÑPð 	Ø—=’=Ø—	’	˜$ Ñ&Ô&×-Ò-¨gÐ7HÑIÔIñô ð õ Ô& qÑ)Ô)Ð)r!   c                 óF   — |r || ¦  «        S |                       | ¦  «        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  zConnection.cursor3  s.   € ð ð 	 Ø�6˜$‘<”<ÐØ×Ò Ñ%Ô%Ð%r!   c                 óæ   — t          |t          ¦  «        r|                     | j        d¦  «        }|                      t
          j        |¦  «         |                      |¬¦  «        | _        | j        S )Nr  ©Ú
unbuffered)	r‹   r“   r”   r˜   rì   r   rí   Ú_read_query_resultrœ   )r©   Úsqlr  s      r   ÚqueryzConnection.query@  sg   € õ �c�3ÑÔð 	?Ø—*’*˜Tœ]Ð,=Ñ>Ô>ˆCØ×Ò�gÔ/°Ñ5Ô5Ð5Ø"×5Ò5ÀÐ5ÑLÔLˆÔØÔ"Ð"r!   c                 óF   — |                       |¬¦  «        | _        | j        S )Nr  )r  rœ   )r©   r  s     r   Únext_resultzConnection.next_resultI  s$   € Ø"×5Ò5ÀÐ5ÑLÔLˆÔØÔ"Ð"r!   c                 ó   — | j         S r^   )rœ   r­   s    r   Úaffected_rowszConnection.affected_rowsM  ó   € ØÔ"Ð"r!   c                 ó€   — t          |t          ¦  «        st          d¦  «        ‚|                      d|d›�¦  «         d S )Nzthread_id must be an integerzKILL Úd)r‹   rr   Ú	TypeErrorr   )r©   Ú	thread_ids     r   ÚkillzConnection.killP  sG   € Ý˜)¥SÑ)Ô)ð 	<ÝÐ:Ñ;Ô;Ð;Ø�
Š
Ð(˜9Ð(Ð(Ð(Ñ)Ô)Ð)Ð)Ð)r!   c                 óŒ  — |rt          j        dt          d¦  «         | j        €-|r|                      ¦   «          d}nt          j        d¦  «        ‚	 |                      t          j	        d¦  «         |  
                    ¦   «          dS # t          $ r0 |r,|                      ¦   «          |                      d¦  «         Y dS ‚ w xY w)a1  
        Check if the server is alive.

        `reconnect` is deprecated. Create a new connection if you want to reconnect.

        :param reconnect: If the connection is closed, reconnect.
        :type reconnect: boolean

        :raise Error: If the connection is closed and reconnect=False.
        zYThe 'reconnect' argument is deprecated. Create a new connection if you want to reconnect.é   NFrÐ   r0   )r}   r~   r   r§   r¨   r   rÓ   rì   r   ÚCOM_PINGrê   r`   Úping)r©   Ú	reconnects     r   r.  zConnection.pingU  sä   € ð ð 	ÝŒMØkÝ"Øñô ð ð
 Œ:ÐØð 2Ø—’‘”�Ø!�	�	å”iÐ 0Ñ1Ô1Ð1ð	Ø×!Ò!¥'Ô"2°BÑ7Ô7Ð7Ø× Ò Ñ"Ô"Ð"Ð"Ð"øÝð 	ð 	ð 	Øð Ø—’‘”�Ø—	’	˜%Ñ Ô Ð Ð Ð Ð àð	øøøs   Á4B	 Â	5CÃCc                 óf   — t          j        dt          d¦  «         |                      |¦  «         dS )z,Deprecated. Use set_character_set() instead.z<'set_charset' is deprecated, use 'set_character_set' insteadr,  N)r}   r~   r   Úset_character_set)r©   r8   s     r   Úset_charsetzConnection.set_charsetw  s;   € åŒØJÝØñ	
ô 	
ð 	
ð 	×Ò˜wÑ'Ô'Ð'Ð'Ð'r!   c                 óà   — t          |¦  «        j        }|r	d|› d|› �}nd|› �}|                      t          j        |¦  «         |                      ¦   «          || _        || _        || _        dS )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   r1  zConnection.set_character_set„  s„   € õ # 7Ñ+Ô+Ô4ˆàð 	+Ø> Ð>Ð>°9Ð>Ð>ˆEˆEà* Ð*Ð*ˆEØ×Ò�gÔ/°Ñ7Ô7Ð7Ø×ÒÑÔÐØˆŒØ ˆŒØ"ˆŒˆˆr!   c           	      óÐ  — d| _         	 |�€‰| j        r‚t          j        t          j        t          j        ¦  «        }|                     | j        ¦  «         |                     | j        ¦  «         d| _        d| _	        t          rt          d¦  «         nëi }| j        �| j        df|d<   	 	 t          j        | j        | j        f| j        fi |¤Ž}n-# t           $ r }|j        t"          j        k    rY d }~ŒK‚ d }~ww xY wd| j        | j        fz  | _        t          rt          d¦  «         |                     t          j        t          j        d	¦  «         |                     t          j        t          j        d	¦  «         |                     d ¦  «         || _        |                     d
¦  «        | _        d| _        |                      ¦   «          |                      ¦   «          |                      | j        | j         ¦  «         | j!        �D|  "                    ¦   «         }| #                    d| j!        f¦  «         | $                    ¦   «          | j%        �B|  "                    ¦   «         }| #                    | j%        ¦  «         | $                    ¦   «          | j&        �|  '                    | j&        ¦  «         d S d S # tP          $ r�}|  )                    ¦   «          tU          |t           tV          f¦  «        rgtY          j-        t\          j/        d| j        ›d|› d�¦  «        }||_0        tc          j2        ¦   «         |_1        t          rt          |j1        ¦  «         |‚‚ d }~ww xY w)NFzLocalhost via UNIX socketTzconnected using unix_socketr   Úsource_addresszsocket %s:%dzconnected using socketr   ÚrbzSET 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_authenticationr1  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¨   zConnection.connect˜  sP  € ØˆŒðS	Ø‰|ØÔ#ð OÝ!œ=­¬½Ô9KÑLÔL�DØ—O’O DÔ$8Ñ9Ô9Ð9Ø—L’L Ô!1Ñ2Ô2Ð2Ø%@�D”NØ#'�D”LÝð =ÝÐ;Ñ<Ô<Ð<øà�FØÔ(Ð4Ø48Ô4EÀqÐ3I˜Ð/Ñ0ð	"ð"Ý#)Ô#;Ø!%¤¨D¬IÐ 6¸Ô8Lð$ð $ØPVð$ð $˜Dð "øÝ&ð "ð "ð "Ø œw­%¬+Ò5Ð5Ø (    Ø!øøøøð"øøøð &4°t´yÀ$Ä)Ð6LÑ%L�D”NÝð 8ÝÐ6Ñ7Ô7Ð7Ø—O’O¥FÔ$6½Ô8JÈAÑNÔNÐNØ—O’O¥FÔ$5µvÔ7JÈAÑNÔNÐNØ—’ Ñ%Ô%Ð%àˆDŒJØŸ-š-¨Ñ-Ô-ˆDŒKØ !ˆDÔà×(Ò(Ñ*Ô*Ð*Ø×(Ò(Ñ*Ô*Ð*ð ×"Ò" 4¤<°´Ñ@Ô@Ð@àŒ}Ð(Ø—K’K‘M”M�Ø—	’	Ð+¨d¬mÐ-=Ñ>Ô>Ð>Ø—’‘	”	�	àÔ Ð,Ø—K’K‘M”M�Ø—	’	˜$Ô+Ñ,Ô,Ð,Ø—’‘	”	�	àÔ#Ð/Ø—’ Ô 4Ñ5Ô5Ð5Ð5Ð5ð 0Ð/øåð 	ð 	ð 	Ø×ÒÑÔÐå˜!�g¥wÐ/Ñ0Ô0ð 
ÝÔ*ÝÔ)ØK¸¼	ÐKÐKÀqÐKÐKÐKñô �ð
 *+�Ô&Ý )Ô 4Ñ 6Ô 6�”Ýð )Ý˜#œ-Ñ(Ô(Ð(Ø�	ð
 øøøøð%	øøøsJ   ‰B"J> Â,$C ÃJ> Ã
C;ÃC6Ã0J> Ã5C6Ã6C;Ã;F?J> Ê>
M%ËBM Í M%c                 óê   — t          t          |¦  «        ¦  «        t          | j        g¦  «        z   |z   }t          rt          |¦  «         |                      |¦  «         | j        dz   dz  | _        dS )zvWrites an entire "mysql packet" in its entirety to the network
        adding its length and sequence number.
        r   é   N)r    Úlenr+   rH  r<  r   rÕ   )r©   ÚpayloadÚdatas      r   Úwrite_packetzConnection.write_packetï  st   € õ �3˜w™<œ<Ñ(Ô(­5°$Ô2CÐ1DÑ+EÔ+EÑEÈÑOˆÝð 	Ý˜ÑÔÐØ×Ò˜$ÑÔÐØ!Ô.°Ñ2°cÑ9ˆÔÐÐr!   c                 óÀ  — t          ¦   «         }	 |                      d¦  «        }t          j        d|¦  «        \  }}}||dz  z   }|| j        k    rW|                      ¦   «          |dk    rt          j        t          j	        d¦  «        ‚t          j
        d|| j        fz  ¦  «        ‚| j        dz   d	z  | _        |                      |¦  «        }t          rt          |¦  «         ||z  }|t          k     rnŒç |t          |¦  «        | j        ¦  «        }	|	                     ¦   «         r5| j        �| j        j        du rd| 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   rX  NF)r  Ú_read_bytesr   ÚunpackrH  rÖ   r   ræ   r	   ÚCR_SERVER_LOSTÚInternalErrorr<  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ä   zConnection._read_packetû  s„  € õ ‰{Œ{ˆð	Ø ×,Ò,¨QÑ/Ô/ˆMõ )/¬°f¸mÑ(LÔ(LÑ%ˆD�$˜Ø  D¨B¡JÑ/ˆMØ Ô 1Ò1Ð1Ø×!Ò!Ñ#Ô#Ð#Ø  AÒ%Ð%åÔ.ÝÔ)ØFñô ð õ Ô'ØGØ$ dÔ&7Ð8ñ9ñô ð ð "&Ô!2°QÑ!6¸#Ñ =ˆDÔà×(Ò(¨Ñ7Ô7ˆIÝð 'Ý˜IÑ&Ô&Ð&Ø�IÑˆDà�~Ò-Ð-Øð5	ð8 ��U 4™[œ[¨$¬-Ñ8Ô8ˆØ×!Ò!Ñ#Ô#ð 	%ØŒ|Ð'¨D¬LÔ,JÈdÐ,RÐ,RØ16�”Ô.Ø×"Ò"Ñ$Ô$Ð$Øˆr!   c                 ó  — | j                              | j        ¦  «         	 	 | j                             |¦  «        }n�# t
          $ rV}|j        t          j        k    rY d }~ŒA|                      ¦   «          t          j
        t          j        d|› d�¦  «        ‚d }~wt          $ r |                      ¦   «          ‚ w xY wt          |¦  «        |k     r3|                      ¦   «          t          j
        t          j        d¦  «        ‚|S )NTz.Lost connection to MySQL server during query (r7  r`  )r§   r:  r•   rÛ   r‡   r?  r@  rA  rÖ   r   ræ   r	   rc  rL  rY  )r©   Ú	num_bytesr[  rT  s       r   ra  zConnection._read_bytes&  s$  € ØŒ
×Ò˜dÔ0Ñ1Ô1Ð1ð	ðØ”{×'Ò'¨	Ñ2Ô2�ØøÝð ð ð Ø”7�eœkÒ)Ð)Ø�H�H�H�HØ×!Ò!Ñ#Ô#Ð#ÝÔ*ÝÔ%ØIÀQÐIÐIÐIñô ð øøøøõ !ð ð ð à×!Ò!Ñ#Ô#Ð#Øðøøøõ ˆt‰9Œ9�yÒ Ð Ø×ÒÑÔÐÝÔ&ÝÔ!Ð#Qñô ð ð ˆs   ¢= ½
B;ÁBÁ!7BÂ#B;c                 ó  — | j                              | j        ¦  «         	 | j                              |¦  «         d S # t          $ r<}|                      ¦   «          t          j        t          j	        d|›d�¦  «        ‚d }~ww xY w)NzMySQL server has gone away (r7  )
r§   r:  r–   Úsendallr?  rÖ   r   ræ   r	   ÚCR_SERVER_GONE_ERROR)r©   r[  rT  s      r   rÕ   zConnection._write_bytes?  s–   € ØŒ
×Ò˜dÔ1Ñ2Ô2Ð2ð	ØŒJ×Ò˜tÑ$Ô$Ð$Ð$Ð$øÝð 	ð 	ð 	Ø×ÒÑÔÐÝÔ&ÝÔ'Ð)NÈÐ)NÐ)NÐ)Nñô ð øøøøð	øøøs   ¡= ½
BÁ7A>Á>Bc                 óÆ   — d | _         t          | ¦  «        }|r|                     ¦   «          n|                     ¦   «          || _         |j        �|j        | _        |j        S r^   )r›   rú   Úinit_unbuffered_queryr‡   rá   r$  )r©   r  rü   s      r   r  zConnection._read_query_resultI  sd   € ØˆŒÝ˜TÑ"Ô"ˆØð 	Ø×(Ò(Ñ*Ô*Ð*Ð*à�KŠK‰MŒMˆMØˆŒØÔÐ+Ø!'Ô!5ˆDÔØÔ#Ð#r!   c                 ó,   — | j         r| j         j        S dS ©Nr   )r›   Ú	insert_idr­   s    r   r{  zConnection.insert_idU  s   € ØŒ<ð 	Ø”<Ô)Ð)à�1r!   c                 ó`  — | j         st          j        dd¦  «        ‚| j        �l| j        j        r-t          j        d¦  «         | j                             ¦   «          | j        j        r |  	                    ¦   «          | j        j        ° d| _        t          |t          ¦  «        r|                     | j        ¦  «        }t          t          t!          |¦  «        dz   ¦  «        }t#          j        d||¦  «        }||d|dz
  …         z   }|                      |¦  «         t(          rt+          |¦  «         d| _        |t          k     rdS ||dz
  d…         }	 t          t          t!          |¦  «        ¦  «        }|                      |d|…         ¦  «         ||d…         }|s|t          k     rdS ŒY)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›   rg  r}   r~   Ú_finish_unbuffered_queryÚhas_nextr"  r‹   r“   r”   r˜   Úminre  rY  r   r   rÕ   r<  r   rH  r\  )r©   Úcommandr  Úpacket_sizeÚpreluderq  s         r   rì   zConnection._execute_command[  sµ  € ð
 Œzð 	,ÝÔ$ Q¨Ñ+Ô+Ð+ð Œ<Ð#ØŒ|Ô-ð 8Ý”ÐNÑOÔOÐOØ”×5Ò5Ñ7Ô7Ð7Ø”,Ô'ð #Ø× Ò Ñ"Ô"Ð"ð ”,Ô'ð #àˆDŒLå�c�3ÑÔð 	,Ø—*’*˜Tœ]Ñ+Ô+ˆCå�.­#¨c©(¬(°Q©,Ñ7Ô7ˆõ ”+˜e [°'Ñ:Ô:ˆØ˜3Ð0 ¨q¡Ð0Ô1Ñ1ˆØ×Ò˜&Ñ!Ô!Ð!Ýð 	 Ý˜ÑÔÐØˆÔà�Ò'Ð'ØˆFà�+ ‘/Ð#Ð#Ô$ˆð	Ý�n­c°#©h¬hÑ7Ô7ˆKØ×Ò˜c , ; ,Ô/Ñ0Ô0Ð0Ø�k�l�lÔ#ˆCØð ˜;­Ò7Ð7Ø�ð	r!   c                 ób  — t          | j                             dd¦  «        d         ¦  «        dk    r| xj        t          j        z  c_        | j        €t          d¦  «        ‚t          | j	        ¦  «        j
        }t          | j        t          ¦  «        r$| j                             | j        ¦  «        | _        | j        }| j        rO| j        t          j        z  rd}|t          j        z  }n+| j        rt'          j        t*          j        d¦  «        ‚d}nd}t/          j        d	|t2          |d
¦  «        }|rf|                      |¦  «         | j                             | j        | j        ¬¦  «        | _        | j                             d¦  «        | _         d| _!        || j        z   dz   }d
}d }| j"        dk    r"d
}tG          j$        | j%        | j&        ¦  «        }n´| j"        dk    r"d}tG          j$        | j%        | j&        ¦  «        }n‡| j"        dk    rVd}| j%        r6tN          rtQ          d¦  «         tG          j)        | j%        | j&        ¦  «        }n=tN          rtQ          d¦  «         n&| j"        dk    rd}|r| j%        dz   }n| j%        rd}nd}| j        t          j*        z  r#|tW          tY          |¦  «        ¦  «        |z   z  }nE| j        t          j-        z  r)|t/          j        dtY          |¦  «        ¦  «        |z   z  }n||dz   z  }| j.        r_| j        t          j/        z  rKt          | j.        t          ¦  «        r$| j.                             | j        ¦  «        | _.        || j.        dz   z  }| j        t          j0        z  r
||pd
dz   z  }| j        t          j1        z  r±d
}| j2         3                    ¦   «         D ]s\  }	}
|	                     d¦  «        }	|tW          tY          |	¦  «        ¦  «        |	z   z  }|
                     d¦  «        }
|tW          tY          |
¦  «        ¦  «        |
z   z  }Œt|tW          tY          |¦  «        ¦  «        |z   z  }|                      |¦  «         |  4                    ¦   «         }| 5                    ¦   «         rtN          rtQ          d¦  «         | 6                    ¦   «          | 7                    ¦   «         }| j        t          j0        z  r|�|  8                    ||¦  «        }nšt'          j        d¦  «        ‚| 9                    ¦   «         rrtN          rtQ          d¦  «         | j"        dk    rtG          j:        | |¦  «        }n;| j"        dk    rtG          j;        | |¦  «        }nt'          j        d| j"        ¦  «        ‚tN          rtQ          d¦  «         d S d S )Nú.r   r   é   zDid not specify a usernameTz1SSL is required but the server doesn't support itFz<iIB23sr!   )Úserver_hostnamer6  ó    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-8zreceived auth switchz$received unknown auth switch requestzreceived extra dataz(Received extra packet for auth method %rzSucceed to auth)<rr   Úserver_versionÚsplitr>   r   ÚMULTI_RESULTSr2   r*   r   r8   Úidr‹   r“   r”   r˜   rN   Úserver_capabilitiesr�   r�   r   ræ   r	   ÚCR_SSL_CONNECTION_ERRORr   r   re  r\  r‘   Úwrap_socketr§   r4   rG  rÛ   r;  Ú_auth_plugin_namer   Úscramble_native_passwordr3   Úsaltr<  r=  Úscramble_caching_sha2ÚPLUGIN_AUTH_LENENC_CLIENT_DATAr-   rY  ÚSECURE_CONNECTIONrY   rš   ÚPLUGIN_AUTHÚCONNECT_ATTRSr¦   r    rä   Úis_auth_switch_requestÚ
read_uint8Úread_stringÚ_process_authÚis_extra_auth_dataÚcaching_sha2_password_authÚsha256_password_auth)r©   Ú
charset_idÚclient_flagsÚ_do_sslÚ	data_initr[  ÚauthrespÚplugin_nameÚconnect_attrsru   rv   Úauth_packets               r   rJ  z"Connection._request_authentication†  sµ  € åˆtÔ"×(Ò(¨¨aÑ0Ô0°Ô3Ñ4Ô4¸Ò9Ð9ØÐÔ¥Ô 4Ñ4ÐÔàŒ9ÐÝÐ9Ñ:Ô:Ð:å$ T¤\Ñ2Ô2Ô5ˆ
Ý�d”i¥Ñ%Ô%ð 	8Øœ	×(Ò(¨¬Ñ7Ô7ˆDŒIð Ô'ˆØŒ8ð 	ØÔ'­&¬*Ñ4ð  à�Ø¥¤
Ñ*��ØÔ#ð  ÝÔ*ÝÔ.ØGñô ð ð  ��àˆGå”KØ�|¥^°ZÀñ
ô 
ˆ	ð ð 	 Ø×Ò˜iÑ(Ô(Ð(Øœ×-Ò-¨d¬jÈ$Ì)Ð-ÑTÔTˆDŒJØœ*×-Ò-¨dÑ3Ô3ˆDŒKØˆDŒLà˜4œ9Ñ$ uÑ,ˆàˆØˆàÔ! RÒ'Ð'ØˆKÝÔ5°d´mÀTÄYÑOÔOˆHˆHØÔ#Ð'>Ò>Ð>Ø2ˆKÝÔ5°d´mÀTÄYÑOÔOˆHˆHØÔ#Ð'>Ò>Ð>Ø2ˆKØŒ}ð :Ýð <ÝÐ:Ñ;Ô;Ð;Ý Ô6°t´}ÀdÄiÑPÔP��åð :ÝÐ8Ñ9Ô9Ð9øØÔ#Ð'8Ò8Ð8Ø,ˆKØð !Øœ=¨5Ñ0��Ø”ð !Ø ��à �àÔ#¥fÔ&KÑKð 	%Ø•K¥ H¡¤Ñ.Ô.°Ñ9Ñ9ˆDˆDØÔ%­Ô(@Ñ@ð 	%Ø•F”K ¥S¨¡]¤]Ñ3Ô3°hÑ>Ñ>ˆDˆDà�H˜uÑ$Ñ$ˆDàŒ7ð 	$�tÔ/µ&Ô2HÑHð 	$Ý˜$œ'¥3Ñ'Ô'ð 8Øœ'Ÿ.š.¨¬Ñ7Ô7�”Ø�D”G˜e‘OÑ#ˆDàÔ#¥fÔ&8Ñ8ð 	1Ø�[Ð' C¨5Ñ0Ñ0ˆDàÔ#¥fÔ&:Ñ:ð 	DØˆMØÔ+×1Ò1Ñ3Ô3ð 9ð 9‘��1Ø—H’H˜WÑ%Ô%�Ø¥­S°©V¬VÑ!4Ô!4°qÑ!8Ñ8�Ø—H’H˜WÑ%Ô%�Ø¥­S°©V¬VÑ!4Ô!4°qÑ!8Ñ8��Ø•K¥ MÑ 2Ô 2Ñ3Ô3°mÑCÑCˆDà×Ò˜$ÑÔÐØ×'Ò'Ñ)Ô)ˆð ×-Ò-Ñ/Ô/ð 	Ýð .ÝÐ,Ñ-Ô-Ð-à×"Ò"Ñ$Ô$Ð$Ø%×1Ò1Ñ3Ô3ˆKàÔ(­6Ô+=Ñ=ðSàÐ+à"×0Ò0°¸kÑJÔJ��åÔ*Ð+QÑRÔRÐRØ×+Ò+Ñ-Ô-ð 	Ýð -ÝÐ+Ñ,Ô,Ð,àÔ%Ð)@Ò@Ð@Ý#Ô>¸tÀ[ÑQÔQ��ØÔ'Ð+<Ò<Ð<Ý#Ô8¸¸{ÑKÔK��åÔ*Ø>ÀÔ@Vñô ð õ ð 	%ÝÐ#Ñ$Ô$Ð$Ð$Ð$ð	%ð 	%r!   c                 óR  — |                       |¦  «        }|r_	 |                     |¦  «        S # t          $ r< |dk    r3t          j        t
          j        d|› dt          |¦  «        ›d�¦  «        ‚Y nw xY w|dk    rt          j	        | |¦  «        S |dk    rt          j
        | |¦  «        S |dk    r.t          j        | j        |                     ¦   «         ¦  «        }�n	|dk    r.t          j        | j        |                     ¦   «         ¦  «        }�nÕ|d	k    r1t          j        | j        |                     ¦   «         ¦  «        d
z   }�nž|dk    r| j        d
z   }�nŒ|dk    �rc|}	 |                     ¦   «         }|dz  dk    }|dz  dk    }|                     ¦   «         }	|	dk    r|                      | j        d
z   ¦  «         n¿|ršd}
	 |                     ||	¦  «        }
|                      |
d
z   ¦  «         n‹# t          $ r' t          j        t
          j        d|› d|›d�¦  «        ‚t&          $ r, t          j        t
          j        d|› d|›d|
›d|	›�¦  «        ‚w xY wt          j        t
          j        d|› d�¦  «        ‚|                      ¦   «         }|                     ¦   «          |                     ¦   «         s|rn�Œ^|S t          j        t
          j        d|z  ¦  «        ‚|                      |¦  «         |                      ¦   «         }|                     ¦   «          |S )Ns   dialogúAuthentication plugin 'ú' not loaded: - z missing authenticate methodrŒ  rŽ  rŠ  s   client_ed25519s   mysql_old_passwordrˆ  s   mysql_clear_passwordTé   r,  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_LOADrq   r   r¦  r§  rš  r3   Úread_allÚed25519_passwordÚscramble_old_passwordr¢  r\  Úpromptr(  ÚCR_AUTH_PLUGIN_ERRrä   Úcheck_errorrå   )r©   r­  r¯  Úhandlerr[  rè   ÚflagÚechoÚlastr»  Úresps              r   r¤  zConnection._process_auth	  sý  € Ø×/Ò/°Ñ<Ô<ˆØð 		ðØ×+Ò+¨KÑ8Ô8Ð8øÝ!ð ð ð Ø )Ò+Ð+ÝÔ.ÝÔ5ðX°+ð Xð XÝ*.¨w©-¬-ðXð Xð Xñô ð ð ,Ð+ðøøøð Ð2Ò2Ð2ÝÔ3°D¸+ÑFÔFÐFØÐ.Ò.Ð.ÝÔ-¨d°KÑ@Ô@Ð@ØÐ4Ò4Ð4ÝÔ1°$´-À×AUÒAUÑAWÔAWÑXÔXˆD‰DØÐ-Ò-Ð-ÝÔ)¨$¬-¸×9MÒ9MÑ9OÔ9OÑPÔPˆD‰DØÐ1Ò1Ð1åÔ+¨D¬M¸;×;OÒ;OÑ;QÔ;QÑRÔRØñð ‰Dð Ð3Ò3Ð3à”= 5Ñ(ˆD‰DØ˜IÒ%Ñ%ØˆCð!Ø—~’~Ñ'Ô'�Ø˜t™¨Ò,�Ø˜t™¨Ò,�ØŸš™œ�à˜]Ò*Ð*Ø×%Ò% d¤m°eÑ&;Ñ<Ô<Ð<Ð<Øð ØP�DðØ&Ÿ~š~¨d°FÑ;Ô;˜Ø×)Ò)¨$°©,Ñ7Ô7Ð7Ð7øÝ)ð ð ð Ý!Ô2ÝÔ9ðP°kð Pð PØ.5ðPð Pð Pñô ð õ
 %ð ð ð Ý!Ô2ÝÔ1ðq°kð qð qØ 'ðqð qØRVðqð qØflðqð qñô ð ðøøøõ Ô.ÝÔ5ØO°+ÐOÐOÐOñô ð ð ×'Ò'Ñ)Ô)�Ø—’Ñ!Ô!Ð!Ø×#Ò#Ñ%Ô%ð ¨ð ØñC!ðD ˆJåÔ&ÝÔ-Ø;¸kÑIñô ð ð
 	×Ò˜$ÑÔÐØ×ÒÑ!Ô!ˆØ�ŠÑÔÐØˆ
s   ™. ®AA4Á3A4Ç.G: Ç:A%Ic           	      óL  — | j                              |¦  «        }|sBt          |t          ¦  «        r-| j                              |                     d¦  «        ¦  «        }|rA	  || ¦  «        }n6# t
          $ r' t          j        t          j	        d|› d|›d�¦  «        ‚w xY wd }|S )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_handlerU  sà   € ØÔ,×0Ò0°Ñ=Ô=ˆØð 	R¥
¨;½Ñ >Ô >ð 	RØÔ0×4Ò4°[×5GÒ5GÈÑ5PÔ5PÑQÔQˆLØð 
	ðØ&˜, tÑ,Ô,��øÝð ð ð ÝÔ*ÝÔ1ðd¨kð dð dØ&2ðdð dð dñô ð ðøøøð ˆGØˆs   Á"A. Á.1Bc                 ó   — | j         d         S rz  )Úserver_thread_idr­   s    r   r)  zConnection.thread_idg  s   € ØÔ$ QÔ'Ð'r!   c                 ó   — | j         S r^   )r8   r­   s    r   Úcharacter_set_namezConnection.character_set_namej  s
   € ØŒ|Ðr!   c                 ó   — | j         S r^   )r�   r­   s    r   Úget_host_infozConnection.get_host_infom  s
   € ØŒ~Ðr!   c                 ó   — | j         S r^   )Úprotocol_versionr­   s    r   Úget_proto_infozConnection.get_proto_infop  s   € ØÔ$Ð$r!   c                 ó@  — d}|                       ¦   «         }|                     ¦   «         }||         | _        |dz  }|                     d|¦  «        }|||…                              d¦  «        | _        |dz   }t          j        d|||dz   …         ¦  «        | _        |dz  }|||dz   …         | _	        |dz  }t          j        d	|||d
z   …         ¦  «        d         | _
        |d
z  }t          |¦  «        |dz   k    rÀt          j        d|||dz   …         ¦  «        \  }}}}|dz  }|| _        	 t          |¦  «        j        | _        n# t           $ r
 d | _        Y nw xY w|| _        t$          rt'          d|z  ¦  «         | xj
        |dz  z  c_
        t$          rt'          d|¦  «         t)          d|dz
  ¦  «        }|dz  }t          |¦  «        ||z   k    r | xj	        ||||z   …         z  c_	        ||z  }|dz  }| j
        t*          j        z  rtt          |¦  «        |k    ra|                     d|¦  «        }|dk     r#||d …                              d¦  «        | _        n"|||…                              d¦  «        | _        t0          �t0          | _        d S d S )Nr   r   rˆ  rm   r   r^  é   é	   r%   r,  r³  z<BHHBzserver_status: %xr_  z	salt_len:é   r1   r‘  )rä   Úget_all_datarÌ  Úfindr  r’  r   rb  rÆ  r›  r–  rY  Úserver_languager   ÚnameÚserver_charsetÚKeyErrorrá   r<  r=  Úmaxr   rŸ  r™  Ú_DEFAULT_AUTH_PLUGIN)	r©   r,   rq  r[  Ú
server_endÚlangÚstatÚcap_hÚsalt_lens	            r   rI  z"Connection._get_server_informations  sÑ  € ØˆØ×"Ò"Ñ$Ô$ˆØ×"Ò"Ñ$Ô$ˆà $ Q¤ˆÔØ	ˆQ‰ˆà—Y’Y˜u aÑ(Ô(ˆ
Ø" 1 Z <Ô0×7Ò7¸ÑAÔAˆÔØ˜‰Nˆå &¤¨d°D¸¸QÀ¹U¸´OÑ DÔ DˆÔØ	ˆQ‰ˆà˜˜Q ™U˜”OˆŒ	Ø	ˆQ‰ˆå#)¤=°°t¸AÀÀAÁ¸I´Ñ#GÔ#GÈÔ#JˆÔ Ø	ˆQ‰ˆåˆt‰9Œ9˜˜A™ÒÐÝ*0¬-¸ÀÀaÈ!ÈaÉ%ÀiÄÑ*QÔ*QÑ'ˆD�$˜˜xØ�‰FˆAð $(ˆDÔ ð+Ý&3°DÑ&9Ô&9Ô&>�Ô#Ð#øÝð +ð +ð +à&*�Ô#Ð#Ð#ð+øøøð "&ˆDÔÝð 2ÝÐ)¨DÑ0Ñ1Ô1Ð1àÐ$Ô$¨°©Ñ3Ð$Ô$Ýð -Ý�k 8Ñ,Ô,Ð,Ý˜2˜x¨!™|Ñ,Ô,ˆHð 	
ˆR‰ˆåˆt‰9Œ9˜˜H™Ò$Ð$àˆIŒI˜˜a ! h¡,Ð.Ô/Ñ/ˆIŒIØ�‰MˆAà	ˆQ‰ˆàÔ#¥fÔ&8Ñ8ð 	L½SÀ¹Y¼YÈ!º^¸^ð Ÿš 5¨!Ñ,Ô,ˆJØ˜AŠ~ˆ~à)-¨a¨b¨b¬¯ª¸Ñ)AÔ)A�Ô&Ð&à)-¨a°
¨lÔ);×)BÒ)BÀ7Ñ)KÔ)K�Ô&åÐ+Ý%9ˆDÔ"Ð"Ð"ð ,Ð+s   Ä3E ÅE!Å E!c                 ó   — | j         S r^   )r’  r­   s    r   Úget_server_infozConnection.get_server_info·  r%  r!   r^   )F)EÚ__name__Ú
__module__Ú__qualname__Ú__doc__r§   rÛ   r™  rÒ   r;  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.  r2  r1  r¨   r\  r   rä   ra  rÕ   r  r{  rì   rJ  r¤  r´  r)  rÈ  rÊ  rÍ  rI  rà  r   ÚWarningrÓ   r}  ÚDatabaseErrorÚ	DataErrorræ   ÚIntegrityErrorrd  ÚProgrammingErrorÚNotSupportedErrorro   r!   r   r/   r/   ^   s  € € € € € ðHð HðT €EØ€FØÐØ€GØ€Gð
 ØØØØØØØØØØØØØØØØØØØ+ØØØØØØØØØØØØØØØØ ØØØØðUEð Eð Eð Eð EðNð ð ðð ð ð&ð &ð &ðP ð  ð  ð, ð&ð &ñ „Xð&ð
ð 
ð 
ð €Gð)ð )ð )ðQð Qð Qð	ð 	ð 	ðð ð ðð ð ð
ð ð ðð ð ðð ð ðð ð ðJð Jð Jð Jð/ð /ð /ð+ð +ð +ð
*ð *ð *ð
&ð 
&ð 
&ð 
&ð#ð #ð #ð #ð#ð #ð #ð #ð#ð #ð #ð*ð *ð *ð
 ð  ð  ð  ðD(ð (ð (ð#ð #ð #ð #ð(Uð Uð Uð Uðn
:ð 
:ð 
:ð (3ð )ð )ð )ð )ðVð ð ð2ð ð ð
$ð 
$ð 
$ð 
$ðð ð ð)ð )ð )ðVA%ð A%ð A%ðFJð Jð JðXð ð ð$(ð (ð (ðð ð ðð ð ð%ð %ð %ðB:ð B:ð B:ðH#ð #ð #ð Œk€GØŒI€EØÔ'€NØÔ%€MØ”€IØÔ+ÐØÔ'€NØÔ%€MØÔ+ÐØÔ-ÐÐÐr!   r/   c                   ó\   — e Zd Zd„ Zd„ Zd„ Zd„ Zd„ Zd„ Zd„ Z	d„ Z
d	„ Zd
„ Zd„ Zd„ Zd„ ZdS )rú   c                 ó    — || _         d| _        d| _        d| _        d| _        d| _        d| _        d| _        d| _        d| _	        d| _
        dS )z.
        :type connection: Connection
        Nr   F)Ú
connectionr$  r{  rá   Úwarning_countÚmessageÚfield_countÚdescriptionrû   r  rg  )r©   rï  s     r   r«   zMySQLResult.__init__Ç  s]   € ð %ˆŒØ!ˆÔØˆŒØ!ˆÔØˆÔØˆŒØˆÔØˆÔØˆŒ	ØˆŒØ!&ˆÔÐÐr!   c                 ó@   — | j         r|                      ¦   «          d S d S r^   )rg  r~  r­   s    r   ræ  zMySQLResult.__del__×  s/   € ØÔ!ð 	,Ø×)Ò)Ñ+Ô+Ð+Ð+Ð+ð	,ð 	,r!   c                 ó2  — 	 | j                              ¦   «         }|                     ¦   «         r|                      |¦  «         n?|                     ¦   «         r|                      |¦  «         n|                      |¦  «         d | _         d S # d | _         w xY wr^   )rï  rä   rå   rê   Úis_load_local_packetÚ_read_load_local_packetÚ_read_result_packet©r©   Úfirst_packets     r   r‡   zMySQLResult.readÛ  s¢   € ð
	#Øœ?×7Ò7Ñ9Ô9ˆLà×(Ò(Ñ*Ô*ð 7Ø×$Ò$ \Ñ2Ô2Ð2Ð2Ø×2Ò2Ñ4Ô4ð 7Ø×,Ò,¨\Ñ:Ô:Ð:Ð:à×(Ò(¨Ñ6Ô6Ð6à"ˆDŒOˆOˆOø˜dˆDŒOÐ"Ð"Ð"Ð"s   ‚BB Â	Bc                 ó�  — | j                              ¦   «         }|                     ¦   «         rd| _         |                      |¦  «         dS |                     ¦   «         r+	 |                      |¦  «         d| _         dS # d| _         w xY w|                     ¦   «         | _        |                      ¦   «          d| _	        d| _
        dS )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$  rg  rù  s     r   rx  z!MySQLResult.init_unbuffered_queryè  sÕ   € ð
 ”×3Ò3Ñ5Ô5ˆà×$Ò$Ñ&Ô&ð 	*Ø"ˆDŒOØ× Ò  Ñ.Ô.Ð.Ð.Ð.Ø×.Ò.Ñ0Ô0ð 	*ð'Ø×,Ò,¨\Ñ:Ô:Ð:à"&�”��ø $�”Ð&Ð&Ð&Ð&à+×GÒGÑIÔIˆDÔØ×"Ò"Ñ$Ô$Ð$ð
 "6ˆDÔØ%)ˆDÔ"Ð"Ð"s   Á!A? Á?	Bc                 ó´   — t          |¦  «        }|j        | _        |j        | _        |j        | _        |j        | _        |j        | _        |j        | _        d S r^   )r   r$  r{  rá   rð  rñ  r  )r©   rú  Ú	ok_packets      r   rê   zMySQLResult._read_ok_packet  sR   € Ý# LÑ1Ô1ˆ	Ø&Ô4ˆÔØ"Ô,ˆŒØ&Ô4ˆÔØ&Ô4ˆÔØ Ô(ˆŒØ!Ô*ˆŒˆˆr!   c                 óº  — | j         j        st          d¦  «        ‚t          |¦  «        }t	          |j        | j         ¦  «        }	 |                     ¦   «          n#  | j                              ¦   «          ‚ xY w| j                              ¦   «         }|                     ¦   «         st          j
        t          j        d¦  «        ‚|                      |¦  «         d S )NzF**WARN**: Received LOAD_LOCAL packet but local_infile option is false.zCommands Out of Sync)rï  r‚   Ú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°T´_ÑEÔEˆð	Ø×ÒÑÔÐÐøð	ØŒO×(Ò(Ñ*Ô*Ð*Øøøøà”O×0Ò0Ñ2Ô2ˆ	à×&Ò&Ñ(Ô(ð	õ Ô&ÝÔ*Ø&ñô ð ð 	×Ò˜YÑ'Ô'Ð'Ð'Ð's   ÁA ÁA7c                 ó€   — |                      ¦   «         sdS t          |¦  «        }|j        | _        |j        | _        dS )NFT)Úis_eof_packetr   rð  r  )r©   rq  Úwps      r   Ú_check_packet_is_eofz MySQLResult._check_packet_is_eof!  sC   € Ø×#Ò#Ñ%Ô%ð 	Ø�5õ ˜fÑ%Ô%ˆØÔ-ˆÔØœˆŒØˆtr!   c                 óˆ   — |                      ¦   «         | _        |                      ¦   «          |                      ¦   «          d S r^   )rü  rò  rý  Ú_read_rowdata_packetrù  s     r   rø  zMySQLResult._read_result_packet.  s@   € Ø'×CÒCÑEÔEˆÔØ×ÒÑ Ô Ð Ø×!Ò!Ñ#Ô#Ð#Ð#Ð#r!   c                 óê   — | j         sd S | j                             ¦   «         }|                      |¦  «        rd| _         d | _        d | _        d S |                      |¦  «        }d| _        |f| _        |S )NFr   )rg  rï  rä   r	  rû   Ú_read_row_from_packetr$  )r©   rq  Úrows      r   Ú_read_rowdata_packet_unbufferedz+MySQLResult._read_rowdata_packet_unbuffered3  s�   € àÔ%ð 	ØˆFð ”×-Ò-Ñ/Ô/ˆØ×$Ò$ VÑ,Ô,ð 	Ø%*ˆDÔ"Ø"ˆDŒOØˆDŒIØˆFà×(Ò(¨Ñ0Ô0ˆØˆÔØ�FˆŒ	Øˆ
r!   c                 óD  — | j         r˜	 | j                             ¦   «         }nQ# t          j        $ r?}|j        d         t          j        t          j        fv rd| _         d | _        Y d }~d S ‚ d }~ww xY w|  	                    |¦  «        rd| _         d | _        | j         °–d S d S )Nr   F)
rg  rï  rä   r   ræ   Úargsr
   ÚQUERY_TIMEOUTÚSTATEMENT_TIMEOUTr	  )r©   rq  rT  s      r   r~  z$MySQLResult._finish_unbuffered_queryE  sØ   € ð Ô$ð 	'ðØœ×5Ò5Ñ7Ô7��øÝÔ'ð 
ð 
ð 
Ø”6˜!”9ÝÔ$ÝÔ(ð!ð ð ð
 .3�DÔ*Ø&*�D”OØ�F�F�F�F�Fàøøøøð
øøøð ×(Ò(¨Ñ0Ô0ð 'Ø).�Ô&Ø"&�”ð# Ô$ð 	'ð 	'ð 	'ð 	'ð 	's   ‰# £A1²3A,Á+A,Á,A1c                 ó  — g }	 | j                              ¦   «         }|                      |¦  «        rd| _         n)|                     |                      |¦  «        ¦  «         Œ_t          |¦  «        | _        t          |¦  «        | _        dS )z:Read a rowdata packet for each data row in the result set.TN)	rï  rä   r	  Úappendr  rY  r$  Útuplerû   )r©   rû   rq  s      r   r  z MySQLResult._read_rowdata_packet\  s…   € àˆð	<Ø”_×1Ò1Ñ3Ô3ˆFØ×(Ò(¨Ñ0Ô0ð Ø"&�”ØØ�KŠK˜×2Ò2°6Ñ:Ô:Ñ;Ô;Ð;ð	<õ ! ™YœYˆÔÝ˜$‘K”KˆŒ	ˆ	ˆ	r!   c                 ó0  — g }| j         D ]~\  }}	 |                     ¦   «         }n# t          $ r Y  nWw xY w|�;|�|                     |¦  «        }t          rt          d|¦  «         |� ||¦  «        }|                     |¦  «         Œt          |¦  «        S )NzDEBUG: DATA = )r   Úread_length_coded_stringÚ
IndexErrorr  r<  r=  r  r  )r©   rq  r  r˜   Ú	converterr[  s         r   r  z!MySQLResult._read_row_from_packeti  sÅ   € ØˆØ#'¤?ð 	ð 	ÑˆH�iðØ×6Ò6Ñ8Ô8��øÝð ð ð ð ��ðøøøð ÐØÐ'ØŸ;š; xÑ0Ô0�DÝð 2ÝÐ*¨DÑ1Ô1Ð1ØÐ(Ø$˜9 T™?œ?�DØ�JŠJ�tÑÔÐÐÝ�S‰zŒzÐs   �%¥
3²3c                 ó"  — g | _         g | _        | j        j        }| j        j        }g }t          | j        ¦  «        D �]}| j                             t          ¦  «        }| j          	                    |¦  «         | 	                    | 
                    ¦   «         ¦  «         |j        }|r0|t          j        k    r|}n|t          v r|j        dk    rd}n|}nd}nd}| j        j                             |¦  «        }|t          j        u rd}t&          rt)          d|› d|› �¦  «         | j         	                    ||f¦  «         �Œ| j                             ¦   «         }	|	                     ¦   «         s
J d¦   «         ‚t-          |¦  «        | _
        dS )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_   Úthroughr<  r=  r  r  )
r©   r=   Úconn_encodingró  r,   ÚfieldÚ
field_typer˜   r  Ú
eof_packets
             r   rý  zMySQLResult._get_descriptions|  s£  € àˆŒØˆŒØ”oÔ1ˆØœÔ0ˆØˆå�tÔ'Ñ(Ô(ð 	:ñ 	:ˆAØ”O×0Ò0Õ1FÑGÔGˆEØŒK×Ò˜uÑ%Ô%Ð%Ø×Ò˜u×0Ò0Ñ2Ô2Ñ3Ô3Ð3ØœˆJØð  Ø¥¤Ò0Ð0ð  -�H�HØ¥:Ð-Ð-Ø”¨"Ò,Ð,à#'˜˜à#0˜˜ð  '�H�Hà�ØœÔ0×4Ò4°ZÑ@Ô@ˆIØ�JÔ.Ð.Ð.Ø �	Ýð FÝÐD eÐDÐD¸ÐDÐDÑEÔEÐEØŒO×"Ò" H¨iÐ#8Ñ9Ô9Ð9Ñ9à”_×1Ò1Ñ3Ô3ˆ
Ø×'Ò'Ñ)Ô)ÐJÐJÐ+JÑJÔJÐJÝ  Ñ-Ô-ˆÔÐÐr!   N)rá  râ  rã  r«   ræ  r‡   rx  rê   r÷  r	  rø  r  r~  r  r  rý  ro   r!   r   rú   rú   Æ  s×   € € € € € ð'ð 'ð 'ð ,ð ,ð ,ð#ð #ð #ð*ð *ð *ð2+ð +ð +ð(ð (ð (ð.ð ð ð$ð $ð $ð
ð ð ð$'ð 'ð 'ð. ð  ð  ðð ð ð&).ð ).ð ).ð ).ð ).r!   rú   c                   ó   — e Zd Zd„ Zd„ ZdS )r  c                 ó"   — || _         || _        d S r^   )r  rï  )r©   r  rï  s      r   r«   zLoadLocalFile.__init__©  s   € Ø ˆŒØ$ˆŒˆˆr!   c                 ó*  — | j         j        st          j        dd¦  «        ‚| j         }	 t	          | j        d¦  «        5 }t          |j        d¦  «        }	 |                     |¦  «        }|sn| 	                    |¦  «         Œ.	 ddd¦  «         n# 1 swxY w Y   n6# t          $ r) t          j        t          j        d| j        › d�¦  «        ‚w xY w|j        s| 	                    d	¦  «         dS dS # |j        s| 	                    d	¦  «         w w xY w)
z3Send data packets from the local file to the serverr   r0   r6  i @  TNzCan't find file 'r  r!   )rï  r§   r   r}  rÙ   r  r€  rE   r‡   r\  r?  ræ   r
   ÚFILE_NOT_FOUNDrÒ   )r©   ÚconnÚ	open_filer‚  Úchunks        r   r×   zLoadLocalFile.send_data­  sŠ  € àŒÔ$ð 	,ÝÔ$ Q¨Ñ+Ô+Ð+Øœ?ˆð	'Ý�d”m TÑ*Ô*ð -¨iÝ!ØÔ+¨Yñô �ð-Ø%ŸNšN¨;Ñ7Ô7�EØ ð ØØ×%Ò% eÑ,Ô,Ð,ð	-ð ð-ð -ð -ñ -ô -ð -ð -ð -ð -ð -ð -øøøð -ð -ð -ð -øøõ ð 	ð 	ð 	ÝÔ&ÝÔ!Ø4 D¤MÐ4Ð4Ð4ñô ð ð	øøøð ”<ð 'à×!Ò! #Ñ&Ô&Ð&Ð&Ð&ð'ð 'ø�4”<ð 'à×!Ò! #Ñ&Ô&Ð&Ð&ð'øøøsA   ªB ¿ABÂB ÂBÂB ÂBÂB ÂC3 Â3CÃC3 Ã3DN)rá  râ  rã  r«   r×   ro   r!   r   r  r  ¨  s2   € € € € € ð%ð %ð %ð'ð 'ð 'ð 'ð 'r!   r  )<r@  rˆ   re   r   r„   rP  r}   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×  r?  r<  rÙ  ÚBITÚBLOBÚ	LONG_BLOBÚMEDIUM_BLOBÚSTRINGÚ	TINY_BLOBÚ
VAR_STRINGÚVARCHARÚGEOMETRYr!  r—   re  r    r-   r/   rú   r  ro   r!   r   ú<module>r?     sØ  ðð
 €€€Ø 	€	€	€	Ø €€€Ø €€€Ø 
€
€
€
Ø Ð Ð Ð Ø €€€à Ð Ð Ð Ð Ð à 3Ð 3Ð 3Ð 3Ð 3Ð 3Ð 3Ð 3Ø IÐ IÐ IÐ IÐ IÐ IÐ IÐ IÐ IÐ IÐ IÐ IÐ IÐ IÐ IÐ IØ Ð Ð Ð Ð Ð Ø Ð Ð Ð Ð Ð Ø Ð Ð Ð Ð Ð ðð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð "Ð !Ð !Ð !Ð !Ð !Ð !Ð !ðØ€J€J€Jà€K€KøØð ð ð Ø
€CØ€K€K€Kðøøøð	Ø€N€N€Nà"�7”?Ñ$Ô$€LØˆøØ�X˜wÐ'ð ð ð ð €L€L€Lð	øøøð 	€ØÐ ð „NØ„OØÔØÔØÔØÔØÔØÔØÔð
€
ð €à€ð$ð $ð $ð

ð 
ð 
ð&e.ð e.ð e.ð e.ð e.ñ e.ô e.ð e.ðP#_.ð _.ð _.ð _.ð _.ñ _.ô _.ð _.ðD'ð 'ð 'ð 'ð 'ñ 'ô 'ð 'ð 'ð 's$   Á&A- Á-	A9Á8A9Á=B Â
BÂB