Ë
|
WñúhÈ¡ ã óÌ d Z ddlZddlZddlZddlZddlZddlmZmZm Z m
|
Z
|
m Z m Z m Z mZmZmZ ddlmZ ddlmZ ddlmZmZ ddlmZmZmZm Z m Z dd l m Z dd
|
l 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/ dd l0m1Z1m2Z2m3Z3 dZ4 ddl5Z5ddl5m6Z6 ddl7m8Z8m9Z9m:Z:m;Z;m<Z<m=Z=m>Z>m?Z? dZ4ddlBmCZC ddlDmEZE eCrddlFmGZGmHZH G d de« ZIy# e@$ rZA e@deA d« eAdZA[Aww xY w)z'Connection class using the C Extension.é N)
|
ÚAnyÚBinaryIOÚDictÚListÚNoReturnÚOptionalÚSequenceÚTupleÚTypeÚUnioné )Úversion)Úcmd_refresh_verify_options)ÚCMySQLPrepStmtÚMySQLConnectionAbstract)Ú
|
ClientFlagÚ FieldFlagÚ FieldTypeÚ
|
ServerFlagÚ ShutdownType)ÚMySQLConverter)ÚInterfaceErrorÚ InternalErrorÚOperationalErrorÚProgrammingErrorÚget_mysql_exception)Ú MySQLProtocol)ÚCextEofPacketTypeÚCextResultTypeÚDescriptionTypeÚParamsSequenceOrDictTypeÚRowTypeÚStatsPacketTypeÚ
|
StrOrBytes)Ú import_objectÚ warn_ciphersuites_deprecatedÚwarn_tls_version_deprecatedF)ÚMySQLInterfaceError)Ú CMySQLCursorÚCMySQLCursorBufferedÚCMySQLCursorBufferedDictÚCMySQLCursorBufferedRawÚCMySQLCursorDictÚCMySQLCursorPreparedÚCMySQLCursorPreparedDictÚCMySQLCursorRawTz2MySQL Connector/Python C Extension not available (ú))Ú OTEL_ENABLED)Úwith_context_propagation)Úend_spanÚrecord_exception_eventc óª e Zd ZdZdeddf fd ZdhdZdhdZede fd« Z
|
d e ddfd
|
Z e j j d eddfd « Zedefd « Zej d eddfd« Zedee fd« Zej de ddfd« Zedee fd« Zej de ddfd« Zede fd« Zej d e ddfd« Zedefd« ZdhdZdhdZeZdefdZdefdZdided e d e ddfd Z d e ddfd Z d!e dee fd"Z edee fd#« Z! djd$ee d%ed&ee"e# d'ee d(ee$ dede%e"e ee& f fd)Z' dkd%ed&ee"e# d'ee d(ee$ dede%ee ee& f f d*Z(dee fd+Z)dhd,Z*dhd-Z+dhd.Z,d/e ddfd0Z- dld(ee$ de.fd1Z/dee& fd2Z0d3e1dede$fd4Z2e3d5e$d6ededee4e&e.f fd7« Z5d5e$deddfd8Z6d5e$deddfd9Z7e3 dmd!e d'ee d:ed;ededee4e&e.f f d<« Z8e8Z9 dnd:ee d'ee d=ee d>ee:e; d?ee d@ee dAee de;fdBZ<ede fdC« Z=ede fdD« Z>edefdE« Z?edefdF« Z@edefdG« ZAdHeBde4eCe1 eDe1e1f f fdIZEdhdJZF dodKe dLe d/e d ee dMe dNe dOe dPee dQee dRee ddfdSZGdefdTZH eI« dUe dee& fdV« ZJdhdWZKdldXee ddfdYZLdeMfdZZNd[e ddfd\ZOdePfd]ZQdePfd^ZRd_e dedePfd`ZSd5e$dae dbeTdedePf
|
dcZUdpd=eddfddZV dqdeeeDe ef dfeeDe ef ddfdgZW xZXS )rÚCMySQLConnectionz6Class initiating a MySQL Connection using Connector/C.ÚkwargsÚreturnNc ó t s t d« d| _ g | _ t j
|
j t j
|
j t j
|
j t j « « ddd« | _ t j « dk( rQt j
|
j | j « s(t j
|
j d« rdnd| _ d| _ t | E « |r | j$ d i |¤ yy# t& $ r | j) « w xY w)
|
ÚInitializationz0MySQL Connector/Python C Extension not availableNÚmysqlÚvendorÚpluginÚLinuxz/usr/lib64/mysql/pluginz/usr/lib/mysql/plugin© )Ú HAVE_CMYSQLÚ RuntimeErrorÚ_cmysqlÚ_columnsÚosÚpathÚjoinÚdirnameÚabspathÚ_mysql_connectorÚ__file__Ú _plugin_dirÚplatformÚsystemÚexistsÚ converterÚsuperÚ__init__ÚconnectÚ ExceptionÚclose)Úselfr8 Ú __class__s úRH:\Change_password\venv_build\Lib\site-packages\mysql/connector/connection_cext.pyrR zCMySQLConnection.__init__r s ø åÜ Ð QÓRÐ Rð ð ð 02 Ü "§¡§ ¡ Ü GGOOBGGOOÔ,<×,EÑ,EÓ FÓ GØ Ø Ø ó !
|
Ôô ??Ó Ò 'ä77>> $×"2Ñ"2Ô3ô ww~~Ð&?Ô@ñ .à0ð Ô ð 48Ü ÑÔá ð Ø Ñ&vÓ&ð øô ò Ø
|
|
Øð ús ÄD$ Ä$D?c ó8 t j j d« }|d dk( rd}nd}| j j d|dj t j dd D cg c] }t |« c}« t j « d « y
|
c c}w ) z!Add default connection attributesú r ÚGPLv2zGPL-2.0Ú
|
Commercialzmysql-connector-pythonú.é )Ú_connector_nameÚ_connector_licenseÚ_connector_versionÚ _source_hostN)
|
r ÚLICENSEÚsplitÚ _conn_attrsÚupdaterG ÚVERSIONÚstrÚsocketÚ gethostname)rV Úlicense_chunksÚclient_licenseÚxs rX Ú_add_default_conn_attrsz(CMySQLConnection._add_default_conn_attrs s ä ×.Ñ.¨sÓ3Ø !Ñ Ò 'Ø &Nà )Nà ×Ñ× Ñ à#;Ø&4Ø&)§h¡hÄÇÁÐPQÐRSÐ@TÖ/U¸1´°AµÒ/UÓ&VÜ &× 2Ñ 2Ó 4ñ õ
|
ùò 0Vs Á$Bc ót | j j « | j j « | j j « dddd| j j « d| _ | j | j
|
d « | _ | j j | j « y)z<Gather information of the MySQL server before authenticationN)ÚprotocolÚserver_version_originalÚserver_threadidÚcharsetÚ server_statusÚ auth_pluginÚ auth_dataÚ capabilitiesrq )
|
rC Úget_proto_infoÚget_server_infoÚ thread_idÚst_server_capabilitiesÚ
|
_handshakeÚ_check_server_versionÚ_server_versionÚ_character_setÚset_mysql_version©rV s rX Ú _do_handshakez CMySQLConnection._do_handshake¤ s ð ×3Ñ3Ó5Ø'+§|¡|×'CÑ'CÓ'EØ #||× 5Ñ 5Ó 7ØØ !Ø Ø Ø LL× ?Ñ ?Ó Añ
|
ð $× 9Ñ 9Ø OOÐ 5Ñ 6ó
|
Ô ð ×Ñ×-Ñ-¨d×.BÑ.BÕCó c ó6 | j j « S )z6Returns the server status attribute of MYSQL structure)rC Úst_server_statusr s rX Ú_server_statusz CMySQLConnection._server_status¶ s ð ||×,Ñ,Ó.Ð.r rF c óT | j r | j j |« yy)zJset local_infile_in_path
|
|
Set allow_local_infile_in_path.
|
N)rC Ú!set_load_data_local_infile_option)rV rF s rX Ú set_allow_local_infile_in_pathz/CMySQLConnection.set_allow_local_infile_in_path» s" ð <<Ø LL× :Ñ :¸4Õ @ð r Úvaluec ó° || _ | j r| j j |« | j r | j j |« y y ©N)Ú _use_unicoderC Ú use_unicoderP Ú set_unicode©rV r s rX r z CMySQLConnection.use_unicodeÄ sA à !ÔØ <<Ø LL× $Ñ $ UÔ +Ø >>Ø NN× &Ñ & uÕ -ð r c ó4 | j d« d }|dk( S )z#Get whether autocommit is on or offzSELECT @@session.autocommitr r ©Ú
|
info_queryr s rX Ú
|
autocommitzCMySQLConnection.autocommitÌ s" ð Ð =Ó>¸qÑAØzÐr c ó | j j |« || _ y# t $ rS}t |d« r-t |j |j |j ¬« |t t |« « |d}~ww xY w)zToggle autocommitÚerrno©ÚmsgÚsqlstateN) rC r Ú _autocommitr( Úhasattrr r r r r rh ©rV r Úerrs rX r zCMySQLConnection.autocommitÒ sq ð 4Ø LL× #Ñ # EÔ *Ø $DÕ øÜ"ò 4ÜsGÔ$Ü)ØII 3§7¡7°S·\±\ôàðô !¤ S£Ó*°Ð 3ûð 4ús "% ¥ B®AA<Á<Bc ó | j S r )Ú _read_timeoutr s rX Ú read_timeoutz CMySQLConnection.read_timeoutß s à×!Ñ!Ð!r Útimeoutc ó t d« )Nz
|
The use of read_timeout after the connection has been established is unsupported
|
in the C-Extension
|
©r ©rV r¡ s rX r z CMySQLConnection.read_timeoutã ó ä ð ó
|
ð
|
r c ó | j S r )Ú_write_timeoutr s rX Ú write_timeoutz CMySQLConnection.write_timeoutì s à×"Ñ"Ð"r c ó t d« )Nz
|
Changes in write_timeout after the connection has been established is unsupported
|
in the C-Extension
|
r£ r¤ s rX r¨ z CMySQLConnection.write_timeoutð r¥ r c ó* | j d« d S )zGet the current databasezSELECT DATABASE()r r r s rX ÚdatabasezCMySQLConnection.databaseù s ð Ð 2Ó3°AÑ6Ð6r c óú | j j |« y# t $ rS}t |d« r-t |j
|
|j |j ¬« |t t |« « |d}~ww xY w)zSet the current databaser r N©
|
rC Ú select_dbr( r r r r r r rh r s rX r« zCMySQLConnection.databaseþ si ð 4Ø LL× "Ñ " 5Õ )øÜ"ò 4ÜsGÔ$Ü)ØII 3§7¡7°S·\±\ôàðô !¤ S£Ó*°Ð 3ûð 4úó A:§AA5Á5A:c óN t | j t j z « S )z'MySQL session has started a transaction)Úboolr r ÚSTATUS_IN_TRANSr s rX Úin_transactionz CMySQLConnection.in_transaction
|
s ô D×'Ñ'¬*×*DÑ*DÑDÓEÐEr c óè | j j | j « d }t j | j
|
| j || j xs d| j | j | j ¬« | _ | j t j « si | _ i d| j d| j" d| j$ d| j& d| j( d| j* d | j, d
|
| j. d | j0 d | j2 d | j4 ddd| j d| j6 d| j8 d| j: d| j< t? | j@ tB « rtE | j@ « n | j@ | jF | jH r | jH nd| jJ r | jJ ndd¥}| jL jO d« }|#|jQ d¬« djS |« }| jL jO d« A| jL jO d« d xs d }| jL jO d« d }nd }d }|d|v r|sd }| jT sª|jW | jL jO d « | jL jO d « | jL jO d « |||| jL jO d « xs d!| jL jO d"« xs d!| jT d# « tX jZ d$k( r| j\ d%k( rd|d&< | j j^ d*i |¤ | j` | j _1 | jd r| j` | jd _3 | jw « | jT stk | j d)« r|ty | j jz « r\| j j{ « }t} | jL jO dg « « D ] }t |« t ||« y y y y # th $ rS}tk |d'« r-tm |jn |jp |jr ¬(« |tu tC |« « |d }~ww xY w)+Nr )ÚbufferedÚrawÚ charset_nameÚconnection_timeoutr ru Ú
|
plugin_dirÚhostÚuserÚpasswordÚ password1Ú password2Ú password3r« ÚportÚ client_flagsÚ unix_socketÚcompressÚ ssl_disabledTÚ
|
conn_attrsÚ local_infileÚload_data_local_dirÚoci_config_fileÚoci_config_profile)Úwebauthn_callbackÚopenid_token_filer r¨ Ú tls_versions)Úreverseú,Útls_ciphersuitesr zTLSv1.3ÚTLS_AES_256_GCM_SHA384ÚcaÚcertÚkeyÚ verify_certFÚverify_identity) Ússl_caÚssl_certÚssl_keyÚssl_cipher_suitesrÌ Útls_cipher_suitesÚssl_verify_certÚssl_verify_identityrÄ ÚntÚMySQLKerberosAuthPluginÚuse_kerberos_gssapir r Úget_ssl_cipherr@ )Ar Úget_infoÚ _charset_idrJ ÚMySQLÚ _bufferedÚ_rawÚ_connection_timeoutr Ú _auth_pluginrL rC Úisset_client_flagr Ú CONNECT_ARGSre Ú_hostÚ_userÚ _passwordÚ
|
_password1Ú
|
_password2Ú
|
_password3Ú _databaseÚ_portrÁ Ú _unix_socketÚ _compressÚ_allow_local_infileÚ_allow_local_infile_in_pathÚ_oci_config_fileÚ_oci_config_profileÚ
|
isinstanceÚ_webauthn_callbackrh r% Ú_openid_token_filer r§ Ú_sslÚgetÚsortrG Ú _ssl_disabledrf rE ÚnameÚ_auth_plugin_classrS Ú_converter_str_fallbackÚconverter_str_fallbackrP Ú str_fallbackr( r r r r r r r Úcallablerà Úsetr' r& ) rV r· Ú
|
cnx_kwargsrÌ Ússl_ciphersuitesrÏ r ÚcipherÚ tls_versions rX Ú_open_connectionz!CMySQLConnection._open_connection s Ø×*Ñ*×3Ñ3°D×4DÑ4DÓEÀaÑH ä'×-Ñ-Ø^^Ø Ø%Ø $× 8Ñ 8Ò =¸AØ ×(Ñ(Ø ×)Ñ)Ø×'Ñ'ô
|
ð ×%Ñ%¤j×&=Ñ&=Ô>Ø !DÔ ð
|
Ø DJJð
|
à DJJð
|
ð ð
|
ð ð
|
ð
|
ð
|
ð ð
|
ð ð
|
ð DJJð
|
ð D× -Ñ -ð
|
ð 4×,Ñ,ð
|
ð ð
|
ð Dð
|
ð $×*Ñ*ð
|
ð D× 4Ñ 4ð
|
ð " 4×#CÑ#Cð
|
ð t× 4Ñ 4ð!
|
ð" ! $×":Ñ":ð#
|
ô( d× 5Ñ 5´sÔ;ô d× 5Ñ 5Ô6à×,Ñ,à!%×!8Ñ!8Ø26×2DÒ2DD× .Ò .È!Ø48×4GÒ4GT× 0Ò 0ÈQò3
|
|
ð8 yy}} ^Ó4 Ø Ð #Ø × Ñ dÐ Ô +Ø 88 LÓ1LØ 99==Ð+Ó ,Ð 8à Ð 0Ó1°!Ñ4Ò<¸ð ð $yy}}Ð-?Ó @Øñ Ñ ð $Ð Ø #Ð à Ð $Ø\Ñ)Ù$à 7Ð Ø×!Ò!Ø × Ñ à "iimm¨DÓ 1Ø $§ ¡ § ¡ ¨fÓ 5Ø #yy}}¨UÓ 3Ø)9Ø$0Ø)9Ø'+§y¡y§}¡}°]Ó'CÒ'LÀuØ+/¯9©9¯=©=Ð9JÓ+KÒ+TÈuØ$(×$6Ñ$6ñ
|
ô ô 77d?t× 6Ñ 6Ð:SÒ SØ04JÐ,Ñ -ð
|
4Ø DLL× Ñ Ñ . :Ò .Ø26×2NÑ2NDLLÔ /Ø~~Ø.2×.JÑ.JÔ+ð ×ÑÔ ð ×"Ò"Ü Ð&6Ô7Ü ×4Ñ4Ô5ð \\×0Ñ0Ó2FÜ " 4§9¡9§=¡=° ÀÓ#DÓ Eò B Ü+¨KÔ8Ü,¨V°[ÕAñ Bð 6ð 8ð #øô #ò 4ÜsGÔ$Ü)ØII 3§7¡7°S·\±\ôàðô !¤ S£Ó*°Ð 3ûð 4ús ÎA R Ò S1Ò AS,Ó,S1c ó | j rE| j j « r+t | j t j « d « | j
|
sy | j « | j
|
j « t rt# | j « y y # t $ ro}t rt | j |« t |d« r-t |j |j |j ¬« |t t! |« « |d }~ww xY w# t rt# | j « w w xY w)Nr r r )Ú_spanÚ is_recordingr5 ÚsysÚexc_inforC Ú free_resultrU r( r2 r r r r r r rh r4 )rV r s rX rU zCMySQLConnection.close} sì Ø ::$**×1Ñ1Ô3ä " 4§:¡:¬s¯|©|«~¸aÑ/@Ô Aà||Ø ð %Ø × Ñ Ô Ø LL× Ñ Õ õ ÜÕ$ð øô #ò 4ÝÜ& t§z¡z°3Ô7ÜsGÔ$Ü)ØII 3§7¡7°S·\±\ôàðô !¤ S£Ó*°Ð 3ûð 4ûõ ÜÕ$ð ús% Á *B( Â( D Â1A*DÄD Ä D# Ä# Ec ó8 | j j « S )z8Return True if the connection to MySQL Server is closed.)rC Ú connectedr s rX Ú is_closedzCMySQLConnection.is_closed s à<<×)Ñ)Ó+Ð+Ð+r c óp | j r*| j « | j j « S y)z;Reports whether the connection to MySQL Server is availableF)rC Úhandle_unread_resultÚpingr s rX Ú is_connectedz CMySQLConnection.is_connected s+ à <<Ø × %Ñ %Ô 'Ø<<×$Ñ$Ó&Ð &àr Ú reconnectÚattemptsÚdelayc ó¾ | j « | j j « }|ry|r| j ||¬« yt d« # t $ r Y ,w 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.
|
N)r r z$Connection to MySQL is not available)r rC r ÚAttributeErrorr r )rV r r r r s rX r zCMySQLConnection.ping¢ sb ð ×!Ñ!Ô#ð Ø ×)Ñ)Ó+Iñ Øá Ø NN H°ENÕ :ä Ð!GÓHÐ Høô ò Ù ð ús A Á A ÁA rs c ó: | j j |« y)z;Sets the default character set name for current connection.N)rC Úset_character_set)rV rs s rX Úset_character_set_namez'CMySQLConnection.set_character_set_name¿ s à ×&Ñ& wÕ/r Úqueryc ó d} | j j |« | j j rY| j j « }| j j « r%| j j « t d« | j j « |S # t $ rS}t |d« r-t |j |j |j ¬« |t t |« « |d}~ww xY w)z%Send a query which only returns 1 rowr@ z'Query should not return more than 1 rowr r N) rC r Úhave_result_setÚ fetch_rowr r r( r r r r r rh )rV r Ú first_rowr s rX r zCMySQLConnection.info_queryà sÓ à ð 4Ø LL× Ñ uÔ %Ø||×+Ò+Ø LL× 2Ñ 2Ó 4 Ø<<×)Ñ)Ô+ØLL×,Ñ,Ô.Ü(Ð)RÓSÐSØ LL× $Ñ $Ô &ð Ðøô #ò 4ÜsGÔ$Ü)ØII 3§7¡7°S·\±\ôàðô !¤ S£Ó*°Ð 3ûð 4ús B$B* Â* DÂ3ADÄDc óV | j j « S # t $ r Y yw xY w)zMySQL connection IDN)rC rz r( r s rX Ú connection_idz CMySQLConnection.connection_id× s/ ð Ø<<×)Ñ)Ó+Ð +øÜ"ò Ø àð ús (§(ÚcountÚbinaryÚcolumnsr¶ Ú prep_stmtc óü |r |j n | j }| j r|s t d« | | j }g }||dk r t d« d} |r |j n| j j }
|
| j s|r| j j d« |
|
« } | rt | « } | j j « sQ|sOt | j « D ]7 \ } } | d t j k( s t j | | « | | < 9 | j sQ| j rEt | « D ]7 \ } }|r | j j! | j | | | « | | < 9 |j# t% | « « | dz } |r| |k( rn |
|
« } | r| s?| j' |« d }|r|j) « d| _ n| j) « nd}||fS # t, $ rv}|r|j) « n| j) « t/ |d « r-t1 |j2 |j4 |j6 ¬
|
« |t9 t; |« « |d}~ww xY w) z8Get all or a subset of rows returned by the MySQL serverzNo result set availableNr z$count should be 1 or higher, or NoneTr ÚeofFr r ) r" Ú unread_resultrC r rå r r# rP r¶ ÚlistÚ enumeraterD r ÚVECTORr Ú_vector_to_pythonÚ to_pythonÚappendÚtupleÚfetch_eof_columnsr Ú_unread_resultr( r r r r r r rh )rV r' r( r) r¶ r* r8 r- ÚrowsÚcounterr# ÚrowÚiÚdscÚ_Ú_eofr s rX Úget_rowszCMySQLConnection.get_rowsá sQ ñ 6? ×1Ò1ÀD×DVÑDV Ø ¡ Ü Ð 9Ó:Ð :à ;Ø))Cà Ø Ð ¨!¢Ü Ð!GÓHÐ Hàð: 4Ù/8 ×+Ò+¸d¿l¹l×>TÑ>TIØ~~¡ð × Ñ Ô&á+CÚÜ3ià||×'Ñ'Ô)±#ô #,¨D¯M©MÓ":ò N3Ø q6¤Y×%5Ñ%5Ó5Ü%3×%EÑ%EÀcÈ!ÁfÓ%MC FðNð yy T§^¢^Ü )¨#£ò X1Ú "Ø%)§^¡^×%=Ñ%=¸d¿m¹mÈAÑ>NÐPSÐTUÑPVÓ%WC FðXð E #JÔ'Ø1 áW¨Ò -Øá kó9 ñ: Ø48×4JÑ4JÈ9Ó4UØñ5ñ Ø ×)Ñ)Ô+Ø*/DÕ'à×$Ñ$Õ&àð TzÐøô #ò 4ÙØ×%Ñ%Õ'à× Ñ Ô"ÜsGÔ$Ü)ØII 3§7¡7°S·\±\ôàðô !¤ S£Ó*°Ð 3ûð 4ús/ ÁB/G< Ä AG< ÅA!G< Æ5AG< Ç< I;ÈA1I6É6I;c ón | j d||||¬« \ }}|r|d |fS d|fS # t $ r Y yw xY w)z.Get the next rows returned by the MySQL serverr )r' r( r) r¶ r* r N©NN)r> Ú
|
IndexError)rV r( r) r¶ r* r8 r7 r, s rX Úget_rowzCMySQLConnection.get_row5 s\ ð Ø ØØ Ø ØØ#ð &ó ID#ñ Ø Q ~Ð%Ø#;Ð øÜò á ð ús !( ¤( ¨ 4³4c ó | j r4| j j « | j j « S y)zReads the next resultN)rC Úconsume_resultÚ next_resultr s rX rE z CMySQLConnection.next_resultM s/ à <<Ø LL× 'Ñ 'Ô )Ø<<×+Ñ+Ó-Ð -Ør c óR | j r| j j « yy)zFrees the resultN)rC r r s rX r z CMySQLConnection.free_resultT s à <<Ø LL× $Ñ $Õ &ð r c ór | j r+| j « | j j « yy)zCommit current transactionN)rC r Úcommitr s rX rH zCMySQLConnection.commitY s* à <<Ø × %Ñ %Ô 'Ø LL× Ñ Õ !ð r c ó | j r5| j j « | j j « yy)z Rollback current transactionN)rC rD Úrollbackr s rX rJ zCMySQLConnection.rollback_ s. à <<Ø LL× 'Ñ 'Ô )Ø LL× !Ñ !Õ #ð r r« c óú | j j |« y# t $ rS}t |d« r-t |j
|
|j |j ¬« |t t |« « |d}~ww xY w)zChange the current databaser r Nr )rV r« r s rX Ú cmd_init_dbz CMySQLConnection.cmd_init_dbe si ð 4Ø LL× "Ñ " 8Õ ,øÜ"ò 4ÜsGÔ$Ü)ØII 3§7¡7°S·\±\ôàðô !¤ S£Ó*°Ð 3ûð 4úr¯ c ó |r |j n| j j }|s t d« |r|j « n| j j « }g | _ |D ]k }| j j |d t |d « ddddt |d « t j z t |d « t |d « f « m | j | j j « d| j dS ) z Fetch EOF and column informationú No result seté é Né é )Ú status_flagÚ warning_count)r, r) ) r" rC r Ú fetch_fieldsrD r3 Úintr ÚNOT_NULLr Úst_warning_count)rV r* r" ÚfieldsÚcols rX r5 z"CMySQLConnection.fetch_eof_columnsp sû ñ
|
*3I× %Ò %¸¿ ¹ ×8TÑ8Tð ñ Ü Ó1Ð 1á-6×'Ñ'Ô)¸D¿L¹L×<UÑ<UÓ<WØ Øò CØ MM× Ñ àFÜAKØØØØÜQ[L¤9×#5Ñ#5Ñ5ÜAKÜAKð
|
õ ð ð" $× 2Ñ 2Ø!%§ ¡ ×!>Ñ!>Ó!@ñð }}ñ
|
ð
|
r c ó | j rr| j j « | j j « | j j « | j j « | j
|
dS y)z Fetch EOF and status information)rT Ú field_countÚ insert_idÚ affected_rowsrt N)rC rX Úst_field_countr] r^ r r s rX Úfetch_eof_statusz!CMySQLConnection.fetch_eof_status sa à <<à!%§ ¡ ×!>Ñ!>Ó!@Ø #||× :Ñ :Ó <Ø !\\× 3Ñ 3Ó 5Ø!%§ ¡ ×!;Ñ!;Ó!=Ø!%×!4Ñ!4ñ ð ð r Ú statementc ó^ | j s t d« | j j |« }| j |_ t |« S # t $ rS}t |d« r-t |j |j |j ¬« |t t |« « |d}~ww xY w)zPrepares the SQL statementú MySQL Connection not availabler r N)rC r Ú stmt_preparer r r r( r r r r r r rh )rV ra r8 Ústmtr s rX Úcmd_stmt_preparez!CMySQLConnection.cmd_stmt_prepare s ð ||Ü"Ð#CÓDÐ Dð 4Ø<<×,Ñ,¨YÓ7DØ*.×*FÑ*FDÔ 'Ü! $Ó'Ð 'øÜ"ò 4ÜsGÔ$Ü)ØII 3§7¡7°S·\±\ôàðô !¤ S£Ó*°Ð 3ûð 4ús 6A Á B,ÁAB'Â'B,Ú statement_idÚargsc ó~ |j |d| j i g | _
|
|j sd| _ | j « S d| _ | j |« S # t $ rS}t |d« r-t |j
|
|j |j ¬« |t t |« « |d}~ww xY w)z Executes the prepared statementÚ query_attrsr r NFT)Ú stmt_executerj r( r r r r r r rh rD r" r6 r` r5 )rV rg rh r8 r s rX Úcmd_stmt_executez!CMySQLConnection.cmd_stmt_execute´ s¶ ð 4Ø %L× %Ñ % tÐ J¸×9IÑ9IÒ Jð Ø×+Ò+à"'DÔ Ø×(Ñ(Ó*Ð *à "ÔØ×%Ñ% lÓ3Ð3øô #ò 4ÜsGÔ$Ü)ØII 3§7¡7°S·\±\ôàðô !¤ S£Ó*°Ð 3ûð 4ús A Á B<Á)AB7Â7B<c ó | j r t d« |j « y# t $ rS}t |d« r-t |j |j |j ¬« |t t |« « |d}~ww xY w)z Closes the prepared statementúUnread result foundr r N) r6 r Ú
|
stmt_closer( r r r r r r rh ©rV rg r8 r s rX Úcmd_stmt_closez CMySQLConnection.cmd_stmt_closeÎ óz ð × Ò Ü Ð 5Ó6Ð 6ð 4Ø × #Ñ #Õ %øÜ"ò 4ÜsGÔ$Ü)ØII 3§7¡7°S·\±\ôàðô !¤ S£Ó*°Ð 3ûð 4úó * ª B³ABÂBc ó | j r t d« |j « y# t $ rS}t |d« r-t |j |j |j ¬« |t t |« « |d}~ww xY w)z Resets the prepared statementrn r r N) r6 r Ú
|
stmt_resetr( r r r r r r rh rp s rX Úcmd_stmt_resetz CMySQLConnection.cmd_stmt_resetß rr rs rµ Ú raw_as_stringc óÈ | j « | | j } t |t « s|j d« }|| _ d | _ | j j ||||| j ¬« g | _ | j j0 s| j3 « S | j5 « S # t $ rS}t |d« r-t |j |j |j ¬« |t! t# |« « |d }~wt$ $ rH}| j& r | j& n| j( d| j* }t- d|df¬« |d }~ww xY w) Nzutf-8)r¶ rµ rw rj r r ú:i zConnection not available.)r Úvalues)r rå rø ÚbytesÚencodeÚ_queryÚ_local_infile_filenamesrC r rj r( r r r r r r rh r rò rê rñ r rD r" r` r5 )rV r r¶ rµ rw r8 r Úaddrs rX Ú cmd_queryzCMySQLConnection.cmd_queryð sO ð ×!Ñ!Ô#Ø ;Ø))Cð Ü e¤UÔ+Ø WÓ-ð DKØ+/DÔ (à LL× Ñ ØØØ!Ø +Ø × ,Ñ ,ð ô ð* Ø||×+Ò+à×(Ñ(Ó*Ð *à×%Ñ%Ó'Ð'øô' #ò 4ÜsGÔ$Ü)ØII 3§7¡7°S·\±\ôàðô !¤ S£Ó*°Ð 3ûÜ ò à%)×%6Ò%6×!Ò!¸t¿z¹z¸lÈ!ÈDÏJÉJÈ<Ð<Xð ô #Ø DÐ*EÐ#Fôàð ûð ús& AB6 Â6 E!Â?AD Ä E!ÄAE Å E!ÚpreparedÚ cursor_classÚ
|
dictionaryr r¨ c ó | j |« | j « s t d« |s|rt j dt
|
¬« |#t |t « s t d« || « S |xs | j }|xs | 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)ay Instantiates and returns a cursor using C Extension
|
|
By default, CMySQLCursor 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_cext.CMySQLCursor.
|
|
Raises ProgrammingError when cursor_class is not a subclass of
|
CMySQLCursor. Raises ValueError when cursor is not available.
|
|
Returns instance of CMySQLCursor or subclass.
|
|
:param buffered: Return a buffering cursor
|
:param raw: Return a raw cursor
|
:param prepared: Return a cursor which uses prepared statements
|
:param cursor_class: Use a custom cursor class
|
:param dictionary: Rows are returned as dictionary
|
:return: Subclass of CMySQLCursor
|
:rtype: CMySQLCursor or subclass
|
ú MySQL Connection not available.zsThe use of read_timeout after the connection has been established is unsupported
|
in the C-Extension)ÚcategoryNz=Cursor class needs be to subclass of cursor_cext.CMySQLCursorr Tr é rO é )r r r r^ rO é r é )rµ r¶ r r z*Cursor not available with given criteria: z, )r r r ÚwarningsÚwarnÚWarningÚ
|
issubclassr) r rä rå r* r0 r, r- r+ r. r/ ÚKeyErrorÚ
|
ValueErrorrG Úrange) rV rµ r¶ r r r r r¨ Ú cursor_typeÚtypesrh r: s rX ÚcursorzCMySQLConnection.cursor" su ðJ ×!Ñ! (Ô+Ø× Ñ Ô"Ü"Ð#DÓEÐ EÙ =Ü MMð&ä õ ð
|
Ð #Ü l¬LÔ9Ü&ØSóð ñ ! $Ó'Ð 'àÒ-t~~ØÒ TYYà Ø tÑ Ø 1Ñ KØ $;Ø 1Ñ KØ Ñ Ø 1Ñ KØ tÑ Ø 2Ñ Kô Ü#Ü Ü&Ü Ü'Ü$Ü(ñ
|
ð Ø&E+Ñ&¨Ó-Ð -øÜò Ø@DÜ Ø<Ø))¬e°A«hÖ V¨¸+ÈÈaÉÑ:PÐTUÓ:UT !WÑ VùÔ VÓWñXóð ð ð ús Ã#
|
C. Ã.)EÄD0Ä(D0Ä/Ec óx | j j s t d« | j j « S )z,Returns number of rows of current result setrN )rC r" r Únum_rowsr s rX r zCMySQLConnection.num_rowsw s/ ð ||×+Ò+Ü Ó1Ð 1à||×$Ñ$Ó&Ð&r c óP | j sy| j j « S )zReturns number of warningsr )rC rT r s rX rT z CMySQLConnection.warning_count s! ð ||Øà||×)Ñ)Ó+Ð+r c óH | j sy| j j S )z"Check if a result set is availableF)rC r" r s rX Úresult_set_availablez%CMySQLConnection.result_set_available s ð ||Øà||×+Ñ+Ð+r c ó | j S )z)Check if there are unread results or rows)r r s rX r- z CMySQLConnection.unread_result s ð ×(Ñ(Ð(r c ó6 | j j « S )z Check if there are more results)rC Ú more_resultsr s rX r z CMySQLConnection.more_results s ð ||×(Ñ(Ó*Ð*r Úparamsc
|
óv g }t |t t f« r| j rg|D cg c]Z }| j j | j j | j j |« | j « « \ }}|S | j j | }|S t |t « rÚi }| j r|j « D ]n \ }}| j j | j j | j j |« | j « « ||j « < p |S |j « D ]4 \ }}| j j |« d ||j « < 6 |S t dt |« j d| d« c c}w )z¬Prepare parameters for statements
|
|
This method is use by cursors to prepared parameters found in the
|
list (or tuple) params.
|
|
Returns dict.
|
r z Could not process parameters: ú(z)), it must be of type list, tuple or dict)rø r. r4 rP ÚquoteÚescapeÚto_mysqlÚ _sql_moderC Úconvert_to_mysqlÚdictÚitemsr| r ÚtypeÚ__name__)rV r Úresultr rÓ s rX Úprepare_for_mysqlz"CMySQLConnection.prepare_for_mysql s ð :<Ü ft¤UmÔ ,Ø~~ð "(ö ð ð NN×(Ñ(Ø ×-Ñ-Ø NN× 3Ñ 3°EÓ :¸D¿N¹Nóõðð ð8 ð' 7 ×6Ñ6¸Ð?ð& ô% ¤Ô %ØFØ~~Ø"(§,¡,£.ò JCØ+/¯>©>×+?Ñ+?Ø ×-Ñ-Ø NN× 3Ñ 3°EÓ :¸D¿N¹Nóó,F3::<Ò(ðð ð #)§,¡,£.ò SJCØ+/¯<©<×+HÑ+HÈÓ+OÐPQÑ+RF3::<Ò(ðSð ô #Ø0´°f³ ×1FÑ1FÐ0GÀqÈÈð Q:ð :óð ùò/s ©A F6c ó8 | j j « y)zlConsume the current result
|
|
This method consume the result by reading (consuming) all rows.
|
N)rC rD r s rX Úconsume_resultsz CMySQLConnection.consume_resultsÄ s ð
|
×#Ñ#Õ%r Úusernamer¼ r½ r¾ r¿ rÈ rÉ rË c ó | j j |||||||| |
|
« |2t |t « s t d« |dk r t d« || _ || _ | j « y# t $ rS} t | d« r-t | j
|
| j | j ¬« | t t | « « | d} ~ ww xY w)z!Change the current logged in userr r Nzcharset must be an integerr z2charset should be either zero or a postive integer)rC Ú change_userr( r r r r r r rh rø rV r râ rë Ú_post_connection) rV r r¼ r« rs r½ r¾ r¿ rÈ rÉ rË r s rX Úcmd_change_userz CMySQLConnection.cmd_change_userË sÒ ð 4Ø LL× $Ñ $ØØØØØØØ Ø"Ø!ô
|
ð* Ð Ü g¤sÔ+Ü Ð!=Ó>Ð>Ø{Ü Ð!UÓVÐVØ &DÔ Ø
|
Ø × Ñ Õ øô! #ò 4ÜsGÔ$Ü)ØII 3§7¡7°S·\±\ôàðô !¤ S£Ó*°Ð 3ûð 4ús #A1 Á1 C Á:ACÃC c ó^ | j j « }|r| j « |S )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
|
)rC Úreset_connectionr° )rV Úress rX Úcmd_reset_connectionz%CMySQLConnection.cmd_reset_connectionø s* ð ll×+Ñ+Ó-Ù Ø × !Ñ !Ô #Ø
|
r Úoptionsc ó8 | j « | j j |« | j « S # t $ rS}t |d« r-t |j |j |j ¬« |t t |« « |d }~ww xY w)Nr r ) r rC Úrefreshr( r r r r r r rh r` )rV r¶ r s rX Ú cmd_refreshz CMySQLConnection.cmd_refresh s ð 4Ø × %Ñ %Ô 'Ø LL× Ñ Ô )ð ×$Ñ$Ó&Ð&øô #ò 4ÜsGÔ$Ü)ØII 3§7¡7°S·\±\ôàðô !¤ S£Ó*°Ð 3ûð 4ús += ½ BÁABÂBc ó$ | j « y)z,Close the current connection with the serverN)rU r s rX Úcmd_quitzCMySQLConnection.cmd_quit s à
|
|
r Ú shutdown_typec ó² | j s t d« |r#t j |« s t d« |}nt j
|
} | j j |« | j « y# t $ rS}t |d« r-t |j |j |j ¬« |t t |« « |d}~ww xY w)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.
|
rc zInvalid shutdown typer r N)rC r r rá r ÚSHUTDOWN_DEFAULTÚshutdownr( r r r r r rh rU )rV r¼ Úlevelr s rX Ú cmd_shutdownz CMySQLConnection.cmd_shutdown s¸ ð ||Ü"Ð#CÓDÐ Dá Ü ×(Ñ(¨ Ô7Ü$Ð%<Ó=Ð=Ø!Eä ×1Ñ1Eð 4Ø LL× !Ñ ! %Ô (ð
|
|
øô #ò 4ÜsGÔ$Ü)ØII 3§7¡7°S·\±\ôàðô !¤ S£Ó*°Ð 3ûð 4ús ÁA: Á: CÂACÃCc óX | j « | j j « }t « j |d¬« S # t
|
t f$ rS}t |d« r-t |j |j |j ¬« |t t |« « |d}~ww xY w)z'Return statistics from the MySQL serverF)Ú with_headerr r N) r rC Ústatr Úparse_statisticsr( r r r r r r rh )rV rÄ r s rX Úcmd_statisticsz CMySQLConnection.cmd_statistics1 s à ×!Ñ!Ô#ð 4Ø<<×$Ñ$Ó&DÜ ?×3Ñ3°DÀeÐ3ÓLÐ LøÜ#¤^Ð4ò 4ÜsGÔ$Ü)ØII 3§7¡7°S·\±\ôàðô !¤ S£Ó*°Ð 3ûð 4ús 4A ÁB)ÁAB$Â$B)Ú mysql_pidc ób t |t « s t d« | j d| « y)zKill a MySQL processzMySQL PID must be intzKILL N)rø rV r r )rV rÇ s rX Úcmd_process_killz!CMySQLConnection.cmd_process_kill? s+ ä)¤SÔ)Ü Ð 4Ó5Ð 5Ø ykÐ*Õ+r c ó t )zSend the DEBUG command©ÚNotImplementedErrorr s rX Ú cmd_debugzCMySQLConnection.cmd_debugE ó ä!Ð!r c ó t )zSend the PING commandrË r s rX Úcmd_pingzCMySQLConnection.cmd_pingI rÎ r Ú
|
statementsc ó t )z/Send one or more statements to the MySQL serverrË )rV rÑ r8 s rX Úcmd_query_iterz CMySQLConnection.cmd_query_iterM rÎ r Úparam_idÚdatac ó t )zSend data for a columnrË )rV rg rÔ rÕ r8 s rX Úcmd_stmt_send_long_dataz(CMySQLConnection.cmd_stmt_send_long_dataQ s
|
ô "Ð!r c ó |du r | j n | j }| j r| j « y|r t d« y)z'Check whether there is an unread resultTrn N)r6 r- Úcan_consume_resultsr¬ r )rV r r- s rX r z%CMySQLConnection.handle_unread_result[ sE à/7¸4Ñ/?×+Ò+ÀT×EWÑEW Ø × #Ò #Ø × Ñ Õ "Ù Ü Ð 5Ó6Ð 6ð r Úuser_variablesÚsession_variablesc ó | j « s t d« | j « st | j | j | j
|
| j | j | j | j | j | j | j « |s|r| j « }|r/|j! « D ] \ }}|j# d| d|f« |r/|j! « D ] \ }}|j# d| d|f« |j% « yy# 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.
|
r
zSET @`z` = %sz SET SESSION `N)r r rµ r± rë rì rð râ rí rî rï rö r÷ r r r r¦ ÚexecuterU )rV rÚ rÛ ÚcurrÓ r s rX Ú reset_sessionz CMySQLConnection.reset_sessionc s0 ð( × Ñ Ô"Ü"Ð#DÓEÐ Eà×(Ñ(Ô*ð !Ø×$Ñ$ØJJØNNØNNØ×$Ñ$ØOOØOOØOOØ×)Ñ)Ø×,Ñ,ô
|
ñ Ñ .Ø++-CÙ Ø"0×"6Ñ"6Ó"8ò @JCØKK &¨¨¨VÐ 4°u°hÕ?ð@á Ø"3×"9Ñ"9Ó";ò GJCØKK -°¨u°FÐ ;¸e¸XÕFðGà IIKð /øô $ò !ØÖ ð !ús A3D( Ä(EÅE)r9 N)Fr r )NFNNN)FNNNr )NFF)NNNNNNN)
|
Ú rà rà Nrà rà rà NNN)Fr@ )Yr¨ Ú
|
__module__Ú __qualname__Ú__doc__r rR rn r ÚpropertyrV r rh r r r Úsetterr± r r r r¨ r« r³ r
|
rU Ú
|
disconnectr r r r r$ r" r r& r r r r
|
r r> rB rE r rH rJ rL r r5 r` r{ rf r3 r rl rq rv r Ú_execute_queryr r) r r rT 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ß Ú __classcell__)rW s @rX r7 r7 o sú ø Ù@ð ð ¨õ óB
|
ó"Dð$ ð/ ò /ó ð/ðA°3ð A¸4ó Að ×(Ñ(×/Ñ/ð. ð .¨$ò .ó 0ð.ð ðDò ó ðð
|
×Ñð
|
4 ð
|
4¨ò
|
4ó ð
|
4ð ð"h smò "ó ð"ð ×Ñð
|
Cð
|
¨Dò
|
ó ð
|
ð ð#x¨}ò #ó ð#ð ×Ñð
|
Sð
|
¨Tò
|
ó ð
|
ð ð7#ò 7ó ð7ð __ð 4cð 4 dò 4ó ð 4ð ðF ò Fó ðFólBó\%ð. Jð,4ó ,ðdó ñIdð I°cð IÀcð IÐRVó Ið:0¨cð 0°dó 0ð
|
ð ¨x¸Ñ/@ó ð( ðx¨}ò ó ðð $Ø Ø37Ø "Ø.2ñ Rà}ðRð ðRð $Ñ/Ñ0ð Rð
|
d^ð Rð NÑ+ð Rð ðRð
|
tG}hÐ'8Ñ 9Ð9Ñ :óRðl Ø37Ø "Ø.2ñ àð ð $Ñ/Ñ0ð ð d^ð ð
|
NÑ+ð ð ð ð
|
xÑ (Ð+<Ñ"=Ð=Ñ >ó ð0X d^ó ó'ó
|
"ó $ð 4 Cð 4¨Dó 4ð 59ñ!
|
Ø! .Ñ1ð!
|
à ó!
|
ðF (Ð+<Ñ"=ó ð4àð4ð ð4ð
|
ó 4ð( ð4à$ð4ð ð4ð ð 4ð
|
|
%Ð)¨>Ð9Ñ:Ñ ;ò 4ó ð4ð24à$ð4ð ð4ð
|
ó 4ð"4à$ð4ð ð4ð
|
ó 4ð" ð #Ø Ø #ñ -(àð-(ð d^ð-(ð ð -(ð
|
ð -(ð ð -(ð
|
%Ð)¨>Ð9Ñ:Ñ ;ò-(ó ð-(ð^ Nð $(Ø "Ø#'Ø59Ø%)Ø&*Ø'+ñSà4.ðSð d^ðSð 4.ð Sð
|
t LÑ 1Ñ2ð Sð TNð Sð smðSð }ðSð
|
óSðj ð'#ò 'ó ð'ð ð,sò ,ó ð,ð ð, dò ,ó ð,ð ð)tò )ó ð)ð ð+dò +ó ð+ð)Ø.ð)à x U¨E \Ñ 2Ð2Ñ 3ó)óV&ð ØØØ!%ØØØØ)-Ø,0Ø+/ñ+ àð+ ð ð+ ð ð + ð
|
# ð + ð ð + ð ð+ ð ð+ ð " # ð+ ð % SMð+ ð $ C=ð+ ð
|
ó+ ðZ dó ñ Ó!ð ' 3ð '¨8Ð4EÑ+Fò 'ó "ð 'óñ¨(°3©-ð À4ó ð4 4 ó 4ð ,¨#ð ,°$ó ,ð "8ó "ð"(ó "ð"¨ð "¸ð "Àó "ð"à$ð"ð ð"ð ð "ð
|
ð "ð
|
ó "ñ7¨Tð 7¸dó 7ð 48Ø6:ñ/à c¨3 h¡ Ñ0ð/ð $ D¨¨c¨¡NÑ3ð/ð
|
÷ /r r7 )Jrã rE rM ri r r Útypingr r r r r r r r
|
r r rà r Ú _decoratingr Ú abstractsr r Ú constantsr r r r r Ú
|
conversionr Úerrorsr r r r r rp r r r r r r! r" r# r$ Úutilsr% r& r' rA rJ r( Ú cursor_cextr) r* r+ r, r- r. r/ r0 Ú ImportErrorÚexcÚopentelemetry.constantsr2 Ú!opentelemetry.context_propagationr3 Ú opentelemetry.instrumentationr4 r5 r7 r@ r rX ú<module>rö s× ðñ> .ã Û Û Û
|
Û ÷ ÷ ÷ õ Ý 3ß >ß QÕ QÝ &÷õ õ $÷÷ ñ ÷ñ ð ðÛå4÷ ÷ ó ð Kõ 2Ý GáßOôcÐ.õ cøð ò Ù
|
Ø
|
<¸S¸EÀÐCó à ðûðús Â
|
C Ã C#Ã C Ã C#
|
