Ë
|
Wñúhû ã óB d Z ddlmZ ddlZddlZddlZddlZddlZddlZddl Z ddl
|
m Z ddl m Z ddlmZmZmZmZmZmZmZmZmZmZmZmZ ddlm Z dd l m Z m Z dd
|
l m!Z! dd l"m#Z# dd l$m%Z%m&Z& dd l'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z- ddl.m/Z/ ddl0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8 ddl9m:Z:m;Z;m<Z<m=Z=m>Z>m?Z?m@Z@mAZAmBZBmCZCmDZD ddlEmEZE ddlFmGZGmHZHmIZI ddlJmKZK ddlLmMZM ddlNmOZOmPZPmQZQmRZRmSZS ddlTmUZUmVZVmWZWmXZXmYZYmZZZm[Z[m\Z\m]Z] ddl^m_Z_m`Z`maZambZbmcZcmdZd erddl"meZe eKrddlfmgZgmhZh G d de#« Ziy) z.Implementing communication with MySQL servers.é )Ú annotationsN)ÚDecimal)ÚIOBase) Ú TYPE_CHECKINGÚAnyÚBinaryIOÚDictÚ GeneratorÚListÚMappingÚOptionalÚSequenceÚTupleÚTypeÚUnioné )Úversion)Úcmd_refresh_verify_optionsÚhandle_read_write_timeout)Úget_local_infile_filenames)ÚMySQLConnectionAbstract)ÚMySQLAuthenticatorÚget_auth_plugin)Ú
|
ClientFlagÚ FieldTypeÚ RefreshOptionÚ ServerCmdÚ
|
ServerFlagÚ flag_is_set)ÚMySQLConverter)Ú MySQLCursorÚMySQLCursorBufferedÚMySQLCursorBufferedDictÚMySQLCursorBufferedRawÚMySQLCursorDictÚMySQLCursorPreparedÚMySQLCursorPreparedDictÚMySQLCursorRaw) ÚConnectionTimeoutErrorÚ DatabaseErrorÚErrorÚInterfaceErrorÚ InternalErrorÚNotSupportedErrorÚOperationalErrorÚProgrammingErrorÚReadTimeoutErrorÚWriteTimeoutErrorÚ get_exception)Úlogger)Ú MySQLSocketÚMySQLTCPSocketÚMySQLUnixSocket)Ú OTEL_ENABLED)Úwith_context_propagation)Ú
|
EOF_STATUSÚ
|
ERR_STATUSÚLOCAL_INFILE_STATUSÚ OK_STATUSÚ MySQLProtocol) ÚBinaryProtocolTypeÚDescriptionTypeÚ EofPacketTypeÚ HandShakeTypeÚ OkPacketTypeÚ
|
ResultTypeÚRowTypeÚStatsPacketTypeÚ
|
StrOrBytes)Ú get_platformÚ int1storeÚ int4storeÚlc_intÚ warn_ciphersuites_deprecatedÚwarn_tls_version_deprecated)ÚCMySQLPrepStmt)Úend_spanÚrecord_exception_eventc ó> e Zd ZdZd7 fd Zd8dZd8dZ d9 d:dZd;dZd8dZ d8dZ
|
d8d Z e Z e « d< d=d
|
« Z e « d> d?d « Zd@d ZedAd « ZdBdZdCdZ e « dD dEd« Z e « dD dFd« Z dG dHdZ e « dI dJd« Zd8dZdKdZe e « dL dMd« « Z e « dNd« Z e « dOd« Z dPdZ dQdRdZ! e « dSd« Z"dTd Z#dUd Z$dVd Z% e « dW dXd « Z&edYd « Z'e'jP dZd!« Z'dAd"Z)d[d#Z*e+jX jP d\d$« Z, dD d]d%Z-d^d_d&Z.ed`d'« Z/ da dbd(Z0d8d)Z1d8d*Z2dcd+Z3ddd,Z4ded-Z5 e « dQ dfd.« Z6 dg dhd/Z7 e « did0« Z8e dj dkd1« Z9 dld2Z: dmd3Z; dld4Z<dAd5Z=d8d6Z> xZ?S )nÚMySQLConnectionz Connection to a MySQL Serverc ó¾ d | _ d | _ d | _ t | « t
|
| _ t j « | _ 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| _& tO « | _( |r | jR di |¤ y y # tT $ r | jW « d | _ w xY w) NFÚ z 127.0.0.1iê r Tr © ),Ú _protocolÚ_socketÚ
|
_handshakeÚsuperÚ__init__r Ú_converter_classr Ú get_defaultÚ _client_flagsÚ _sql_modeÚ
|
_time_zoneÚ _autocommitÚ_userÚ _passwordÚ _databaseÚ_hostÚ_portÚ _unix_socketÚ _client_hostÚ _client_portÚ_sslÚ _force_ipv6Ú _use_unicodeÚ _get_warningsÚ_raise_on_warningsÚ _bufferedÚ_unread_resultÚ_have_next_resultÚ_rawÚ_in_transactionÚ_prepared_statementsÚ _ssl_activeÚ _auth_pluginÚ_krb_service_principalÚ_pool_config_versionÚ_query_attrs_supportedÚ _columns_descÚ _mfa_nfactorr Ú_authenticatorÚconnectÚ ExceptionÚclose)ÚselfÚkwargsÚ __class__s úMH:\Change_password\venv_build\Lib\site-packages\mysql/connector/connection.pyrZ zMySQLConnection.__init__ sg ø Ø26Ø.2 Ø37Ü ÑÔä6DÔ ä",×"8Ñ"8Ó":ÔØ(,Ø)-Ø!&Ôà
|
Ø Ø Ø%
|
Ø
|
Ø+/ÔØ!#ÔØ!"ÔØFH Ø!&Ôà"&ÔØ#(ÔØ(-Ô Ø $Ø$)ÔØ',Ô Ø Ø%*Ô à)-Ô!à!&ÔØ+/ÔØ59Ô#Ø)-Ô!Ø+0Ô#à46ÔØ!"Ôä2DÓ2FÔá ð Ø Ñ&vÓ&ð øô ò à
|
|
Ø # Øð ús Ä&D: Ä:"E c ó t « }t j j d« }|d dk( rd}nd}t t j « « |d t j « d|dj t j dd D cg c] }t |« c}« |d
|
d }| j j |« y c c}w ) z&Add the default connection attributes.ú r ÚGPLv2zGPL-2.0Ú
|
CommercialÚarchzmysql-connector-pythonú.é r )Ú_pidÚ _platformÚ _source_hostÚ _client_nameÚ_client_licenseÚ_client_versionÚ_osN) rH r ÚLICENSEÚsplitÚstrÚosÚgetpidÚsocketÚ gethostnameÚjoinÚVERSIONÚ _conn_attrsÚupdate)r ÚplatformÚlicense_chunksÚclient_licenseÚxÚdefault_conn_attrss r Ú_add_default_conn_attrsz'MySQLConnection._add_default_conn_attrsÀ s¯ ä >Ü ×.Ñ.¨sÓ3Ø !Ñ Ò 'Ø &Nà )Nä Ó$Ø! &Ñ)Ü "× .Ñ .Ó 0Ø 4Ø -Ø "xx¼¿ ¹ ÈÈ1Ð9MÖ(N°A¬¨QÒ(NÓ OØIÑ&ñ
|
Ðð ×Ñ× Ñ Ð!3Õ5ùò )Os  Cc ó> t | j j « « }|d t k( r t |« d| _ | j j |« }|d }| j t |t t t f« r|nd« | _ | j j | j « |d t j z s| j" s4| j$ dk( r t' d« | j$ dk( r t' d « | j( j+ d
|
« r t' d d ¬ « | xj, t j z c_ n/| j. s#| xj, t j z c_ |d t j0 z rt j0 g| _ |d t j4 z r d| _ t j4 g| _ |d t j8 z rt j8 g| _ || _ y)z'Get the handshake from the MySQL serveré NÚserver_version_originalÚUnknownÚ capabilitiesÚmysql_clear_passwordzEClear password authentication is not supported over insecure channelsÚ$authentication_openid_connect_clientzEOpenID Connect authentication is not supported over insecure channelsÚ verify_certz1SSL is required but the server doesn't support itiê )ÚerrnoT) ÚbytesrW Úrecvr; r3 rX rV Úparse_handshakeÚ_check_server_versionÚ
|
isinstancer Ú bytearrayÚ_server_versionÚ_character_setÚset_mysql_versionr ÚSSLÚ is_secureru r, ri Úgetr] Ú _ssl_disabledÚ PLUGIN_AUTHÚ client_flagsÚCLIENT_QUERY_ATTRIBUTESrx ÚMULTI_FACTOR_AUTHENTICATION)r ÚpacketÚ handshakeÚserver_versions r Ú _do_handshakez MySQLConnection._do_handshakeÔ sÑ ät||×(Ñ(Ó*Ó+Ø !9
|
Ò "Ü Ó'Ð 'à ØNN×2Ñ2°6Ó: à"Ð#<Ñ=à #× 9Ñ 9ä.¬3´´yÐ*AÔBñ àó
|
Ô ð
|
×Ñ×-Ñ-¨d×.BÑ.BÔCà Ñ(¬:¯>©>Ò9Ø>>Ø×$Ñ$Ð(>Ò>Ü(ð,óð ð ×$Ñ$Ð(NÒNÜ(ð,óð ð yy}}]Ô+Ü$ØGØ ôð ð × Ò ¤:§>¡> /Ñ 1Ö Ø×#Ò#Ø × Ò ¤*§.¡.Ñ 0Õ à ^Ñ $¤z×'=Ñ'=Ò =Ü!+×!7Ñ!7Ð 8DÔ à ^Ñ $¤z×'IÑ'IÒ IØ*.DÔ 'Ü!+×!CÑ!CÐ DDÔ à ^Ñ $¤z×'MÑ'MÒ MÜ!+×!GÑ!GÐ HDÔ à#ó c ó | j j d« s.| j j d« rJt j dk( r7|s5t j
|
« }t j d|| j « | j r|| j k7 r | j }d| _ | j sX|t j z rE| j j | j | j || j" |¬« d| _ | j j% | j& | j( | j* | j, | j. d¬ « | j j1 | j | j2 ||| j4 | j6 || j" || j | j8 |¬
|
« }| j; |« |t j< z s|r| j? |« y) 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.
|
Úauthentication_ociÚauthentication_kerberosÚntz4MySQL user is empty, OS user: %s will be used for %sF)Úcharsetr¹ T)Úkrb_service_principalÚoci_config_fileÚoci_config_profileÚwebauthn_callbackÚopenid_token_file©Úconfig) Úsockr½ ÚusernameÚ password1Ú password2Ú password3ÚdatabaserÅ r¹ Ú auth_pluginÚauth_plugin_classÚ
|
conn_attrs) ru Ú
|
startswithr ÚnameÚgetpassÚgetuserr4 ÚdebugÚ
|
_password1rt r· r r´ r{ Ú setup_sslrW Ú server_hostÚ _charset_idÚupdate_plugin_configrv Ú_oci_config_fileÚ_oci_config_profileÚ_webauthn_callbackÚ_openid_token_fileÚ authenticaterX Ú
|
_password2Ú
|
_password3Ú_auth_plugin_classÚ
|
_handle_okÚCONNECT_WITH_DBÚ cmd_init_db)r rÎ ÚpasswordrÒ r¹ Ú ssl_optionsrÕ Úok_pkts r Ú_do_authzMySQLConnection._do_auth s½ ð& × Ñ × (Ñ (Ð)=Ô >à×!Ñ!×,Ñ,Ð-FÔGÜGGtOáÜ Ó(HÜ LLØFØØ×!Ñ!ô ð ??x¨4¯?©?Ò :ØHà ÔØ×!Ò! |´j·n±nÒ'DØ × Ñ × )Ñ )Ø Ø× Ñ ØØ ×(Ñ(Ø )ð *ô ð $DÔ ð ×Ñ×0Ñ0à)-×)DÑ)DØ#'×#8Ñ#8Ø&*×&>Ñ&>Ø%)×%<Ñ%<Ø%)×%<Ñ%<ñ ð 1ô
|
ð ×$Ñ$×1Ñ1Ø ØooØ Ø ØooØooØ Ø×$Ñ$Ø%Ø ×)Ñ)Ø "× 5Ñ 5Ø!ð 2ó
|
ð Ô à z× 9Ñ 9Ò9¹xØ × Ñ XÔ &àrÀ c ó d}| j r*t j dk( rt | j ¬« }n,t | j | j | j ¬« }|j | 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ÚportÚ
|
force_ipv6) rf r r× r7 rñ r6 rÝ Ú server_portrj Úset_connection_timeoutÚ_connection_timeout)r Úconns r Ú_get_connectionz MySQLConnection._get_connectionU sm ð Ø × Ò ¤§¡¨GÒ!3Ü"¨t×/?Ñ/?Ô@Dä!Ø×%Ñ%Ø×%Ñ%Ø ×+Ñ+ôDð ×#Ñ# D×$<Ñ$<Ô=Ø rÀ c ó4 | j }| j }dx| _ | _ | j dk( rA| j s5t | j | j
|
« }|j « | _ t « | _ | j « | _
|
| j j « | j « | j | j | j | j | j | j" | j$ « | j& | _ | j t* j, z r| j j/ « | j j1 d« || _ || _ | jB stE | j jF d« rjtI | j jF jJ « r@| j jF jK « \ }}}tM |« tO ||« yyyy# t2 $ rY}| j j5 « t7 |t8 t: f« r"t= |j> |j@ ¬« ||d}~ww xY w# || _ || _ w xY w)zOpen the connection to the MySQL server
|
|
This method sets up and opens the connection to the MySQL server.
|
|
Raises on errors.
|
NÚ authentication_kerberos_client)rª ÚmsgÚcipher)(Ú read_timeoutÚ write_timeoutru ra r rç Úget_user_from_credentialsr> rV rù rW Úopen_connectionr¿ rî rb rc r] ri r r[ Úconverter_classr ÚCOMPRESSÚswitch_to_compressed_moderö r} Úclose_connectionr¯ r1 r2 r) rª rü r· ÚhasattrrÍ Úcallablerý rM rL )r Ústored_read_timeoutÚstored_write_timeoutÚclsÚerrrý Ú tls_versionÚ_s r Ú_open_connectionz MySQLConnection._open_connectionj s ð #× /Ñ /ÐØ #× 1Ñ 1Ð Ø15Ð5ÔDÔ .à × Ñ Ð @Ò @ÈÏÊÜ! $×"3Ñ"3°T×5LÑ5LÓMCØ ×6Ñ6Ó8DJä& Ø×+Ñ+Ó- ð# 6Ø LL× (Ñ (Ô *ð × Ñ Ô ð MMØ
|
|
ØØØ×"Ñ"Ø Ø× Ñ ô ð $(×#8Ñ#8DÔ à×!Ñ!¤J×$7Ñ$7Ò7à ×6Ñ6Ô8à LL× /Ñ /°Õ 5ð !4DÔ Ø!5DÔ ð ×"Ò"Ü ×)Ñ)¨8Ô4Ü ×*Ñ*×1Ñ1Ô2ð &*§\¡\×%6Ñ%6×%=Ñ%=Ó%?Ñ "FK Ü '¨ Ô 4Ü (¨°Õ =ð 3ð 5ð #øô! ò à LL× )Ñ )Ô +Ü#Ô 0Ô2CÐ DÔEÜ,Ø ))Øôð ðð Iûð ûð !4DÔ Ø!5DÕ ús&  C H" È" JÈ+AI?É?JÊJ ÊJc ó~ | j sy | j j « y# t t f$ r Y yw xY w)ah Shut down connection to MySQL Server.
|
|
This method closes the socket. It raises no exceptions.
|
|
Unlike `disconnect()`, `shutdown()` closes the client connection without
|
attempting to send a QUIT command to the server first. Thus, it will not
|
block if the connection is disrupted for some reason such as network failure.
|
N)rW ÚshutdownÚAttributeErrorr+ ©r s r r zMySQLConnection.shutdown± s: ð ||Ø ð Ø LL× !Ñ !Õ #øÜ ¤Ð&ò Ù ð ús * ª<»<c ó6 | j rE| j j « r+t | j t j « d « | j
|
sy | j « | j
|
j « t r t | j « d | _ y d | _ y # t t f$ r Y Xw xY w# t $ r"}t rt | j |« d }~ww xY w# t rt | j « w w xY w)Nr )Ú_spanÚ is_recordingrP ÚsysÚexc_inforW Úcmd_quitr r+ r r} r8 rO rX )r r s r r~ zMySQLConnection.close sÑ Ø ::$**×1Ñ1Ô3ä " 4§:¡:¬s¯|©|«~¸aÑ/@Ô Aà||Ø ð Ø MMOð %Ø LL× )Ñ )Õ +õ ÜÔ$à $øô ¤Ð&ò Ù ð ûô
|
ò ÝÜ& t§z¡z°3Ô7Ø ûð ûõ
|
ÜÕ$ð ús6 Á B7 Á1C Â7C ÃC Ã C7Ã C2Ã2C7Ã7C: Ã: Dc óL | j « | j j | j j ||xs |« |||xs | j
|
« |r)| j j |xs | j « S dS # t $ r} t d« | d} ~ ww xY w)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.
|
Nú MySQL Connection not available)
|
Úhandle_unread_resultrW ÚsendrV Ú make_commandÚ_write_timeoutr¬ Ú _read_timeoutr r/ )
|
r ÚcommandÚargumentÚ packet_numberr¼ Úexpect_responseÚcompressed_packet_numberrþ rÿ r s
|
r Ú _send_cmdzMySQLConnection._send_cmdÝ sª ð6 ×!Ñ!Ô#ð NØ LL× Ñ Ø×+Ñ+¨G°VÒ5G¸xÓHØ Ø(Ø Ò4 ×!4Ñ!4ô ñ #ð ×!Ñ! ,Ò"D°$×2DÑ2DÓEð ð ð øô
|
ò NÜ"Ð#CÓDÈ#Ð Mûð Nús A4B ÂB Â B#Â B Â B#c óD | j « t |d« s t d« d} |j |dz
|
« }|rB| j j ||xs | j ¬« |j |dz
|
« }|rB|r, | j j d|xs | j ¬« | j j |xs | j « S # t $ r}t d« |d}~ww xY w# t $ r}|d}~wt $ r}t d« |d}~ww xY w) 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ÿ r NrÀ ) r r Ú
|
ValueErrorr' rW r r r r/ r2 r¬ r )r Ú data_fileÚsend_empty_packetrþ rÿ Ú
|
chunk_sizeÚbufr s r Ú
|
_send_datazMySQLConnection._send_data s+ ð" ×!Ñ!Ô#äy &Ô)Ü Ð ;Ó<Ð <à
|
ð NØ.. ¨b¡ Ó1CÙØ ×!Ñ!Ø }Ò'K¸×8KÑ8Kð "ô ð nn Z°"¡_Ó5ò ñ ð RØ ×!Ñ!Ø }Ò'K¸×8KÑ8Kð "ô ð ||× Ñ Ò!C°×1CÑ1CÓDÐDøô ò NÜ"Ð#CÓDÈ#Ð Mûð Nûô %ò Ø ûÜ!ò RÜ&Ð'GÓHÈcÐQûð Rús< «AC Â+C7 à C4Ã# C/Ã/C4Ã7 D Ä DÄ D Ä DÄD c ó t t j |« | _ t t j |« | _ y)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 ÚMORE_RESULTS_EXISTSrp ÚSTATUS_IN_TRANSrr )r Úflagss r Ú_handle_server_statusz%MySQLConnection._handle_server_status6 s. ô "-¬Z×-KÑ-KÈUÓ!SÔ Ü *¬:×+EÑ+EÀuÓ MÕ rÀ c ó | j S )z'MySQL session has started a transaction)rr r s r Úin_transactionz MySQLConnection.in_transaction@ s ð ×#Ñ#Ð#rÀ c óÀ |d t k( r1| j j |« }| j |d « |S |d t k( r t |« t d« )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£ Ú status_flagzExpected OK packet)r= rV Úparse_okr5 r; r3 r, )r r¼ rí s r rè zMySQLConnection._handle_okE s_ ð !9 Ò !Ø^^×,Ñ,¨VÓ4FØ × &Ñ & v¨mÑ'<Ô =ØMØ !9
|
Ò "Ü Ó'Ð 'Ü Ð 1Ó2Ð2rÀ c óÀ |d t k( r1| j j |« }| j |d « |S |d t k( r t |« t d« )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£ r9 zExpected EOF packet)r: rV Ú parse_eofr5 r; r3 r, )r r¼ Úeofs r Ú _handle_eofzMySQLConnection._handle_eofV s_ ð !9
|
Ò "Ø..×*Ñ*¨6Ó2CØ × &Ñ & s¨=Ñ'9Ô :ØJØ !9
|
Ò "Ü Ó'Ð 'Ü Ð 2Ó3Ð3rÀ c ó | j 1t | j « | _ | j s"t d« | j s t d« t j
|
j |« }t j
|
j | j j « « }t j
|
j |« st d| d« t j
|
j |« st d| d« t j
|
j ||« st d| d| d « t j
|
j |« r t d
|
« | j s| j s t d « | j s{| j rot j
|
j | j « }d} t j
|
j! ||g« }||k7 r d } t | j% ||« « t) |d« }
|
| j+ | j- |
|
d||« « |
|
j/ « S # t $ r }t |d}~ww xY w# t" $ r-}d } t | j% t' |« ||« « |d}~ww xY w# t0 t2 f$ r Y S w xY w# t0 $ r[ | j4 j7 d|xs | j8 ¬« n # t: $ r}t d« |d}~ww xY wt d| d« dw xY w#
|
j/ « w # t0 t2 f$ r Y w w xY wxY w)z'Handle a LOAD DATA INFILE LOCAL requestNzxNo `LOCAL INFILE` statements found in the client's request. Check your request includes valid `LOCAL INFILE` statements.z Got more `LOCAL INFILE` responses than number of `LOCAL INFILE` statements specified in the client's request. Please, report this issue to the development team.z Location specified by filename z& from client's request does not exist.z' from server's response does not exist.z Filename z8 from the server's response is not the same as filename z from the client's request.z#Use of symbolic link is not allowedúKLOAD DATA LOCAL INFILE file request rejected due to restrictions on access.zL{} while loading file `{}` and path `{}` given in allow_local_infile_in_pathzEThe file `{}` is not found in the given allow_local_infile_in_path {}ÚrbTrÀ r* r zFile 'z' could not be read) Ú_local_infile_filenamesr Ú_queryr, r ÚpathÚabspathÚpopleftÚexistsÚsamefileÚOSErrorÚislinkr/ Ú_allow_local_infileÚ_allow_local_infile_in_pathr* Ú
|
commonpathr+ Úformatr Úopenrè r0 r~ ÚIOErrorÚ NameErrorrW r r r ) r Úfilenamerþ rÿ Ú file_nameÚfile_name_from_requestr Ú infile_pathÚc_pathÚerr_msgr, s r Ú_handle_load_data_infilez(MySQLConnection._handle_load_data_infileg sI ð × 'Ñ 'Ð /Ü+EÀdÇkÁkÓ+RDÔ (Ø×/Ò/Ü$ðSóð ð ×-Ò-Ü ð1óð ô GGOO HÓ- Ü!#§¡§ ¡ °×1MÑ1M×1UÑ1UÓ1WÓ!XÐ ô ww~~Ð 4Ô5Ü Ø1Ð2HÐ1Ið J8ð 8óð ô ww~~iÔ(Ü Ø1°)°ð =+ð +óð ð *Ü77×#Ñ# IÐ/EÔFÜ$Ø {ð +#Ø#9Ð":ð ;(ð(óð ð Gô 77>>)Ô $Ü"Ð#HÓIÐ IØ×'Ò'°×0PÒ0PÜ ð*óð ð ×'Ò'¨D×,LÒ,Lä ''//¨$×*JÑ*JÓKKØFð Ü×+Ñ+¨[¸)Ð,DÓEð Ò$ð4ð ô $ G§N¡N°9¸kÓ$JÓKÐKð Ü Y¨Ó-IØ??Ø ¨4° ¸}ÓMóð ØÕ!øôa ò *Ü cÐ )ûð *ûô ò ð5ð ô %ØNN¤3 s£8¨Y¸ ÓDóàðûð ûôB YÐ'ò Ùð ûô ò Tð RØ ×!Ñ!Ø }Ò'K¸×8KÑ8Kð "õ øô "ò RÜ&Ð'GÓHÈcÐQûð Rúä 6¨)¨Ð4GÐ!HÓIÈtÐ Sð Tûð ØÕ!øÜYÐ'ò Ùð ýs¢ Ä2I Ç !I( È.J6 È?J!É I%ÉI É I%É( J É1(JÊJ Ê!J3Ê2J3Ê6 LË +K,Ë+LË, LË5 LÌLÌLÌL Ì MÌ L0Ì/MÌ0MÌ?MÍMÍMc ó6 |rt |« dk r t d« |d t k( r| j |« S |d t k( r&|dd j « }| j |||« S |d t k( r| j |« S |d t k( r t |« | j j |« }|rt |t « s t d« dg|z | _ t! d|« D ]\ }| j j# | j$ j' |xs | j( « | j* « | j |< ^ | j | j$ j' |xs | j( « « }d| _ | j |dS ) 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 responseé NzIllegal result setr T)Úcolumnsr= )Úlenr, r= rè r< ÚdecoderX r: r> r; r3 rV Úparse_column_countr¯ Úintry ÚrangeÚ parse_columnrW r¬ r Úpython_charsetÚ unread_result)r r¼ rþ rÿ rR Ú column_countÚir= s r Ú_handle_resultz MySQLConnection._handle_resultË s ñ( V q Ü Ð!1Ó2Ð 2Ø !9 Ò !Ø?? 6Ó*Ð *Ø !9Ô+Ò +Ø abz×(Ñ(Ó*HØ×0Ñ0°¸<È ÓWÐ WØ !9
|
Ò "Ø×#Ñ# FÓ+Ð +Ø !9
|
Ò "Ü Ó'Ð 'ð ~~×8Ñ8¸Ó@ Ù¤:¨l¼CÔ#@Ü Ð!5Ó6Ð 6ð ð
|
à ñ Ôô q,Ó'ò AØ$(§N¡N×$?Ñ$?Ø ×!Ñ! ,Ò"D°$×2DÑ2DÓEØ×#Ñ#ó%D× Ñ qÒ !ð ð × Ñ t||× 0Ñ 0° Ò1SÀ×ASÑASÓ TÓUØ !ÔØ ×-Ñ-°cÑ:Ð:rÀ c ór |j dd« }| j 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þ Nr )ÚcountÚbinaryr\ Úrawrþ r )r¶ Úget_rows) r rj r\ rk Ú prep_stmtr rþ Úrowsr= s r Úget_rowzMySQLConnection.get_rowý sW ð" zz .°$Ó7 ØmmØØØØØ%ð $ó
|
sñ ØGS>Ð !Øc{ÐrÀ c óØ | | j }| j s t d« g df} |j dd« }|rK| j } | dk( rd} | j
|
j | j ||| |xs | j « }n@| j
|
j | j | j ||xs | j « }|\ }} |sR|sP| j D|rBt | d« r6| j j } |D cg c] } | | | j « }} | $| j! d| v r| d n| d « d| _ || fS # t $ r}
|
d| _ |
|
d}
|
~
|
ww xY wc c} w )
|
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 availablerþ Úutf8mb4Úutf8FÚ converterr9 Ú server_status)rq rd r- r¶ rÅ rV Úread_binary_resultrW r Úread_text_resultr± r+ ry r rs Ú row_to_pythonr5 )r ri rj r\ rk rm r rn rþ rÅ r Úeof_prw Úrows r rl zMySQLConnection.get_rows s
ð$ ;Ø))Cà×!Ò!Ü Ð 9Ó:Ð :àDzð Ø!:: n°dÓ;LÙØ ,,ØiÒ'Ø $GØ~~×8Ñ8ØLLØØØØ Ò6 D×$6Ñ$6ó ð ~~×6Ñ6ØLLØ×(Ñ(ØØ Ò6 D×$6Ñ$6ó ð eá3Ø×"Ñ"Ð.ÙÜkÔ*à NN× 8Ñ 8MØFJÖK¸sM # t×'9Ñ'9Õ:ÐKDÐKà Ð Ø × &Ñ &à EÑ)ð mÒ$à?Ñ+ô ð
|
"'DÔ àU{Ðøô- ò Ø!&DÔ ØIûð üò Ls «B E ÄE'Å E$Å E Å E$c ó> | j r| j « yy)zConsume resultsN)rd rl r s r Úconsume_resultsz MySQLConnection.consume_results_ s à × Ò Ø MMOð rÀ c ó~ | j | j t j |j 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 ÚINIT_DBÚencode)r rÒ s r rê zMySQLConnection.cmd_init_dbd s2 ð Ø NN9×,Ñ,¨h¯o©o¸gÓ.FÓ Gó
|
ð
|
rÀ c ó¾ t |t « s,t |t « r|j d« }t |« }|| _ d | _ | j dk7 r | j nd}t « }| j s'| j rt j dt ¬« | j t j z rcg }g } g }
|
dgt | j « dz dz z } t! | j j# « « D ]2 \ } } | d }d}|K| | dz xx d | dz z z cc< | j% t' t( j* « t' |« z « [t |t, « r2| j. j1 |« \ }}}|
|
j% |« n6t |t « rI|j |« }|
|
j% t3 t |« « |z « t( j4 }nÝt |t6 « r8|
|
j% t3 t |« « |z « t( j4 }nt |t8 « rh|
|
j% t3 t t |« j |« « « t |« j |« z « t( j: }n t |t< « r6|
|
j% t? j@ d
|
|« « t( jB }n×t |tD jD tD jF f« r0| j. jI |« \ }}|
|
j% |« n}t |tD jJ tD jL f« r0| j. jO |« \ }}|
|
j% |« n#tQ d |jR jT d « | j% t' |« t' |« z « | d j |« }|j% t3 t |« « |z « 5 |jW t3 t | j « « « |jW t3 d « « |
|
r|jW d jY | D cg c] }t? j@ d|« c}« t' d « z « t[ | |« D ]' \ }}|jW |« |jW |« ) |
|
D ] }|jW |« |jW |« t7 |« } |j] dd « }|j] dd « }| j_ | ja tb jd |||¬« ||« }|S c c}w # tP $ r1}|jf dk( r d|jh v rd}tk |« | d }~ww xY w)Nr} rq rr ú<This version of the server does not support Query Attributes©Úcategoryr é é r z<dz&MySQL binary protocol can not handle 'z ' objectsrÀ ÚBrþ rÿ ©rþ rÿ il z Loading local data is disabledr@ )6r¯ r° r r rC rB rÅ rx Ú _query_attrsÚwarningsÚwarnÚWarningr] r rº r] Ú enumerateÚitemsÚappendrI r ÚNULLr` rV Úprepare_binary_integerrK ÚSTRINGr« r ÚDECIMALÚfloatÚstructÚpackÚDOUBLEÚdatetimeÚdateÚprepare_binary_timestampÚ timedeltaÚtimeÚprepare_binary_timer0 r Ú__name__Úextendr Úzipr¶ rg r% r ÚQUERYrª rü r* )r Úqueryrk ÚbufferedÚ raw_as_stringr rÅ r¼ ÚnamesÚtypesÚvaluesÚ null_bitmapÚposÚ
|
attr_tupleÚvaluer4 ÚpackedÚ
|
field_typer× ÚbitÚ_typerþ rÿ Úresultr rW s r Ú cmd_queryzMySQLConnection.cmd_queryq sç ô %¤Ô+Ü%¤Ô%Ø WÓ-Ü eÓ$Eð Ø'+Ô$ð #'§,¡,°)Ò";$,,ÀÜØ×*Ò*¨t×/@Ò/@Ü MMØNÜ õ ð × Ñ ¤
|
× BÑ BÓ BØEØEØ"$FØ #¤# d×&7Ñ&7Ó"8¸1Ñ"<ÀÑ!BÑCKÜ#,¨T×->Ñ->×-DÑ-DÓ-FÓ#Gó . 7ZØ" 1 ØØ=Ø ¨¡Ó+¨q°S¸1±W©~Ñ=Ó+ØLL¤¬9¯>©>Ó!:¼YÀuÓ=MÑ!MÔNØ Ü e¤SÔ)ð
|
×=Ñ=¸eÓDñ Ø Ø"Ø àMM &Ö)Ü ¤sÔ+Ø !LL¨Ó 1EØMM¤&¬¨U«Ó"4°uÑ"<Ô=Ü!*×!1Ñ!1JÜ ¤uÔ-ØMM¤&¬¨U«Ó"4°uÑ"<Ô=Ü!*×!1Ñ!1JÜ ¤wÔ/ØMMÜ s¤3 u£:×#4Ñ#4°WÓ#=Ó >Ó?Ü e*×+Ñ+¨GÓ4ñ5ôô "+×!2Ñ!2JÜ ¤uÔ-ØMM¤&§+¡+¨d°EÓ":Ô;Ü!*×!1Ñ!1JÜ ¬×(9Ñ(9¼8¿=¹=Ð'IÔJð ×?Ñ?ÀÓFñØ Ø"àMM &Õ)Ü ¬×(:Ñ(:¼H¿M¹MÐ'JÔKØ+/¯>©>×+MÑ+MÈeÓ+TÑ(VZØMM &Õ)ä*ð Ø !OO× 4Ñ 4Ð5°Yð@óð ð Y zÓ 2´Y¸uÓ5EÑ EÔFØ! !}×+Ñ+¨GÓ4Ø V¤C¨£IÓ .°Ñ 5Ö6ð]. 7ðb MM&¤ T×%6Ñ%6Ó!7Ó8Ô 9ð MM& )Ô $ÙØ ØHH¸{Ö K¸fkk¨#¨sÕ 3Ò KÓLÜ lñ#ôô $' u¨eÓ#4ò (KE4ØMM %Ô(ØMM $Õ'ð(ð $ò )EØMM %Õ(ð)ð eÔ Üf ð Ø!:: n°dÓ;LØ "JJ ¸Ó =Mà×(Ñ(ØÜ OOØØ!-Ø"/ð ó ð Ø ó Fð$ ùòE Løô4 ò ØyyDÒ Ð%EÈÏÉÑ%Pð1ð ô $ GÓ,°#Ð5Ø ûð ús Ò$ V ÕAV" Ö" W Ö+,W×W c + óô K |j dd« }|j dd« }t « }t |t « s,t |t « r|j d« }t |« }| j
|
t j z r4|j t d« « |j t d« « |j |« t |« }| j | j t j |||¬« ||« | j r[| j! « | j | j" j% |xs | j& ¬« ||« | j rZyyw) 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þ Nrÿ rr r r r )rþ )r¶ r° r¯ r r r] r rº r rK r« rg r% r r rp r rW r¬ r )r Ú
|
statementsr rþ rÿ r¼ r¡ s r Úcmd_query_iterz MySQLConnection.cmd_query_iterì s? è ø ð, zz .°$Ó7 Ø
|
|
?°DÓ9 ÜÜ*¤iÔ0Ü*¤cÔ*Ø '× .Ñ .¨vÓ 6
|
Ü" :Ó.Jà × Ñ ¤
|
× BÑ BÒ Bà MM& )Ô $ð MM& )Ô $à jÔ!Üf à×!Ñ!Ø NNÜØØ )Ø +ð ó ð Ø ó
|
ò
|
ð ×$Ò$Ø × %Ñ %Ô 'Ø×%Ñ%Ø ×!Ñ!¨|Ò/Q¸t×?QÑ?QÐ!ÓRØ Ø óò ð ×$Õ$ùs E3E8Å6E8c ó |t j t j z t j z t j z t j
|
z t j z z s t d« d }|t j z r| j d« }|t j z r| j d« }|t j z r| j d« }|t j z r| j d« }|t j
|
z r| j d« }|t j z r"| j | j dk rdnd « }|S )
|
Nz Invalid command REFRESH optionzFLUSH PRIVILEGESz
|
FLUSH LOGSz FLUSH TABLESz,TRUNCATE TABLE performance_schema.host_cachez FLUSH STATUS)r
r é z RESET SLAVEz RESET REPLICA)
|
r ÚGRANTÚLOGÚTABLESÚHOSTÚSTATUSÚREPLICAr+ r° r± )r ÚoptionsÚress r Ú cmd_refreshzMySQLConnection.cmd_refresh( s5 àÜ × Ñ Ü× Ñ ñ ä×"Ñ"ñ #ô × Ñ ñ !ô ×"Ñ"ñ #ô
|
×#Ñ#ñ $ò
|
ô Ð =Ó>Ð >àØ ]×(Ñ(Ò (Ø..Ð!3Ó4CØ ]×&Ñ&Ò &Ø.. Ó.CØ ]×)Ñ)Ò )Ø.. Ó0CØ ]×'Ñ'Ò 'Ø..Ð!OÓPCØ ]×)Ñ)Ò )Ø.. Ó0CØ ]×*Ñ*Ò *Ø..Ø!%×!5Ñ!5¸
|
Ò!B ÈóCð
|
rÀ c óø | j « | j j t j « } | j
|
j |dd| j « |S # t $ r }Y d}~|S d}~ww xY w)a Close the current connection with the server
|
|
This method sends the `QUIT` command to the MySQL server, closing the
|
current connection. Since there is no response from the MySQL server,
|
the packet that was sent is returned.
|
|
Returns a str()
|
r N) r rV r r ÚQUITrW r r r2 )r r¼ r s r r zMySQLConnection.cmd_quitF sl ð ×!Ñ!Ô#à ×,Ñ,¬Y¯^©^Ó<ð Ø LL× Ñ f a¨¨D×,?Ñ,?Ô @ð øô !ò Û Ø ûð ús »(A% Á% A9Á4A9c ó& | j d« y)z»Shut down the MySQL Server
|
|
This method sends the SHUTDOWN command to the MySQL server.
|
The `shutdown_type` is not used, and it's kept for backward compatibility.
|
ÚSHUTDOWNN)r° )r Ú shutdown_types r Ú cmd_shutdownz MySQLConnection.cmd_shutdownX s ð zÕ"rÀ c ó@ | j « | j j t j « }| j
|
j |dd| j « | j j | j
|
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 rV r r Ú
|
STATISTICSrW r r Úparse_statisticsr¬ r ©r r¼ s r Úcmd_statisticsz MySQLConnection.cmd_statistics` sr ð ×!Ñ!Ô#à ×,Ñ,¬Y×-AÑ-AÓBØ ×Ñ& ! Q¨×(;Ñ(;Ô<Ø~~×.Ñ.¨t¯|©|×/@Ñ/@À×ASÑASÓ/TÓUÐUrÀ c ó` t |t « s t d« | j d| « 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.
|
zMySQL PID must be intzKILL )r¯ r` r+ r° )r Ú mysql_pids r Úcmd_process_killz MySQLConnection.cmd_process_killo s0 ô )¤SÔ)Ü Ð 4Ó5Ð 5Ø~~ i [Ð 1Ó2Ð2rÀ c ó^ | j | j t j « « 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 s r Ú cmd_debugzMySQLConnection.cmd_debugz s" ð × Ñ §¡¬y¯©Ó ?Ó@Ð@rÀ c ó^ | j | j t j « « 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 ÚPINGr s r Úcmd_pingzMySQLConnection.cmd_ping s ð t~~¬i¯n©nÓ =Ó>Ð>rÀ c ó |2t |t « s t d« |dk r t d« || _ d| _ || _ || _ || _ || _ || _ | j r || j k7 r| j | _ | j « | j r t d« |r|| _ |
|
r|
|
| _ | | _ | j j# | j | j | j d¬« | j j% | j& | j( | j
|
| j | j | j || j | j* | j, | j. | j0 d| j2 | j4 ¬ « } | j* t6 j8 z s|r| j; |« | j= « | j? | « 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Ë T)rÍ r½ rÎ rÏ rÐ rÑ rÒ rÅ r¹ rÓ rÔ rÕ Úis_change_user_requestrþ rÿ ) r¯ r` r+ rÞ rz ra rb rÛ rå ræ r Ú _compressr. rà rã rá r{ rß rä rW rX r] ru rç r r r r ré rê Ú_post_connectionrè ) r rÎ rë rÒ rÅ rÏ rÐ rÑ rÇ rÈ rÊ rí s r Úcmd_change_userz MySQLConnection.cmd_change_user sÊ ð. Ð Ü g¤sÔ+Ü Ð!=Ó>Ð>Ø{Ü Ð!UÓVÐVØ &DÔ à ÔØ
|
Ø!Ø#Ø#Ø#à ??x¨4¯?©?Ò :Ø !__DNà ×!Ñ!Ô#à >>Ü#Ð$SÓTÐ Tá Ø$3DÔ !Ù Ø&7DÔ #Ø#5Ô ð ×Ñ×0Ñ0à#'×#8Ñ#8Ø&*×&>Ñ&>Ø%)×%<Ñ%<ñð 1ô
|
ð ×$Ñ$×1Ñ1Ø ØooØZZØnnØooØooØ Ø×$Ñ$Ø ×+Ñ+Ø ×)Ñ)Ø "× 5Ñ 5Ø×'Ñ'Ø#'Ø ×+Ñ+Ø ×-Ñ-ð 2ó
|
ð$ ×"Ñ"¤Z×%?Ñ%?Ò?ÁXØ × Ñ XÔ &à × Ñ Ô ð vÓ&Ð&rÀ c ó* | j d« d S )zGet the current databasezSELECT DATABASE()r )Ú
|
info_queryr s r rÒ zMySQLConnection.databaseç s ð Ð 2Ó3°AÑ6Ð6rÀ c ó& | j |« y)zSet the current databaseN)rê ©r rª s r rÒ zMySQLConnection.databaseì s ð ×ÑÕ rÀ c óD | j « y# t $ r Y yw xY w)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)rÒ r+ r s r Ú is_connectedz MySQLConnection.is_connectedñ s) ð Ø MMOð øô ò Ùð ús c ó || _ y)zySet the path that user can upload files.
|
|
Args:
|
path (str): Path that user can upload files.
|
N)rL )r rD s r Ú set_allow_local_infile_in_pathz.MySQLConnection.set_allow_local_infile_in_path s ð ,0Õ(rÀ c ób || _ | j r | j j |« y y ©N)rk rs Ú set_unicoderÛ s r Ú use_unicodezMySQLConnection.use_unicode s( à !ÔØ >>Ø NN× &Ñ & uÕ -ð rÀ c ó | j « s t d« | j « s | j | j | j
|
| j | j | j | j | j | j | j | j «
|
| j! « }|r/|j# « D ] \ }}|j% d| d|f« |r/|j# « D ] \ }}|j% d| d|f« |j' « y# t $ r | j « Y w xY w)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× ra rb rc rÞ rÛ rå ræ rà rá rã r0 Ú reconnectÚcursorr Úexecuter~ )r Úuser_variablesÚsession_variablesÚcurÚkeyrª s r Ú reset_sessionz MySQLConnection.reset_session s, ð( × Ñ Ô"Ü"Ð#DÓEÐ Eà×(Ñ(Ô*ð !Ø×$Ñ$ØJJØNNØNNØ×$Ñ$ØOOØOOØOOØ×)Ñ)Ø×,Ñ,Ø×+Ñ+ô ð kkmÙ Ø ,× 2Ñ 2Ó 4ò <
|
UØ f S E¨Ð 0°5°(Õ;ð <á Ø /× 5Ñ 5Ó 7ò C
|
UØ m¨C¨5°Ð 7¸%¸ÕBð Cà øô $ò !ØÖ ð !ús A>D. Ä.E
|
Å E
|
c ó | j « y# t $ r,}|r| j ||¬« n t d« |Y d}~yd}~ww xY w)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.
|
)ÚattemptsÚdelayz$Connection to MySQL is not availableN)rÒ r+ ræ r, )r ræ rï rð r s r ÚpingzMySQLConnection.ping? sJ ð VØ MMOøÜò VÙب¸Õ>ä$Ð%KÓLÐRUÐUô ?ûð Vús A"AÁAc óR | j r| j j d« S y)zMySQL connection IDÚserver_threadidN)rX r¶ r s r Ú connection_idz MySQLConnection.connection_idU s$ ð ??Ø??×&Ñ&Ð'8Ó9Ð 9ØrÀ c óÞ | j « | j « s t d« | t |t « r|dk r t d« | t |t « r|dk r t d« |%t |t « s t d« || ||« S ||n | j }||n | j }d}|du r|dz }|du r|d z }|du r|d
|
z }|du r|d z }t t t t t t t t" d } | | | ||« S # t$ $ rM d }
|
t' ddj) t+ d
|
« D cg c] } |d| z z dk7 s|
|
| nc c} w c} « z « dw xY w)aD 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 a dictionary or a tuple.
|
|
Dictionary 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.MySQLCursor.
|
|
Raises ProgrammingError when cursor_class is not a subclass of
|
MySQLCursor. Raises ValueError when cursor is not available.
|
Raises InterfaceError when read_timeout or write_timeout is not
|
a positive integer.
|
|
Returns a cursor-object
|
r Nr z.Option read_timeout must be a positive integerz/Option write_timeout must be a positive integerz0Cursor class needs be to subclass of MySQLCursorTr é r£ r) )r r rö r r£ r[ r) é )r¢ rk Ú
|
dictionaryÚpreparedz*Cursor not available with given criteria: z, )r rÝ r/ r¯ r` r, Ú
|
issubclassr! r0 rn rq r" r( r$ r% r# r& r' ÚKeyErrorr+ r ra ) r r¢ rk rù Ú cursor_classrø rþ rÿ Ú cursor_typer¥ Úargsrf s r rç zMySQLConnection.cursor\ s¨ ð> ×!Ñ!Ô#à× Ñ Ô"Ü"Ð#CÓDÐ DØ Ð #Ü<¬Ô-° ÀÒ1Aä Ð!QÓRÐ RØ Ð $Ü=¬#Ô.°-À!Ò2Cä Ð!RÓSÐ SØ Ð #Ü l¬KÔ8Ü&ØFóð ñ ! $¨ °mÓDÐ Dà 'Ð 38¸¿ ¹ Ø_c¨$¯)©)à Ø tÑ Ø 1Ñ KØ $;Ø 1Ñ KØ Ñ Ø 1Ñ KØ tÑ Ø 2Ñ Kô Ü"Ü Ü%Ü Ü&Ü#Ü'ñ
|
ð Ø&E+Ñ&¨¨l¸MÓJÐ JøÜò Ø@DÜ Ø<Ø))¬e°A«hÖ V¨¸+ÈÈaÉÑ:PÐTUÓ:UT !WÑ VùÔ VÓWñXóð ð ð ús Ä D Ä)E,Ä?EÅEÅE,c ó& | j d« y)zCommit current transactionÚCOMMITN)Ú_execute_queryr s r ÚcommitzMySQLConnection.commit® s à ×ÑHÕ%rÀ c ó^ | j r| j « | j d« y)z Rollback current transactionÚROLLBACKN)rd rl r r s r ÚrollbackzMySQLConnection.rollback² s" à × Ò Ø MMOà ×ÑJÕ'rÀ c óF | j « | j |« y)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 r° )r r¡ s r r z MySQLConnection._execute_query¹ s ð ×!Ñ!Ô#Ø uÕ rÀ c ó | j d| j | j ¬« }|j |« |j « S )z%Send a query which only returns 1 rowT)r¢ rþ rÿ )rç r r rè Úfetchone)r r¡ rç s r rÙ zMySQLConnection.info_queryÅ sE àØØ ×+Ñ+Ø ×-Ñ-ð ó
|
ð
|
uÔ ØÓ Ð rÀ c ó |d t k( r| j j |« S |d t k( r t |« t d« )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£ zExpected Binary OK packet)r= rV Úparse_binary_prepare_okr; r3 r, rÈ s r Ú_handle_binary_okz!MySQLConnection._handle_binary_okÏ sH ð !9 Ò !Ø>>×9Ñ9¸&ÓAÐ AØ !9
|
Ò "Ü Ó'Ð 'Ü Ð 8Ó9Ð9rÀ c ó |rt |« dk r t d« |d t k( r| j |« S |d t k( r| j |« S |d t k( r t |« | j j |« }|rt |t « s t d« dg|z }t d|« D ]R }| j j | j j |xs | j « | j" « ||< T | j | j j |xs | 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£ rZ zIllegal result set.Nr )r] r, r= rè r: r> r; r3 rV r_ r¯ r` ra rb rW r¬ r rc )r r¼ rþ re r\ rf r= s r Ú_handle_binary_resultz%MySQLConnection._handle_binary_resultß s3 ñ" V q Ü Ð!1Ó2Ð 2Ø !9 Ò !Ø?? 6Ó*Ð *Ø !9
|
Ò "Ø×#Ñ# FÓ+Ð +Ø !9
|
Ò "Ü Ó'Ð 'ð ~~×8Ñ8¸Ó@ Ù¤:¨l¼CÔ#@Ü Ð!6Ó7Ð 7à*.¨°,Ñ)>Üq,Ó'ò AØ ×4Ñ4Ø ×!Ñ! ,Ò"D°$×2DÑ2DÓEØ×#Ñ#óGAJð ð × Ñ t||× 0Ñ 0° Ò1SÀ×ASÑASÓ TÓUØ g sÐ+Ð+rÀ c óè |j dd« }|j dd« }| j j ||« }d| _ | j t
|
j |d||¬« d| _ y)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.
|
rþ Nrÿ F©r# rþ rÿ T)r¶ rV Úmake_stmt_fetchrd r% r Ú
|
STMT_FETCH)r Ú statement_idrn r rþ rÿ r¼ s r Úcmd_stmt_fetchz MySQLConnection.cmd_stmt_fetch sr ð zz .°$Ó7 Ø
|
|
?°DÓ9 Ø ×/Ñ/° ¸dÓCØ "ÔØ Ü × Ñ Ø Ø !Ø%Ø'ð ô
|
ð "ÕrÀ c ó |j dd« }|j dd« }| j t j |||¬« }| j |« }g |d< g |d< |d dkD r«t d|d « D ]a }|d j | j j | j j |xs | j « | j « « c | j | j j |xs | j « « |d dkD r«t d|d « D ]a }|d j | j j | j j |xs | j « | j « « c | j | j j |xs | 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þ Nrÿ r r\ Ú
|
parametersÚ
|
num_paramsr Ú num_columns)r¶ r% r Ú STMT_PREPAREr ra r rV rb rW r¬ r rc r> )r Ú statementr rþ rÿ r¼ r¯ r s r Úcmd_stmt_preparez MySQLConnection.cmd_stmt_prepare s® ð zz .°$Ó7 Ø
|
|
?°DÓ9 à Ü × "Ñ "Ø Ø%Ø'ð ó
|
ð ×'Ñ'¨Ó/à yÑØ !|Ñ Ø ,Ñ !Ò #Ü1f \Ñ 2Ó3ò Ø|Ñ$×+Ñ+ØNN×/Ñ/Ø ×)Ñ)¨,Ò*L¸$×:LÑ:LÓMØ ×+Ñ+óõð ð × Ñ T\\× .Ñ .¨|Ò/Q¸t×?QÑ?QÓ RÔ SØ -Ñ 1Ò $Ü1f ]Ñ 3Ó4ò ØyÑ!×(Ñ(ØNN×/Ñ/Ø ×)Ñ)¨,Ò*L¸$×:LÑ:LÓMØ ×+Ñ+óõð ð × Ñ T\\× .Ñ .¨|Ò/Q¸t×?QÑ?QÓ RÔ SØ rÀ c
|
ó\ t |« }i }|j dd« }|j dd« }|rZt |« D ]L \ } }
|
t || t « sd} d|| j
|
v} | j || || ||¬« | f|| < N | j s'| j rt j dt ¬« | j t j z rJ| j j# ||t% |« ||| j& | j( | j* « } n?| j j# ||t% |« ||| j& | j* ¬ « } | j- t. j0 | ||¬
|
« } | j3 | |« }|S # t $ r Y =w xY w) z"Execute a prepared MySQL statementrþ Nrÿ TÚbr r r )Úconverter_str_fallback)r¼ rþ rÿ )Úlistr¶ r r¯ r Úmoder Úcmd_stmt_send_long_datarx r r r r r] r rº rV Úmake_stmt_executeÚtuplerÅ Ú query_attrsÚ_converter_str_fallbackr% r Ú STMT_EXECUTEr )r r Údatar r4 r Úlong_data_usedrþ rÿ Úparam_idr rj Úexecute_packetr¼ r¯ s r Úcmd_stmt_executez MySQLConnection.cmd_stmt_executeN sÀ ô *Ó%
|
ØØ zz .°$Ó7 Ø
|
|
?°DÓ9 á Ü (¨Ó 4ò 9 !Ü d 8n¬fÕ5Ø !Fð Ø!$¨D°©N×,?Ñ,?Ð!?ð ×0Ñ0Ø$Ø Ø XØ%1Ø&3ð 1ô ð 17¨yN 8Ò,ð 9ð ×*Ò*¨t×/@Ò/@Ü MMØNÜ õ ð × Ñ ¤
|
× BÑ BÒ BØ !^^× =Ñ =Ø ØÜjÓ!ØØ Ø Ø× Ñ Ø×,Ñ,ó Nð "^^× =Ñ =Ø ØÜjÓ!ØØ Ø Ø'+×'CÑ'Cð >ó Nð Ü × "Ñ "Ø!Ø%Ø'ð ó
|
ð ×+Ñ+¨F°LÓAØ øôW *ò Ú ð ús Á F Æ F+Æ*F+c
|
ó | j t j t |« d|j dd« |j dd« ¬« y)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þ Nrÿ r )r% r Ú
|
STMT_CLOSErJ r¶ ©r r r s r Úcmd_stmt_closez MySQLConnection.cmd_stmt_close sE ð Ü × Ñ Ü lÓ #Ø !Ø N°DÓ9Ø ** _°dÓ;ð õ
|
rÀ c
|
óv d}d} |j |« }|r| j j |||« }| j t j
|
|d|j dd« |j dd« ¬« |t |« z }|j |« }|r|S # t $ r} t d« | d} ~ ww xY w) 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 Frþ Nrÿ )r¼ r# rþ rÿ r )
|
r' rV Úprepare_stmt_send_long_datar% r ÚSTMT_SEND_LONG_DATAr¶ r] r r/ )
|
r r r( r& r r. Ú
|
total_sentr/ r¼ r s
|
r r z'MySQLConnection.cmd_stmt_send_long_data£ sË ð.
|
Ø
|
ð NØ))JÓ'CÙØ ×CÑCØ (¨Cóð Ü ×1Ñ1Ø!Ø$)Ø!'§¡¨N¸DÓ!AØ"(§*¡*¨_¸dÓ"Cð ô ð c #hÑ&
|
Øii
|
Ó+ò ð Ðøô ò NÜ"Ð#CÓDÈ#Ð Mûð Nús BB  B8Â' B3Â3B8c óº | j | j t j t |« |j dd« |j dd« ¬« « y)zReset data for prepared statement sent as long data
|
|
The result is a dictionary with OK packet information.
|
|
Returns a dict()
|
rþ Nrÿ r )rè r% r Ú
|
STMT_RESETrJ r¶ r- s r Úcmd_stmt_resetz MySQLConnection.cmd_stmt_resetÐ sN ð Ø NNÜ×$Ñ$Ü,Ó'Ø #ZZ¨¸Ó =Ø $jj¨ ¸$Ó ?ð ó õ
|
rÀ c ó¬ | j | j t j « « | j « y# t
|
t f$ r Y yw xY w)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
|
TF)rè r% r ÚRESET_CONNECTIONrÖ r. r/ r s r rå z$MySQLConnection.cmd_reset_connectionä sI ð Ø OODNN¬9×+EÑ+EÓ FÔ GØ × !Ñ !Ô #ØøÜ!Ô#3Ð4ò Ùð ús >A ÁAÁAc ól | j r| j « y| j r t d« y)z'Check whether there is an unread resultzUnread result foundN)Úcan_consume_resultsr{ rd r- r s r r z$MySQLConnection.handle_unread_resultó s1 à × #Ò #Ø × Ñ Õ "Ø × Ò Ü Ð 5Ó6Ð 6ð rÀ )r r ÚreturnÚNone)r: r; )NNNr NN)rÎ ú Optional[str]rë r< rÒ r< r¹ r` rì z:Optional[Dict[str, Optional[Union[str, bool, List[str]]]]]rÕ zOptional[Dict[str, str]]r: Úbool)r: r5 )Nr NTr NN)r r` r! úOptional[bytes]r" r` r¼ r> r# r= r$ r` rþ ú Optional[int]rÿ r? r: zOptional[bytearray])FNN)
|
r, r r- r= rþ r? rÿ r? r: r° )r4 r` r: r; )r: r= )r¼ r« r: rC )r¼ r« r: rA )NN)rR r rþ r? rÿ r? r: rC )r¼ r« rþ r? rÿ r? r: rD )FNNN) rj r= r\ ú Optional[List[DescriptionType]]rk úOptional[bool]rm úOptional[CMySQLPrepStmt]r r r: z1Tuple[Optional[RowType], Optional[EofPacketType]])NFNNN)ri r? rj r= r\ r@ rk rA rm rB r r r: z-Tuple[List[RowType], Optional[EofPacketType]])rÒ r r: rC )FFF) r¡ rG rk r= r¢ r= r£ r= r r r: rD )r² rG r r r: z!Generator[ResultType, None, None])r¼ r` r: rC )r: r« rá )rà r? r: r; )r: rF )rË r` r: rC )r: rA )r: rC )
|
rT rT rT NrT rT rT rT rT rT )rÎ r rë r rÒ r rÅ r? rÏ r rÐ r rÑ r rÇ r rÈ r rÊ r r: zOptional[OkPacketType])r: r )rª r r: r; )rD r r: r; )rª r= r: r; )ré úOptional[Dict[str, Any]]rê rC r: r; )Fr r )ræ r= rï r` rð r` r: r; )r: r? )NNNNNNN)r¢ rA rk rA rù rA rü zOptional[Type[MySQLCursor]]rø rA rþ r? rÿ r? r: r! )r¡ r r: r; )r¡ r r: zOptional[RowType])r¼ r« r: zDict[str, int])r¼ r« rþ r? r: úEUnion[OkPacketType, Tuple[int, List[DescriptionType], EofPacketType]])r )r r` rn r` r r r: r; )r r« r r r: z/Mapping[str, Union[int, List[DescriptionType]]])rU rU r ) r r` r& z Sequence[BinaryProtocolType]r r r4 r` r r r: rD )r r` r r r: r; )
|
r r` r( r` r& r r r r: r` )@r Ú
|
__module__Ú __qualname__Ú__doc__rZ r¡ r¿ rî rù r r r~ Ú
|
disconnectr r% r0 r5 Úpropertyr7 rè r> rX rg ro rl r{ rê r9 r° r³ r r¾ r rÄ rÉ rÌ rÏ rÒ r× rÒ ÚsetterrÝ rß r rã rí rñ rô rç r r r rÙ r r r r r* r. r r5 rå r Ú __classcell__)r s @r rR rR s? ø Ù&õ5ón6ó(1$ðj #'Ø"&Ø"&Ø ØRVØ/3ðLà ðLð ðLð ð Lð
|
ð Lð Pð Lð -ðLð
|
óLó\ó*E>óNó" ð2 Já Ó ð %)Ø Ø"&Ø $Ø()Ø&*Ø'+ð)Nàð)Nð "ð)Nð ð )Nð
|
ð )Nð ð )Nð #&ð)Nð $ð)Nð %ð)Nð
|
ò)Nó !ð)NñV Ó ð #(Ø&*Ø'+ð *Eàð*Eð ð*Eð $ð *Eð
|
%ð *Eð
|
ò *Eó !ð*EóXNð ò$ó ð$ó3ó"4ñ" Ó ð '+Ø'+ð aàðað $ðað %ð að
|
|
ò aó !ðañF Ó ð '+Ø'+ð /;àð/;ð $ð/;ð %ð /;ð
|
|
ò /;ó !ð/;ðf Ø37Ø "Ø.2ð àðð 1ðð ð ð
|
,ð ð ð ð
|
;óñ: Ó ð $Ø Ø37Ø "Ø.2ð Bà ðBð ðBð 1ð Bð
|
ð Bð ,ð Bð ðBð
|
7òBó !ðBóH ó
|
|
ð Ù Ó ð Ø Ø #ð wàðwð ðwð ð wð
|
ð wð ð wð
|
òwó !ó ðwñr Ó ð9à ð9ð ð9ð
|
+ò 9ó !ð9ñv Ó!òó "ðó:ô$#ñ Ó ò Vó !ð Vó 3ó
|
Aó ?ñ Ó ð ØØØ!%ØØØØ !Ø"$Ø!#ðS'àðS'ð ðS'ð ð S'ð
|
ð S'ð ð S'ð ðS'ð ðS'ð ðS'ð ðS'ð ðS'ð
|
òS'ó !ðS'ðj ò7ó ð7ð __ò ó ð ó ó 0ð ×(Ñ(×/Ñ/ò.ó 0ð.ð 48Ø6:ð/à0ð/ð 4ð/ð
|
ó /ôbVð, òó ðð $(Ø "Ø#'Ø48Ø%)Ø&*Ø'+ðPà ðPð ðPð !ð Pð
|
2ð Pð #ð Pð $ðPð %ðPð
|
óPód&ó(ó
|
ó!ó:ñ Ó à;?ð&,Øð&,Ø+8ð&,à Nò&,ó !ð&,ðV ð"àð"ð ð"ð ð "ð
|
|
ó "ñ0 Ó ð+àð+ð ð+ð
|
9ò +ó !ð+ðZ ð .0Ø !Øð ?àð?ð +ð?ð ð ?ð
|
ð ?ð ð ?ð
|
Oò?ó ð?ðB
|
àð
|
ð ð
|
ð
|
ó
|
ð&+àð+ð ð+ð ð +ð
|
ð +ð
|
ó +ðZ
|
àð
|
ð ð
|
ð
|
ó
|
ó( ÷ 7rÀ rR )jrG Ú
|
__future__r r rØ r r r r r Údecimalr Úior Útypingr r r r r
|
r r r r r r r rT r Ú _decoratingr r Ú
|
_scriptingr Ú abstractsr Úauthenticationr r Ú constantsr r r r r r Ú
|
conversionr rç r! r" r# r$ r% r& r' r( Úerrorsr) r* r+ r, r- r. r/ r0 r1 r2 r3 r4 Únetworkr5 r6 r7 Úopentelemetry.constantsr8 Ú!opentelemetry.context_propagationr9 Úprotocolr: r; r< r= r> r¥ r? r@ rA rB rC rD rE rF rG ÚutilsrH rI rJ rK rL rM rN Ú opentelemetry.instrumentationrO rP rR rU rÀ r ú<module>r] sÐ ðñ> 5Ý "ã Û Û Û Û Û
|
Û å Ý ÷ ÷ ÷ ó õ ß NÝ 2Ý .ß ?÷÷ õ '÷ ÷ ó ÷ ÷ ÷ ñ õ ß AÑ AÝ 1Ý G÷õ ÷
|
÷
|
õ
|
÷÷ ñ Ý)áßOôr7Ð-õ r7rÀ
|
