U
|
·ý°d É ã @ s 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 zd dl!Z!d Z"W n e#k
|
rô dZ!d Z"Y nX zd dl$Z$e$ %¡ Z&[$W n e#e'fk
|
r* dZ&Y nX d Z(ej)ej*ej+ej,ej-ej.ej/ej0ej1h Z2d Z3dZ4dd Z5dd Z6G dd dZ7G dd dZ8G dd dZ9dS )é 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_STRINGTFZutf8mb4éÿÿÿ c C s t d| ¡d d
S )Nú<Ié )ÚstructÚpack)Ún© r úJd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\pymysql/connections.pyÚ _pack_int24C s r c C s | dk rt d| nr| dk r(t| gS | dk r@dt d| ¡ S | dk r`dt d | ¡d d
|
S | d k rxd t d | ¡ S t d| d f d S )Nr zFEncoding %d is less than 0 - no representation in LengthEncodedIntegeréû i ó üú<Hé ó ýr r l ó þz<QzIEncoding %x is larger than %x - no representation in LengthEncodedInteger)Ú
|
ValueErrorÚbytesr r )Úir r r Ú _lenenc_intH s" ÿ
|
ÿÿr) c ' @ s& e Zd ZdZdZdZdZdZddddddddddddedddddddddddddddddddddddddd &d
|
d Z d d Z
|
dd Z dd Z dd Z edd Zdd ZeZdd Zdd Zd d Zd d Zd d! Zd"d# Zd$d% Zd&d' Zd(d) Zdbd*d+Zd,d- Z d.d/ Z d0d1 Z dcd2d3Z ddd4d5Z ded6d7Z!d8d9 Z"d:d; Z#dfd<d=Z$d>d? Z%dgd@dAZ&dBdC Z'e(fdDdEZ)dFdG Z*dHdI Z+dhdJdKZ,dLdM Z-dNdO Z.dPdQ Z/dRdS Z0dTdU Z1dVdW Z2dXdY Z3dZd[ Z4d\d] Z5d^d_ Z6d`da Z7e8j9Z9e8j:Z:e8j;Z;e8j<Z<e8j=Z=e8j>Z>e8j?Z?e8j@Z@e8jAZAe8jBZBdS )iÚ
|
ConnectionaI
|
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 charset: Charset 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_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Ú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_verify_certÚssl_verify_identityÚcompressÚ
|
named_pipeÚpasswdÚdbc & * s¼ |&d k r|d kr|&}|%d k r$|s$|%}|#s,|$r4t dt|| _| jrN| tjO } rl| sltj d¡rhd} nd} | r6szdt t
|
j | ¡¡ fdd}'|'d|}|'d |}|'d
|
|}|'d |}|'d |}t |'d |}|'d|}|'d|}| süi } t| tr6dD ](}(|'d|( | |(¡})|)r |)| |(< q d| _| sÒ| s`| s`| s`|!s`|"r¢| t|"|!d k rv|!ndd} | d k r| | d< | d k r¢| | d< | rÒts¶t dd| _| tjO } | | ¡| _|pÚd| _|pæd| _t| jt k rtd|p
|
t| _|pd| _ t| j t r6| j d ¡| _ || _ || _ || _!d | k r`d ksjn td |prd | _"|d k r|d krtd || _#|d k r´|d kr´td!|| _$|pÂt%| _&| | _'t(| j&j)| _)| tj*O } | j rö| tj+O } | | _,| | _-d | _.d | _/d"| _0|| _1|
|
d kr*t2j3}
|
d#d$ |
|
4¡ D | _5d%d$ |
|
4¡ D | _6|| _7|| _8|| _9|pli | _:|| _;|| _<d&t t
|
=¡ t>d'| _?|r¢|| j?d(< |r°d | _@n| A¡ d S ))Nz3compress and named_pipe arguments are not supportedÚwinz c:\my.iniz /etc/my.cnfÚclientc s4 |r|S z | ¡W S tk
|
r. | Y S X d S ©N)ÚgetÚ Exception)ÚkeyÚarg©Úcfgr< r r Ú_configñ s z$Connection.__init__.<locals>._configr- r. r/ r0 Úsocketr2 z bind-addresszdefault-character-set)ÚcaÚcapathÚcertrX Úcipherzssl-F)r^ Úcheck_hostnameÚ verify_moder` rX zssl module not foundTÚ localhostiê zport should be of type intó Úlatin1r i3áz+connect_timeout should be >0 and <=31536000zread_timeout should be > 0zwrite_timeout should be > 0z Not connectedc S s" i | ]\}}t |tk r||qS r ©ÚtypeÚint©Ú.0ÚkÚvr r r Ú
|
<dictcomp>K s z'Connection.__init__.<locals>.<dictcomp>c S s" i | ]\}}t |tkr||qS r rg rj r r r rn L s Zpymysql)Z _client_nameZ_pidZ_client_versionrF )BÚNotImplementedErrorÚboolÚ _local_infiler Z LOCAL_FILESÚsysÚplatformÚ
|
startswithr ÚreadÚosÚpathÚ
|
expanduserri Ú
|
isinstanceÚdictrV rH Ú SSL_ENABLEDÚSSLÚ_create_ssl_ctxÚctxr/ r2 rh r& Ú DEFAULT_USERr- r. ÚstrÚencoderR r1 rD r; Ú _read_timeoutÚ_write_timeoutÚDEFAULT_CHARSETr3 r7 r ÚencodingZ CAPABILITIESÚCONNECT_WITH_DBr8 r9 Ú_resultÚ_affected_rowsÚ host_infoÚautocommit_moder Z conversionsÚitemsÚencodersÚdecodersr4 r: r? Ú_auth_plugin_mapÚ_binary_prefixrG Úgetpidr Ú_connect_attrsÚ_sockÚconnect)*Úselfr- r. r/ r0 r1 r2 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 r\ rX Úvaluer rZ r Ú__init__¤ sÔ * ÿ
|
|
|
|
|
|
|
|
|
ÿû
|
|
|
|
|
|
|
ý
|
zConnection.__init__c C s | S rU r ©r r r r Ú __enter__b s zConnection.__enter__c G s ~| ¡ d S rU )Úclose)r Úexc_infor r r Ú__exit__e s zConnection.__exit__c C sR t |tjr|S | d¡}| d¡}|d ko2|d k}tj||d}| oR| dd¡|_| d¡}|d kr||rrtjntj|_nxt |t r|rtjntj|_nZt |t
|
r¬| ¡ }|dkr¾tj|_n6|dkrÐtj |_n$|d krâtj|_n|rìtjntj|_d
|
|kr|j |d
|
| d ¡d d |kr.| |d ¡ | jtjO _| jtjO _|S )Nr^ r_ )Úcafiler_ rb Trc )ÚnoneÚ0ÚfalseÚnoÚoptional)ÚrequiredÚ1ÚtrueÚyesr` rX )Úkeyfilera )ry rH Ú
|
SSLContextrV Úcreate_default_contextrb Ú CERT_NONEÚ CERT_REQUIREDrc rp r ÚlowerÚ CERT_OPTIONALÚload_cert_chainÚ set_ciphersÚoptionsÚ OP_NO_SSLv2Ú OP_NO_SSLv3)r Zsslpr^ r_ Zhasnocar~ Zverify_mode_valuer r r r} i s8
|
|
|
|
|
|
|
|
|
|
zConnection._create_ssl_ctxc C sl | j rt d¡d| _ | jdkr$dS t ddtj¡}z(z| |¡ W n t
|
k
|
rX Y nX W 5 | ¡ X dS )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 ZCOM_QUITÚ _force_closeÚ _write_bytesrW )r Ú send_datar r r r s
|
|
|
zConnection.closec C s
|
| j dk S )z&Return True if the connection is open.N)r r r r r Úopen s zConnection.openc C s2 | j r"z| j ¡ W n Y nX d| _ d| _dS )z&Close connection without QUIT message.N)r r Ú_rfiler r r r r¶ ¤ s zConnection._force_closec C s& t || _| ¡ }||kr"| ¡ d S rU )rp r Úget_autocommitÚ_send_autocommit_mode)r r Úcurrentr r r r= ° s
|
zConnection.autocommitc C s t | jtj@ S rU )rp Ú server_statusr ZSERVER_STATUS_AUTOCOMMITr r r r r» ¶ s zConnection.get_autocommitc C s2 | ¡ }| ¡ s t tjd¡t|}|j| _|S )NzCommand Out of Sync)Ú _read_packetÚ is_ok_packetr ÚOperationalErrorr ÚCR_COMMANDS_OUT_OF_SYNCr r¾ )r ÚpktÚokr r r Ú_read_ok_packet¹ s þzConnection._read_ok_packetc C s& | tjd| | j¡ ¡ | ¡ dS )z3Set whether or not to commit after every execute().zSET AUTOCOMMIT = %sN)Ú_execute_commandr Ú COM_QUERYÚescaper rÅ r r r r r¼ Ä s
|
ÿz Connection._send_autocommit_modec C s | tjd¡ | ¡ dS )zBegin transaction.ZBEGINN©rÆ r rÇ rÅ r r r r ÚbeginË s zConnection.beginc C s | tjd¡ | ¡ dS )z¨
|
Commit changes to stable storage.
|
|
See `Connection.commit() <https://www.python.org/dev/peps/pep-0249/#commit>`_
|
in the specification.
|
ZCOMMITNrÉ r r r r ÚcommitÐ s zConnection.commitc C s | tjd¡ | ¡ dS )z
|
Roll back the current transaction.
|
|
See `Connection.rollback() <https://www.python.org/dev/peps/pep-0249/#rollback>`_
|
in the specification.
|
ZROLLBACKNrÉ r r r r ÚrollbackÚ s zConnection.rollbackc C s$ | tjd¡ t| }| ¡ |jS )z%Send the "SHOW WARNINGS" SQL command.z SHOW WARNINGS)rÆ r rÇ Ú MySQLResultru Úrows)r Úresultr r r Ú show_warningsä s zConnection.show_warningsc C s | tj|¡ | ¡ dS )zI
|
Set current db.
|
|
:param db: The name of the db.
|
N)rÆ r Z COM_INIT_DBrÅ )r rR r r r Ú select_dbë s zConnection.select_dbc C sX t |tr d| |¡ d S t |ttfrF| |¡}| jrBd| }|S tj|| j |dS )zxEscape whatever value is passed.
|
|
Non-standard, for internal use; do not use this in your applications.
|
ú'Ú_binary)Úmapping)
|
ry r Ú escape_stringr' Ú bytearrayÚ _quote_bytesr r Z escape_itemr3 )r ÚobjrÔ Úretr r r rÈ ô s
|
|
zConnection.escapec C s | || j¡S )zkAlias for escape().
|
|
Non-standard, for internal use; do not use this in your applications.
|
)rÈ r )r rØ r r r Úliteral s zConnection.literalc C s" | j tj@ r| dd¡S t |¡S )NrÒ z'')r¾ r Ú"SERVER_STATUS_NO_BACKSLASH_ESCAPESÚreplacer rÕ ©r Úsr r r rÕ s zConnection.escape_stringc C s0 | j tj@ r&d| dd¡ dd¡f S t |¡S )Nz'%s'ó 's ''ÚasciiÚsurrogateescape)r¾ r rÛ rÜ Údecoder Z escape_bytesrÝ r r r r× s zConnection._quote_bytesc C s |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`.
|
)r9 )r Úcursorr r r rã s zConnection.cursorc C s: t |tr| | jd¡}| tj|¡ | j|d| _| jS )Nrá ©Ú
|
unbuffered) ry r r r
rÆ r rÇ Ú_read_query_resultr )r Úsqlrå r r r Úquery s
|
|
zConnection.queryc C s | j |d| _| jS )Nrä )ræ r )r rå r r r Ú next_result( s zConnection.next_resultc C s | j S rU )r r r r r Ú affected_rows, s zConnection.affected_rowsc C s" t d|¡}| tj|¡ | ¡ S )Nr )r r rÆ r ZCOM_PROCESS_KILLrÅ )r Ú thread_idrY r r r Úkill/ s zConnection.killc C st | j dkr&|r | ¡ d}n
|
t d¡z| tjd¡ | ¡ W n. tk
|
rn |rh| ¡ | d¡ n Y nX dS )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² r+ )
|
r r r rµ rÆ r ZCOM_PINGrÅ rW Úping)r Z reconnectr r r rí 4 s
|
|
zConnection.pingc C s: t |j}| tjd| |¡ ¡ | ¡ || _|| _d S )Nz SET NAMES %s)r r
rÆ r rÇ rÈ r¿ r3 )r r3 r
r r r Ú set_charsetM s
|
|
zConnection.set_charsetc
|
C s^ d| _ z´|d kr&| jr\t tjtj¡}| | j¡ | | j¡ d| _d| _ t
|
rZt d nÀi }| j d k rx| j df|d< z"tj | j| jf| jf|}W qÚW qx ttfk
|
rÖ } z|jtjkrÄW Y ¢qx W 5 d }~X Y qxX qxd| j| jf | _t
|
røt d | tjtjd ¡ | tjtjd ¡ | d ¡ || _| d
|
¡| _d| _ | ¡ | ¡ | j d k rr| ¡ }| !d | j f¡ | j"d k r¢| ¡ }| !| j"¡ | #¡ | $¡ | j%d k rº| &| j%¡ W n t'k
|
rX } z|d | _|d k rúz | #¡ W n Y nX t(|ttfrFt) *t+j,d | j|f ¡}||_-t. /¡ |_.t
|
rBt |j. | W 5 d }~X Y nX d S ) 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 %r (%s))0r´ r1 r] ÚAF_UNIXÚ SOCK_STREAMÚ
|
settimeoutr; r r Ú_secureÚDEBUGÚprintrD Úcreate_connectionr/ r2 ÚOSErrorÚIOErrorÚerrnoÚEINTRÚ
|
setsockoptÚ IPPROTO_TCPÚ TCP_NODELAYÚ
|
SOL_SOCKETÚ SO_KEEPALIVEr Úmakefilerº Ú _next_seq_idÚ_get_server_informationÚ_request_authenticationr4 rã Úexecuter: r rË r r= Ú BaseExceptionry r rÁ r ZCR_CONN_HOST_ERRORZoriginal_exceptionÚ tracebackÚ
|
format_exc)r ÚsockÚkwargsÚeÚcÚexcr r r r V s
|
|
|
|
ÿÿ
|
|
þ
|
|
zConnection.connectc C sF t t|t| jg | }tr(t| | |¡ | jd d | _dS )zvWrites an entire "mysql packet" in its entirety to the network
|
adding its length and sequence number.
|
r é N)r Úlenr' r rõ r r· )r ÚpayloadÚdatar r r Ú write_packet£ s
|
|
zConnection.write_packetc
|
C sð t }| d¡}t d|¡\}}}||d> }|| jkrj| ¡ |dkrVt tj d¡t
|
d|| jf ¡| jd d | _| |¡}t rt | ||7 }|d kr¢q|t k rq®q|t|| j} | ¡ rì| jd
|
k rä| jjd krä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.
|
é z<HBBé r ú,Lost connection to MySQL server during queryz1Packet sequence number wrong - got %d expected %dr r r NTF)rÖ Ú _read_bytesr Úunpackr r¶ r rÁ r ÚCR_SERVER_LOSTÚ InternalErrorrõ r ÚMAX_PACKET_LENr' r
Zis_error_packetr Úunbuffered_activeZraise_for_error)
|
r Z packet_typeZbuffZ packet_headerZbtrlZbtrhZ packet_numberZ bytes_to_readZ recv_dataÚpacketr r r r¿ ¯ s>
|
|
þÿÿ
|
zConnection._read_packetc
|
C s¾ | j | j¡ z| j |¡}W qW q ttfk
|
rx } z4|jtjkrLW Y ¢"q| ¡ t
|
t j d|f ¡W 5 d }~X Y q tk
|
r | ¡ Y qX qt||k rº| ¡ t
|
t j d¡|S )Nz1Lost connection to MySQL server during query (%s)r )r ró r rº ru rù rø rú rû r¶ r rÁ r r r r )r Ú num_bytesr r r r r r Ü s, þ
|
ÿzConnection._read_bytesc
|
C sb | j | j¡ z| j |¡ W n> tk
|
r\ } z | ¡ t tj d|f ¡W 5 d }~X Y nX d S )Nz MySQL server has gone away (%r))
|
r ró r Úsendallrù r¶ r rÁ r ZCR_SERVER_GONE_ERROR)r r r r r r r· õ s ÿzConnection._write_bytesc C sj d | _ |r<zt| }| ¡ W qL d|_d |_ Y qLX nt| }| ¡ || _ |jd k rd|j| _|jS ©NF)r rÍ Úinit_unbuffered_queryr Ú
|
connectionru r¾ rê )r rå rÏ r r r ræ ÿ s
|
|
z Connection._read_query_resultc C s | j r| j jS dS d S ©Nr )r Ú insert_idr r r r r# s zConnection.insert_idc C s | j st dd¡| jdk rP| jjr8t d¡ | j ¡ | jjrJ| ¡ q8d| _t
|
|t rf| | j ¡}ttt|d }t d||¡}||d|d
}| |¡ tr°t| d| _|tk rÂdS ||d d
}ttt|}| |d|
¡ ||d
}|sÒ|tk rÒqqÒdS )z~
|
:raise InterfaceError: If the connection is closed.
|
:raise ValueError: If no username was specified.
|
r r+ Nz.Previous unbuffered result was left incompleter r³ )r r ÚInterfaceErrorr r ÚwarningsÚwarnÚ_finish_unbuffered_queryÚhas_nextré ry r r r
Úminr r r r r· rõ r r r )r Úcommandrç Ú packet_sizeZpreluder r r r rÆ s4
|
|
|
|
|
|
zConnection._execute_commandc
|
C s¬ t | j dd¡d dkr*| jtjO _| jd kr<tdt| j j
|
}t | jt rd| j | j¡| _t d| jt|d¡}| jr¾| jtj@ r¾| |¡ | jj| j| jd| _| j d ¡| _d
|
| _ || j d }d}d }| j d krôd}t | j | j!¡}n®| j d krd}t | j | j!¡}n| j dkr^d}| j rNt"r<t#d t $| j | j!¡}nt"r¢t#d nD| j dkr¢d}| jr| jtj@ r| j d }n| j rd}nd }| jtj%@ rÆ|t&t'|| 7 }n4| jtj(@ rî|t dt'|¡| 7 }n ||d 7 }| j)r<| jtj*@ r<t | j)t r.| j) | j¡| _)|| j)d 7 }| jtj+@ r\||pTdd 7 }| jtj,@ rÔd}| j- .¡ D ]F\}}| d¡}|t&t'|| 7 }| d¡}|t&t'|| 7 }qx|t&t'|| 7 }| |¡ | /¡ } | 0¡ r@t"rþt#d | 1¡ | 2¡ }| jtj+@ r4|d k r4| 3|| ¡} n
|
t4 5d¡nZ| 6¡ rt"rXt#d | j dkrrt 7| | ¡} n(| j dkrt 8| | ¡} nt4 5d| j ¡t"r¨t#d d S ) NÚ.r r é zDid not specify a usernamez<iIB23sre )Úserver_hostnamerð Tó r+ Zmysql_native_passwordó mysql_native_passwordZcaching_sha2_passwordó caching_sha2_passwordz caching_sha2: trying fast pathz caching_sha2: empty passwordZsha256_passwordó sha256_passwordó ÚBúutf-8zreceived auth switchz$received unknown auth switch requestzreceived extra dataz(Received extra packet for auth method %rzSucceed to auth)9ri Úserver_versionÚsplitr8 r Z MULTI_RESULTSr- r& r r3 Úidry r r r
r r r rH Úserver_capabilitiesr| r r~ Ú wrap_socketr r/ r rº rô Ú_auth_plugin_namer Úscramble_native_passwordr. Úsaltrõ rö Zscramble_caching_sha2Z PLUGIN_AUTH_LENENC_CLIENT_DATAr) r ZSECURE_CONNECTIONrR r Ú PLUGIN_AUTHZ CONNECT_ATTRSr r r¿ Zis_auth_switch_requestÚ
|
read_uint8Ú read_stringÚ _process_authr rÁ Zis_extra_auth_dataÚcaching_sha2_password_authÚsha256_password_auth)
|
r Z
|
charset_idZ data_initr ZauthrespÚ plugin_nameZ connect_attrsrl rm Ú auth_packetr r r r B s°
|
ÿ
|
|
|
|
|
|
|
|
ÿþ
|
ÿz"Connection._request_authenticationc C s6 | |¡}|rRz | |¡W S tk
|
rP |dkrLt tjd|t|f ¡Y nX |dkrft | |¡S |dkrzt
|
| |¡S |dkrt | j | ¡ ¡}n|dkr¶t | j | ¡ ¡}nb|dkrØt | j | ¡ ¡d }n@|d krî| j d }n*|dkr|}| ¡ }|d
|
@ d k}|d @ d k}| ¡ } | d kr@| | j d ¡ n|rÆd}
|
z | || ¡}
|
| |
|
d ¡ W nZ tk
|
r t tjd||f ¡Y n0 tk
|
r t tjd|||
|
| f ¡Y nX nt tjd|f ¡| ¡ }| ¡ | ¡ s| rüq qü|S t tjd| ¡| |¡ | ¡ }| ¡ |S )Ns dialogzGAuthentication plugin '%s' not loaded: - %r missing authenticate methodr1 r2 r0 s client_ed25519s mysql_old_passwordr/ s mysql_clear_passwordé é r s
|
Password: z3no response - TypeError within plugin.prompt methodzAAuthentication plugin '%s' not loaded: - %r missing prompt methodzTAuthentication plugin '%s' %r didn't respond with string. Returned '%r' to prompt %rz)Authentication plugin '%s' not configured)Ú_get_auth_plugin_handlerZ authenticateÚAttributeErrorr rÁ r ÚCR_AUTH_PLUGIN_CANNOT_LOADrh r rB rC r< r. Zread_allZed25519_passwordZscramble_old_passwordr? r ÚpromptÚ TypeErrorZCR_AUTH_PLUGIN_ERRr¿ Z check_errorrÀ ) r rD rE Úhandlerr rà ÚflagZechoÚlastrK Úrespr r r rA ° s
|
|
þþ
|
ÿÿ
|
|
þþ
|
þþ þþ
|
zConnection._process_authc C sr | j |¡}|s,t|tr,| j | d¡¡}|rjz || }W qn tk
|
rf t tj d||f ¡Y qnX nd }|S )Nrà zXAuthentication plugin '%s' not loaded: - %r cannot be constructed with connection object)
|
r rV ry r' râ rL r rÁ r rJ )r rD Z plugin_classrM r r r rH ÿ s þþ z#Connection._get_auth_plugin_handlerc C s
|
| j d S r" )Úserver_thread_idr r r r rë s zConnection.thread_idc C s | j S rU )r3 r r r r Úcharacter_set_name s z Connection.character_set_namec C s | j S rU )r r r r r Ú get_host_info s zConnection.get_host_infoc C s | j S rU )Úprotocol_versionr r r r Úget_proto_info s zConnection.get_proto_infoc C s
|
d}| ¡ }| ¡ }|| | _|d7 }| d|¡}|||
d¡| _|d }t d|||d
¡| _|d7 }|||d
| _ |d7 }t d |||d
|
¡d | _
|
|d
|
7 }t ||d krft d |||d
¡\}}}}|d 7 }|| _ zt |j| _W n tk
|
r d | _Y nX || _tr6td | | j
|
|d> O _
|
trXtd| td|d }|d7 }t ||| kr¢| j ||||
7 _ ||7 }|d7 }| j
|
tj@ rt ||kr| d|¡}|dk rò||d
d¡| _n|||
d¡| _d S )Nr r r/ rf r r é é r" rG rF z<BHHBzserver_status: %xr z salt_len:é r, r5 )r¿ Z get_all_datarT Úfindrâ r6 r r rQ r= r9 r Zserver_languager ÚnameZserver_charsetÚKeyErrorr¾ rõ rö Úmaxr r> r; ) r r( r r Z
|
server_endÚlangÚstatZcap_hZsalt_lenr r r r sN
|
|
|
z"Connection._get_server_informationc C s | j S rU )r6 r r r r Úget_server_info_ s zConnection.get_server_info)N)N)F)F)T)N)F)CÚ__name__Ú
|
__module__Ú __qualname__Ú__doc__r r; r´ rô r r r r r} r Úpropertyr¹ r¶ Ú__del__r= r» rÅ r¼ rÊ rË rÌ rÐ rÑ rÈ rÚ rÕ r× rã rè ré rê rì rí rî r r r r¿ r r· ræ r# rÆ r rA rH rë rR rS rU r r_ r ÚWarningrµ r$ Z DatabaseErrorZ DataErrorrÁ ZIntegrityErrorr ZProgrammingErrorZNotSupportedErrorr r r r r* \ sÈ BØ ?
|
|
|
|
|
|
|
|
|
|
M -
|
|
+nOAr* c @ st e Zd Zdd Zdd Zdd Zdd Zd d
|
Zd d Zd d Z dd Z
|
dd Z dd Z dd Z dd Zdd ZdS ) rÍ c C sF || _ d| _d| _d| _d| _d| _d| _d| _d| _d| _ d| _
|
dS )z.
|
:type connection: Connection
|
Nr F) r! rê r# r¾ Ú warning_countÚmessageÚ field_countÚ descriptionrÎ r( r )r r! r r r r o s zMySQLResult.__init__c C s | j r| ¡ d S rU )r r' r r r r re s zMySQLResult.__del__c C sN z@| j ¡ }| ¡ r | |¡ n | ¡ r4| |¡ n
|
| |¡ W 5 d | _ X d S rU )r! r¿ rÀ rÅ Úis_load_local_packetÚ_read_load_local_packetÚ_read_result_packet©r Ú first_packetr r r ru s
|
zMySQLResult.readc C sl d| _ | j ¡ }| ¡ r0| |¡ d| _ d| _n8| ¡ rP| |¡ d| _ d| _n| ¡ | _| ¡ d| _
|
dS )zw
|
:raise OperationalError: If the connection to the MySQL server is lost.
|
:raise InternalError:
|
TFNl ÿÿÿÿ ) r r! r¿ rÀ rÅ rk rl Úread_length_encoded_integerri Ú_get_descriptionsrê rn r r r r s
|
|
|
|
z!MySQLResult.init_unbuffered_queryc C s< t |}|j| _|j| _|j| _|j| _|j| _|j| _d S rU )r rê r# r¾ rg rh r( )r ro Ú ok_packetr r r rÅ © s zMySQLResult._read_ok_packetc C sz | j jstdt|}t|j| j }z | ¡ W n | j ¡ Y nX | j ¡ }| ¡ slt
|
t j d¡| |¡ d S )NzF**WARN**: Received LOAD_LOCAL packet but local_infile option is false.zCommands Out of Sync)r! rq Ú RuntimeErrorr Ú LoadLocalFileÚfilenamer¸ r¿ rÀ r rÁ r r rÅ )r ro Z load_packetZsenderrr r r r rl ² s& ÿ
|
|
ÿþz#MySQLResult._read_load_local_packetc C s( | ¡ s dS t|}|j| _|j| _dS )NFT)Ú is_eof_packetr rg r( )r r Zwpr r r Ú_check_packet_is_eofÉ s z MySQLResult._check_packet_is_eofc C s | ¡ | _| ¡ | ¡ d S rU )rp ri rq Ú_read_rowdata_packetrn r r r rm Õ s
|
z MySQLResult._read_result_packetc C sP | j s
|
d S | j ¡ }| |¡r4d| _ d | _d | _d S | |¡}d| _|f| _|S )NFr )r r! r¿ rw rÎ Ú_read_row_from_packetrê )r r Úrowr r r Ú _read_rowdata_packet_unbufferedÚ s
|
|
|
z+MySQLResult._read_rowdata_packet_unbufferedc C s, | j r(| j ¡ }| |¡r d| _ d | _q d S r )r r! r¿ rw )r r r r r r' ì s
|
|
|
z$MySQLResult._finish_unbuffered_queryc C sJ g }| j ¡ }| |¡r d| _ q2| | |¡¡ qt|| _t|| _dS )z:Read a rowdata packet for each data row in the result set.N) r! r¿ rw Úappendry r rê ÚtuplerÎ )r rÎ r r r r rx ö s
|
|
|
z MySQLResult._read_rowdata_packetc C s g }| j D ]r\}}z | ¡ }W n tk
|
r8 Y q~Y nX |d k rr|d k rT| |¡}trbtd| |d k rr||}| |¡ q
|
t|S )NzDEBUG: DATA = )r Zread_length_coded_stringÚ
|
IndexErrorrâ rõ rö r| r} )r r rz r
Ú converterr r r r ry s
|
|
z!MySQLResult._read_row_from_packetc
|
C s g | _ g | _| jj}| jj}g }t| jD ]°}| j t¡}| j |¡ | |
|
¡ ¡ |j }|r|t j krn|}q|tkr|jdkrd}q|}qd}nd}| jj |¡}|tjkr²d}trÊtd| d| | j ||f¡ q*| j ¡ } | ¡ sötdt|| _
|
dS )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! r7 r
Úrangeri r¿ r r| rj Z type_coder
|
ZJSONÚ
|
TEXT_TYPESZ charsetnrr rV Zthroughrõ rö rv ÚAssertionErrorr} )
|
r r7 Z conn_encodingrj r( ÚfieldZ
|
field_typer
r Z
|
eof_packetr r r rq s8
|
|
|
|
z MySQLResult._get_descriptionsN)r` ra rb r re ru r rÅ rl rw rm r{ r' rx ry rq r r r r rÍ n s
|
rÍ c @ s e Zd Zdd Zdd ZdS )rt c C s || _ || _d S rU )ru r! )r ru r! r r r r C s zLoadLocalFile.__init__c C s¢ | j jst dd¡| j }zvzDt| jd.}t|jd}| |¡}|sHqT| |¡ q8W 5 Q R X W n, t
|
k
|
r t t j d| j d¡Y nX W 5 | d¡ X dS ) z3Send data packets from the local file to the serverr r+ re rð i @ zCan't find file 'rÒ N)r! r r r$ r r¹ ru r) r? ru rù rÁ r ZFILE_NOT_FOUND)r ÚconnÚ open_filer+ Úchunkr r r r¸ G s& ÿ
|
þzLoadLocalFile.send_dataN)r` ra rb r r¸ r r r r rt B s rt ):rú rv r] r rr r r% r+ r r3 r r Ú constantsr r r r r
|
r r Zcursorsr Z
|
optionfiler Úprotocolr r r r r r r r rH r{ Ú ImportErrorÚgetpassÚgetuserr r[ rõ ZBITZBLOBZ LONG_BLOBZ MEDIUM_BLOBÚSTRINGZ TINY_BLOBZ
|
VAR_STRINGZVARCHARZGEOMETRYr r r r r) r* rÍ rt r r r r Ú<module> sj
|
|
÷ U
|
