U
|
£ý°dö ã @ sÌ d Z ddlZddlZddlZddlZddlZddlZddlmZ ddl m
|
Z
|
ddl m Z m Z mZmZmZmZmZmZmZmZmZ ddlmZ ddlmZ dd lm Z dd
|
l m Z m Z m Z m!Z!m"Z"m#Z#m$Z$ dd l%m&Z& dd l'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4 dd l5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;m<Z<m=Z= ddl>m>Z> ddl?m@Z@mAZA ddlBmCZC ddlDmEZE ddlFmGZGmHZHmIZImJZJmKZKmLZLmMZMmNZNmOZOmPZPmQZQ ddlRmSZSmTZTmUZUmVZV G dd deZWdS )z.Implementing communication with MySQL servers.é N)ÚDecimal)ÚIOBase) ÚAnyÚBinaryIOÚDictÚ GeneratorÚListÚMappingÚOptionalÚSequenceÚTupleÚTypeÚUnioné )Úversion)ÚMySQLConnectionAbstract)Úget_auth_plugin)Ú CharacterSetÚ
|
ClientFlagÚ FieldTypeÚ ServerCmdÚ
|
ServerFlagÚ ShutdownTypeÚ flag_is_set)ÚMySQLConverter) Ú
|
CursorBaseÚ MySQLCursorÚMySQLCursorBufferedÚMySQLCursorBufferedDictÚ MySQLCursorBufferedNamedTupleÚMySQLCursorBufferedRawÚMySQLCursorDictÚMySQLCursorNamedTupleÚMySQLCursorPreparedÚMySQLCursorPreparedDictÚ MySQLCursorPreparedNamedTupleÚMySQLCursorPreparedRawÚMySQLCursorRaw)Ú DatabaseErrorÚErrorÚInterfaceErrorÚ InternalErrorÚNotSupportedErrorÚOperationalErrorÚProgrammingErrorÚ get_exception)Úlogger)ÚMySQLTCPSocketÚMySQLUnixSocket)ÚBaseAuthPlugin)Ú MySQLProtocol) Ú ConnAttrsTypeÚDescriptionTypeÚ EofPacketTypeÚ HandShakeTypeÚ OkPacketTypeÚ
|
ResultTypeÚRowTypeÚ
|
SocketTypeÚStatsPacketTypeÚ
|
StrOrBytesÚ!SupportedMysqlBinaryProtocolTypes)Ú get_platformÚ int1storeÚ int4storeÚlc_intc s e Zd ZdZedd fdd ZddddZddd d
|
Zdee ee ee e
|
e
|
ee e ee e e ee f f ee e d ddZdee ee ee dddZeee dddZee eedddZedddZdddd Zddd d Zddd d Z e Z de
|
ee e
|
ee e e
|
ee d"d#d$Z de e ed&d'd(Z e
|
dd)d*d+Z!e"e dd,d-Z#eedd.d/Z$ee%dd0d1Z&e ed2d3d4Z'ee(dd5d6Z)de eee* ee e+ee, ee% f d7d8d9Z-dee
|
e eee* ee ee+ee, ee% f d:d;d<Z.ddd=d>Z/e ed?d@dAZ0de1e e e e(dBdCdDZ2e1e3e(ddf dEdFdGZ4e
|
edHdIdJZ5eddKdLZ6dee
|
e%dMdNdOZ7e8ddPdQZ9e
|
edRdSdTZ:e%ddUdVZ;eddWdXZ<de e e e
|
e e e e e ee dZ
|
d[d\Z=e"e dd]d^Z>e>j?e dd_d`d^Z>e ddadbZ@e ddcdddeZAdee e ef ee e ef ddfdgdhZBde e
|
e
|
ddjdkdlZCe"ee
|
ddmdnZDd ee ee ee eeEeF ee ee eFdodpdqZGdddrdsZHdddtduZIe1ddvdwdxZJe1ee, dvdydzZKee e e
|
f dd{d|ZLee ee+e
|
ee* e%f f dd}d~ZMd¡e
|
e
|
ddddZNeeOe e e
|
ee* f f dddZPd¢e
|
eQeR eQe e
|
e ee+e
|
ee* e%f f dddZSe
|
ddddZTe
|
e
|
e e
|
dddZUe
|
ddddZVe dddZWddddZX ZYS )£ÚMySQLConnectionz Connection to a MySQL ServerN)ÚkwargsÚreturnc s" d | _ d | _d | _t ¡ t| _t ¡ | _ d| _
|
d | _ d | _ d| _ d| _d| _d| _d| _d| _d | _d| _d| _i | _d| _d| _d| _d| _d| _d| _ d| _ d| _ d| _ d | _ d| _!d | _"d | _#d | _$d| _%g | _&d| _'|r z| j(f | W n& t)k
|
r | *¡ d | _ Y nX d S ) Né- FÚ z 127.0.0.1iê r Tr )+Ú _protocolÚ_socketÚ
|
_handshakeÚsuperÚ__init__r Ú_converter_classr Z get_defaultÚ _client_flagsÚ _charset_idZ _sql_modeZ
|
_time_zoneZ _autocommitÚ_userÚ _passwordÚ _databaseZ_hostZ_portÚ _unix_socketZ _client_hostZ _client_portÚ_sslÚ _force_ipv6Z _use_unicodeZ _get_warningsZ_raise_on_warningsÚ _bufferedZ_unread_resultÚ_have_next_resultÚ_rawÚ_in_transactionZ_prepared_statementsÚ _ssl_activeÚ _auth_pluginÚ_krb_service_principalZ_pool_config_versionÚ_query_attrs_supportedÚ _columns_descÚ _mfa_nfactorÚconnectÚ ExceptionÚclose)ÚselfrE ©Ú __class__© úQd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\mysql/connector/connection.pyrM u sV
|
|
zMySQLConnection.__init__)rF c C sz t }tj d¡}|d dkr$d}nd}tt ¡ |d t ¡ d|d d d
|
tj
|
dd
D ¡|d d }| j |¡ dS )z&Add the default connection attributes.ú r ZGPLv2zGPL-2.0Z
|
CommercialÚarchzmysql-connector-pythonÚ.c S s g | ] }t |qS rg )Ústr)Ú.0Úxrg rg rh Ú
|
<listcomp>¹ s z;MySQLConnection._add_default_conn_attrs.<locals>.<listcomp>é r )Z_pidÚ _platformZ _source_hostZ _client_nameZ_client_licenseZ_client_versionÚ_osN) r@ r ÚLICENSEÚsplitrl ÚosÚgetpidÚsocketÚ gethostnameÚjoinÚVERSIONÚ _conn_attrsÚupdate)rd ÚplatformZlicense_chunksZclient_licenseZdefault_conn_attrsrg rg rh Ú_add_default_conn_attrs« s
|
ù
|
z'MySQLConnection._add_default_conn_attrsc C s4 | j ¡ }|d dkr t|d| _| j |¡}|d }| t|tt t
|
frP|nd¡| _ t | j ¡ |d tj@ s¶| jdkr| jstd| j d ¡r¢td
|
d d | jtj M _n| jsÌ| jtjO _|d tj@ rè| tjg¡ |d tj@ r d | _| tjg¡ |d tj@ r*| tjg¡ || _dS )z'Get the handshake from the MySQL serveré éÿ NZserver_version_originalÚUnknownZ capabilitiesZmysql_clear_passwordzEClear password authentication is not supported over insecure channelsÚ verify_certz1SSL is required but the server doesn't support itiê )ÚerrnoT) rJ Úrecvr/ rK rI Zparse_handshakeZ_check_server_versionÚ
|
isinstancerl ÚbytesÚ bytearrayÚ_server_versionr Zset_mysql_versionr ÚSSLr\ Ú is_securer* rU ÚgetrO Ú _ssl_disabledZ PLUGIN_AUTHZset_client_flagsÚCLIENT_QUERY_ATTRIBUTESr^ ZMULTI_FACTOR_AUTHENTICATION)rd ÚpacketÚ handshakeZserver_versionrg rg rh Ú _do_handshake¿ sB
|
ÿý ÿ þz MySQLConnection._do_handshaker rG )ÚusernameÚpasswordÚdatabaseÚ client_flagsÚcharsetÚ ssl_optionsÚ
|
conn_attrsrF c
|
C st d| _ |dkri }| js¬|tj@ r¬| jj||d}| j |¡ | d¡dk r^d | d¡¡} nd} | j
|
| d¡| d¡| d ¡| d
|
¡pd| d ¡pd| | d ¡¡ d | _ | j rÂ|| j krÂ| j }t d| j¡ | j d¡sö| j d¡rtjdkr|st ¡ }t d|| j¡ | jj| j|||||| j | j|| jd
|
}| j |¡ | ||¡ |tj@ sp|rp| |¡ d S )ae Authenticate with the MySQL server
|
|
Authentication happens in two parts. We first send a response to the
|
handshake. The MySQL server will then send either an AuthSwitchRequest
|
or an error packet.
|
|
Raises NotSupportedError when we get the old, insecure password
|
reply back. Raises any error coming from MySQL.
|
FN)r r Útls_ciphersuitesú:rH ÚcaÚcertÚkeyr Zverify_identityZ tls_versionsTz## _do_auth(): self._auth_plugin: %sZauthentication_ociZauthentication_kerberosÚntz4MySQL user is empty, OS user: %s will be used for %s)
|
r r r r r r Ú ssl_enabledÚ auth_pluginr Zauth_plugin_class)r[ r r r rI Z make_auth_sslrJ Úsendr ry Z switch_to_sslÚ
|
_password1r0 Údebugr\ Ú
|
startswithru ÚnameÚgetpassÚgetuserZ make_authrK Ú_auth_plugin_classÚ_auth_switch_requestÚCONNECT_WITH_DBÚ cmd_init_db)
|
rd r r r r r r r r r rg rg rh Ú_do_authì sp ÿ ù
|
ÿ
|
ýüúýö
|
zMySQLConnection._do_auth)r r rF c C s8 d}| j p| jd }t d|¡ | j ¡ }|d dkrJt|dkrJtd|d dkr| j |¡\}}t
|
|| j ||pz| j || j d}| |||¡}|d d krî| j |¡}t
|
|| j ||| j d
|
}|d krî| ¡ }|rä| j |¡ | j ¡ }|d d kr| |¡S |d d kr | |¡S |d dkr4t|dS )z®Handle second part of authentication
|
|
Raises NotSupportedError when we get the old, insecure password
|
reply back. Raises any error coming from MySQL.
|
Nr znew_auth_plugin: %sr éþ é zAuthentication with old (insecure) passwords is not supported. For more information, lookup Password Hashing in the latest MySQL manual©r r r r ©r r Úcaching_sha2_passwordr é r )r\ rK r0 r¢ rJ r Úlenr, rI Zparse_auth_switch_requestr r§ rQ r Ú_auth_continueÚparse_auth_more_dataÚ auth_responser Ú
|
_handle_okÚ _handle_mfar/ )rd r r ÚauthZnew_auth_pluginr Ú auth_dataÚresponserg rg rh r¨ < sP ÿ
|
ÿ
|
ý
|
ü
|
ÿ
|
|
|
z$MySQLConnection._auth_switch_request)r rF c C s, | j d7 _ | j dkr | j}n| j dkr2| j}ntdt d| j ¡ | j |dd
¡\}}t|| j d| j
|
|| j d}| |||¡}|d dkrä| j |¡}t|| j ||| j d }|d
|
krä| ¡ }|rÚ| j |¡ | j ¡ }|d d krú| |¡S |d dkr| |¡S |d d kr(t|dS ) z#Handle Multi Factor Authentication.r r± rp z5Failed Multi Factor Authentication (invalid N factor)z# MFA N Factor #%dr Nr® r¯ r° r r )r` Ú
|
_password2Ú
|
_password3r* r0 r¢ rI Zparse_auth_next_factorr r§ rQ r r³ r´ rµ rJ r r r¶ r· r/ )rd r r r r¸ r¹ rº rg rg rh r· q sH
|
|
ÿ
|
ü
|
ÿ
|
|
|
zMySQLConnection._handle_mfa)r¸ r r¹ rF c C s |dkr"t d|¡ | | j¡}nX|dkrBt d|¡ | |¡}n8|dkrrt d| j¡ | j|_| j|_| ¡ }n| ¡ }t d|t|¡ | j
|
|¡ | j ¡ }t d|¡ |dkrLt|dkrL|d d
|
krL|d d krL|d d
}| |¡}| j
|
|¡ | j ¡ }|d d kr|d d kr| |d d
¡r| j ¡ }nÆ|dkrÔ|dkrÔ|d dkrÔd }t d¡ t d|d |d
¡ t dt|¡ t d¡ d} d}
|
| sH|
|
d k rHt dd|
|
d d¡ t d|¡ t d|d |d
¡ | ||d
¡\} } t d | ¡ | j
|
| p.d ¡ | j ¡ }|
|
d7 }
|
q¶| sbtd |
|
d | t d |t|¡ | ||d
¡} t d!| t| ¡ | j
|
| ¡ | j ¡ }t d"|¡ | j ¡ }t d#|¡ n>|dkr|d dkrd }t d$¡ t d%|d |d
¡ t d&t|¡ t d¡ d} d}
|
| sÐ|
|
d k rÐt dd|
|
d d¡ t d'|¡ t d(|d |d
¡ | ||d
¡\} } | r¤| j
|
| ¡ | r®qÐ| j ¡ }t d)| ¡ |
|
d7 }
|
q4| sêtd |
|
d | t d*|t|¡ | j ¡ }t d+|¡ |S ),z!Continue with the authentication.Z authentication_ldap_sasl_clientz# auth_data: %sÚ authentication_kerberos_clientZauthentication_oci_clientz!# oci configuration file path: %sz# request: %s size: %sz # server response packet: %sé r ér é= Név s GSSAPIr r z*# Continue with sasl GSSAPI authenticationz# response header: %sr z# response size: %sz # Negotiate a service requestFr z%s Attempt %s %sz--------------------z<< server response: %sz# response code: %sz >> response to server: %só z'Unable to fulfill server request after z! attempts. Last server response: z0 last GSSAPI response from server: %s length: %dz* >> last response to server: %s length: %dz"<< final handshake from server: %sz << ok packet from server: %sz%# Continue with GSSAPI authenticationz# Response header: %sz# Response size: %sz<< Server response: %sz# Response code: %sz>> Response to server: %sz(Last response from server: %s length: %dz << Ok packet from server: %s)r0 r¢ rµ r] Ú_oci_config_fileÚoci_config_fileÚ_oci_config_profileÚoci_config_profiler² rJ r r Z auth_continueZ auth_finalizeZauth_continue_krbr* Zauth_accept_close_handshake)rd r¸ r r¹ rº r Z dec_responseZ cresponseZ
|
rcode_sizeZcompleteÚtriesÚstepZ last_stepÚtokenrg rg rh r³ sÒ
|
|
ÿ
|
þ
|
ý
|
ü
|
|
ÿþ
|
ý
|
|
|
ÿýý
|
|
|
|
|
ÿý
|
z MySQLConnection._auth_continuec C sF d}| j r"tjdkr"t| jd}nt| j| j| jd}| | j
|
¡ |S )zÉGet connection based on configuration
|
|
This method will return the appropriated connection object using
|
the connection parameters.
|
|
Returns subclass of MySQLBaseSocket.
|
NÚposix)Ú unix_socket)ÚhostÚportZ
|
force_ipv6) rT ru r¤ r2 rË r1 Z server_hostZ server_portrV Úset_connection_timeoutZ_connection_timeout)rd Úconnrg rg rh Ú_get_connection s ý z MySQLConnection._get_connectionc C s, | j dkr(| js(t| j | j}| ¡ | _t | _| ¡ | _zv| j ¡ |
|
¡ | | j| j | j | j| j| j| j¡ | | j¡ | jtj@ r¢| jj| j_| jj| j_| j d¡ W n tk
|
rÐ | j ¡ Y nX | j s(t | jj dr(t | jj j!r(| jj !¡ }|dkr(d| d}t" #|t$¡ dS )zOpen the connection to the MySQL server
|
|
This method sets up and opens the connection to the MySQL server.
|
|
Raises on errors.
|
r½ Nr )ÚTLSv1zTLSv1.1zThis connection is using zZ which is now deprecated and will be removed in a future release of MySQL Connector/Python)%r\ rQ r r§ Zget_user_from_credentialsr4 rI rÐ rJ Zopen_connectionr r« rR rS rO rP rU r{ Zset_converter_classrN r ZCOMPRESSZrecv_compressedr Zsend_compressedr rÎ rb Úclose_connectionr ÚhasattrÚsockÚcallabler ÚwarningsÚwarnÚDeprecationWarning)rd ÚclsZ tls_versionZwarn_msgrg rg rh Ú_open_connection, sH
|
|
|
ù
|
ÿ þ ý
|
|
ÿz MySQLConnection._open_connectionc C s6 | j s
|
dS z| j ¡ W n ttfk
|
r0 Y nX dS )z%Shut down connection to MySQL Server.N)rJ ÚshutdownÚAttributeErrorr) ©rd rg rg rh rÛ ^ s zMySQLConnection.shutdownc C sD | j s
|
dS z | ¡ W n ttfk
|
r. Y nX | j ¡ d| _dS )z Disconnect from the MySQL serverN)rJ Úcmd_quitrÜ r) rÒ rK rÝ rg rg rh rc h s
|
zMySQLConnection.closeT)ÚcommandÚargumentÚ packet_numberr Úexpect_responseÚcompressed_packet_numberrF c
|
C sj | ¡ z"| j | j ||p |¡||¡ W n, tk
|
rV } ztd|W 5 d}~X Y nX |s`dS | j ¡ S )a4 Send a command to the MySQL server
|
|
This method sends a command with an optional argument.
|
If packet is not None, it will be sent and the argument will be
|
ignored.
|
|
The packet_number is optional and should usually not be used.
|
|
Some commands might not result in the MySQL server returning
|
a response. If a command does not return anything, you should
|
set expect_response to False. The _send_cmd method will then
|
return None instead of a MySQL packet.
|
|
Returns a MySQL packet or None.
|
ú MySQL Connection not availableN)Úhandle_unread_resultrJ r rI Ú make_commandrÜ r- r )rd rß rà rá r râ rã Úerrrg rg rh Ú _send_cmdv s ý zMySQLConnection._send_cmdF)Ú data_fileÚsend_empty_packetrF c
|
C sÊ | ¡ t|dstdd}z2| |d ¡}|rN| j |¡ | |d ¡}q.W n, tk
|
r| } ztd|W 5 d}~X Y nX |rÀz| j d¡ W n, tk
|
r¾ } ztd|W 5 d}~X Y nX | j ¡ S )a4 Send data to the MySQL server
|
|
This method accepts a file-like object and sends its data
|
as is to the MySQL server. If the send_empty_packet is
|
True, it will send an extra empty package (for example
|
when using LOAD LOCAL DATA INFILE).
|
|
Returns a MySQL packet.
|
Úreadz expecting a file-like objecté é rä Nr ) rå rÓ Ú
|
ValueErrorrë rJ r rÜ r- r )rd ré rê Ú
|
chunk_sizeÚbufrç rg rg rh Ú
|
_send_data s"
|
zMySQLConnection._send_data)ÚflagsrF c C s t tj|| _t tj|| _dS )a Handle the server flags found in MySQL packets
|
|
This method handles the server flags send by MySQL OK and EOF
|
packets. It, for example, checks whether there exists more result
|
sets or whether there is an ongoing transaction.
|
N)r r ZMORE_RESULTS_EXISTSrX ZSTATUS_IN_TRANSrZ )rd rò rg rg rh Ú_handle_server_status¿ s z%MySQLConnection._handle_server_statusc C s | j S )z'MySQL session has started a transaction)rZ rÝ rg rg rh Úin_transactionÉ s z MySQLConnection.in_transactionc C sJ |d dkr*| j |¡}| |d ¡ |S |d dkr>t|tddS )a Handle a MySQL OK packet
|
|
This method handles a MySQL OK packet. When the packet is found to
|
be an Error packet, an error will be raised. If the packet is neither
|
an OK or an Error packet, InterfaceError will be raised.
|
|
Returns a dict()
|
r r Ú status_flagr zExpected OK packetN)rI Zparse_okró r/ r* )rd r Zok_pktrg rg rh r¶ Î s zMySQLConnection._handle_okc C sJ |d dkr*| j |¡}| |d ¡ |S |d dkr>t|tddS )a Handle a MySQL EOF packet
|
|
This method handles a MySQL EOF packet. When the packet is found to
|
be an Error packet, an error will be raised. If the packet is neither
|
and OK or an Error packet, InterfaceError will be raised.
|
|
Returns a dict()
|
r r¬ rõ r zExpected EOF packetN)rI Z parse_eofró r/ r* )rd r Úeofrg rg rh Ú _handle_eofß s zMySQLConnection._handle_eof)ÚfilenamerF c C s t j |¡}t j |¡r td| js4| js4td| jsÂ| jrÂt j | j¡}d}zt j ||g¡}W n> t k
|
r¤ } z d}t
|
| t |||¡|W 5 d}~X Y nX ||krÂd}t| ||¡zz$t|d}| | j|dd¡W W ¢nS tk
|
rP z| j d ¡ W n. tk
|
r8 } ztd
|
|W 5 d}~X Y nX t
|
d | d dY nX W 5 z | ¡ W n ttfk
|
r| Y nX X dS ) z'Handle a LOAD DATA INFILE LOCAL requestz#Use of symbolic link is not allowedúKLOAD DATA LOCAL INFILE file request rejected due to restrictions on access.NzL{} while loading file `{}` and path `{}` given in allow_local_infile_in_pathzEThe file `{}` is not found in the given allow_local_infile_in_path {}ÚrbT)rê r rä zFile 'z' could not be read)ru ÚpathÚabspathÚislinkr- Z_allow_local_infileÚ_allow_local_infile_in_pathr( Ú
|
commonpathrî r* Úformatrl rc ÚIOErrorÚ NameErrorÚopenr¶ rñ rJ r rÜ )rd rø Ú file_nameZ infile_pathZc_pathrç Úerr_msgré rg rg rh Ú_handle_load_data_infileð sJ ÿ ÿÿþÿ
|
z(MySQLConnection._handle_load_data_infilec C sú |rt |dk rtd|d dkr.| |¡S |d dkrT|dd
¡ }| |¡S |d dkrj| |¡S |d dkr~t|| j |¡}|rt |t
|
s td dg| | _ t d|D ] }| j | j ¡ | j¡| j |< q¶| | j ¡ ¡}d
|
| _| j |d S ) a Handle a MySQL Result
|
|
This method handles a MySQL result, for example, after sending the
|
query command. OK and EOF packets will be handled and returned. If
|
the packet is an Error packet, an Error-exception will be
|
raised.
|
|
The dictionary returned of:
|
- columns: column information
|
- eof: the EOF-packet information
|
|
Returns a dict()
|
r úEmpty responser éû r Nr¬ r zIllegal result setT)Úcolumnsrö )r² r* r¶ Údecoder r÷ r/ rI Úparse_column_countr
Úintr_ ÚrangeÚ parse_columnrJ r Úpython_charsetÚ unread_result)rd r rø Ú column_countÚirö rg rg rh Ú_handle_result s4
|
|
|
ÿþ ÿ z MySQLConnection._handle_result)Úbinaryr ÚrawrF c C s. | j d|||d\}}|r&|d |fS d|fS )aT Get the next rows returned by the MySQL server
|
|
This method gets one row from the result set after sending, for
|
example, the query command. The result is a tuple consisting of the
|
row and the EOF packet.
|
If no row was available in the result set, the row data will be None.
|
|
Returns a tuple.
|
r )Úcountr r r r N)Úget_rows)rd r r r Úrowsrö rg rg rh Úget_rowK s zMySQLConnection.get_row)r r r r Ú prep_stmtrF c
|
|
s |dkrj }js tdg df}zF|rRj}|dkr<d}j j|||¡}njjjj|d}W n, t k
|
r } zd_|W 5 d}~X Y nX |\}} |sÜ|sÜj
|
dk rÜ|rÜt drÜj j fdd |D }| dk r
|
d
|
| krú| d
|
n| d ¡ d_|| fS ) a Get all rows returned by the MySQL server
|
|
This method gets all rows returned by the MySQL server after sending,
|
for example, the query command. The result is a tuple consisting of
|
a list of rows and the EOF packet.
|
|
Returns a tuple()
|
NzNo result set availableÚutf8mb4Úutf8)r FÚ converterc s g | ]} |j qS rg )r_ )rm Úrow©Ú row_to_pythonrd rg rh ro s z,MySQLConnection.get_rows.<locals>.<listcomp>rõ Z server_status)rY r r+ r rI Zread_binary_resultrJ Zread_text_resultr r) r_ rÓ r r ró )
|
rd r r r r r r r rç Zeof_prg r rh r _ sZ ÿ ÿ
|
ÿÿþýü
|
ÿ
|
ýzMySQLConnection.get_rowsc C s | j r| ¡ dS )zConsume resultsN)r r rÝ rg rg rh Úconsume_results s z MySQLConnection.consume_results)r rF c C s | | tj| d¡¡¡S )zëChange the current database
|
|
This method changes the current (default) database by sending the
|
INIT_DB command. The result is a dictionary containing the OK packet
|
information.
|
|
Returns a dict()
|
úutf-8)r¶ rè r ZINIT_DBÚencode)rd r rg rg rh rª s ÿzMySQLConnection.cmd_init_db)Úqueryr ÚbufferedÚ raw_as_stringrF c
|
C s t |ts&t |tr | d¡}t|}| jdkr6| jnd}t }| jsZ| jrZtjdt d | j
|
t j @ rg }g }g } dgt | jd d }
|
t| jD ]ð\} } | d } d}| d
|
krê|
|
| d d | d > O < | ttjt| ¡ qt | tr| j | ¡\}}}| |¡ n8t | trL| |¡} | tt | | ¡ tj}nt | trv| tt | | ¡ tj}nØt | tr´| tt t| |¡t| |¡ ¡ tj}nt | t rÚ| t d | ¡¡ tj }ntt | t j t j!fr
|
| j "| ¡\}}| |¡ nDt | t j#t j$fr:| j %| ¡\}}| |¡ nt&d | j'j( d | t|t| ¡ | d |¡}| tt || ¡ q| )tt | j¡ | )td ¡ | r| )d *dd |
|
D ¡td ¡ t+||D ] \}}| )|¡ | )|¡ qÞ| D ]} | )| ¡ q| )|¡ t|}z| ,| -t.j/|¡¡}W nL t&k
|
r } z,|j0dkrxd|j1krxd}t2|| W 5 d
|
}~X Y nX | j3rt4d|S )a Send a query to the MySQL server
|
|
This method send the query to the MySQL server and returns the result.
|
|
If there was a text result, a tuple will be returned consisting of
|
the number of columns and a list containing information about these
|
columns.
|
|
When the query doesn't return a text result, the OK or EOF packet
|
information as dictionary will be returned. In case the result was
|
an error, exception Error will be raised.
|
|
Returns a tuple()
|
r" r r ú<This version of the server does not support Query Attributes©Úcategoryr é é r Nz<dz&MySQL binary protocol can not handle 'z ' objectsr c S s g | ]}t d |¡qS )ÚB)ÚstructÚpack)rm Úbitrg rg rh ro s z-MySQLConnection.cmd_query.<locals>.<listcomp>il z Loading local data is disabledrù z8Use cmd_query_iter for statements with multiple queries.)5r
r rl r# r r^ Ú _query_attrsrÖ r× ÚWarningrO r r r² Ú enumerateÚappendrA r ÚNULLr rI Zprepare_binary_integerrC ZVARCHARr ZBLOBr ZDECIMALÚfloatr- r. ÚDOUBLEÚdatetimeÚdateZprepare_binary_timestampÚ timedeltaÚtimeZprepare_binary_timer. rf Ú__name__Úextendry Úzipr rè r ÚQUERYr Úmsgr( rX r* )rd r$ r r% r& r r ÚnamesÚtypesÚvaluesZ null_bitmapÚposZ
|
attr_tupleÚvaluerò ÚpackedZ
|
field_typer¤ Ú_typeÚresultrç r rg rg rh Ú cmd_query¬ s´
|
|
|
þ
|
ü
|
|
ÿÿ
|
ý ÿÿÿ
|
|
ÿ
|
ÿzMySQLConnection.cmd_query)Ú
|
statementsrF c c s¢ t }t|t s,t|tr$| d¡}t |}| jtj@ rT| td¡ | td¡ | |¡ t |}|
|
| t j |¡¡V | jr| ¡ |
|
| j ¡ ¡V q|dS )at Send one or more statements to the MySQL server
|
|
Similar to the cmd_query method, but instead returns a generator
|
object to iterate through results. It sends the statements to the
|
MySQL server and through the iterator you can get the results.
|
|
statement = 'SELECT 1; INSERT INTO t1 VALUES (); SELECT 2'
|
for result in cnx.cmd_query(statement, iterate=True):
|
if 'columns' in result:
|
columns = result['columns']
|
rows = cnx.get_rows()
|
else:
|
# do something useful with INSERT result
|
|
Returns a generator.
|
r r r N)r r
rl r# rO r r r< rC r r rè r r> rX rå rJ r )rd rI r r$ rg rg rh Úcmd_query_iter& s
|
|
|
|
z MySQLConnection.cmd_query_iter)ÚoptionsrF c C s | | tjt|¡¡S )aÚ Send the Refresh command to the MySQL server
|
|
This method sends the Refresh command to the MySQL server. The options
|
argument should be a bitwise value using constants.RefreshOption.
|
Usage example:
|
RefreshOption = mysql.connector.RefreshOption
|
refresh = RefreshOption.LOG | RefreshOption.THREADS
|
cnx.cmd_refresh(refresh)
|
|
The result is a dictionary with the OK packet information.
|
|
Returns a dict()
|
)r¶ rè r ZREFRESHrB )rd rK rg rg rh Ú cmd_refreshP s zMySQLConnection.cmd_refreshc C s* | ¡ | j tj¡}| j |dd¡ |S )a Close the current connection with the server
|
|
This method sends the QUIT command to the MySQL server, closing the
|
current connection. Since the no response can be returned to the
|
client, cmd_quit() will return the packet it send.
|
|
Returns a str()
|
r )rå rI ræ r ZQUITrJ r ©rd r rg rg rh rÞ ` s zMySQLConnection.cmd_quit)Ú shutdown_typerF c C s: |r t |¡std|}nt j}| | tjt|¡¡S )aZ Shut down the MySQL Server
|
|
This method sends the SHUTDOWN command to the MySQL server and is only
|
possible if the current user has SUPER privileges. The result is a
|
dictionary containing the OK packet information.
|
|
Note: Most applications and scripts do not the SUPER privilege.
|
|
Returns a dict()
|
zInvalid shutdown type) r Úget_infor* ZSHUTDOWN_DEFAULTr÷ rè r ZSHUTDOWNrB )rd rN Úatyperg rg rh Ú cmd_shutdowno s
|
z MySQLConnection.cmd_shutdownc C s8 | ¡ | j tj¡}| j |dd¡ | j | j ¡ ¡S )zâSend the statistics command to the MySQL Server
|
|
This method sends the STATISTICS command to the MySQL server. The
|
result is a dictionary with various statistical information.
|
|
Returns a dict()
|
r ) rå rI ræ r Z
|
STATISTICSrJ r Zparse_statisticsr rM rg rg rh Úcmd_statistics s z MySQLConnection.cmd_statistics)Ú mysql_pidrF c C s | | tjt|¡¡S )zÞKill a MySQL process
|
|
This method send the PROCESS_KILL command to the server along with
|
the process ID. The result is a dictionary with the OK packet
|
information.
|
|
Returns a dict()
|
)r¶ rè r Z PROCESS_KILLrB )rd rS rg rg rh Úcmd_process_kill s ÿz MySQLConnection.cmd_process_killc C s | | tj¡¡S )aF Send the DEBUG command
|
|
This method sends the DEBUG command to the MySQL server, which
|
requires the MySQL user to have SUPER privilege. The output will go
|
to the MySQL server error log and the result of this method is a
|
dictionary with EOF packet information.
|
|
Returns a dict()
|
)r÷ rè r ÚDEBUGrÝ rg rg rh Ú cmd_debug s
|
zMySQLConnection.cmd_debugc C s | | tj¡¡S )a Send the PING command
|
|
This method sends the PING command to the MySQL server. It is used to
|
check if the the connection is still valid. The result of this
|
method is dictionary with OK packet information.
|
|
Returns a dict()
|
)r¶ rè r ZPINGrÝ rg rg rh Úcmd_ping© s zMySQLConnection.cmd_pingrH )
|
r r r r Ú password1Ú password2Ú password3rÄ rÆ rF c
|
C sò t |tstd|dk r"tdd| _|| _|| _|| _|| _|| _| jr\|| jkr\| j}| ¡ | j
|
rrt d| j j | j||||| j| j| j| jd }
|
| j |
|
dd¡ |r´|| _| | _| ||¡} | jtj@ sà|rà| |¡ || _| ¡ | S )zÑChange the current logged in user
|
|
This method allows to change the current logged in user information.
|
The result is a dictionary with OK packet information.
|
|
Returns a dict()
|
zcharset must be an integerr z2charset should be either zero or a postive integerr z-Change user is not supported with compression) r r r r r r r r r ) r
r rî r` rQ rR r¡ r» r¼ rå Z _compressr, rI Zmake_change_userrK rO r[ r\ r{ rJ r rà rÅ r¨ r r© rª rP Ú_post_connection) rd r r r r rX rY rZ rÄ rÆ r Z ok_packetrg rg rh Úcmd_change_user´ sH
|
÷
|
z MySQLConnection.cmd_change_userc C s | d¡d S )zGet the current databasezSELECT DATABASE()r )Ú
|
info_queryrÝ rg rg rh r ö s zMySQLConnection.database)rD rF c C s | d| ¡ dS )zSet the current databasezUSE N)rH )rd rD rg rg rh r û s c C s( z | ¡ W n tk
|
r" Y dS X dS )a2 Reports whether the connection to MySQL Server is available
|
|
This method checks whether the connection to MySQL is available.
|
It is similar to ping(), but unlike the ping()-method, either True
|
or False is returned and no exception is raised.
|
|
Returns True or False.
|
FT)rW r) rÝ rg rg rh Ú is_connected s
|
z MySQLConnection.is_connected)rû rF c C s
|
|| _ dS )zySet the path that user can upload files.
|
|
Args:
|
path (str): Path that user can upload files.
|
N)rþ )rd rû rg rg rh Ú set_allow_local_infile_in_path s z.MySQLConnection.set_allow_local_infile_in_path)Úuser_variablesÚsession_variablesrF c C sÊ | ¡ std| ¡ sfz0| | j| j| j| j| j| j | j
|
| j | j ¡ W n t k
|
rd | ¡ Y nX | ¡ }|r| ¡ D ] \}}| d| d|f¡ qz|rÆ| ¡ D ] \}}| d| d|f¡ q¦dS )aÇ Clears the current active session
|
|
This method resets the session state, if the MySQL server is 5.7.3
|
or later active session will be reset without re-authenticating.
|
For other server versions session will be reset by re-authenticating.
|
|
It is possible to provide a sequence of variables and their values to
|
be set after clearing the session. This is possible for both user
|
defined variables and session variables.
|
This method takes two arguments user_variables and session_variables
|
which are dictionaries.
|
|
Raises OperationalError if not connected, InternalError if there are
|
unread results and InterfaceError on errors.
|
z MySQL Connection not available.zSET @`z` = %sz SET SESSION `N)r^ r- Úcmd_reset_connectionr\ rQ rR rS rP r¡ r» r¼ rà rÅ r. Ú reconnectÚcursorÚitemsÚexecute)rd r` ra Úcurr rD rg rg rh Ú reset_session s0 ÷ z MySQLConnection.reset_sessionr )rc ÚattemptsÚdelayrF c
|
C sR z | ¡ W n@ tk
|
rL } z"|r2| j||d n
|
td|W 5 d}~X Y nX dS )aî Check availability of the MySQL server
|
|
When reconnect is set to True, one or more attempts are made to try
|
to reconnect to the MySQL server using the reconnect()-method.
|
|
delay is the number of seconds to wait between each retry.
|
|
When the connection is not available, an InterfaceError is raised. Use
|
the is_connected()-method if you just want to check the connection
|
without raising an error.
|
|
Raises InterfaceError on errors.
|
)ri rj z$Connection to MySQL is not availableN)rW r) rc r* )rd rc ri rj rç rg rg rh ÚpingF s zMySQLConnection.pingc C s | j r| j d¡S dS )zMySQL connection IDZserver_threadidN)rK r rÝ rg rg rh Ú connection_id\ s z MySQLConnection.connection_id)r% r ÚpreparedÚ cursor_classÚ
|
dictionaryÚ named_tuplerF c s& | ¡ | ¡ std|dk r:t|ts2td|| S |dk rF|n| j}|dk rX|n| j}d|dkrrdO |dkrdO |dkrdO |dkr¢d O |dkr²d
|
O tt t
|
t t t ttttttd }z| | W S tk
|
r d td d fddtdD ¡ dY nX dS )aï Instantiates and returns a cursor
|
|
By default, MySQLCursor is returned. Depending on the options
|
while connecting, a buffered and/or raw cursor is instantiated
|
instead. Also depending upon the cursor options, rows can be
|
returned as dictionary or named tuple.
|
|
Dictionary and namedtuple based cursors are available with buffered
|
output but not raw.
|
|
It is possible to also give a custom cursor through the
|
cursor_class parameter, but it needs to be a subclass of
|
mysql.connector.cursor.CursorBase.
|
|
Raises ProgrammingError when cursor_class is not a subclass of
|
CursorBase. Raises ValueError when cursor is not available.
|
|
Returns a cursor-object
|
rä Nz6Cursor class needs be to subclass of cursor.CursorBaser Tr r± r r+ rí ) r r r± rp r r r+ é rí é é é )r% r ro rp rm z*Cursor not available with given criteria: z, c s$ g | ] }d |> @ dkr | qS )r r rg )rm r ©ÚargsZ cursor_typerg rh ro s z*MySQLConnection.cursor.<locals>.<listcomp>r )rå r^ r- Ú
|
issubclassr r. rW rY r r r' r r! r r" r r# r& r$ r% ÚKeyErrorrî ry r )rd r% r rm rn ro rp rA rg ru rh rd c s\
|
ÿô ÿÿýzMySQLConnection.cursorc C s | d¡ dS )zCommit current transactionZCOMMITN)Ú_execute_queryrÝ rg rg rh Úcommit° s zMySQLConnection.commitc C s | j r| ¡ | d¡ dS )z Rollback current transactionZROLLBACKN)r r ry rÝ rg rg rh Úrollback´ s zMySQLConnection.rollback)r$ rF c C s | ¡ | |¡ dS )a Execute a query
|
|
This method simply calls cmd_query() after checking for unread
|
result. If there are still unread result, an InterfaceError
|
is raised. Otherwise whatever cmd_query() returns is returned.
|
|
Returns a dict()
|
N)rå rH )rd r$ rg rg rh ry » s z MySQLConnection._execute_queryc C s | j dd}| |¡ | ¡ S )z%Send a query which only returns 1 rowT)r% )rd rf Zfetchone)rd r$ rd rg rg rh r] Ç s
|
zMySQLConnection.info_queryc C s8 |d dkr| j |¡S |d dkr,t|tddS )a> Handle a MySQL Binary Protocol OK packet
|
|
This method handles a MySQL Binary Protocol OK packet. When the
|
packet is found to be an Error packet, an error will be raised. If
|
the packet is neither an OK or an Error packet, InterfaceError
|
will be raised.
|
|
Returns a dict()
|
r r r zExpected Binary OK packetN)rI Zparse_binary_prepare_okr/ r* rM rg rg rh Ú_handle_binary_okÍ s
|
|
z!MySQLConnection._handle_binary_okc C sÈ |rt |dk rtd|d dkr.| |¡S |d dkrD| |¡S |d dkrXt|| j |¡}|rrt|tsztddg| }t d|D ] }| j
|
| j ¡ | j ¡||< q| | j ¡ ¡}|||fS )aý Handle a MySQL Result
|
|
This method handles a MySQL result, for example, after sending the
|
query command. OK and EOF packets will be handled and returned. If
|
the packet is an Error packet, an Error exception will be raised.
|
|
The tuple returned by this method consist of:
|
- the number of columns in the result,
|
- a list of tuples with information about the columns,
|
- the EOF packet information as a dictionary.
|
|
Returns tuple() or dict()
|
r r r r¬ r zIllegal result set.N)r² r* r¶ r÷ r/ rI r r
r r r rJ r r )rd r r r r rö rg rg rh Ú_handle_binary_resultÝ s&
|
|
|
ÿ
|
z%MySQLConnection._handle_binary_result)Ú statement_idr rF c C s0 | j ||¡}d| _| jtj|dd d| _dS )z³Fetch a MySQL statement Result Set
|
|
This method will send the FETCH command to MySQL together with the
|
given statement id and the number of rows to fetch.
|
F©râ TN)rI Zmake_stmt_fetchr rè r Z
|
STMT_FETCH)rd r~ r r rg rg rh Úcmd_stmt_fetch s z MySQLConnection.cmd_stmt_fetch)Ú statementrF c C sÌ | tj|¡}| |¡}g |d< g |d< |d dkrxtd|d D ]$}|d | j | j ¡ | j
|
¡¡ qB| | j ¡ ¡ |d dkrÈtd|d D ]$}|d | j | j ¡ | j
|
¡¡ q| | j ¡ ¡ |S )z£Prepare a MySQL statement
|
|
This method will send the PREPARE command to MySQL together with the
|
given statement.
|
|
Returns a dict()
|
r Ú
|
parametersZ
|
num_paramsr Z num_columns) rè r Z STMT_PREPAREr| r r3 rI r rJ r r r÷ )rd r r rG Ú_rg rg rh Úcmd_stmt_prepare s.
|
|
ÿÿ ÿÿz MySQLConnection.cmd_stmt_preparerg )r~ Údatar rò rF c
|
C s t |}i }|rxt|D ]^\}}t|| trd}zd|| jk}W n tk
|
rX Y nX | |||| ¡ |f||< q| js| jrt j
|
dt d | j t j@ rÄ| j ||t|||| j| j| j¡} n"| jj||t|||| j| jd} | jtj| d}
|
| |
|
¡} | S )z"Execute a prepared MySQL statementTÚbr' r( )Zconverter_str_fallback)r )Úlistr2 r
r ÚmoderÜ Úcmd_stmt_send_long_datar^ r0 rÖ r× r1 rO r r rI Zmake_stmt_executeÚtupler Z_converter_str_fallbackrè r Z STMT_EXECUTEr} ) rd r~ r
r rò Zlong_data_usedÚparam_idr r Zexecute_packetr rG rg rg rh Úcmd_stmt_execute1 sP þ ø ù
|
z MySQLConnection.cmd_stmt_execute)r~ rF c C s | j tjt|dd dS )zÃDeallocate a prepared MySQL statement
|
|
This method deallocates the prepared statement using the
|
statement_id. Note that the MySQL server does not return
|
anything.
|
Fr N)rè r Z
|
STMT_CLOSErB ©rd r~ rg rg rh Úcmd_stmt_closed s
|
ýz MySQLConnection.cmd_stmt_close)r~ r r
rF c
|
C s d}d}zL| |¡}|rR| j |||¡}| jtj|dd |t|7 }| |¡}qW n, tk
|
r } ztd|W 5 d}~X Y nX |S )a. Send data for a column
|
|
This methods send data for a column (for example BLOB) for statement
|
identified by statement_id. The param_id indicate which parameter
|
the data belongs too.
|
The data argument should be a file-like object.
|
|
Since MySQL does not send anything back, no error is raised. When
|
the MySQL server is not reachable, an OperationalError is raised.
|
|
cmd_stmt_send_long_data should be called before cmd_stmt_execute.
|
|
The total bytes send is returned.
|
|
Returns int.
|
rì r F)r râ rä N) rë rI Zprepare_stmt_send_long_datarè r ZSTMT_SEND_LONG_DATAr² rÜ r- ) rd r~ r r
rï Ú
|
total_sentrð r rç rg rg rh r q s(
|
ÿý z'MySQLConnection.cmd_stmt_send_long_datac C s | | tjt|¡¡ dS )zReset data for prepared statement sent as long data
|
|
The result is a dictionary with OK packet information.
|
|
Returns a dict()
|
N)r¶ rè r Z
|
STMT_RESETrB r rg rg rh Úcmd_stmt_reset s z MySQLConnection.cmd_stmt_resetc C s@ z | | tj¡¡ | ¡ W dS ttfk
|
r: Y dS X dS )zÖResets the session state without re-authenticating
|
|
Reset command only works on MySQL server 5.7.3 or later.
|
The result is True for a successful reset otherwise False.
|
|
Returns bool
|
TFN)r¶ rè r ZRESET_CONNECTIONr[ r, r- rÝ rg rg rh rb ¡ s z$MySQLConnection.cmd_reset_connectionc C s" | j r| ¡ n| jr tddS )z'Check whether there is an unread resultzUnread result foundN)Zcan_consume_resultsr! r r+ rÝ rg rg rh rå ° s
|
z$MySQLConnection.handle_unread_result)NNNr rG NN)NN)Nr NTr )F)FNN)NFNNN)FFF)N) rH rH rH rG rH rH rH rH rH )NN)Fr r )NNNNNN)r )rg rg r )Zr; Ú
|
__module__Ú __qualname__Ú__doc__r rM r~ r r
|
rl r r r Úboolr r5 r« r9 r¨ r r· r3 r r³ r< rÐ rÚ rÛ rc Z
|
disconnectrè r rñ ró Úpropertyrô r¶ r7 r÷ r r: r r6 r r; r r r! rª r> rH r rJ rL rÞ rQ r= rR rT rV rW r\ r Úsetterr^ r_ rh rk rl r r rd rz r{ ry r] r| r} r r r r r? r r r r rb rå Ú __classcell__rg rg re rh rD r s 6/ ø ÷ Q ÿ þ 5+ þ |2
|
ùø ( ÿ þ "
|
0- ü
|
û ú
|
ù ; ûú { þ * öõ B
|
ýü / ù
|
ø M þ ' þ % ûú 3 þ ' rD )Xr r7 r¥ ru rw r- rÖ Údecimalr Úior Útypingr r r r r r r
|
r r r r rH r Z abstractsr Zauthenticationr Ú constantsr r r r r r r Ú
|
conversionr rd r r r r r r r! r" r# r$ r% r& r' Úerrorsr( r) r* r+ r, r- r. r/ r0 Únetworkr1 r2 Zpluginsr3 Úprotocolr4 rA r5 r6 r7 r8 r9 r: r; r< r= r> r? Úutilsr@ rA rB rC rD rg rg rg rh Ú<module> s. 4 $ <(
|
4
|
