Ë
|
WñúhTì ã óð d Z dgZddlZddlZddlZddlZddlZddlZddlZddl Z ddl
|
m Z ddl m Z ddlmZmZmZmZmZmZmZmZmZmZmZ ddlmZ dd l m Z dd
|
l m Z m Z m!Z!m"Z"m#Z#m$Z$ dd l%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0 dd l1m2Z2m3Z3m4Z4m5Z5 dd l6m7Z7m8Z8m9Z9m:Z:m;Z;m<Z<m=Z=m>Z> ddl?m@Z@mAZAmBZBmCZCmDZDmEZE ddlFmGZGmHZH ddlImJZJmKZKmLZL ddlMmMZM ddlNmOZOmPZPmQZQmRZRmSZSmTZTmUZUmVZV ddlWmWZW ddlXmYZYmZZZ G d deJ« Z[y)zDImplemention of the communication with MySQL servers in pure Python.ÚMySQLConnectioné N)ÚDecimal)ÚIOBase) ÚAnyÚAsyncGeneratorÚBinaryIOÚDictÚListÚMappingÚOptionalÚSequenceÚTupleÚTypeÚUnioné )Úversion)Úget_local_infile_filenames)Ú
|
ClientFlagÚ FieldTypeÚ RefreshOptionÚ ServerCmdÚ
|
ServerFlagÚ flag_is_set) ÚConnectionTimeoutErrorÚ DatabaseErrorÚErrorÚInterfaceErrorÚ InternalErrorÚNotSupportedErrorÚOperationalErrorÚProgrammingErrorÚReadTimeoutErrorÚWriteTimeoutErrorÚ get_exception)Ú
|
EOF_STATUSÚ
|
ERR_STATUSÚLOCAL_INFILE_STATUSÚ OK_STATUS)ÚBinaryProtocolTypeÚDescriptionTypeÚ EofPacketTypeÚ OkPacketTypeÚ
|
ResultTypeÚRowTypeÚStatsPacketTypeÚ
|
StrOrBytes)Ú get_platformÚ int1storeÚ int4storeÚlc_intÚ warn_ciphersuites_deprecatedÚwarn_tls_version_deprecatedé )Úcmd_refresh_verify_optionsÚhandle_read_write_timeout)ÚMySQLConnectionAbstractÚMySQLCursorAbstractÚ
|
ServerInfo)Úcharsets)Ú MySQLCursorÚMySQLCursorBufferedÚMySQLCursorBufferedDictÚMySQLCursorBufferedRawÚMySQLCursorDictÚMySQLCursorPreparedÚMySQLCursorPreparedDictÚMySQLCursorRaw)Úlogger)ÚMySQLTcpSocketÚMySQLUnixSocketc ó e Zd ZU dZdZeed< edee fd« Z dcdZ
|
dcdZ d e de fd
|
Zdcd Zdcd Zd edefdZdeddfdZd edefdZ e« ddde dee dee defd« Z e« ddd edee dee de fd« Zd edee ef fdZ e« d ede ee ee e ef f fd« Z e« dededee ded ee d e!d edee dee dee" fd « Z# e« dfd e$d e!dee dee de"f
|
d!« Z%de!fd"Z&de!fd#Z' ddd$eee e(f d%eee e(f ddfd&Z) dgd'e!d(ed)eddfd*Z*dcd+Z+dcd,Z,e,Z- dhd-ee! d.ee! d/ee! d0ee.e/ d1ee! dee dee de0fd2Z1 e« dfd3e!d4ee e d.ee! d5e(de ee2 ee f f
|
d6« Z3 e« did7ee d3e!d4ee e d.ee! d8e(d5e(de e e2 ee f fd9« Z4dcd:Z5dcd;Z6de!fd<Z7d=e defd>Z8 djd e9d.e!d-e!d?e!d5e(de f d@Z:dAe9d5e(de;e df fdBZ< dkdCedDed5e(ddfdEZ= e« dFed5e(de>e e ee e f f fdG« Z? dldCedHe@eA dIe@e( ded5e(de ee ee e ef f f dJZBdCed5e(ddfdKZCdCed5e(ddfdLZD eE« dMedefdN« ZFdCedOedHe$d5e(def
|
dPZGdefdQZHdmdRee ddfdSZIdeJfdTZKdUedefdVZLdefdWZMdefdXZN dndYe dZe d=e d[ee d\e d]e d^e d_e d`e dae dee fdbZOy)or z3Implementation of the pure Python MySQL connection.r7 Ú _mfa_nfactorÚreturnc óR | j r| j j d« S y)zMySQL connection ID.Úserver_threadidN)Ú
|
_handshakeÚget©Úselfs úQH:\Change_password\venv_build\Lib\site-packages\mysql/connector/aio/connection.pyÚ connection_idz MySQLConnection.connection_id| s$ ð ??Ø??×&Ñ&Ð'8Ó9Ð 9Øó Nc ó K | j r/t j dk( r t | j ¬« | _ n&t | j | j ¬« | _ t j | j j « | j « d { | j « d { | j « d { | j( t* j, z r| j j/ « | j0 | _ | j9 « d { | j: st= | j j> d
|
« rktA | j j> jB « rA| j j> jC d « \ }}}tE |« tG ||« y y y y 7 /7 7 # t $ r|}| j j « d { 7 t! |t j" t j$ f« r)t' dd| j d| j d¬« | d }~ww xY w# t4 $ r}t7 d « |d }~ww xY w7 Lw) NÚposix)Ú unix_socket)ÚhostÚportiÓ z!Can't connect to MySQL server on ú:z (timed out))ÚerrnoÚmsgzFConverter classA should be a subclass of conversion.MySQLConverterBaseÚget_extra_infoÚcipher)$Ú _unix_socketÚosÚnamerH Ú_socketrG Ú_hostÚ_portÚasyncioÚwait_forÚopen_connectionÚ_connection_timeoutÚ _do_handshakeÚ_do_authÚ ExceptionÚclose_connectionÚ
|
isinstanceÚCancelledErrorÚ TimeoutErrorr Ú _client_flagsr ÚCOMPRESSÚswitch_to_compressed_modeÚ_converter_classÚconverter_classÚ TypeErrorÚAttributeErrorÚ_post_connectionÚ _ssl_disabledÚhasattrÚ_writerÚcallabler] r6 r5 )rQ Úerrr^ Ú tls_versionÚ_s rR ÚconnectzMySQLConnection.connect s è ø ð Ø× Ò ¤R§W¡W°Ò%7Ü .¸4×;LÑ;LÔ M ä -°4·:±:ÀDÇJÁJÔ O Ü×"Ñ"Ø ×,Ñ,Ó.°×0HÑ0Hó÷ ð ð ×$Ñ$Ó&× &Ð &Ø--/× !Ð !ð × Ñ ¤
|
× 3Ñ 3Ò 3à LL× 2Ñ 2Ô 4ð Ø#'×#8Ñ#8DÔ ð ×#Ñ#Ó%×%Ð%ð ×"Ò"Ü ×,Ñ,Ð.>Ô?Ü ×-Ñ-×<Ñ<Ô=ð &*§\¡\×%9Ñ%9×%HÑ%HÈÓ%RÑ "FK Ü '¨ Ô 4Ü (¨°Õ =ð >ð @ð #ðA ùð 'ùØ !úÜò Ø,,×/Ñ/Ó1× 1Ñ 1Ü#¤× 6Ñ 6¼×8LÑ8LÐ MÔNÜ,Ø Ø;¸D¿J¹J¸<ÀqÈÏÉÈ ÐT`Ðaôð ðð ûð ûô ò Ü ð0óð ð ûð úð &ûs J B G  GÂ!G Â8GÂ9G ÃGÃG Ã7J Ä I Ä J Ä1I=Ä2B J ÇG ÇG ÇG Ç I Ç! IÇ>HÇ?AIÉI É J É I:É) I5É5I:É:J 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) r1 r ÚLICENSEÚsplitÚstrr` ÚgetpidÚsocketÚ gethostnameÚjoinÚVERSIONÚ_connection_attrsÚupdate)rQ ÚplatformÚlicense_chunksÚclient_licenseÚxÚdefault_conn_attrss rR Ú_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Ñ&ñ
|
Ðð × Ñ ×%Ñ%Ð&8Õ9ùò )Os  CÚqueryc ót K | j « d{ | j |« d{ S 7 7 w)zì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.
|
N)Úhandle_unread_resultÚ cmd_query)rQ r s rR Ú_execute_queryz MySQLConnection._execute_queryË s5 è ø ð ×'Ñ'Ó)×)Ð)Ø^^ EÓ*×*Ð*ð *øØ*ús 848¯6°8¶8c óð K | j j « d{ }t j d|« |d t k( r t |« | j j |« | _ t | j d | j d | j d | j d | j d | j d | j d
|
| j d ¬ « | _
|
t j | j j d « t j d| j j « | j r<| j r0t j" | j | j « | _ na| j r%t j& | j « | _ n0| j r$t j( | j « | _ | j d t* j, z s~| j. s4| j0 dk( r t3 d« | j0 dk( r t3 d« | j4 r t3 dd¬« | xj6 t* j, z c_ n/| j8 s#| xj6 t* j, z c_ | j d t* j: z rt* j: g| _ | j d t* j> z r'd| j _ t* j> g| _ | j d t* jB z rt* jB g| _ yy7 Sw)z(Get the handshake from the MySQL server.Nz Protocol::Handshake packet: %sé ÚprotocolÚserver_version_originalrM ÚcharsetÚ server_statusÚ auth_pluginÚ auth_dataÚ capabilities)r¥ r Ú thread_idr§ Ú status_flagsr© rª r« r z Protocol::Handshake charset: %sÚmysql_clear_passwordzEClear password authentication is not supported over insecure channelsÚ$authentication_openid_connect_clientzEOpenID Connect authentication is not supported over insecure channelsz1SSL is required but the server doesn't support itiê )r[ T)"rb ÚreadrF Údebugr& r$ Ú _protocolÚparse_handshakerN r< Ú _server_infor= Úset_mysql_major_versionÚ version_tupler§ Ú _charset_nameÚ_charset_collationÚget_by_name_and_collationÚ_charsetÚ get_by_nameÚget_by_collationr ÚSSLÚ is_secureÚ _auth_pluginr Ú_ssl_verify_certrp rx Ú PLUGIN_AUTHÚ client_flagsÚCLIENT_QUERY_ATTRIBUTESÚquery_attrs_is_supportedÚMULTI_FACTOR_AUTHENTICATION©rQ Úpackets rR ri z MySQLConnection._do_handshakeÕ sà è ø à||×(Ñ(Ó*×*Ü Ð5°vÔ>Ø !9
|
Ò "Ü Ó'Ð 'à ..×8Ñ8¸Ó@ä &Ø__ ZÑ0ØOOÐ$=Ñ>ØooÐ&7Ñ8ØOO IÑ.Ø ¨ Ñ9Ø ¨ Ñ6Øoo kÑ2Ø ¨ Ñ8ô
|
Ôô ×(Ñ(¨×):Ñ):×)HÑ)HÈÑ)KÔLÜ Ð6¸×8IÑ8I×8QÑ8QÔRð × Ò $×"9Ò"9Ü $× >Ñ >Ø×"Ñ" D×$;Ñ$;ó DMð × Ò Ü $× 0Ñ 0°×1CÑ1CÓ DDMØ × $Ò $Ü $× 5Ñ 5°d×6MÑ6MÓ NDMà~Ñ.´· ± Ò?Ø>>Ø×$Ñ$Ð(>Ò>Ü(ð,óð ð ×$Ñ$Ð(NÒNÜ(ð,óð ð ×$Ò$Ü$ØGØ ôð ð × Ò ¤:§>¡> /Ñ 1Ö Ø×#Ò#Ø × Ò ¤*§.¡.Ñ 0Õ à ??>Ñ *¬Z×-CÑ-CÒ CÜ!+×!7Ñ!7Ð 8DÔ à ??>Ñ *¬Z×-OÑ-OÒ OØ9=D× Ñ Ô 6Ü!+×!CÑ!CÐ DDÔ à ??>Ñ *¬Z×-SÑ-SÒ SÜ!+×!GÑ!GÐ HDÕ ð Tðy +ûs M6 M3¡MM6c ó K | j r| j j d« s:| j r~| j j d« rct j dk( rP| j sDt j « | _ t j d| j | j « | j r%| j | j k7 r | j n | j }d| _ | j s | j t j z rð| j j# | j$ | j& | j( | j* | j, | j. | j0 ¬« }| j2 j5 | j6 j8 | j ¬« }| j j; |« d{ | j j= |« d{ d | _ | j> jA | jB | jD | jF | jH | jJ d
|
¬ « | j> jM | j | jN | j || jP | jR | jT | j6 j8 | j | j | j | jV | jX ¬ « d{ }| j[ |« | j t j\ z s1| jT r$| j_ | jT « d{ yyy7 7 u7 j7 w) af 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)Ússl_caÚssl_certÚssl_keyÚssl_verify_certÚssl_verify_identityÚ tls_versionsÚtls_cipher_suites)r§ r NT)Úkrb_service_principalÚoci_config_fileÚoci_config_profileÚwebauthn_callbackÚopenid_token_file©Úconfig) ÚsockÚ handshakeÚusernameÚ password1Ú password2Ú password3Údatabaser§ rÂ Ú ssl_enabledr© Úauth_plugin_classÚ
|
conn_attrs)0r¿ Ú
|
startswithr` ra Ú_userÚgetpassÚgetuserrF r± Ú
|
_password1Ú _passwordÚ _ssl_activerx rp r r½ rb Úbuild_ssl_contextÚ_ssl_caÚ _ssl_certÚ_ssl_keyrÀ Ú_ssl_verify_identityÚ _tls_versionsÚ_tls_ciphersuitesr² Ú make_auth_sslrº Ú
|
charset_idÚwriteÚ switch_to_sslÚ_authenticatorÚupdate_plugin_configÚ_krb_service_principalÚ_oci_config_fileÚ_oci_config_profileÚ_webauthn_callbackÚ_openid_token_fileÚ authenticaterN Ú
|
_password2Ú
|
_password3Ú _databaseÚ_auth_plugin_classr Ú
|
_handle_okÚCONNECT_WITH_DBÚ cmd_init_db)rQ ÚpasswordÚ ssl_contextrÇ Úok_pkts rR rj zMySQLConnection._do_auth sÆ è ø ð × Ò Ø×!Ñ!×,Ñ,Ð-AÔBà×!Ò!Ø×%Ñ%×0Ñ0Ð1JÔKÜGGtOà**Ü Ó*DJÜ LLØFØ
|
|
Ø×!Ñ!ô ð 4§>¡>°T·_±_Ò#Dð OOà ð ð !ÔØ×!Ó! t×'9Ñ'9¼J¿N¹NÒ'JØ ,,×8Ñ8Ø||Ø Ø Ø $× 5Ñ 5Ø$(×$=Ñ$=Ø !× /Ñ /Ø"&×"8Ñ"8ð 9ó Kð !NN× 8Ñ 8Ø ×0Ñ0¸t×?QÑ?Qð 9ó Fð ,,×$Ñ$ VÓ,× ,Ð ,Ø,,×,Ñ,¨[Ó9× 9Ð 9Ø #DÔ ð ×Ñ×0Ñ0à)-×)DÑ)DØ#'×#8Ñ#8Ø&*×&>Ñ&>Ø%)×%<Ñ%<Ø%)×%<Ñ%<ñ ð 1ô
|
ð ×*Ñ*×7Ñ7Ø ØooØZZØ ØooØooØ^^ØMM×,Ñ,Ø ×+Ñ+Ø ×(Ñ(Ø ×)Ñ)Ø "× 5Ñ 5Ø×-Ñ-ð 8ó
|
÷
|
ð Ô à×"Ñ"¤Z×%?Ñ%?Ò?ÀTÇ^Â^Ø×"Ñ" 4§>¡>Ó2× 2Ñ 2ð FTÐ?ðA -ùØ 9ùð
|
øð$ 3úsJ G!NÇ#M8Ç$"NÈM;ÈD NÌM>ÌA NÍ0N Í1NÍ;NÍ>NÎ NrÇ c óÀ |d t k( r1| j j |« }| j |d « |S |d t k( r t |« t d« )zý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.
|
r¤ Ú status_flagzExpected OK packet)r( r² Úparse_okÚ_handle_server_statusr& r$ r )rQ rÇ r s rR r zMySQLConnection._handle_okg s_ ð !9 Ò !Ø^^×,Ñ,¨VÓ4FØ × &Ñ & v¨mÑ'<Ô =ØMØ !9
|
Ò "Ü Ó'Ð 'Ü Ð 1Ó2Ð2rT Úflagsc ó 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_EXISTSÚ_have_next_resultÚSTATUS_IN_TRANSÚ_in_transaction)rQ r s rR r z%MySQLConnection._handle_server_statusv s. ô "-¬Z×-KÑ-KÈUÓ!SÔ Ü *¬:×+EÑ+EÀuÓ MÕ rT 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.
|
r¤ r zExpected EOF packet)r% r² Ú parse_eofr r& r$ r )rQ rÇ Úeofs rR Ú _handle_eofzMySQLConnection._handle_eof s_ ð !9
|
Ò "Ø..×*Ñ*¨6Ó2CØ × &Ñ & s¨=Ñ'9Ô :ØJØ !9
|
Ò "Ü Ó'Ð 'Ü Ð 2Ó3Ð3rT ÚfilenameÚ read_timeoutÚ write_timeoutc ó¾ K | 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||« d{ « |
|
j/ « S # t $ r }t |d}~ww xY w# t" $ r-}d } t | j% t' |« ||« « |d}~ww xY w7 j# t0 t2 f$ r Y S w xY w# t0 $ rd | j4 j7 d|xs | j8 ¬« d{ 7 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 ww)z(Handle a LOAD DATA INFILE LOCAL request.NzxNo `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 {}ÚrbTrT ©r ú MySQL Connection not availablezFile '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 Ú
|
commonpathÚ
|
ValueErrorÚformatr Úopenr Ú
|
_send_dataÚcloseÚIOErrorÚ NameErrorrb rô Ú_write_timeoutrv ) rQ r r r Ú file_nameÚfile_name_from_requestr| Ú infile_pathÚc_pathÚerr_msgÚ data_files rR Ú_handle_load_data_infilez(MySQLConnection._handle_load_data_infile s_ è ø ð × 'Ñ 'Ð /Ü+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Ø??Øoo i°°|À]ÓS×Sóð ØÕ!øôa ò *Ü cÐ )ûð *ûô ò ð5ð ô %ØNN¤3 s£8¨Y¸ ÓDóàðûð úð& Tùô YÐ'ò Ùð ûô ò Tð RØll×(Ñ(Ø }Ò'K¸×8KÑ8Kð )ó ÷ ò øô "ò RÜ&Ð'GÓHÈcÐQûð Rúä 6¨)¨Ð4GÐ!HÓIÈtÐ Sð Tûð ØÕ!øÜYÐ'ò Ùð ÿs÷ DM Ä
|
2I Ä<BM Ç!I2 Ç/"M È.K É J+ÉK É J-ÉM É I/É#I*É*I/É/M É2 J(É;(J#Ê#J(Ê(M Ê+K Ê-J?Ê<M Ê>J?Ê?M Ë L/Ë .LË:K=Ë;LÌ L/Ì LÌ
|
LÌLÌL/Ì/L2 Ì2MÌ4MÍMÍMÍMÍMÍMÍM c ó| K |rt |« dk r t d« |d t k( r| j |« S |d t k( r.|dd j « }| j |||« d{ S |d t k( r| j |« S |d t k( r t |« | j j |« }|rt |t « s t d« dg|z | _ t! d|« D ]d }| j j# | j$ j' |xs | j( « d{ | j* « | j |< f | j | j$ j' |xs | j( « d{ « }d| _ | j |dS 7 E7 {7 #w) au 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
|
r¤ úEmpty responseé NzIllegal result setr T)Úcolumnsr )Úlenr r( r r' Údecoder8 r% r r& r$ r² Úparse_column_countrm ÚintÚ _columns_descÚrangeÚ parse_columnrb r° Ú _read_timeoutÚpython_charsetÚ unread_result)rQ rÇ r r r Ú column_countÚir s rR Ú_handle_resultz MySQLConnection._handle_resultó s· è ø ñ" V q Ü Ð!1Ó2Ð 2Ø !9 Ò !Ø?? 6Ó*Ð *Ø !9Ô+Ò +Ø abz×(Ñ(Ó*HØ ×6Ñ6Ø,¨ ó÷ ð ð !9
|
Ò "Ø×#Ñ# FÓ+Ð +Ø !9
|
Ò "Ü Ó'Ð 'ð ~~×8Ñ8¸Ó@ Ù¤:¨l¼CÔ#@Ü Ð!5Ó6Ð 6ð ð
|
à ñ Ôô q,Ó'ò AØ$(§N¡N×$?Ñ$?Øll×'Ñ'¨ Ò(J¸×8JÑ8JÓK×KØ×#Ñ#ó%D× Ñ qÒ !ð ð × Ñ Ø,,×#Ñ# LÒ$F°D×4FÑ4FÓG× Gó
|
ð "ÔØ ×-Ñ-°cÑ:Ð:ð5ùð$ Løð
|
Hús8 A.F<Á0F5Á1C F<Ä<F8
|
Ä=AF<ÆF:Æ F<Æ8F<Æ:F<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( r² Úparse_binary_prepare_okr& r$ r rÆ s rR Ú_handle_binary_okz!MySQLConnection._handle_binary_ok& sH ð !9 Ò !Ø>>×9Ñ9¸&ÓAÐ AØ !9
|
Ò "Ü Ó'Ð 'Ü Ð 8Ó9Ð9rT c ó² K |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 ]V }| j j | j j | j « d{ | j" « ||< X | j | j j | j « d{ « }|||fS 7 Y7 w)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: zIllegal result set.Nr )r= r r( r r% r r& r$ r² r? rm r@ rB rC rb r° rD rE )rQ rÇ rG r< rH r s rR Ú_handle_binary_resultz%MySQLConnection._handle_binary_result6 s> è ø ñ" V q Ü Ð!1Ó2Ð 2Ø !9 Ò !Ø?? 6Ó*Ð *Ø !9
|
Ò "Ø×#Ñ# FÓ+Ð +Ø !9
|
Ò "Ü Ó'Ð 'ð ~~×8Ñ8¸Ó@ Ù¤:¨l¼CÔ#@Ü Ð!6Ó7Ð 7à*.¨°,Ñ)>Üq,Ó'ò AØ ×4Ñ4Øll×'Ñ'¨×(:Ñ(:Ó;×;¸T×=PÑ=PóGAJð ð
|
× Ñ T§\¡\×%6Ñ%6°t×7IÑ7IÓ%J× JÓKØ g sÐ+Ð+ð <øð Kús% C7EÃ9E
|
Ã:A EÅEÅEÅEÚcommandÚargumentÚ packet_numberÚexpect_responseÚcompressed_packet_numberc ó K | j « d{ | j j | j j ||xs |« |||xs | j
|
« d{ |sy| j j |xs | j « d{ S 7 7 :# t $ r} t d« | d} ~ ww xY w7 %w)aü 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.
|
Nr )
|
r rb rô r² Ú make_commandr1 rv r r° rD )
|
rQ rO rP rQ rÇ rR rS r r r| s
|
rR Ú _send_cmdzMySQLConnection._send_cmd^ sÇ è ø ð. ×'Ñ'Ó)×)Ð)ð NØ,,×$Ñ$Ø×+Ñ+¨G°VÒ5G¸xÓHØ Ø(Ø Ò4 ×!4Ñ!4ó ÷ ð ñ ØØ\\×&Ñ& |Ò'I°t×7IÑ7IÓJ×JÐJð *øð ùô ò NÜ"Ð#CÓDÈ#Ð Mûð Núð
|
KúsQ CB"CA B& Á)B$Á*B& Á./CÂ CÂ CÂ$B& Â& C Â/ B;Â;C Ã Cr7 Úsend_empty_packetc ó K | j « d{ t |d« s t d« d} |j |dz
|
« }|rJ| j j ||xs | j ¬« d{ |j |dz
|
« }|rJ|r3 | j j d|xs | j « d{ | j j |xs | j « d{ }|S 7 æ7
# t $ r}t d« |d}~ww xY w7 X# t $ r}t d« |d}~ww xY w7 Fw) 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.
|
Nr° z expecting a file-like objecté é r r rT )
|
r ry r* r° rb rô r1 rv r rD ) rQ r7 rW r r Ú
|
chunk_sizeÚbufr| Úress rR r- zMySQLConnection._send_data
sL è ø ð" ×'Ñ'Ó)×)Ð)äy &Ô)Ü Ð ;Ó<Ð <à
|
ð NØ.. ¨b¡ Ó1CÙØll×(Ñ(Ø }Ò'K¸×8KÑ8Kð )ó ÷ ð ð nn Z°"¡_Ó5ò ñ ð RØll×(Ñ(¨¨mÒ.R¸t×?RÑ?RÓS×SÐSð LL×%Ñ% lÒ&H°d×6HÑ6HÓI×IØ
|
ð/ *øðùô ò NÜ"Ð#CÓDÈ#Ð Mûð Núð
|
TùÜ!ò RÜ&Ð'GÓHÈcÐQûð Rúð Jús D?C= D?µAD Á9C?Á:D ÂD?Â-D ÃD ÃD Ã
|
,D?Ã6D=Ã7D?Ã?D Ä DÄ
|
DÄDÄD?Ä D Ä D:Ä) D5Ä5D:Ä:D?c ód t | j xr | j j « « S )z«Reports whether the socket is connected.
|
|
Instead of ping the server like ``is_connected()``, it only checks if the
|
socket connection flag is set.
|
)Úboolrb Ú is_connectedrP s rR Úis_socket_connectedz#MySQLConnection.is_socket_connected¯ s% ô DLLÒ@ T§\¡\×%>Ñ%>Ó%@ÓAÐArT c ó` K | j « d{ y7 # t $ r Y yw xY ww)a 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.
|
NFT)Úcmd_pingr rP s rR r` z MySQLConnection.is_connected· s5 è ø ð Ø--/× !Ð !ð ð "ùÜò Ùð üs( . . +¨.ª+«.Úuser_variablesÚsession_variablesc óX K | j « d{ s t d« | j « d{ s | j | j | j
|
| j | j j | j | j | j | j | j | j «
|
d{ | j# « d{ }|r7|j% « D ]$ \ }}|j' d| d|f« d{ & |r7|j% « D ]$ \ }}|j' d| d|f« d{ & |j) « d{ y7 \7 <7 # t $ r | j! « d{ 7 Y Ïw xY w7 ¿7 7 S7 ;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.
|
Nz MySQL Connection not available.zSET @`z` = %sz SET SESSION `)r` r Úcmd_reset_connectionÚcmd_change_userrå ré r rº ró rè rþ rÿ rù rú rü r! Ú reconnectÚcursorÚitemsÚexecuter. )rQ rd re ÚcurÚkeyÚvalues rR Ú reset_sessionz MySQLConnection.reset_sessionÄ s è ø ð( ×&Ñ&Ó(×(Ð(Ü"Ð#DÓEÐ Eà×.Ñ.Ó0×0Ð0ð 'Ø×*Ñ*ØJJØNNØNNØMM×,Ñ,ØOOØOOØOOØ×)Ñ)Ø×,Ñ,Ø×+Ñ+ó ÷ ð ð KKM×!Ù Ø ,× 2Ñ 2Ó 4ò B
|
UØkk F¨3¨%¨vÐ"6¸¸ÓA×AÑAð Bá Ø /× 5Ñ 5Ó 7ò I
|
UØkk M°#°°fÐ"=À¸xÓH×HÑHð Iàiik×Ñð7 )ùð 1ùð ùô $ò 'ØnnÓ&×&Ó&ð 'úð "øð Bøð IøØús£ F*E2"F*¹E5ºF*¿B E: Ã
|
E8à E: ÃF*Ã"F"Ã#6F*ÄF$Ä8F*ÅF&ÅF*Å,F(Å-F*Å5F*Å8E: Å: F ÆFÆF Æ F*Æ F Æ F*Æ$F*Æ&F*Æ(F*ri ÚattemptsÚdelayc óÄ K | j « d{ y7 # t $ r5}|r | j ||¬« d{ 7 n t d« |Y d}~yd}~ww xY ww)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)rq rr z$Connection to MySQL is not available)rc r ri r )rQ ri rq rr r| s rR ÚpingzMySQLConnection.pingõ sZ è ø ð" VØ--/× !Ò !ùÜò VÙØnn¨h¸enÓD×DÒDä$Ð%KÓLÐRUÐUô Eûð VüsB A A A ¨AÁ AÁAÁA ÁA Á A c ó K | j sy | j j « d{ y7 # t $ r Y yw xY ww)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)rb rl rk rP s rR ÚshutdownzMySQLConnection.shutdown s> è ø ð ||Ø ð Ø,,×/Ñ/Ó1× 1Ò 1ùÜò Ù ð üs0 A 6 ®4¯6 ³A´6 ¶ A¿AÁAÁAc óò K t j t « 5 t | j « D ] }|j « d { | j j « | j r2| j j « r| j « d { d d d « | j r"| j j « d { d | _ y 7 7 D# 1 sw Y CxY w7 w©N) Ú
|
contextlibÚsuppressr ÚtupleÚ_cursorsr. Úclearrb r` Úcmd_quitrl )rQ rj s rR r. zMySQLConnection.close s¼ è ø Ü × Ñ ¤Ó 'ñ &Ü § ¡ Ó.ò %Ø lln×$Ñ$ð %à MM× Ñ Ô !à|| § ¡ × 9Ñ 9Ô ;Ømmo×%Ð%÷ &ð <<Ø,,×/Ñ/Ó1× 1Ð 1Ø ð %øð &ø÷ &ð &úð 2úsM C7,C)ÁC%Á AC)Â"C'Â#C)Â'1C7ÃC5Ã C7Ã%C)Ã'C)Ã)C2Ã.C7ÚbufferedÚrawÚpreparedÚ cursor_classÚ
|
dictionaryc ó* K | j r| j j « s t d« | t |t « r|dk r t d« | t |t « r|dk r t d« | j « 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 7 ª# t& $ rO d }
|
dj) t+ d
|
« D cg c] } |d| z z dk7 s|
|
| nc c} w c} « } t- d| « dw xY ww)aï Instantiate and return 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.
|
|
It is possible to also give a custom cursor through the cursor_class
|
parameter, but it needs to be a subclass of
|
mysql.connector.aio.abstracts.MySQLCursorAbstract.
|
|
Raises:
|
ProgrammingError: When cursor_class is not a subclass of
|
MySQLCursor.
|
ValueError: When cursor is not available.
|
InterfaceError: When read or write timeout is not a positive integer.
|
r Nr z.Option read_timeout must be a positive integerz/Option write_timeout must be a positive integerz8Cursor class needs be to subclass of MySQLCursorAbstractTr7 r r¤ rZ )r r7 r r r¤ r; rZ é )r r r r z, z*Cursor not available with given criteria: )rb r` r rm r@ r r Ú
|
issubclassr> r! Ú _bufferedÚ_rawr? rE rA rB r@ rC rD ÚKeyErrorr rB r* ) rQ r r r r r r r Ú cursor_typeÚtypesÚargsrH Úcriterias rR rj zMySQLConnection.cursor. sÉ è ø ð6 || 4§<¡<×#<Ñ#<Ô#>Ü"Ð#CÓDÐ Dà Ð #Ü<¬Ô-° ÀÒ1Aä Ð!QÓRÐ RØ Ð $Ü=¬#Ô.°-À!Ò2Cä Ð!RÓSÐ Sà×'Ñ'Ó)×)Ð)à Ð #Ü l¬KÔ8Ü&ØNóð ñ ! $¨ °mÓDÐ Dà 'Ð 38¸¿ ¹ Ø_c¨$¯)©)à Ø tÑ Ø 1Ñ KØ $;Ø 1Ñ KØ Ñ Ø 1Ñ KØ tÑ Ø 2Ñ Kô Ü"Ü Ü%Ü Ü&Ü#Ü'ñ
|
ð Ø&E+Ñ&¨¨l¸MÓJÐ JðC *ùôD ò Ø@DØyyÜ"'¨£(ÖJQ¨k¸QÀ!¹VÑ.DÈÓ.IaÑJùÔJóHô Ø<¸X¸JÐGóàð ð üs= B F D6 B FÄ) D8 Ä5FÄ8#FÅE4
|
Å,E4
|
Å3 FÆFÚbinaryr< Úkwargsc ól K | j dd|||d|¤ d{ \ }}|r|d |fS d|fS 7 w)a3 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.
|
r7 )Úcountr r< r Nr © )Úget_rows)rQ r r< r r Úrowsr s rR Úget_rowzMySQLConnection.get_row s^ è ø ð ($--ð
|
ØØØØñ
|
ð
|
ñ
|
÷
|
cñ ØGS>Ð !Øc{Ðð
|
ús 424r Ú prep_stmtc ó K | | j }| j s t d« g df} |j dd« }|rS| j } | dk( rd} | j
|
j | j ||| |xs | j « d{ }nR| j
|
j | j | j j ||xs | j « d{ }|\ }} |sR|sP| j D|rBt | d« r6| j j } |D cg c] } | | | j « }} | $| j# d| v r| d n| d « d| _ || fS 7 Ú7 # t $ r}
|
d| _ |
|
d}
|
~
|
ww xY wc c} w w)
|
zù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.
|
NzNo result set availabler Úutf8mb4Úutf8FÚ converterr r¨ )r rF r rO r§ r² Úread_binary_resultrb rD Úread_text_resultr´ r r rA ry r Ú row_to_pythonr )rQ r r r< r r r r r r§ r| Úeof_pr Úrows rR r zMySQLConnection.get_rows s¥ è ø ð ;Ø))Cà×!Ò!Ü Ð 9Ó:Ð :àDzð Ø!:: n°dÓ;LÙØ ,,ØiÒ'Ø $GØ !^^× >Ñ >ØLLØØØØ Ò6 D×$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{ÐðIøðùô ò Ø!&DÔ ØIûð üò LùsZ *F A!E- ÂE)ÂAE- Ã!E+Ã"E- Ã&=F Ä#FÄ=,F Å)E- Å+E- Å- FÅ6 E?Å?FÆF c óB K | j d« d{ y7 w)zCommit current transaction.ÚCOMMITN)r¢ rP s rR ÚcommitzMySQLConnection.commitÜ s è ø à×!Ñ! (Ó+×+Ò+úó c ó K | j r| j « d{ | j d« d{ y7 7 w)z Rollback current transaction.NÚROLLBACK)rF r r¢ rP s rR ÚrollbackzMySQLConnection.rollbackà s; è ø à × Ò Ø--/× !Ð !Ø×!Ñ! *Ó-×-Ñ-ð "øØ-ús A¢A£A»A¼AÁAc óÜ K | j | j t j « d{ « | j « d{ y7 !7 # t
|
t f$ r Y yw xY ww)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.
|
NTF)r rV r ÚRESET_CONNECTIONrw r r rP s rR rg z$MySQLConnection.cmd_reset_connectionæ s_ è ø ð Ø OO $§.¡.´×1KÑ1KÓ"L× LÔ MØ×'Ñ'Ó)× )Ð )Øð MøØ )ùä!Ô#3Ð4ò Ùð üsJ A,-A ±A²A Á AÁA ÁA,ÁA ÁA ÁA)Á&A,Á(A)Á)A,rà c ó K | j | j t j |j d« « d{ « S 7 w)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 infawaitormation.
|
zutf-8N)r rV r ÚINIT_DBÚencode)rQ rà s rR r zMySQLConnection.cmd_init_dbó s< è ø ð Ø..¤×!2Ñ!2°H·O±OÀGÓ4LÓM× Mó
|
ð
|
Ø Mús >A Á A Á A Ú raw_as_stringc ó K t |t « s+t |t « r|j « }t |« }|| _ d | _ | j j dk7 r| j j nd}t « }| j j s'| j rt j dt ¬« | j t j z rUg }g } g }
|
dgt# | j « dz dz z } t% | j « D ]2 \ } } | d }d}|K| | dz xx d| dz z z cc< | j' t) t* j, « t) |« z « [t |t. « r2| j0 j3 |« \ }}}|
|
j' |« n6t |t « rI|j |« }|
|
j' t5 t# |« « |z « t* j6 }nÝt |t8 « r8|
|
j' t5 t# |« « |z « t* j: }nt |t< « rh|
|
j' t5 t# t |« j |« « « t |« j |« z « t* j> }n t |t@ « r6|
|
j' tC jD d |« « t* jF }n×t |tH jH tH jJ f« r0| j0 jM |« \ }}|
|
j' |« n}t |tH jN tH jP f« r0| j0 jS |« \ }}|
|
j' |« n#tU d
|
|jV jX d « | j' t) |« t) |« z « | d j |« }|j' t5 t# |« « |z « 5 |j[ t5 t# | j « « « |j[ t5 d« « |
|
r|j[ d j] | D cg c] }tC jD d |« c}« t) d« z « t_ | |« D ]' \ }}|j[ |« |j[ |« ) |
|
D ] }|j[ |« |j[ |« t9 |« } |ja dd « }|ja dd « }| jc | je tf jh |||¬« d { ||« d { }|S c c}w 7 7 # tT $ r1}|jj dk( r d|jl v rd}to |« | d }~ww xY ww)Nr r ú<This version of the server does not support Query Attributes©Úcategoryr é é r7 z<dz&MySQL binary protocol can not handle 'z ' objectsrT ÚBr r ©r r il z Loading local data is disabledr )8rm Ú bytearrayr r« r r rº ra r´ rÄ Ú _query_attrsÚwarningsÚwarnÚWarningrp r rà r= Ú enumerateÚappendr2 r ÚNULLr@ r² Úprepare_binary_integerr4 ÚVARCHARÚbytesÚBLOBr ÚDECIMALÚfloatÚstructÚpackÚDOUBLEÚdatetimeÚdateÚprepare_binary_timestampÚ timedeltaÚtimeÚprepare_binary_timer! Ú __class__Ú__name__Úextendr ÚziprO rI rV r ÚQUERYr[ r\ r )rQ r r r r¬ r r§ rÇ Únamesr ÚvaluesÚ null_bitmapÚposÚ
|
attr_tuplero r ÚpackedÚ
|
field_typera ÚbitÚ_typer r Úresultr| r6 s rR r¡ zMySQLConnection.cmd_queryý s è ø ô %¤Ô+Ü%¤Ô%Ø Ü eÓ$Eð Ø'+Ô$ð )-¯ © ×(:Ñ(:¸iÒ(G$--×$Ò$ÈVÜØ× Ñ ×9Ò9¸d×>OÒ>OÜ MMØNÜ õ ð × Ñ ¤
|
× BÑ BÓ BØEØEØ"$FØ #¤# d×&7Ñ&7Ó"8¸1Ñ"<ÀÑ!BÑCKÜ#,¨T×->Ñ->Ó#?ó . 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Ñ"<Ô=Ü!*×!2Ñ!2JÜ ¤uÔ-ØMM¤&¬¨U«Ó"4°uÑ"<Ô=Ü!*§ ¡ JÜ ¤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Ø ×.Ñ.ØnnÜ OOØØ!-Ø"/ð %ó ÷ ð Ø ó ÷ Fð$ ùòC Lð øð ùô ò ØyyDÒ Ð%EÈÏÉÑ%Pð1ð ô $ GÓ,°#Ð5Ø ûð üs\ R3XÒ5 V> ÓBXÕAW Ö)WÖ* W Ö7WÖ8W Ö<X×W ×W × X×,W<×<XØXÚ
|
statementsc ó 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 |||¬« d{ ||« d{ | j rs| j! « d{ | j | j" j% |xs | j& « d{ ||« d{ | j rryy7 7 7 d7 *7 # t( t* f$ r}|d}~ww xY ww)ac 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 await cnx.cmd_query(statement, iterate=True):
|
if 'columns' in result:
|
columns = result['columns']
|
rows = await cnx.get_rows()
|
else:
|
# do something useful with INSERT result
|
r Nr r r r7 r´ )rO rµ rm r r« rp r rà rÎ r4 r¿ rI rV r rÐ r r rb r° rD r" r# )rQ rÛ r r r rÇ r r| s rR Úcmd_query_iterz MySQLConnection.cmd_query_iteru s è ø ð&' Ø!:: n°dÓ;LØ "JJ ¸Ó =MÜ [FÜ j¬)Ô4Ü j¬#Ô.Ø!+×!2Ñ!2°6Ó!:JÜ & zÓ 2
|
à×!Ñ!¤J×$FÑ$FÒFà f QiÔ(ð f QiÔ(à MM*Ô %Ü&MEà ×+Ñ+ØnnÜ OOØØ!-Ø"/ð %ó ÷ ð Ø ó ÷ ó ð ×(Ò(Ø×/Ñ/Ó1×1Ð1Ø × /Ñ /Ø ,,×+Ñ+¨LÒ,N¸D×<NÑ<NÓO×OØ Ø!ó ÷ ó ð ×(Õ(ðøð øð 2øàOøðùô
|
!Ô"3Ð4ò ØIûð üs GDF, Ä F"Ä F, ÄF$Ä&F, ÅF&Å;F, Å=F(Å> F, Æ F*Æ F, Æ GÆ"F, Æ$F, Æ&F, Æ(F, Æ*F, Æ,GÆ;F=Æ=GÇGÚ statement_idr c ó K |j dd« }|j dd« }| j j ||« }d| _ | j t
|
j |d||¬« d{ d| _ y7 w)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©rR r r T)rO r² Úmake_stmt_fetchrF rV r Ú
|
STMT_FETCH)rQ rÞ r r r r rÇ s rR Úcmd_stmt_fetchz MySQLConnection.cmd_stmt_fetch± s
è ø ð zz .°$Ó7 Ø
|
|
?°DÓ9 Ø ×/Ñ/° ¸dÓCØ "ÔØnnÜ × Ñ Ø Ø !Ø%Ø'ð ó
|
÷
|
ð
|
ð "Õð
|
ús A/B Á1A>Á2 B Ú statementc ó K |j dd« }|j dd« }| j t j |||¬« d{ }| j |« }g |d< g |d< |d dkD r»t d|d « D ]i }|d j | j j | j j |xs | j « d{ | j « « k | j | j j |xs | j « d{ « |d dkD r»t d|d « D ]i }|d j | j j | j j |xs | j « d{ | j « « k | j | j j |xs | j « d{ « |S 7 ¨7 "7 Ó7 c7 w)
|
zPrepare a MySQL statement.
|
|
This method will send the PREPARE command to MySQL together with the given
|
statement.
|
r Nr r´ r< Ú
|
parametersÚ
|
num_paramsr Ú num_columns)rO rV r Ú STMT_PREPARErL rB r» r² rC rb r° rD rE r )rQ rä r r r rÇ rÚ r~ s rR Úcmd_stmt_preparez MySQLConnection.cmd_stmt_prepareÆ sï è ø ð zz .°$Ó7 Ø
|
|
?°DÓ9 Ø~~Ü × "Ñ "Ø Ø%Ø'ð &ó
|
÷
|
ð ×'Ñ'¨Ó/à yÑØ !|Ñ Ø ,Ñ !Ò #Ü1f \Ñ 2Ó3ò Ø|Ñ$×+Ñ+ØNN×/Ñ/Ø "ll× /Ñ /° Ò0RÀ×@RÑ@RÓ S×SØ ×+Ñ+óõð ð × Ñ Øll×'Ñ'¨ Ò(J¸×8JÑ8JÓK×Kô ð -Ñ 1Ò $Ü1f ]Ñ 3Ó4ò ØyÑ!×(Ñ(ØNN×/Ñ/Ø "ll× /Ñ /° Ò0RÀ×@RÑ@RÓ S×SØ ×+Ñ+óõð ð × Ñ Øll×'Ñ'¨ Ò(J¸×8JÑ8JÓK×Kô ð ðC
|
ùð Tùð
|
Løð Tøð
|
Lús^ A HÁ G5ÁBHÃG8ÃAHÄ'G;Ä(A1HÆG=ÆAHÇ*G?Ç+ HÇ8HÇ;HÇ=HÇ?HÚdataræ c
|
ó K t |« }i }|j dd« }|j dd« }|rbt |« D ]T \ } }
|
t || t « sd} d|| j
|
v} | j || || ||¬« d{ | f|| < V | 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, j. | ||¬
|
« d{ } | j1 | « d{ }|S # t $ r Y Tw xY w7 <7 27 w) z#Execute a prepared MySQL statement.r Nr TÚbr´ r® r¯ )Úconverter_str_fallback)rÇ r r )ÚlistrO rº rm r Úmoderv Úcmd_stmt_send_long_dataÚ_query_attrs_supportedr¶ r· r¸ r¹ rp r rà r² Úmake_stmt_executer{ r§ Ú_converter_str_fallbackrV r Ú STMT_EXECUTErN )rQ rÞ rë ræ r r Úlong_data_usedr r Úparam_idr~ r Úexecute_packetrÇ rÚ s rR Úcmd_stmt_executez MySQLConnection.cmd_stmt_executeö sæ è ø ô *Ó%
|
ØØ zz .°$Ó7 Ø
|
|
?°DÓ9 á Ü (¨Ó 4ò 9 !Ü d 8n¬fÕ5Ø !Fð Ø!$¨D°©N×,?Ñ,?Ð!?ð ×6Ñ6Ø$Ø Ø XØ%1Ø&3ð 7ó ÷ ð ð 17¨yN 8Ò,ð 9ð ×*Ò*¨t×/@Ò/@Ü MMØNÜ õ ð × Ñ ¤
|
× BÑ BÒ BØ !^^× =Ñ =Ø ØÜjÓ!ØØ Ø Ø×!Ñ!Ø×,Ñ,ó Nð "^^× =Ñ =Ø ØÜjÓ!ØØ Ø Ø'+×'CÑ'Cð >ó Nð ~~Ü × "Ñ "Ø!Ø%Ø'ð &ó
|
÷
|
ð ×1Ñ1°&Ó9×9Ø øôW *ò Ú ð úðùðD
|
øð :úsa AGÁGÁ F7Á/ GÂ GÂ D GÆG
|
ÆGÆ0G Æ1GÆ7 GÇ GÇGÇGÇ
|
GÇ Gc óÖ K | j | j t j t |« |j dd« |j dd« ¬« d{ « y7 w)z}Reset data for prepared statement sent as long data.
|
|
The result is a dictionary with OK packet information.
|
r Nr r´ )r rV r Ú
|
STMT_RESETr3 rO ©rQ rÞ r s rR Úcmd_stmt_resetz MySQLConnection.cmd_stmt_reset7 s\ è ø ð
|
Ø..Ü×$Ñ$Ü,Ó'Ø #ZZ¨¸Ó =Ø $jj¨ ¸$Ó ?ð !ó ÷ õ
|
ð ús AA)Á A'Á
|
A)c
|
óº K | j t j t |« d|j dd« |j dd« ¬« d{ y7 w)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à )rV r Ú
|
STMT_CLOSEr3 rO rü s rR Úcmd_stmt_closez MySQLConnection.cmd_stmt_closeE sS è ø ð nnÜ × Ñ Ü lÓ #Ø !Ø N°DÓ9Ø ** _°dÓ;ð ó
|
÷
|
ò
|
ús AAÁAÁAÚoptionsc óV K |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« d { }|t j z r| j d« d { }|t j z r| j d« d { }|t j z r| j d« d { }|t j
|
z r| j d« d { }|t j z r4| j | j j dk rdnd « d { }|S 7 ý7 Ó7 ©7 7 U7 w)
|
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¶ )rQ r r] s rR Ú cmd_refreshzMySQLConnection.cmd_refreshS sr è ø àÜ × Ñ Ü× Ñ ñ ä×"Ñ"ñ #ô × Ñ ñ !ô ×"Ñ"ñ #ô
|
×#Ñ#ñ $ò
|
ô Ð =Ó>Ð >àØ ]×(Ñ(Ò (Ø Ð'9Ó:×:CØ ]×&Ñ&Ò &Ø |Ó4×4CØ ]×)Ñ)Ò )Ø ~Ó6×6CØ ]×'Ñ'Ò 'Ø Ð'UÓV×VCØ ]×)Ñ)Ò )Ø ~Ó6×6CØ ]×*Ñ*Ò *Ø à×$Ñ$×2Ñ2°ZÒ?ñ à$ó÷ Cð
|
ð! ;øà4øà6øàVøà6øðúsm B F)Â F Â +F)Ã F Ã +F)Ã7F!Ã8+F)Ä#F#Ä$+F)ÅF%ÅAF)ÆF'ÆF)Æ F)Æ!F)Æ#F)Æ%F)Æ'F)r÷ c
|
ó K d}d} |j |« }|r| j j |||« }| j t j
|
|d|j dd« |j dd« ¬« d{ |t |« z }|j |« }|r|S 7 (# t $ r} t d« | d} ~ ww xY ww) 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.
|
rY r Fr Nr )rÇ rR r r r )
|
r° r² Úprepare_stmt_send_long_datarV r ÚSTMT_SEND_LONG_DATArO r= rv r )
|
rQ rÞ r÷ rë r r[ Ú
|
total_sentr\ rÇ r| s
|
rR rñ z'MySQLConnection.cmd_stmt_send_long_datas sÝ è ø ð(
|
Ø
|
ð NØ))JÓ'CÙØ ×CÑCØ (¨Cóð nnÜ ×1Ñ1Ø!Ø$)Ø!'§¡¨N¸DÓ!AØ"(§*¡*¨_¸dÓ"Cð %ó ÷ ð ð c #hÑ&
|
Øii
|
Ó+ò ð Ððùô ò NÜ"Ð#CÓDÈ#Ð Mûð Nüs; CA7B* Á?B(Â %B* Â&CÂ(B* Â* CÂ3 B?Â?CÃCc ó& K | j « d{ | j j t j « } | j
|
j || j ¬« d{ |S 7 _7 # t $ r }Y d}~|S d}~ww xY ww)zClose the current connection with the server.
|
|
Send the QUIT command to the MySQL server, closing the current connection.
|
Nr ) r r² rU r ÚQUITrb rô r1 r# )rQ rÇ r~ s rR r~ zMySQLConnection.cmd_quit s è ø ð
|
×'Ñ'Ó)×)Ð)Ø ×,Ñ,¬Y¯^©^Ó<ð Ø,,×$Ñ$ V¸4×;NÑ;NÐ$ÓO× OÐ Oð ð *øð PùÜ ò Û Ø ûð üsE BA6-BÁ*A: Á/A8Á0A: Á4BÁ8A: Á: BÂBÂ BÂBÚ shutdown_typec óB K | j d« d{ y7 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.
|
ÚSHUTDOWNN)r¡ )rQ r s rR Ú cmd_shutdownz MySQLConnection.cmd_shutdownª s è ø ð nnZÓ(×(Ò(úr£ c ó K | j « d{ | j j t j « }| j
|
j |dd| j « d{ | j j | j
|
j | j « d{ « S 7 £7 L7 w)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.
|
Nr ) r r² rU r Ú
|
STATISTICSrb rô r1 Úparse_statisticsr° rD rÆ s rR Úcmd_statisticsz MySQLConnection.cmd_statistics² s è ø ð ×'Ñ'Ó)×)Ð)à ×,Ñ,¬Y×-AÑ-AÓBØll× Ñ ¨¨A¨t×/BÑ/BÓC×CÐCØ~~×.Ñ.Ø,,×#Ñ# D×$6Ñ$6Ó7× 7ó
|
ð
|
ð *øð Døà 7ús5 C B:AC Á/B<Á0AC Â1B>Â2 C Â<C Â>C Ú mysql_pidc ó| K t |t « s t d« | j d| « d{ S 7 w)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 N)rm r@ r* r¡ )rQ r s rR Úcmd_process_killz MySQLConnection.cmd_process_killÀ s: è ø ô )¤SÔ)Ü Ð 4Ó5Ð 5Ø^^ e¨I¨;Ð$7Ó8×8Ð8Ð8ús 3<µ:¶<c óz K | j | j t j « d{ « S 7 w)a- 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.
|
N)r rV r ÚDEBUGrP s rR Ú cmd_debugzMySQLConnection.cmd_debugÊ s, è ø ð × Ñ d§n¡n´Y·_±_Ó&E× EÓFÐFÐ Eúó .;°9± ;c óz K | j | j t j « d{ « S 7 w)zî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.
|
N)r rV r ÚPINGrP s rR rc zMySQLConnection.cmd_pingÔ s* è ø ð T§^¡^´I·N±NÓ%C× CÓDÐDÐ Cúr rÜ r r§ rÝ rÞ rß rÔ rÕ r× c ó K |Et |t « s t d« |dk r t d« t j |« | _ d| _ || _ || _ || _ || _
|
|| _ | j r || j k7 r| j | _ | j « d{ | j r t d« |r|| _ |
|
r|
|
| _ | | _ | j$ j' | j | j" | j d¬« | j$ j) | j* | j, | j | j | j | j | j. | j
|
j0 | j2 | j4 | j6 | j8 d | j: | j< ¬
|
« d{ } | j2 t> j@ z s|r| jC |« d{ | jE | « S 7 7 P7 w) 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.
|
Nzcharset must be an integerr z2charset should be either zero or a postive integerr7 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 )#rm r@ r* r= Ú get_by_idrº rJ rå ré rè rþ rÿ r Ú _compressr rù rü rú rö r÷ rý rb rN r ró rp rê r¿ r rD r1 r r r r ) rQ rÜ r rà r§ rÝ rÞ rß rÔ rÕ r× Ú ok_packets rR rh z MySQLConnection.cmd_change_userÝ sø è ø ð( Ð Ü g¤sÔ+Ü Ð!=Ó>Ð>Ø{Ü Ð!UÓVÐVÜ $× .Ñ .¨wÓ 7DMà ÔØ
|
Ø!Ø#Ø#Ø#à ??x¨4¯?©?Ò :Ø !__DNà×'Ñ'Ó)×)Ð)à >>Ü#Ð$SÓTÐ Tá Ø$3DÔ !Ù Ø&7DÔ #Ø#5Ô ð ×Ñ×0Ñ0à#'×#8Ñ#8Ø&*×&>Ñ&>Ø%)×%<Ñ%<ñð 1ô
|
ð "&×!4Ñ!4×!AÑ!AØ ØooØZZØnnØooØooØ^^ØMM×,Ñ,Ø ×+Ñ+Ø ×(Ñ(Ø ×)Ñ)Ø×-Ñ-Ø#'Ø ×+Ñ+Ø ×-Ñ-ð "Bó "
|
÷
|
ð$ ×"Ñ"¤Z×%?Ñ%?Ò?ÁXØ×"Ñ" 8Ó,× ,Ð ,ð yÓ)Ð)ðU *ùð(
|
øð& -ús7 B1H>Â3H7Â4D5H>Ç)H:Ç*7H>È!H<È"H>È:H>È<H>)rK N)NN)Nr NTr NN)FNN)Fr7 r )NNNNNNN)NFNNN)FFF)r7 )r r r rx )
|
Ú r' r' Nr' r' r' r' r' r' )PrÍ Ú
|
__module__Ú __qualname__Ú__doc__rJ r@ Ú__annotations__Úpropertyr rS r r r r- r¢ ri rj r¿ r, r r r+ r r9 r8 rI r rL r r r
|
r* rN r_ rµ rV r r- ra r` r rp rt rv r. Ú
|
disconnectr r; r> rj r. r r r¢ r¦ rg r r0 r¡ r rÝ rã r rê r r) rù rý r r8 r
|
rñ r~ r r/ r r r rc rh r rT rR r r w sý
Ù=àL#Óà ðx¨}ò ó ðó 2>óh:ð(+¨#ð +°*ó +ó?IóBO3ðb 3 ð 3¨<ó 3ð N¨3ð N°4ó Nð 4 %ð 4¨Mó 4ñ Ó ð '+Ø'+ñ aàðað smðað }ð að
|
|
ò aó !ðañF Ó ð '+Ø'+ñ 0;àð0;ð smð0;ð }ð 0;ð
|
|
ò 0;ó !ð0;ðd:¨ð :°$°s¸C°x±.ó :ñ Ó ð%,Øð%,à |U 3¨¨_Ñ(=¸}Ð#LÑ MÐMÑ Nò%,ó !ð%,ñN Ó ð %)Ø Ø"&Ø $Ø()Ø&*Ø'+ñ$Kàð$Kð 5/ð$Kð ð $Kð
|
ð $Kð ð $Kð #&ð$Kð smð$Kð }ð$Kð
|
)Ñ ò$Kó !ð$KñL Ó ð #(Ø&*Ø'+ñ 'àð'ð ð'ð smð 'ð
|
}ð 'ð
|
ò 'ó !ð'ðRB Tó Bð Dó ð 48Ø6:ñ/à c¨3 h¡ Ñ0ð/ð $ D¨¨c¨¡NÑ3ð/ð
|
ó /ðd HIñVØ ðVØ14ðVØADðVà óVó2ó" ð Jð $(Ø "Ø#'Ø<@Ø%)Ø&*Ø'+ñPà4.ðPð d^ðPð 4.ð Pð
|
tÐ$7Ñ 8Ñ9ð Pð TNð Pð smðPð }ðPð
|
óPñd Ó ð Ø37Ø "ñ àðð $Ñ/Ñ0ðð d^ð ð
|
ð ð
|
xÑ (¨=Ñ"9Ð9Ñ :ò ó !ðñ0 Ó ð $Ø Ø37Ø "Ø ñ @à}ð@ð ð@ð $Ñ/Ñ0ð @ð
|
d^ð @ð ð @ð ð@ð
|
tG}h }Ñ 5Ð5Ñ 6ò@ó !ð@óD,ó.ð ¨Dó ð
|
¨#ð
|
°,ó
|
ð Ø Ø #ñ vàðvð ðvð ð vð
|
ð vð ð vð
|
óvðp:à ð:ð ð:ð
|
|
DÐ(Ñ )ó :ðz ./ñ"Ø ð"Ø'*ð"Ø:=ð"à ó"ñ* Ó ð-àð-ð ð-ð
|
eC oÑ!6Ð 6Ñ7Ð7Ñ 8ò -ó !ð-ðd .0Ø$&Øñ ?àð?ð Ð)Ñ*ð?ð SMð ?ð
|
ð ?ð ð ?ð
|
|U 3¨¨_Ñ(=¸}Ð#LÑ MÐMÑ Nó?ðB
|
°ð
|
Àð
|
Èó
|
ð
|
°ð
|
Àð
|
Èó
|
ñ Ó!ð ¨ð ° ò ó "ð ð>(àð(ð ð(ð ð (ð
|
ð (ð
|
ó (ðT ó ñ)°¸± ð )Èó )ð
|
oó
|
ð 9°ð 9¸ ó 9ðG ó GðE ó Eð ØØØ!%ØØØØ !Ø"$Ø!#ñO*àðO*ð ðO*ð ð O*ð
|
# ð O*ð ð O*ð ðO*ð ðO*ð ðO*ð ðO*ð ðO*ð
|
,Ñ ôO*rT )\r* Ú__all__re ry rÆ ræ r` r rà r· Údecimalr Úior Útypingr r r r r
|
r r r r r r r' r Ú
|
_scriptingr Ú constantsr r r r r r Úerrorsr r r r r r r r! r" r# r$ r¥ r% r& r' r( r r) r* r+ r, r- r. r/ r0 Úutilsr1 r2 r3 r4 r5 r6 Ú _decoratingr8 r9 Ú abstractsr: r; r< r= rj r> r? r@ rA rB rC rD rE rF ÚnetworkrG rH r r rT rR ú<module>r9 s ðñ> Kà Ð
|
ã Û Û Û Û Û Û Û å Ý ÷ ÷ ÷ ñ õ Ý 3÷÷ ÷ ÷ ÷ ñ ÷ NÓ M÷ ÷ ó ÷÷ ÷ Oß OÑ OÝ ÷ ÷ ó õ ß 4ôu*Ð-õ u*rT
|
