Ë
|
WñúhÍ ã óv d Z ddlmZ ddlmZ g d¢ZddlZddlZddlZddl Z ddl
|
m Z m Z ddl mZmZ ddlmZ dd lmZ dd
|
lmZmZmZmZmZmZmZm Z m Z m Z m Z m Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z( d d l)m*Z* d d l+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3 d dl4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;m<Z<m=Z= d dl>m?Z?m@Z@ d dlAmBZBmCZCmDZDmEZEmFZF d dlGmHZHmIZI d dlmJZJmKZKmLZLmMZMmNZNmOZOmPZPmQZQmRZRmSZSmTZTmUZU d dlVmWZWmXZX ddlYmZZZ ddl[m\Z\m[Z[ ddl]m^Z^ erddl_m`Z`maZa ejÄ dk( Zce G d d« « Zd G d d e « Ze G d d e « Zf G d d!eW« Zgy)"z+Module gathering all abstract base classes.é )Ú annotations)Úread_option_files)ÚMySQLConnectionAbstractÚMySQLCursorAbstractÚ
|
ServerInfoN)ÚABCÚabstractmethod)Ú dataclassÚfield)Ú signature)Ú TracebackType)Ú TYPE_CHECKINGÚAnyÚAsyncGeneratorÚ AwaitableÚBinaryIOÚCallableÚClassVarÚDequeÚDictÚ GeneratorÚIteratorÚListÚMappingÚNoReturnÚOptionalÚSequenceÚTupleÚTypeÚUnionÚcasté )Ú
|
deprecated)ÚDUPLICATED_IN_LIST_ERRORÚKRB_SERVICE_PRINCIPAL_ERRORÚMYSQL_PY_TYPESÚOPENID_TOKEN_FILE_ERRORÚTLS_V1_3_SUPPORTEDÚTLS_VER_NO_SUPPORTEDÚTLS_VERSION_ERRORÚ TLS_VERSION_UNACCEPTABLE_ERROR) Ú CONN_ATTRS_DNÚDEFAULT_CONFIGURATIONÚDEPRECATED_METHOD_WARNINGÚMYSQL_DEFAULT_CHARSET_ID_57ÚMYSQL_DEFAULT_CHARSET_ID_80ÚOPENSSL_CS_NAMESÚTLS_CIPHER_SUITESÚ TLS_VERSIONSÚ
|
ClientFlag)ÚMySQLConverterÚMySQLConverterBase)ÚErrorÚInterfaceErrorÚ InternalErrorÚNotSupportedErrorÚProgrammingError)Ú UNACCEPTABLE_TLS_CIPHERSUITESÚUNACCEPTABLE_TLS_VERSIONS) ÚBinaryProtocolTypeÚDescriptionTypeÚ EofPacketTypeÚ HandShakeTypeÚMySQLScriptPartitionÚ OkPacketTypeÚParamsSequenceTypeÚ
|
ResultTypeÚRowTypeÚStatsPacketTypeÚ
|
StrOrBytesÚ WarningType)ÚGenericWrapperÚ import_objecté )ÚMySQLAuthenticator)ÚCharsetÚcharsets)Ú MySQLProtocol)ÚMySQLTcpSocketÚMySQLUnixSocketÚposixc ó e Zd ZU dZded< ded< ed¬« Zded < ded
|
< ded < ded < ded < ded< ded< dZded< ddZy)r zStores the server information retrieved on the handshake.
|
|
Also parses and validates the server version, storing it as a tuple.
|
ÚintÚprotocolÚstrÚversionF)ÚinitzTuple[int, ...]Ú version_tupleÚ thread_idÚcharsetÚ status_flagsÚ auth_pluginÚbytesÚ auth_dataÚ capabilitiesÚboolÚquery_attrs_is_supportedc ó t j d« }|j | j « }|s t d« t d |j « dd D « « }|dk rt d| j d« || _ y )
|
zParse and validate server version.
|
|
Raises:
|
InterfaceError: If parsing fails or MySQL version is not supported.
|
z$^(\d{1,2})\.(\d{1,2})\.(\d{1,3})(.*)z Failed parsing MySQL versionc 3 ó2 K | ] }t |« y w©N)rU )Ú.0Úvs úPH:\Change_password\venv_build\Lib\site-packages\mysql/connector/aio/abstracts.pyú <genexpr>z+ServerInfo.__post_init__.<locals>.<genexpr> s è ø Ò< 1AÑ<ùs r é )é rL zMySQL Version 'z' is not supportedN)ÚreÚcompileÚmatchrX r8 ÚtupleÚgroupsrZ )ÚselfÚ
|
version_rero rX s ri Ú __post_init__zServerInfo.__post_init__ s| ô ZZÐ GÓH
|
Ø× Ñ § ¡ Ó.ÙÜ Ð!?Ó@Ð @äÑ<¨¯ © «°q¸Ð(;Ô<Ó<Ø VÒ Ü ?°4·<±<°.Ð@RÐ!SÓTÐ TØ $Õó N©ÚreturnÚNone) Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__Ú__annotations__r rZ rc rt © ru ri r r sT
ñð
|
MØ LÙ%*°Ô%6M?Ó6ØNØ LØÓØÓØÓØÓØ%*Ð dÓ*ô%ru r c 0 ó e Zd ZU dZddddddddddddddddi dddddddddded ed dded ed
|
ed dd ddddded dddddd/ ddZddZ d ddZddZddZ ddZ
|
ddZ e d dd« Z eedd« « Zedd« Zedd« Zedd « Zedd « Zedd « Zej, dd « Zedd « Zej, dd!« Zedd"« Zej, dd#« Zdd$Zdd%Zedd&« Zej, dd'« Zedd(« Z e j, dd)« Z edd*« Z edd+« Z edd,« Z edd-« Z edd.« Z!edd/« Z"e"j, dd0« Z"dd1Z#dd2Z$edd3« Z%e%j, dd4« Z%dd5Z&dd6Z'edd7« Z(e(j, dd8« Z(dd9Z)dd:Z*edd;« Z+e+j, dd<« Z+edd=« Z,e,j, dd>« Z,edd?« Z-e-j, dd@« Z-eddA« Z.eddB« Z/eddC« Z0eddD« Z1e1j, ddE« Z1eddF« Z2eddG« Z3eddH« Z4ddIZ5 d d dJZ6d¡dKZ7d¢dLZ8ddMZ9 e: e;jx dN¬O« « d£dP« Z= e: e;jx dQ¬O« « ddR« Z>ed£dS« Z?eddT« Z@eddU« ZAeddV« ZBe d¤ d¥dW« ZC e: e;jx d¬O« « d¦dX« ZDeddY« ZEeEj, d§dZ« ZE e: e;jx d¬O« « d¨d[« ZFed©d\« ZGeGj, d¨d]« ZGedd^« ZHeHj, dd_« ZHdªd`ZId«daZJddbZKddcZLdddZMd¬deZNddfZOddgZPeddh« ZQd®d¯diZRd°djZSeddk« ZTeTZUdleVdm< e d± d²dn« ZWe d³ d´do« ZXe dµ d¶dp« ZYeddq« ZZeddr« Z[ d³ d·dsZ\e d d¸dt« Z]eddu« Z^ed¹dv« Z_e dº d»dw« Z` d¼dxZae d½ d¾dy« Zbe d¿dz« Zce dÀ dÁd{« Zde dÂd|« ZeedÂd}« ZfedÃd~« Zg dÄdZhedÅd« ZiedÆdÇd« ZjedÈd« ZkedÉd« ZledÊd« ZmedËd
« Zne dÌ dÍd« Zoy)Îr z'Defines the MySQL connection interface.NÚ z 127.0.0.1iê FÚallow_local_infileÚallow_local_infile_in_pathÚconnect_timeoutÚ read_timeoutÚ write_timeoutTÚ ssl_disabled)/ÚuserÚpasswordÚhostÚportÚdatabaseÚ password1Ú password2Ú password3r\ Ú collationr^ Ú client_flagsÚcompressÚconsume_resultsÚ
|
autocommitÚ time_zoneÚ
|
conn_attrsÚsql_modeÚ init_commandÚ get_warningsÚraise_on_warningsÚbufferedÚrawÚkerberos_auth_modeÚkrb_service_principalÚopenid_token_fileÚwebauthn_callbackr r Úconverter_classÚconverter_str_fallbackÚconnection_timeoutr r
Ú unix_socketÚ use_unicodeÚssl_caÚssl_certÚssl_keyÚssl_verify_certÚssl_verify_identityr Ú tls_versionsÚtls_ciphersuitesÚloopÚoci_config_fileÚoci_config_profiler r c / óz d | _ || _ || _ || _ || _ || _ || _ || _ || _ |#| _ | | _
|
|!| _ |"| _ || _ | | _ || _ || _ || _ || _ || _ t) « | _ d | _ | | _ |
|
| _ d| _ |*| _ |%| _ |&| _ |'| _ |(| _ |)| _ |+| _ |,| _! | | _" d | _# d | _$ d | _% |-xs tM jN « | _( | xs tS jT « | _+ d | _, t[ j\ « | _/ i | _0 d| _1 g | _2 tg « | _4 | xs tj | _6 | | _7 || _8 || _9 || _: | | _; | | _< || _= || _> || _? || _@ |$| _A d| _B d| _C d| _D |.| _E |/| _F || _G d | _H d | _I d | _J | j « y )NF)LÚ!_MySQLConnectionAbstract__charsetÚ_userÚ _passwordÚ_hostÚ_portÚ _databaseÚ
|
_password1Ú
|
_password2Ú
|
_password3Ú _unix_socketÚ_connection_timeoutÚ _read_timeoutÚ_write_timeoutÚ_connection_attrsÚ _compressÚ_consume_resultsÚ _autocommitÚ
|
_time_zoneÚ _sql_modeÚ _init_commandrP Ú _protocolÚ_socketÚ _charset_nameÚ_charset_collationÚ _ssl_activeÚ _ssl_disabledÚ_ssl_caÚ _ssl_certÚ_ssl_keyÚ_ssl_verify_certÚ_ssl_verify_identityÚ _tls_versionsÚ_tls_ciphersuitesÚ _auth_pluginÚ_auth_plugin_classÚ_pool_config_versionÚ
|
_handshakeÚasyncioÚget_event_loopÚ_loopr4 Ú get_defaultÚ _client_flagsÚ _server_infoÚweakrefÚWeakSetÚ_cursorsÚ _query_attrsÚ_query_attrs_supportedÚ _columns_descrM Ú_authenticatorr5 Ú_converter_classÚ_converter_str_fallbackÚ_kerberos_auth_modeÚ_krb_service_principalÚ_openid_token_fileÚ_allow_local_infileÚ_allow_local_infile_in_pathÚ _get_warningsr Ú _bufferedÚ_rawÚ _use_unicodeÚ_have_next_resultÚ_unread_resultÚ_in_transactionÚ_oci_config_fileÚ_oci_config_profileÚ_webauthn_callbackÚ converterÚ_local_infile_filenamesÚ_queryÚ _validate_connection_options)0rr r r r r r r r r r\ r r^ r r r r r r r r r r r r r r r r r r r r¡ r¢ r r
r£ r¤ r¥ r¦ r§ r¨ r© r rª r« r¬ r r® s0 ri Ú__init__z MySQLConnectionAbstract.__init__§ s] ðl -1ð ð
|
Ø &Ø
|
Ø
|
Ø &Ø (Ø (Ø (Ø!,ÔØ(:Ô Ø,8ÔØ-:ÔØ1;Ô Ø 'Ø&5Ô Ø!+ÔØ)2Ø(0Ø,8ÔÜ(5«ØIM Ø,3ÔØCØ1:Ô Ø@Ø!&ÔØ#/ÔØ&, Ø(0Ø'. Ø0?Ô Ø4GÔ!Ø2>ÔØ6FÔ Ø+6ÔØ15Ô Ø)-Ô!Ø37à Ò ,G×*Ñ*Ó,ð
|
ð #/Ò"J´*×2HÑ2HÓ2JÔØ26ÔÜ)0¯ © Ó): Ø;=ÔØ+0Ô#Ø46ÔÜ2DÓ2FÔØ6EÒ6WÌ Ô Ø-CÔ$Ø2DÔ Ø5JÔ#Ø1BÔ Ø);Ô Ø:TÔ(Ø#/ÔØ'8Ô Ø 'Ø Ø"-ÔØ',Ô Ø$)ÔØ%*Ô Ø/>Ô Ø-Ø2DÔ Øà ð Ô ð 48à=AÔ$ð (ð (, Ø(à ×)Ñ)Õ+ru c ób K | j « s| j « d { | S 7 wrf )Úis_socket_connectedÚconnect©rr s ri Ú
|
__aenter__z"MySQLConnectionAbstract.__aenter__6 s+ è ø Ø×'Ñ'Ô)Ø,,.× Ð Ø ð !ús $/¦-§/c ó@ K | j « d { y 7 wrf ©Úclose©rr Úexc_typeÚ exc_valueÚ tracebacks ri Ú __aexit__z!MySQLConnectionAbstract.__aexit__; ó è ø ð jjl×Òúó c óÜ | j r | j j « | _ | j rt j
|
g| _ | j rt j j | j « }|r>t j j |« r t j j |« r t j j |« r t d« | j s | j rt j g| _ nt j g| _ | j dk( rt# d| j d« | j$ rt j& dk( rd| _ | j( r4| j d k( r t# d
|
« | j d k( r t# d « t+ | j, t. « s t# d « t1 | j2 | j4 | j6 g« rt9 | j6 | j4 g« s t d« | j6 du | j4 du k7 r t d« | j: | j= « | j> | jA « t+ | jB tD « s t# d« | jB jG « D ]µ \ }}|tH v rt+ |tJ « s t# d| d| jB d« tM |« dkD rt# d| d« |jO d« r t# d« t+ |tJ « st# d| d| d« tM |« dkD s¥t# d| d| d « | jP t jR z r| jU « | jV rt+ | jV tJ « s t# d « | jV jY « }|d k( r&t j& d k7 r t# d « d!| _- n|d"k( rd#| _- n t# d$« | j\ rt+ | j\ tJ « s t# t_ j` d%¬&« « | j\ d'k( r t# t_ j` d(¬&« « d)| j\ vr t# t_ j` d*¬&« « | jb r | je d+| jb d,« | jf r©t+ | jf tJ « s t# ti j` d%¬&« « | jf d'k( r t# ti j` d-¬&« « t j j | jf « st# d.| jf d/« | jj 4t+ | jj t. « r| jj d0k r t# d1« | jl 5t+ | jl t. « r| jl d0k r t# d2« yy# t $ r}t d« |d}~ww xY w)3z Validate connection options.z'user' must be a stringNz.allow_local_infile_in_path must be a directoryÚ authentication_webauthn_clientú'z5' cannot be used as the default authentication pluginrS TÚmysql_clear_passwordzFClear password authentication is not supported over insecure channelsÚ$authentication_openid_connect_clientzEOpenID Connect authentication is not supported over insecure channelsz'TCP/IP port number should be an integerz:ssl_key and ssl_cert need to be both specified, or neitherz4ssl_key and ssl_cert need to be both set, or neitherz conn_attrs must be of type dictz+Attribute name should be a string, found: 'z' in 'é zAttribute name 'z"' exceeds 32 characters limit sizeÚ_zNKey names in connection attributes cannot start with '_', found: '{attr_name}'z Attribute 'z
|
' value: 'z' must be a string typei z$' exceeds 1024 characters limit sizez('kerberos_auth_mode' must be of type strÚsspiÚntz6'kerberos_auth_mode=SSPI' is only available on WindowsÚMySQLSSPIKerberosAuthPluginÚgssapiÚMySQLKerberosAuthPluginz@Invalid 'kerberos_auth_mode' mode. Please use 'SSPI' or 'GSSAPI'zis not a string)Úerrorr zcan not be an empty stringú/zis incorrectly formattedÚwebauth_callbackrL zcannot be an empty stringz
|
The path 'z1' provided via 'openid_token_file' does not existr z.Option read_timeout must be a positive integerz/Option write_timeout must be a positive integer)7r± ÚstripÚAttributeErrorr¾ r4 ÚCOMPRESSr rè ÚosÚpathÚabspathÚexistsÚisdirÚislinkrç Ú LOCAL_FILESrÑ r8 r¹ ÚnamerÉ Ú
|
isinstancer´ rU ÚanyrÊ rË rÌ ÚallrÏ Ú_validate_tls_versionsrÐ Ú_validate_tls_ciphersuitesr½ ÚdictÚitemsr, rW ÚlenÚ
|
startswithrÙ Ú CONNECT_ARGSÚ_add_default_conn_attrsrä ÚlowerrÒ rå r% Úformatrò Ú_validate_callableræ r' r» r¼ )rr ÚerrÚinfile_in_pathÚ attr_nameÚ
|
attr_valuer s ri rö z4MySQLConnectionAbstract._validate_connection_optionsC sô à ::ð IØ !ZZ× -Ñ -Ó /
|
ð >>Ü!+×!4Ñ!4Ð 5DÔ à × +Ò +Ü WW__¨T×-MÑ-MÓ NNá ÜGGNN >Ô2Ü nÔ5Ü77>> .Ô1ä$Ð%UÓVÐVØ × #Ò # t×'GÒ'GÜ!+×!7Ñ!7Ð 8DÕ ä",×"8Ñ"8Ð!8Ð 9DÔ ð × Ñ Ð @Ò @Ü ØD×%Ñ%Ð&ð 'ð óð ð × Ò ¤§¡¨GÒ!3Ø!%DÔ à × Ò Ø× Ñ Ð$:Ò:Ü$ð óð ð × Ñ Ð$JÒJÜ$Ø[óð ô $**¤cÔ*Ü Ð!JÓKÐ Kä dnn¨d¯m©mÐ<Ô =ä t§~¡~Ð6Ô7Ü$ØPóð ð Ð%¨4¯>©>¸TÐ+AÒBÜ$ØJóð ð ×!Ñ!Ð-Ø×+Ñ+Ô-à×%Ñ%Ð1Ø×/Ñ/Ô1ä$×0Ñ0´$Ô7Ü Ð!BÓCÐ Cà%)×%;Ñ%;×%AÑ%AÓ%Cò Ñ !IzØMÑ)Øä i¬Ô-Ü$ðØ!{ &¨×)?Ñ)?Ð(@ÀðCóð ô
|
9~ Ò"Ü$Ø& y kÐ1SÐTóð ð ×#Ñ# CÔ(Ü$ð0óð ô
|
j¬#Ô.Ü$Ø! ) ¨J°z°lð C'ð 'óð ô
|
: Ó%Ü$Ø! ) ¨J°z°lð C9ð 9óð ð9 ðB × Ñ ¤
|
× 7Ñ 7Ò 7Ø × (Ñ (Ô *à × #Ò #Ü d× 6Ñ 6¼Ô<Ü$Ð%OÓPÐPØ!%×!9Ñ!9×!?Ñ!?Ó!AÐ Ø! VÒ+Ü77d?Ü(ØPóð ð +HÕ'Ø# xÒ/Ø*CÕ'ä$ØVóð ð × &Ò &Ü d× 9Ñ 9¼3Ô?Ü$Ü/×6Ñ6Ð=NÔOóð ð ×*Ñ*¨bÒ0Ü$Ü/×6Ñ6Ø :ôóð ð
|
$×5Ñ5Ñ5Ü$Ü/×6Ñ6Ð=WÔXóð ð × "Ò "Ø × #Ñ #Ð$6¸×8OÑ8OÐQRÔ Sà × "Ò "Ü d× 5Ñ 5´sÔ;Ü$Ü+×2Ñ2Ð9JÔKóð ð ×&Ñ&¨"Ò,Ü$Ü+×2Ñ2Ð9TÔUóð ô 77>> $×"9Ñ"9Ô:Ü$Ø ×!8Ñ!8Ð 9ð :%ð %óð ð × Ñ Ð )Ü d× 0Ñ 0´#Ô6¸$×:LÑ:LÈqÒ:PÜ$Ð%UÓVÐVØ × Ñ Ð *Ü d× 1Ñ 1´3Ô7¸4×;NÑ;NÐQRÒ;RÜ$Ð%VÓWÐWð <Sð +øôu "ò IÜ$Ð%>Ó?ÀSÐHûð Iús Y Ù Y+Ù Y&Ù&Y+c ó |j « }g d¢}|D ] \ }} ||vr|| ||< ||= t d i |¤}|j dd« | _ |j dd« | _ |j dt j « « | _ |j dt « | _
|
|j « D ]0 \ }} t | d
|
|z } t | ||j « « 2 | j! « y # t $ r Y ôw xY w# t $ r t d| d« d w xY w# t $ r t | ||« Y w xY w) an Internal utility to set or update the connection options.
|
|
Args:
|
**kwargs: For a complete list of possible arguments, see [1].
|
|
Raises:
|
AttributeError: When provided unsupported connection arguments.
|
|
References:
|
[1]: https://dev.mysql.com/doc/connector-python/en/connector-python-connectargs.html
|
))Údbr )Úusernamer )Úpasswdr )r r¢ )Úread_default_fileÚ option_filesr Fr r r zUnsupported argument 'r Nr r~ )ÚcopyÚKeyErrorr Úpopr r r4 rØ r r5 r r' r- r Úsetattrr rö ) rr ÚkwargsÚconfigÚ
|
compat_mapÚcompatÚ translateÚkeyÚvalueÚ attributes ri Ú_set_connection_optionsz/MySQLConnectionAbstract._set_connection_optionsæ sh ð ò
|
|
ð ",ò Ñ FIð Ø FÑ*Ø(.¨v©F9Ñ%Ø6Nð ô #Ñ, VÑ,ð #JJ ~°uÓ =ÔØ!'§¡Ð,?ÀÓ!GÔ Ø "JJ ~´z×7MÑ7MÓ7OÓ PÔØ %zzÐ*;¼^Ó LÔ ð !,,.ò 0JCð PÜ% cÒ*ð c Ið 0Üi¨¯©« Õ7ð 0ð ×)Ñ)Õ+øô3 ò Ùð ûô ò PÜ$Ð'=¸c¸UÀ!Ð%DÓEÈ4ÐOð Pûô
|
"ò 0Üi¨Ö/ð 0ús/ D Ã DÃD,Ä D Ä D ÄD)Ä,EÅEc óÀ g }| j }t |t « r|j d« r|j d« st d| d« |dd j d« }|s t d« |D ]4 }|j « j « }|s$|j |« 6 n8t |t t f« r|D cg c] }|s| }}nt d | d« | j t d
|
d
|
n| j d
|
d
|
}|j d ¬ « |d }g g g}i }g } t d
|
t j |« dz D ]2 }
|
|j! t" |
|
« | j% t& |
|
« 4 |D ]µ } d| v r9| | v r5| t& d v r|d j | « +|d j | « @| |v rd|| } | |v r t t) j* d| ¬« « | t" d v r|d j || « |d j || « ¨t d| d« |d s|d s t d« |d D ]* } | t, d j/ « v s t1 d| d« |d D ]* } | t, d j/ « v s t1 d| d« dj3 |d « dj3 |d « g| _ y
|
c c}w )z&Validates the tls_ciphersuites option.ú[ú]z)tls_ciphersuites must be a list, found: 'r rL éÿÿÿÿú,z6No valid cipher suite found in 'tls_ciphersuites' listzItls_ciphersuites should be a list with one or more ciphersuites. Found: 'NT)Úreverser ú-úTLSv1.3r« ©ÚlistrC z The value 'z1' in tls_ciphersuites is not a valid cipher suitez:No valid cipher suite found in the 'tls_ciphersuites' listzTLSv1.2zCipher z( when used with TLSv1.2 is unacceptable.z( when used with TLSv1.3 is unacceptable.ú:)rÐ r! rW r) Úendswithr Úsplitr ÚupperÚappendrO ÚsetrÏ r3 ÚsortÚindexÚupdater2 Úextendr1 r$ r- r< Úvaluesr: Újoin)rr r« Útls_csÚtls_cssÚ_tls_csrª Ú newer_tls_verÚtranslated_namesÚiani_cipher_suites_namesÚossl_cipher_suites_namesÚtls_verr Útranslated_nameÚcipher_as_ossls ri r% z2MySQLConnectionAbstract._validate_tls_ciphersuites s{ à ÐØ×'Ñ'ä fcÔ "Ø×%Ñ% cÔ*¨v¯©¸sÔ/CÜ$Ø?À¸xÀqÐIóð ð Qrl×(Ñ(¨Ó-GÙÜ$ØLóð ð #ò 5Ø ,,.×.Ñ.Ó0ÚØ$×+Ñ+¨GÕ4ñ 5ô
|
¤¤s Ô ,Ø5;Ö F¨6ºv¢Ð FÐ Ñ Fä ð)Ø)/¨°ð3óð ð $× 1Ñ 1Ð 9LO¸t×?QÑ?QÑRSÐ?Tð ð ×Ñ $ÐÔ'Ø$ Q ð .0°¨HÐØ#%Ð Ø.0Ð ô $Ð$K¤l×&8Ñ&8¸ Ó&GÈ!Ñ&KÐLò GGØ $× +Ñ +Ô,=¸gÑ,FÔ GØ $× +Ñ +Ô,<¸WÑ,EÕ Fð Gð %ò DØd{tÐ'?Ñ ?ØÔ+¨IÑ6Ñ6Ø$ QÑ'×.Ñ.¨tÕ4à$ QÑ'×.Ñ.¨tÕ4ØÐ1Ñ1Ø":¸4Ñ"@Ø"Ð&6Ñ6Ü(Ü0×7Ñ7Ø!3¸?ôóð ð
|
Ô,¨YÑ7Ñ7Ø$ QÑ'×.Ñ.Ð/GÈÑ/MÕNà$ QÑ'×.Ñ.Ð/GÈÑ/MÕNä$Ø! $ ð (#ð #óð ð' ð. Ò"Ð+;¸AÒ+>Ü ØLóð ð
|
/¨qÑ 1ò NØ Ô!>¸yÑ!I×!PÑ!PÓ!RÒRÜ'Ø nÐ -Ð-UÐVóð ð ð
|
/¨qÑ 1ò NØ Ô!>¸yÑ!I×!PÑ!PÓ!RÒRÜ'Ø nÐ -Ð-UÐVóð ð ð HHÐ% aÑ(Ó )Ø HHÐ% aÑ(Ó )ð"
|
Õ ùòG Gs ÃKÃ Kc óÞ g }| j }t |t « rÆ|j d« r|j d« st d| d« |dd j d« }|D ]M }|j « }|dk( r||v r t t j d |¬
|
« « |j |« O |d gk( rÑt sËt t j |t « « t |t « rJ|s t d « |D ]7 }||v r t t j d |¬
|
« « |j |« 9 nNt |t « r|D ] }|j |« n%t d dj! t « d| d« |s t d« g }g }g }|D ]F }|t v r|j |« |t" v r|j |« 6|j |« H |r7|d gk( r)t s#t% t j |t « « || _ y|r#t% t' j |t « « |r#t t) j t « « y)z"Validates the tls_versions option.rG rH z%tls_versions must be a list, found: 'r rL rI rJ r rª rN rM zJAt least one TLS protocol version must be specified in 'tls_versions' listz>tls_versions should be a list with one or more of versions in z, z
|
. found: 'zdAt least one TLS protocol version must be specified in 'tls_versions' list when this option is givenN)rÏ r! rW r) rQ r rR r r$ r- rT r( r) r3 rO rU r[ r= r: r+ r* )rr rª Ú tls_versionÚtls_versrc Úuse_tls_versionsÚunacceptable_tls_versionsÚinvalid_tls_versionss ri r$ z.MySQLConnectionAbstract._validate_tls_versionsy s« à Ø×(Ñ( ä k¤3Ô 'Ø ×*Ñ*¨3Ô/°K×4HÑ4HÈÔ4MÜ$Ø;¸K¸=ÈÐJóð ð # 1 RÐ(×.Ñ.¨sÓ3HØ#ò
|
1Ø %mmo Ø "Ò$Ø Ø ,Ñ.Ü(Ü0×7Ñ7Ø!/°{ôóð ð
|
×#Ñ# KÕ0ð
|
1ð I;Ò&Õ/AÜ$Ü(×/Ñ/° ¼\ÓJóð ô ¤TÔ *Ù Ü$ð*óð ð 'ò -ØlÑ*Ü(Ü0×7Ñ7Ø!/°wôóð ð
|
×#Ñ# GÕ,ñ -ô ¤SÔ )Ø&ò -Ø ×#Ñ# GÕ,ñ -ô !ðØii¤ Ó-Ð.¨j¸ ¸ÀaðIóð ñ
|
Ü ðCóð ð
|
ÐØ$&Ð!Ø !Ð Ø#ò 5GØ,Ñ&Ø ×'Ñ'¨Ô0ØÔ3Ñ3Ø)×0Ñ0°Õ9à$×+Ñ+¨GÕ4ð 5ñ Ø I ;Ò.Õ7IÜ'Ü(×/Ñ/° ¼\ÓJóð ð "2DÕ Ù &Ü#Ü.×5Ñ5Ø-¬|óóð ñ
|
"Ü Ô!2×!9Ñ!9¸'Ä<Ó!PÓQÐ Qð "ru c ó t |t « r t |« }t |« st d| d« t t |« j « }||k7 rt d| d| d| « y# t $ r}t | « |d}~ww xY w)aø Validates if it's a Python callable.
|
|
Args:
|
option_name (str): Connection option name.
|
callback (str or callable): The fully qualified path to the callable or
|
a callable.
|
num_args (int): Number of positional arguments allowed.
|
|
Raises:
|
ProgrammingError: If `callback` is not valid or wrong number of positional
|
arguments.
|
|
.. versionadded:: 8.2.0
|
NzExpected a callable for 'r z ' requires z4 positional argument, but the callback provided has ) r! rW rK Ú
|
ValueErrorr; Úcallabler( r Ú
|
parameters)Ú option_nameÚcallbackÚnum_argsr/ Ú
|
num_paramss ri r. z*MySQLConnectionAbstract._validate_callableÊ sª ô$ h¤Ô $ð :Ü(¨Ó2ô Ô!Ü"Ð%>¸{¸mÈ1Ð#MÓNÐ Nô 8Ó,×7Ñ7Ó8
|
Ø Ò !Ü"ØK= ¨H¨:ð 6)Ø)3¨ ð6óð ð "øô ò :Ü&¨#¨Ó0°cÐ9ûð :ús A/ Á/ B
|
Á8 BÂB
|
c ó y)zMySQL connection ID.Nr~ rû s ri Ú connection_idz%MySQLConnectionAbstract.connection_idí ó ru c ó | j S )z$User used while connecting to MySQL.)r± rû s ri r z MySQLConnectionAbstract.userò ó ð zzÐru c ó | j S )z MySQL server IP address or name.)r³ rû s ri Ú server_hostz#MySQLConnectionAbstract.server_host÷ rx ru c ó | j S )zMySQL server TCP/IP port.)r´ rû s ri Ú server_portz#MySQLConnectionAbstract.server_portü rx ru c ó | j S )z MySQL Unix socket file location.)r¹ rû s ri r£ z#MySQLConnectionAbstract.unix_socket ó ð × Ñ Ð ru c ó t d« )úGet the current database.zoThe use of async properties are not supported by Python. Use `await get_database()` to get the database instead©r; rû s ri r z MySQLConnectionAbstract.database s ô ð Eó
|
ð
|
ru c ó t d« )úSet the current database.zsThe use of async properties are not supported by Python. Use `await set_database(name)` to set the database insteadr ©rr rC s ri r z MySQLConnectionAbstract.database ó ô ð Ió
|
ð
|
ru c ó | j S )a¸
|
Gets the connection context's timeout in seconds for each attempt
|
to read any data from the server.
|
|
`read_timeout` is number of seconds upto which the connector should wait
|
for the server to reply back before raising an ReadTimeoutError. We can set
|
this option to None, which would signal the connector to wait indefinitely
|
till the read operation is completed or stopped abruptly.
|
©r» rû s ri r z$MySQLConnectionAbstract.read_timeout ó ð ×!Ñ!Ð!ru c óV | t |t « r|dk r t d« || _ y)aß
|
Sets or updates the connection context's timeout in seconds for each attempt
|
to read any data from the server.
|
|
`read_timeout` is number of seconds upto which the connector should wait
|
for the server to reply back before raising an ReadTimeoutError. We can set
|
this option to None, which would signal the connector to wait indefinitely
|
till the read operation is completed or stopped abruptly.
|
|
Args:
|
timeout: Accepts a non-negative integer which is the timeout to be set
|
in seconds or None.
|
Raises:
|
InterfaceError: If a positive integer or None is not passed via the
|
timeout parameter.
|
Examples:
|
The following will set the read_timeout of the current session to
|
5 seconds:
|
```
|
>>> cnx = await mysql.connector.aio.connect(user='scott')
|
>>> cnx.read_timeout = 5
|
```
|
Nr ú6Option read_timeout must be a positive integer or None©r! rU r8 r» ©rr Útimeouts ri r z$MySQLConnectionAbstract.read_timeout# s4 ð2 Ð Ü g¤sÔ+¨w¸ª{Ü$ØLóð ð %Õru c ó | j S )a°
|
Gets the connection context's timeout in seconds for each attempt
|
to send data to the server.
|
|
`write_timeout` is number of seconds upto which the connector should spend to
|
write to the server before raising an WriteTimeoutError. We can set this option
|
to None, which would signal the connector to wait indefinitely till the write
|
operation is completed or stopped abruptly.
|
©r¼ rû s ri r
z%MySQLConnectionAbstract.write_timeoutC ó ð ×"Ñ"Ð"ru c óV | t |t « r|dk r t d« || _ y)aÕ
|
Sets or updates the connection context's timeout in seconds for each attempt
|
to send data to the server.
|
|
`write_timeout` is number of seconds upto which the connector should spend to
|
write to the server before raising an WriteTimeoutError. We can set this option
|
to None, which would signal the connector to wait indefinitely till the write
|
operation is completed or stopped abruptly.
|
|
Args:
|
timeout: Accepts a non-negative integer which is the timeout to be set in
|
seconds or None.
|
Raises:
|
InterfaceError: If a positive integer or None is not passed via the
|
timeout parameter.
|
Examples:
|
The following will set the write_timeout of the current
|
session to 5 seconds:
|
```
|
>>> cnx = await mysql.connector.connect(user='scott')
|
>>> cnx.write_timeout = 5
|
```
|
Nr ú7Option write_timeout must be a positive integer or None©r! rU r8 r¼ r s ri r
z%MySQLConnectionAbstract.write_timeoutP s4 ð2 Ð Ü g¤sÔ+¨w¸ª{Ü$ØMóð ð &Õru c óJ K | j d« d{ }|d S 7 w)r zSELECT DATABASE()Nr ©Ú
|
info_query)rr Úresults ri Ú get_databasez$MySQLConnectionAbstract.get_databasep s' è ø àÐ':Ó;×;ØayÐð <úó #!
|
#c óH K | j d| « d{ y7 w)r zUSE N)Ú cmd_queryr s ri Ú set_databasez$MySQLConnectionAbstract.set_databaseu s è ø ànnt E 7^Ó,×,Ò,ús " "c ó | j S )z"Returns whether to consume results)r¿ rû s ri Úcan_consume_resultsz+MySQLConnectionAbstract.can_consume_resultsy ó ð ×$Ñ$Ð$ru c ó6 t |t « sJ || _ y)zSet if can consume results.N)r! rb r¿ r s ri r z+MySQLConnectionAbstract.can_consume_results~ s ô %¤Ô&Ð&Ð&Ø %Õ ru c ó | j S )z'Returns the pool configuration version.©rÓ rû s ri Úpool_config_versionz+MySQLConnectionAbstract.pool_config_version s ð ×(Ñ(Ð(ru c ó || _ y)z#Sets the pool configuration versionNr¢ r s ri r£ z+MySQLConnectionAbstract.pool_config_version s ð %*Õ!ru c ó | j S )z(MySQL session has started a transaction.)rï rû s ri Úin_transactionz&MySQLConnectionAbstract.in_transaction s ð ×#Ñ#Ð#ru c ó | j S )zReturn the event loop.)r× rû s ri r¬ z MySQLConnectionAbstract.loop rx ru c óJ | j xs | j duxr t S )z&Return True if is a secure connection.N)rÈ r¹ ÚIS_POSIXrû s ri Ú is_securez!MySQLConnectionAbstract.is_secure s% ð × Ñ ÒO D×$5Ñ$5¸TÐ$AÒ$NÄhÐOru c óH t | j j « « S )z Returns query attributes list.)rO rÞ r' rû s ri Ú query_attrsz#MySQLConnectionAbstract.query_attrs s ô D×%Ñ%×+Ñ+Ó-Ó.Ð.ru c ó | j S )zReturn if have next result.)rí rû s ri Úhave_next_resultz(MySQLConnectionAbstract.have_next_result¢ s ð ×%Ñ%Ð%ru c ó t d« )ú$Get whether autocommit is on or off.zsThe use of async properties are not supported by Python. Use `await get_autocommit()` to get the autocommit insteadr rû s ri r z"MySQLConnectionAbstract.autocommit§ r
ru c ó t d« )úToggle autocommit.zxThe use of async properties are not supported by Python. Use `await set_autocommit(value)` to set the autocommit insteadr r s ri r z"MySQLConnectionAbstract.autocommit¯ ó ô ð Nó
|
ð
|
ru c óP K | j d« d{ }|d dk( S 7 w)r° zSELECT @@session.autocommitNr rL r r s ri Úget_autocommitz&MySQLConnectionAbstract.get_autocommit· s, è ø àooÐ&CÓD×DØQx1}Ð ð Eús &$ &c ób K |rdnd}| j d| « d{ || _ y7 w)r² ÚONÚOFFzSET @@session.autocommit = N)r rÀ )rr rC Úswitchs ri Úset_autocommitz&MySQLConnectionAbstract.set_autocommit¼ s7 è ø á EØnnÐ :¸6¸(Ð CÓD×DÐDØ Õð Eús / -¡ /c ó t d« )úGets the current time zone.zqThe use of async properties are not supported by Python. Use `await get_time_zone()` to get the time zone insteadr rû s ri r z!MySQLConnectionAbstract.time_zone s ô ð Gó
|
ð
|
ru c ó t d« )úSets the time zone.zxThe use of async properties are not supported by Python. Use `await get_autocommit(value)` to get the autocommit insteadr r s ri r z!MySQLConnectionAbstract.time_zoneÊ r³ ru c óJ K | j d« d{ }|d S 7 w)r¼ zSELECT @@session.time_zoneNr r r s ri Ú get_time_zonez%MySQLConnectionAbstract.get_time_zoneÒ s' è ø àooÐ&BÓC×CØQxð Dúr c óX K | j d| d« d{ || _ y7 w)r¾ zSET @@session.time_zone = 'r N)r rÁ r s ri Ú set_time_zonez%MySQLConnectionAbstract.set_time_zone× s/ è ø ànnÐ :¸5¸'ÀÐ CÓD×DÐDØ ð Eús *( *c ó K t d« w)úGets the SQL mode.zoThe use of async properties are not supported by Python. Use `await get_sql_mode()` to get the SQL mode insteadr rû s ri r z MySQLConnectionAbstract.sql_modeÜ s è ø ô ð Eó
|
ð
|
ùó c ó K t d« w)á³ Sets the SQL mode.
|
|
This method sets the SQL Mode for the current connection. The value
|
argument can be either a string with comma separate mode names, or
|
a sequence of mode names.
|
|
It is good practice to use the constants class `SQLMode`:
|
```
|
>>> from mysql.connector.constants import SQLMode
|
>>> cnx.sql_mode = [SQLMode.NO_ZERO_DATE, SQLMode.REAL_AS_FLOAT]
|
```
|
ztThe use of async properties are not supported by Python. Use `await set_sql_mode(value)` to set the SQL mode insteadr r s ri r z MySQLConnectionAbstract.sql_modeä s è ø ô ð Jó
|
ð
|
ùrÅ c ó K | j !| j d« d{ d | _ | j S 7 w)rÄ NzSELECT @@session.sql_moder )r r rû s ri Ú get_sql_modez$MySQLConnectionAbstract.get_sql_mode÷ s: è ø à >>Ð !Ø$(§O¡OÐ4OÓ$P× PÐRSÑ TDNØ~~Ð ð Qús !>£<¤>c ó¦ K t |t t f« rdj |« }| j d| d« d{ || _ y7 w)rÇ rJ zSET @@session.sql_mode = 'r N)r! rO rp r[ r r r s ri Ú set_sql_modez$MySQLConnectionAbstract.set_sql_modeý sL è ø ô ed¤E]Ô +ØHHUOEØnnÐ 9¸%¸ÀÐ BÓC×CÐCØ ð Dús A AÁAÁ Ac ó | j S )zGet whether this connection retrieves warnings automatically.
|
|
This method returns whether this connection retrieves warnings automatically.
|
)ré rû s ri r z$MySQLConnectionAbstract.get_warnings s ð ×!Ñ!Ð!ru c óH t |t « s t d« || _ y)a Set whether warnings should be automatically retrieved.
|
|
The toggle-argument must be a boolean. When True, cursors for this connection
|
will retrieve information about warnings (if any).
|
|
Raises:
|
ValueError: When the value is not a bool type.
|
úExpected a boolean typeN)r! rb rm ré r s ri r z$MySQLConnectionAbstract.get_warnings s" ô %¤Ô&Ü Ð 6Ó7Ð 7Ø "Õru c ó | j S )zGet whether this connection raises an error on warnings.
|
|
This method returns whether this connection will raise errors when MySQL
|
reports warnings.
|
)Ú_raise_on_warningsrû s ri r z)MySQLConnectionAbstract.raise_on_warnings% s ð ×&Ñ&Ð&ru c ó\ t |t « s t d« || _ |r|| _ yy)aÄ Set whether warnings raise an error.
|
|
The toggle-argument must be a boolean. When True, cursors for this connection
|
will raise an error when MySQL reports warnings.
|
|
Raising on warnings implies retrieving warnings automatically.
|
In other words: warnings will be set to True. If set to False, warnings will
|
be also set to False.
|
|
Raises:
|
ValueError: When the value is not a bool type.
|
rÎ N)r! rb rm rÐ ré r s ri r z)MySQLConnectionAbstract.raise_on_warnings. s2 ô %¤Ô&Ü Ð 6Ó7Ð 7Ø"'Ô á Ø!&DÕ ð ru c ó | j S )z§Get whether there is an unread result.
|
|
This method is used by cursors to check whether another cursor still needs to
|
retrieve its result set.
|
)rî rû s ri Ú unread_resultz%MySQLConnectionAbstract.unread_resultC ó ð ×"Ñ"Ð"ru c óH t |t « s t d« || _ y)zýSet whether there is an unread result.
|
|
This method is used by cursors to let other cursors know there is still a
|
result set that needs to be retrieved.
|
|
Raises:
|
ValueError: When the value is not a bool type.
|
rÎ N)r! rb rm rî r s ri rÓ z%MySQLConnectionAbstract.unread_resultL s" ô %¤Ô&Ü Ð 6Ó7Ð 7Ø #Õru c ó. | j j S )a Returns the collation for current connection.
|
|
This property returns the collation name of the current connection.
|
The server is queried when the connection is active. If not connected,
|
the configured collation name is returned.
|
|
Returns a string.
|
)Ú_charsetr rû s ri r z!MySQLConnectionAbstract.collationZ s ð }}×&Ñ&Ð&ru c ó. | j j S )a Return the character set for current connection.
|
|
This property returns the character set name of the current connection.
|
The server is queried when the connection is active.
|
If not connected, the configured character set name is returned.
|
©r× r rû s ri r\ z MySQLConnectionAbstract.charsetf s ð }}×!Ñ!Ð!ru c ó. | j j S )zThe charset ID utilized during the connection phase.
|
|
If the charset ID hasn't been set, the default charset ID is returned.
|
)r× Ú
|
charset_idrû s ri rÛ z"MySQLConnectionAbstract.charset_idp s ð }}×'Ñ'Ð'ru c óö | j b| j t j t « S t j | j j
|
dk rt nt « | _ | j S )úBThe charset object encapsulates charset and collation information.)é r )r° rÚ rO Ú get_by_idr/ rZ r0 rû s ri r× z MySQLConnectionAbstract._charsetx sj ð >>Ð !Ø× Ñ Ð(ô
|
×)Ñ)Ô*EÓFÐFä %× /Ñ /ð ×(Ñ(×6Ñ6¸Ò?õ 0ä4ó DNð ~~Ð ru c ó || _ y)rÝ N)r° r s ri r× z MySQLConnectionAbstract._charset s ð ru c óx | j | j j dv ry| j j S )a^ Return the Python character set for current connection.
|
|
This property returns the character set name of the current connection.
|
Note that, unlike property charset, this checks if the previously set
|
character set is supported by Python and if not, it returns the equivalent
|
character set that Python supports.
|
)Úutf8mb4Úutf8mb3ÚbinaryÚutf8rÙ rû s ri Úpython_charsetz&MySQLConnectionAbstract.python_charset s9 ð ==Ð D§M¡M×$6Ñ$6ð ;
|
ñ %
|
ð
|
Ø}}×!Ñ!Ð!ru c ó y)z&Add the default connection attributes.Nr~ rû s ri r+ z/MySQLConnectionAbstract._add_default_conn_attrs¢ rv ru c ó K yw)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.
|
Nr~ )rr Úquerys ri Ú_execute_queryz&MySQLConnectionAbstract._execute_query¦ ó è ø ùó c óÞ K | j | j j ¬« d{ | j | j « d{ | j
|
r#| j | j
|
« d{ | j r#| j | j « d{ | j r$| j | j « d{ yy7 ¶7 7 h7 ;7 w)zøExecutes commands after connection has been established.
|
|
This method executes commands after the connection has been established.
|
Some setting like autocommit, character set, and SQL mode are set using this
|
method.
|
)r\ N) Úset_charset_collationr× rÛ rº rÀ rÁ r r rË rà rê rû s ri Ú_post_connectionz(MySQLConnectionAbstract._post_connection¯ s¿ è ø ð ×(Ñ(°· ± ×1IÑ1IÐ(ÓJ×JÐJØ×!Ñ! $×"2Ñ"2Ó3×3Ð3Ø ??Ø×$Ñ$ T§_¡_Ó5× 5Ð 5Ø >>Ø×#Ñ# D§N¡NÓ3× 3Ð 3Ø × Ò Ø×%Ñ% d×&8Ñ&8Ó9× 9Ñ 9ð ð KøØ3øà 5øà 3øà 9úsW *C-¬C#"C-ÁC%Á.C-Á>C'Á?.C-Â-C)Â..C-à C+à C-Ã%C-Ã'C-Ã)C-Ã+C-c óÀ K d}t |t t f« s |t |j d« « t |t « s | t d« |rO|rMt |t « r t j |« j n|}t j ||« | _ n²|rpt |t « rt j |« | _ n
t |t « rt j |« | _ nZt |j d« « |rt j |« | _ n#t d }t j |« | _ | j d| j j d| j j d« d{ | j r0| j j! | j j « yy7 Aw)aè Set the character set and collation for the current connection.
|
|
This method sets the character set and collation to be used for the current
|
connection. The charset argument can be either the name of a character set as
|
a string, or the numerical equivalent as defined in constants.CharacterSet.
|
|
When the collation is not given, the default will be looked up and used.
|
|
Args:
|
charset: Can be either the name of a character set, or the numerical
|
equivalent as defined in `constants.CharacterSet`.
|
collation: When collation is `None`, the default collation for the
|
character set is used.
|
|
Examples:
|
The following will set the collation for the latin1 character set to
|
`latin1_general_ci`:
|
```
|
>>> cnx = mysql.connector.connect(user='scott')
|
>>> cnx.set_charset_collation('latin1', 'latin1_general_ci')
|
```
|
z+{} should be either integer, string or NoneNr\ z)collation should be either string or Nonez SET NAMES 'z ' COLLATE 'r )r! rU rW rm r- rO rß r Úget_by_name_and_collationr× Ú get_by_nameÚget_by_collationr- r r ró Ú set_charset)rr r\ r Úerr_msgÚ charset_strs ri rî z-MySQLConnectionAbstract.set_charset_collation¿ s è ø ð2 @Ü'¤C¬ :Ô.°7Ð3FÜ W^^¨IÓ 6Ó7Ð 7Ü)¤SÔ)¨iÐ.CÜ Ð HÓIÐ Iá yô g¤sÔ+ô ×"Ñ" 7Ó+×0Ò0à ð ô
|
%× >Ñ >¸{ÈIÓ VDMÙ Ü'¤3Ô'Ü (× 2Ñ 2°7Ó ; ÜG¤SÔ)Ü (× 4Ñ 4°WÓ = ä § ¡ ° Ó!:Ó;Ð;Ù Ü $× 5Ñ 5°iÓ @DMä+¨IÑ6GÜ $× 0Ñ 0°Ó 9DMànnØ$--×,Ñ,Ð-¨[¸¿ ¹ ×9PÑ9PÐ8QÐQRÐ Só
|
÷
|
ð
|
ð >>Ø NN× &Ñ & t§}¡}×'9Ñ'9Õ :ð ð
|
ús FG ÆG ÆAG c ó& | j |z dkD S )z|Checks if a client flag is set.
|
|
Returns:
|
`True` if the client flag was set, `False` otherwise.
|
r ©rÙ )rr Úflags ri Úisset_client_flagz)MySQLConnectionAbstract.isset_client_flagù s ð ×"Ñ" TÑ)¨QÑ.Ð.ru c ó || _ y)zySet the path that user can upload files.
|
|
Args:
|
path (str): Path that user can upload files.
|
N)rè )rr r s ri Ú set_allow_local_infile_in_pathz6MySQLConnectionAbstract.set_allow_local_infile_in_path s ð ,0Õ(ru c ó | S )zReturn self for weakref.proxy.
|
|
This method is used when the original object is needed when using
|
weakref.proxy.
|
r~ rû s ri Úget_selfz MySQLConnectionAbstract.get_self
|
s ð ru Úserver_version©Ú property_namec ó | j S )ú£Gets the MySQL version.
|
|
Returns:
|
The MySQL server version as a tuple. If not previously connected, it will
|
return `None`.
|
)rÿ rû s ri Úget_server_versionz*MySQLConnectionAbstract.get_server_version s ð ×"Ñ"Ð"ru Ú server_infoc ó | j S )ú¶Gets the original MySQL version information.
|
|
Returns:
|
The original MySQL server as text. If not previously connected, it will
|
return `None`.
|
)r rû s ri Úget_server_infoz'MySQLConnectionAbstract.get_server_info s ð × Ñ Ð ru c óH | j | j j S y)r N)rÚ rZ rû s ri rÿ z&MySQLConnectionAbstract.server_version& s% ð × Ñ Ð (Ø×$Ñ$×2Ñ2Ð 2Øru c óL | j d S # t t f$ r Y yw xY w)r Úserver_version_originalN)rÔ Ú TypeErrorr: rû s ri r z#MySQLConnectionAbstract.server_info2 s. ð Ø??Ð#<Ñ=Ð =øÜ8Ð$ò Ùð ús #¢#c ó y)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.
|
Nr~ rû s ri rù z+MySQLConnectionAbstract.is_socket_connected? rv ru c ó K yw)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.
|
Nr~ rû s ri Ú is_connectedz$MySQLConnectionAbstract.is_connectedG rë rì c ó K yw)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.
|
Nr~ )rr Ú reconnectÚattemptsÚdelays ri Úpingz MySQLConnectionAbstract.pingP rë rì c ó( || _ | j S )aí Set the client flags.
|
|
The flags-argument can be either an int or a list (or tuple) of ClientFlag
|
values. If it is an integer, it will set client_flags to flags as is.
|
If flags is a list or tuple, each flag will be set or unset when it's negative.
|
|
client_flags = [ClientFlag.FOUND_ROWS,-ClientFlag.LONG_FLAG]
|
|
Raises:
|
ProgrammingError: When the flags argument is not a set or an integer bigger
|
than 0.
|
)r )rr Úflagss ri Úset_client_flagsz(MySQLConnectionAbstract.set_client_flagsc s ð "ÔØ× Ñ Ð ru c ó | j S )z-Gets the client flags of the current session.rø rû s ri r z$MySQLConnectionAbstract.client_flagst s ð ×!Ñ!Ð!ru c ó t |t « r |dkD r|| _ yt |t t f« rB|D ]< }|dk r | xj t |« z c_ (| xj |z c_ > yt d« )aî Sets the client flags.
|
|
The flags-argument can be either an int or a list (or tuple) of ClientFlag
|
values. If it is an integer, it will set client_flags to flags as is.
|
If flags is a list or tuple, each flag will be set or unset when it's negative.
|
|
client_flags = [ClientFlag.FOUND_ROWS,-ClientFlag.LONG_FLAG]
|
|
Raises:
|
ProgrammingError: When the flags argument is not a set or an integer bigger
|
than 0.
|
r z.client_flags setter expect integer (>0) or setN)r! rU rÙ rp rO Úabsr; )rr r rù s ri r z$MySQLConnectionAbstract.client_flagsy sv ô eSÔ ! e¨a¢iØ!&DÕ Ü ¤¤t}Ô -Ø ò /Ø!8Ø×&Ò&¬3¨t«9¨*Ñ4Ö&à×&Ò&¨$Ñ.Ö&ñ /ô #Ð#SÓTÐ Tru c ó || _ y)zûSet the converter class to be used.
|
|
This should be a class overloading methods and members of
|
conversion.MySQLConverter.
|
|
Raises:
|
TypeError: When the class is not a subclass of `conversion.MySQLConverter`.
|
N)r ©rr Ú convclasss ri Úset_converter_classz+MySQLConnectionAbstract.set_converter_class s ð )Õ ru c ó | j S )z5Gets the converter class set for the current session.)râ rû s ri r z'MySQLConnectionAbstract.converter_class r ru c óÚ |r_t |t « rO|| _ || j j | j
|
« | _ | j | j _ yt d« )züSets the converter class to be used.
|
|
This should be a class overloading methods and members of
|
conversion.MySQLConverter.
|
|
Raises:
|
TypeError: When the class is not a subclass of `conversion.MySQLConverter`.
|
zAConverter class should be a subclass of conversion.MySQLConverterN)
|
Ú
|
issubclassr6 râ r× r r¤ ró rã Ú str_fallbackr r s ri r z'MySQLConnectionAbstract.converter_class£ sY ñ IÔ/AÔBØ$-DÔ !Ù & t§}¡}×'9Ñ'9¸4×;KÑ;KÓ LDNØ*.×*FÑ*FDNNÕ 'äØSóð ru c ó | j S )z7Gets whether we return string fields as unicode or not.)rì rû s ri r¤ z#MySQLConnectionAbstract.use_unicode¶ r~ ru c ób || _ | j r | j j |« yy)zSets whether we return string fields as unicode or not.
|
|
Args:
|
value: A boolean - default is `True`.
|
N)rì ró Ú set_unicoder s ri r¤ z#MySQLConnectionAbstract.use_unicode» s* ð "ÔØ >>Ø NN× &Ñ & uÕ -ð ru c óJ |\ }}|| j vr|| j |< yy)a Add element to the query attributes list on the connector's side.
|
|
If an element in the query attributes list already matches
|
the attribute name provided, the new element will NOT be added.
|
|
Args:
|
value: key-value as a 2-tuple.
|
N©rÞ )rr rC r1 r2 s ri Úquery_attrs_appendz*MySQLConnectionAbstract.query_attrs_appendÆ s1 ð !&Ñ :Ø D× -Ñ -Ñ -Ø+5D× Ñ iÒ (ð .ru c ó: | j j |d« S )z¾Remove element by name from the query attributes list.
|
|
If no match, `None` is returned, else the corresponding value is returned.
|
|
Args:
|
name: key name.
|
N)rÞ r; ©rr r s ri Úquery_attrs_removez*MySQLConnectionAbstract.query_attrs_removeÓ s ð × Ñ ×$Ñ$ T¨4Ó0Ð0ru c ó i | _ y)z5Clears query attributes list on the connector's side.Nr' rû s ri Úquery_attrs_clearz)MySQLConnectionAbstract.query_attrs_clearÝ s
|
à Õru c ó K | j r| j « d{ y| j r t d« y7 w)z¿Handle unread result.
|
|
Consume pending results if is configured for it.
|
|
Raises:
|
InternalError: When there are pending results and they were not consumed.
|
NzUnread result found)r¿ r rÓ r9 rû s ri Úhandle_unread_resultz,MySQLConnectionAbstract.handle_unread_resultá sB è ø ð × Ò Ø×&Ñ&Ó(× (Ñ (Ø × Ò Ü Ð 5Ó6Ð 6ð ð )ús A¢A £ Ac óZ K | j r| j « d{ yy7 w)zConsume pending results.N)rÓ Úget_rowsrû s ri r z'MySQLConnectionAbstract.consume_resultsî s& è ø à × Ò Ø--/× !Ñ !ð Ø !ús +¢)£+c ó. K | j d¬« d{ 4 d{ }|j t t |« « d{ |j « d{ cddd« d{ S 7 ]7 V7 17 7 # 1 d{ 7 sw Y yxY ww)z&Send a query which only returns 1 row.T)r N)ÚcursorÚexecuter! rW Úfetchone)rr ré r3 s ri r z"MySQLConnectionAbstract.info_queryó s è ø à ¨dÓ3×3÷ +ð +°vØ..¤¤c¨5Ó!1Ó2× 2Ð 2Ø Ó*×*÷ +÷ +ñ +Ð3øð +øØ 2øØ*øð +ø÷ +÷ +ñ +üsx BA6B¡A8¢B¥#B ÁA:Á B Á A<Á!B Á$ BÁ0A>Á1BÁ8BÁ:B Á<B Á>B BÂB ÂBÂBc ó: | j j |« y)z Add cursor to the weakref set.N)rÝ Úadd©rr r3 s ri Ú
|
add_cursorz"MySQLConnectionAbstract.add_cursorù s à ×Ñ&Õ!ru c ó: | j j |« y)z#Remove cursor from the weakref set.N)rÝ Úremover8 s ri Ú remove_cursorz%MySQLConnectionAbstract.remove_cursorý s à × Ñ VÕ$ru c ó K yw)z Connect to the MySQL server.Nr~ rû s ri rú z MySQLConnectionAbstract.connect rë rì c ó K d}||k7 ry|dz } | j « d{ | j « d{ | j « d{ ry |dkD r t j |« d{ ||k7 rxyy7 `7 J7 4# t t f$ r#}||k( rd| d| }t |« |Y d}~]d}~ww xY w7 Gw)a Attempts to reconnect to the MySQL server.
|
|
The argument `attempts` should be the number of times a reconnect is tried.
|
The `delay` argument is the number of seconds to wait between each retry.
|
|
You may want to set the number of attempts higher and use delay when you expect
|
the MySQL server to be down for maintenance or when you expect the network to
|
be temporary unavailable.
|
|
Args:
|
attempts: Number of attempts to make when reconnecting.
|
delay: Use it (defined in seconds) if you want to wait between each retry.
|
|
Raises:
|
InterfaceError: When reconnection fails.
|
r rL Nz!Can not reconnect to MySQL after z attempt(s): )Ú
|
disconnectrú r r7 ÚIOErrorr8 rÕ Úsleep)rr r r Úcounterr/ Úmsgs ri r z!MySQLConnectionAbstract.reconnect sà è ø ð" ØÒ!Ø kGð 7ØooÓ'×'Ð'Ølln×$Ð$Ø ×*Ñ*Ó,×,Ð,Øð -ð qyÜ mm EÓ*×*Ð*ð Õ!ð (øØ$øØ,ùä7Ð#ò 7ØhÒ&à;¸H¸:ð F'Ø'* eð-ð ô )¨Ó-°3Ð6ô 'ûð 7úð +úsr CB
|
£B¤B
|
»B¼B
|
ÁBÁB
|
Á CÁ7B?Á8 CÂCÂB
|
ÂB
|
ÂB
|
Â
|
B<ÂB7Â2CÂ7B<Â<Cc ó K t w)ak Shuts 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.
|
)ÚNotImplementedErrorrû s ri Úshutdownz MySQLConnectionAbstract.shutdown( s è ø ô "Ð!ùs c ó K yw)a Close the connection.
|
|
It closes any opened cursor associated to this connection, and closes the
|
underling socket connection.
|
|
`MySQLConnection.close()` is a synonymous for `MySQLConnection.disconnect()`
|
method name and more commonly used.
|
|
This method tries to send a `QUIT` command and close the socket. It raises
|
no exceptions.
|
Nr~ rû s ri rÿ z MySQLConnectionAbstract.close3 rë rì z@ClassVar[Callable[['MySQLConnectionAbstract'], Awaitable[None]]]r? c ó K yw)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.
|
Nr~ )rr r r ÚpreparedÚ cursor_classÚ
|
dictionaryr r
s ri r3 z MySQLConnectionAbstract.cursorC rë rì c ó K yw)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.
|
Nr~ )rr rä Úcolumnsr r= s ri Úget_rowz MySQLConnectionAbstract.get_row_ rë rì c ó K yw)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.
|
Nr~ )rr Úcounträ rM r Ú prep_stmtr= s ri r1 z MySQLConnectionAbstract.get_rowsn rë rì c ó K yw)zCommit current transaction.Nr~ rû s ri Úcommitz MySQLConnectionAbstract.commit rë rì c ó K yw)z Rollback current transaction.Nr~ rû s ri Úrollbackz MySQLConnectionAbstract.rollback rë rì c óê K | j r t d« |ra|j « j dd« j « }g d¢}||vrt d| d« | j d| « d{ |K| j d k rt d
|
| j d « |rd }nd }| j d| « d{ d}|r|dz }| j |« d{ y7 t7 )7 w)at Starts a transaction.
|
This method explicitly starts a transaction sending the
|
START TRANSACTION statement to the MySQL server. You can optionally
|
set whether there should be a consistent snapshot, which
|
isolation level you need or which access mode i.e. READ ONLY or
|
READ WRITE.
|
Args:
|
consistent_snapshot: If `True`, Connector/Python sends WITH CONSISTENT
|
SNAPSHOT with the statement. MySQL ignores this for
|
isolation levels for which that option does not apply.
|
isolation_level: Permitted values are 'READ UNCOMMITTED', 'READ COMMITTED',
|
'REPEATABLE READ', and 'SERIALIZABLE'. If the value is
|
`None`, no isolation level is sent, so the default level
|
applies.
|
readonly: Can be `True` to start the transaction in READ ONLY mode or
|
`False` to start it in READ WRITE mode. If readonly is omitted,
|
the server's default access mode is used.
|
Raises:
|
ProgrammingError: When a transaction is already in progress
|
and when `ValueError` when `isolation_level`
|
specifies an Unknown level.
|
Examples:
|
For example, to start a transaction with isolation level `SERIALIZABLE`,
|
you would do the following:
|
```
|
>>> cnx = mysql.connector.aio.connect(...)
|
>>> await cnx.start_transaction(isolation_level='SERIALIZABLE')
|
```
|
z Transaction already in progressrL ú )zREAD UNCOMMITTEDzREAD COMMITTEDzREPEATABLE READÚ SERIALIZABLEzUnknown isolation level "ú"z SET TRANSACTION ISOLATION LEVEL N)é é rZ zMySQL server version z does not support this featurez READ ONLYz
|
READ WRITEzSET TRANSACTION zSTART TRANSACTIONz WITH CONSISTENT SNAPSHOT) r¦ r; r ÚreplacerS rm rê rÿ r )rr Úconsistent_snapshotÚisolation_levelÚreadonlyÚlevelÚlevelsÚ access_moderé s ri Ústart_transactionz)MySQLConnectionAbstract.start_transaction s% è ø ðF × Ò Ü"Ð#DÓEÐ Eá Ø#×)Ñ)Ó+×3Ñ3°C¸Ó=×CÑCÓEEòFð FÑ"Ü Ð#<¸_Ð<MÈQÐ!OÓPÐPà×%Ñ%Ð(HÈÈÐ&PÓQ× QÐ Qà Ð Ø×"Ñ" YÒ.Ü Ø+¨D×,?Ñ,?Ð+@ð A+ð +óð ñ
|
Ø ) à * Ø×%Ñ%Ð(8¸¸ Ð&FÓG× GÐ Gà#Ù Ø Ð0Ñ 0EØnnUÓ#×#Ñ#ð% Røð Høð
|
$ús7 A6C3Á8C-Á9A C3ÃC/Ã!C3Ã'C1Ã(C3Ã/C3Ã1C3c ó K yw)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.
|
|
Args:
|
user_variables: User variables map.
|
session_variables: System variables map.
|
|
Raises:
|
OperationalError: If not connected.
|
InternalError: If there are unread results and InterfaceError on errors.
|
|
Examples:
|
```
|
>>> user_variables = {'var1': '1', 'var2': '10'}
|
>>> session_variables = {'wait_timeout': 100000, 'sql_mode': 'TRADITIONAL'}
|
>>> await cnx.reset_session(user_variables, session_variables)
|
```
|
Nr~ )rr Úuser_variablesÚsession_variabless ri Ú reset_sessionz%MySQLConnectionAbstract.reset_sessionÍ rë rì c ó K yw)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.
|
Nr~ rû s ri Úcmd_reset_connectionz,MySQLConnectionAbstract.cmd_reset_connectioní rë rì c ó K yw)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.
|
Nr~ )rr r s ri Ú cmd_init_dbz#MySQLConnectionAbstract.cmd_init_dbõ rë rì c ó K yw)aã Send a query to the MySQL server.
|
|
This method send the query to the MySQL server and returns the result.
|
|
If there was a text result, a tuple will be returned consisting of the number
|
of columns and a list containing information about these columns.
|
|
When the query doesn't return a text result, the OK or EOF packet information
|
as dictionary will be returned. In case the result was an error, exception
|
Error will be raised.
|
Nr~ )rr ré r r Ú raw_as_stringr= s ri r z!MySQLConnectionAbstract.cmd_queryý rë rì c ó K yw)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
|
Nr~ )rr Ú
|
statementsr= s ri Úcmd_query_iterz&MySQLConnectionAbstract.cmd_query_iter rë rì c ó K yw)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.
|
Nr~ )rr Ú statement_idÚrowsr= s ri Úcmd_stmt_fetchz&MySQLConnectionAbstract.cmd_stmt_fetch& rë rì c ó K yw)zPrepare a MySQL statement.
|
|
This method will send the PREPARE command to MySQL together with the given
|
statement.
|
Nr~ )rr Ú statementr= s ri Úcmd_stmt_preparez(MySQLConnectionAbstract.cmd_stmt_prepare0 rë rì c ó K yw)z#Execute a prepared MySQL statement.Nr~ )rr rr Údataro r r= s ri Úcmd_stmt_executez(MySQLConnectionAbstract.cmd_stmt_execute< rë rì c ó K yw)z}Reset data for prepared statement sent as long data.
|
|
The result is a dictionary with OK packet information.
|
Nr~ ©rr rr r= s ri Úcmd_stmt_resetz&MySQLConnectionAbstract.cmd_stmt_resetG rë rì c ó K yw)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.
|
Nr~ r| s ri Úcmd_stmt_closez&MySQLConnectionAbstract.cmd_stmt_closeR rë rì c ó K yw)a¡ Send the Refresh command to the MySQL server.
|
|
This method sends the Refresh command to the MySQL server. The options
|
argument should be a bitwise value using constants.RefreshOption.
|
|
Typical usage example:
|
```
|
RefreshOption = mysql.connector.RefreshOption
|
refresh = RefreshOption.LOG | RefreshOption.INFO
|
await cnx.cmd_refresh(refresh)
|
```
|
|
Args:
|
options: Bitmask value constructed using constants from
|
the `constants.RefreshOption` class.
|
|
Returns:
|
A dictionary representing the OK packet got as response when executing
|
the command.
|
|
Raises:
|
ValueError: If an invalid command `refresh options` is provided.
|
DeprecationWarning: If one of the options is deprecated for the server you
|
are connecting to.
|
Nr~ )rr Úoptionss ri Ú cmd_refreshz#MySQLConnectionAbstract.cmd_refreshZ rë rì c ó K yw)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.
|
Nr~ )rr rr Úparam_idry r= s ri Úcmd_stmt_send_long_dataz/MySQLConnectionAbstract.cmd_stmt_send_long_datav rë rì c ó K yw)zClose the current connection with the server.
|
|
Send the QUIT command to the MySQL server, closing the current connection.
|
Nr~ rû s ri Úcmd_quitz MySQLConnectionAbstract.cmd_quit rë rì c ó K yw)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.
|
Nr~ )rr Ú shutdown_types ri Ú cmd_shutdownz$MySQLConnectionAbstract.cmd_shutdown rë rì c ó K yw)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û s ri Úcmd_statisticsz&MySQLConnectionAbstract.cmd_statistics rë rì c ó K yw)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.
|
Nr~ )rr Ú mysql_pids ri Úcmd_process_killz(MySQLConnectionAbstract.cmd_process_kill¢ rë rì c ó K yw)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.
|
Nr~ rû s ri Ú cmd_debugz!MySQLConnectionAbstract.cmd_debugª rë rì c ó K yw)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.
|
Nr~ rû s ri Úcmd_pingz MySQLConnectionAbstract.cmd_ping´ rë rì c ó K yw)aØ Changes the current logged in user.
|
|
It also causes the specified database to become the default (current)
|
database. It is also possible to change the character set using the
|
charset argument. The character set passed during initial connection
|
is reused if no value of charset is passed via this method.
|
|
Args:
|
username: New account's username.
|
password: New account's password.
|
database: Database to become the default (current) database.
|
charset: Client charset (see [1]), only the lower 8-bits.
|
password1: New account's password factor 1 - it's used instead
|
of `password` if set (higher precedence).
|
password2: New account's password factor 2.
|
password3: New account's password factor 3.
|
oci_config_file: OCI configuration file location (path-like string).
|
oci_config_profile: OCI configuration profile location (path-like string).
|
openid_token_file: OpenID Connect token file location (path-like string).
|
|
Returns:
|
ok_packet: Dictionary containing the OK packet information.
|
|
Examples:
|
```
|
>>> cnx.cmd_change_user(username='', password='', database='', charset=33)
|
```
|
|
References:
|
[1]: https://dev.mysql.com/doc/dev/mysql-server/latest/ page_protocol_basic_character_set.html#a_protocol_character_set
|
Nr~ ) rr r5 r r r\ r r r r r® r s ri Úcmd_change_userz'MySQLConnectionAbstract.cmd_change_user½ rë rì )^r ú Optional[str]r rW r rW r rU r r r rW r rW r rW r\ rW r rW r^ r r ú Optional[int]r rb r rb r rb r r r zDict[str, str]r r r r r rb r rb r rb r rb r r r r r r r z+Optional[Union[str, Callable[[str], None]]]r rb r r r zOptional[MySQLConverter]r¡ rb r¢ rU r r r
r r£ r r¤ úOptional[bool]r¥ r r¦ r r§ r r¨ r r© r r r rª úOptional[List[str]]r« r r¬ z#Optional[asyncio.AbstractEventLoop]r r r® r )rw r ©NNN©r z Optional[Type[BaseException]]r zOptional[BaseException]r zOptional[TracebackType]rw rx rv )r= r rw rx )r )rp rW rq zUnion[str, Callable]rr rU rw rx ©rw r )rw rW ©rw rU ©rw r )rC rW rw rx ©r r rw rx ©rw rb )rC rb rw rx )rw r )rC r rw rx )rw zasyncio.AbstractEventLoop)rw z$List[Tuple[str, BinaryProtocolType]])rC zUnion[str, Sequence[int]]rw rx )rw rN )rC rN rw rx )ré rW rw rE ©NN)r\ zOptional[Union[int, str]]r r rw rx )rù rU rw rb )r rW rw rx )rw zOptional[Tuple[int, ...]])FrL r )r rb r rU r rU rw rb )r úUnion[int, Sequence[int]]rw rU )r r¢ rw rx )r z Optional[Type[MySQLConverter]]rw rx )rw zType[MySQLConverter])rC z Tuple[str, BinaryProtocolType]rw rx ©r rW rw r> )ré rH rw úOptional[RowType])r3 r rw rx )rL r )r rU r rU rw rx )rw r )NNNNNNN)r r r r rI r rJ z#Optional[Type[MySQLCursorAbstract]]rK r r r r
r rw r )FNN)
|
rä rb rM ú Optional[List[DescriptionType]]r r r= r rw z1Tuple[Optional[RowType], Optional[EofPacketType]])NFNNN)rP r rä rb rM r¥ r r rQ r r= r rw z-Tuple[List[RowType], Optional[EofPacketType]])r] rb r^ r r_ r rw rx )re úOptional[Dict[str, Any]]rf r¦ rw rx )r rW rw rC )FFF) ré rH r rb r rb rm rb r= r rw rE )ro rH r= r rw z!Generator[ResultType, None, None]©rL )rr rU rs rU r= r rw rx )rv r_ r= r rw z/Mapping[str, Union[int, List[DescriptionType]]])r~ r~ r ) rr zUnion[int, CMySQLPrepStmt]ry z Sequence[BinaryProtocolType]ro r r rU r= r rw z&Optional[Union[Dict[str, Any], Tuple]])rr rU r= r rw rx )r rU rw rC )
|
rr rU r rU ry r r= r rw rU )rw r_ rf )r r rw rx )rw rG )r rU rw rC )rw r@ )rw rC )
|
r r r Nr r r r r r )r5 rW r rW r rW r\ r r rW r rW r rW r rW r® rW r rW rw zOptional[OkPacketType])pry rz r{ r| r- r÷ rü r rö rE r% r$ Ú staticmethodr. Úpropertyr ru r rz r| r£ r Úsetterr r
r r r r£ r¦ r¬ rª r¬ r® r rµ rº r rÀ r r rÉ rË r r rÓ r r\ rÛ r× ræ r+ rê rï 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 r9 r< rú r rF rÿ r? r} r3 rN r1 rS rU rc rg ri rk r rp rt rw rz r} r r r
r r r r r r r r~ ru ri r r ¤ s=
Ù1ð
|
#ØØ ØØ"&ØØØØØØ%)Ø&*Ø Ø %Ø Ø#'Ø%'Ø"&Ø&*Ø "Ø"'Ø ØØ,0Ø/3Ø+/ØIMØ#8Ð9MÑ#NØ4IØ (ñ5
|
ð 59Ø',Ø"7Ð8IÑ"JØ&;¸NÑ&KØ'<¸_Ñ'MØ%)Ø&*Ø $Ø"&Ø!%Ø*/Ø.3Ø'<¸^Ñ'LØ,0Ø04Ø48Ø)-Ø,0ñgM,ð ðM,ð ð M,ð
|
ð M,ð ð M,ð ðM,ð ðM,ð ðM,ð ðM,ð ðM,ð ðM,ð #ðM,ð $ð M,ð ð M,ð ð!M,ð" ð#M,ð$ !ð%M,ð& #ð'M,ð( ð)M,ð* $ð+M,ð, ð-M,ð. ð/M,ð0 ð1M,ð2 ð3M,ð4 *ð5M,ð6 -ð7M,ð8 )ð9M,ð: Gð;M,ð< !ð=M,ð> %2ð?M,ðD 2ðEM,ðF !%ðGM,ðH ðIM,ðJ $ðKM,ðL %ðMM,ðN #ðOM,ðP $ðQM,ðR ðSM,ðT ðUM,ðV ðWM,ðX (ðYM,ðZ ,ð[M,ð\ %ð]M,ð^ *ð_M,ð` .ðaM,ðb 2ðcM,ðd 'ðeM,ðf *ógM,ó^ð 37Ø-1Ø-1ð à/ðð +ðð +ð ð
|
|
ó óaXóF4,ól[
|
ózORðb àJKð Øð Ø$8ð ØDGð à ò ó ð ðD Øò#ó ó ð#ð òó ðð òó ðð òó ðð ò!ó ð!ð ò
|
ó ð
|
ð __ò
|
ó ð
|
ð ò
|
"ó ð
|
"ð ×Ñò %ó ð %ð> ò
|
#ó ð
|
#ð ×Ñò &ó ð &ó>ó
|
-ð ò%ó ð%ð × Ñ ò&ó ð&ð
|
ò)ó ð)ð × Ñ ò*ó ð*ð ò$ó ð$ð òó ðð òPó ðPð ò/ó ð/ð ò&ó ð&ð ò
|
ó ð
|
ð ×Ñò
|
ó ð
|
ó ó
|
!ð ò
|
ó ð
|
ð ×Ñò
|
ó ð
|
óó
|
ð
|
ò
|
ó ð
|
ð __ò
|
ó ð
|
ó$ ó ð$ ò"ó ð"ð ×Ñò #ó ð #ð ò'ó ð'ð × Ñ ò'ó ð'ð( ò#ó ð#ð ×Ñò $ó ð $ð ò 'ó ð 'ð ò"ó ð"ð ò(ó ð(ð ò ó ð ð& __ò ó ð ð ò"ó ð"ð ò5ó ð5ð ò ó ð ó:ð" UYð8;Ø0ð8;ØDQð8;à ó8;ót/ó0óñ Ð0Ð)×0Ñ0Ð?OÔPÓQò#ó Rð#ñ Ð0Ð)×0Ñ0¸}ÔMÓNò ó Oð ð ò ó ð ð ò
|
ó ð
|
ð ò ó ð ð ò ó ð ð àGHð Ø ð Ø14ð ØADð à ò ó ð ñ$ Ð0Ð)×0Ñ0¸~ÔNÓOò!ó Pð!ð ò"ó ð"ð ×ÑòUó ðUñ0 Ð0Ð)×0Ñ0Ð?PÔQÓRò )ó Sð )ð ò%ó ð%ð ×Ñòó ðð$ ò!ó ð!ð ×Ñò.ó ð.ó 6ó1ó ó 7ó"ó
|
+ó "ó%ð ò+ó ð+ô!+óF "ð ò ó ð ð TYJÐPÓXàð $(Ø "Ø#'Ø<@Ø%)Ø&*Ø'+ð à ð ð ð ð !ð ð
|
:ð ð #ð ð $ð ð %ð ð
|
ò ó ð ð6 ð Ø37Ø "ð àð ð 1ð ð ð ð
|
ð ð
|
;ò ó ð ð ð $Ø Ø37Ø "Ø ð à ð ð ð ð 1ð ð
|
ð ð ð ð ð ð
|
7ò ó ð ð ò*ó ð*ð ò,ó ð,ð
|
%*Ø)-Ø#'ð D$à !ðD$ð 'ðD$ð !ð D$ð
|
|
ó D$ðL ð 48Ø6:ð à0ð ð 4ð ð
|
ò ó ð ð> ò ó ð ð ò ó ð ð ð Ø Ø #ð àð ð ð ð ð ð
|
ð ð ð ð
|
ò ó ð ð( à ð ð ð ð
|
+ó ð( à-.ð Ø ð Ø'*ð Ø:=ð à ò ó ð ð ð àð ð ð ð
|
9ò ó ð ð ð .0Ø !Øð 2à0ð2ð +ð2ð ð 2ð
|
ð 2ð ð 2ð
|
0ò2ó ð2ð ð àð ð ð ð
|
ò ó ð ð ò ó ð ð ò ó ð ð6 àð ð ð ð ð ð
|
ð ð
|
ó ð* ò ó ð ð ó ó ð ð ò ó ð ð ò ó ð ð ò ó ð ð ò ó ð ð ð ØØØ!%ØØØØ !Ø"$Ø!#ð, àð, ð ð, ð ð , ð
|
ð , ð ð , ð ð, ð ð, ð ð, ð ð, ð ð, ð
|
ò, ó ñ, ru r c óì e Zd ZdZ d( d)dZd*dZ d+ d,dZd-dZd.dZe d/d« Z
|
e
|
j d0d « Z
|
e d/d
|
« Z e j d0d « Z e d1d « Z e d2d « Ze d/d« Ze d3d« Z e ej& d¬« « d3d« Ze d2d« Ze d4d« Ze d5d« Ze d6d« Zed7d« Ze d8 d9d« Ze d8 d9d« Z e d:d« Z ed;d« Z ed<d « Z ed=d>d « Z d?d Z!ed@d « Z"ed6d « Z# e ej& d!¬« « d/d"« Z$dAdBd#Z%dCd$Z&dDd%Z'dEd&Z(dFd'Z)y)Gr z#Defines the MySQL cursor interface.Nc óX || _ |j | _ d | _ d | _ d | _ d| _ d | _ g | _ g | _ d| _
|
d| _ d| _ d| _ d| _ d | _ d | _ d| _ || _ || _ | j j) | « y )Nr FrI r¡ rL )Ú _connectionr¬ r× Ú _descriptionÚ_last_insert_idÚ _warningsÚ_warning_countÚ _executedÚ_executed_listÚ_stored_resultsÚ_binaryrë Ú _rowcountÚ_nextrowÚ arraysizeÚ_stmt_partitionsÚ_stmt_partitionÚ_stmt_map_resultsr» r¼ r9 )rr Ú
|
connectionr r
s ri r÷ z MySQLCursorAbstract.__init__ð sº ð 5?ÔØ0:·±
|
Ø=AÔØ.2Ô Ø6:Ø#$ÔØ*.Ø+-ÔØ*,Ô Ø " Ø Ø ðL
|
ð ð ð Ô ð @DÔ Ø',Ô à,8ÔØ-:ÔØ ×Ñ×#Ñ# DÕ)ru c ó K | S wrf r~ rû s ri rü z MySQLCursorAbstract.__aenter__ s è ø Ø ùó c ó@ K | j « d { y 7 wrf rþ r s ri r z MySQLCursorAbstract.__aexit__ r r c ó K | S w)zIterate over result set.
|
|
Iteration over the result set which calls self.fetchone()
|
and returns the next row.
|
r~ rû s ri Ú __aiter__z MySQLCursorAbstract.__aiter__ s è ø ð ùr¾ c ó| K | j « d{ }|st |S 7 # t $ r t dw xY ww)zl
|
Used for iterating over the result set. Calls self.fetchone()
|
to get the next row.
|
N)r5 r8 ÚStopAsyncIteration)rr Úrows ri Ú __anext__z MySQLCursorAbstract.__anext__& sD è ø ð
|
/Ø ×'Cñ Ü$Ð $Ø
|
ð (ùÜ ò /Ü$¨$Ð .ð /üs <( &(
|
<¦( ¨9¹<c ó | j S )a´
|
Gets the cursor context's timeout in seconds for each attempt
|
to read any data from the server.
|
|
`read_timeout` is number of seconds upto which the connector should wait
|
for the server to reply back before raising an ReadTimeoutError. We can set
|
this option to None, which would signal the connector to wait indefinitely
|
till the read operation is completed or stopped abruptly.
|
r rû s ri r z MySQLCursorAbstract.read_timeout3 r ru c óV | t |t « r|dk r t d« || _ y)a
|
Sets or updates the cursor context's timeout in seconds for each attempt
|
to read any data from the server.
|
|
`read_timeout` is number of seconds upto which the connector should wait
|
for the server to reply back before raising an ReadTimeoutError. We can set
|
this option to None, which would signal the connector to wait indefinitely
|
till the read operation is completed or stopped abruptly.
|
|
Args:
|
timeout: Accepts a non-negative integer which is the timeout to be set
|
in seconds or None.
|
Raises:
|
InterfaceError: If a positive integer or None is not passed via the
|
timeout parameter.
|
Examples:
|
The following will set the read_timeout of the current session's cursor
|
context to 5 seconds:
|
```
|
>>> cnx = await mysql.connector.connect(user='scott')
|
>>> cur = await cnx.cursor()
|
>>> cur.read_timeout = 5
|
```
|
Nr r r r s ri r z MySQLCursorAbstract.read_timeout@ s4 ð4 Ð Ü g¤sÔ+¨w¸ª{Ü$ØLóð ð %Õru c ó | j S )a¬
|
Gets the cursor context's timeout in seconds for each attempt
|
to send data to the server.
|
|
`write_timeout` is number of seconds upto which the connector should spend to
|
write to the server before raising an WriteTimeoutError. We can set this option
|
to None, which would signal the connector to wait indefinitely till the write
|
operation is completed or stopped abruptly.
|
r rû s ri r
z!MySQLCursorAbstract.write_timeouta r ru c óV | t |t « r|dk r t d« || _ y)a
|
Sets or updates the cursor context's timeout in seconds for each attempt
|
to send data to the server.
|
|
`write_timeout` is number of seconds upto which the connector should spend to
|
write to the server before raising an WriteTimeoutError. We can set this option
|
to None, which would signal the connector to wait indefinitely till the write
|
operation is completed or stopped abruptly.
|
|
Args:
|
timeout: Accepts a non-negative integer which is the timeout to be set in
|
seconds or None.
|
Raises:
|
InterfaceError: If a positive integer or None is not passed via the
|
timeout parameter.
|
Examples:
|
The following will set the write_timeout of the current session's cursor
|
context to 5 seconds:
|
```
|
>>> cnx = await mysql.connector.connect(user='scott')
|
>>> cur = await cnx.cursor()
|
>>> cur.write_timeout = 5
|
```
|
Nr r r r s ri r
z!MySQLCursorAbstract.write_timeoutn s4 ð4 Ð Ü g¤sÔ+¨w¸ª{Ü$ØMóð ð &Õru c ó | j S )a Return description of columns in a result.
|
|
This property returns a list of tuples describing the columns in in a result
|
set. A tuple is described as follows:
|
|
(column_name,
|
type,
|
None,
|
None,
|
None,
|
None,
|
null_ok,
|
column_flags) # Addition to PEP-249 specs
|
|
Returns a list of tuples.
|
)r® rû s ri Ú descriptionz MySQLCursorAbstract.description s ð$ × Ñ Ð ru c ó | j S )aÓ Return the number of rows produced or affected.
|
|
This property returns the number of rows produced by queries such as a
|
SELECT, or affected rows when executing DML statements like INSERT or UPDATE.
|
|
Note that for non-buffered cursors it is impossible to know the number of rows
|
produced before having fetched them all. For those, the number of rows will
|
be -1 right after execution, and incremented when fetching rows.
|
)r¶ rû s ri Úrowcountz MySQLCursorAbstract.rowcount£ s ð ~~Ð ru c ó | j S )z Gets the value generated for an AUTO_INCREMENT column by the previous
|
INSERT or UPDATE statement or None when there is no such value available.
|
©r¯ rû s ri Ú lastrowidz MySQLCursorAbstract.lastrowid° s ð
|
×#Ñ#Ð#ru c ó | j S )zGets warnings.©r° rû s ri Úwarningsz MySQLCursorAbstract.warnings· ó ð ~~Ð ru rÓ r c ó | j S )zReturns Warnings.rÒ rû s ri Ú fetchwarningsz!MySQLCursorAbstract.fetchwarnings¼ rÔ ru c ó | j S )zReturn the number of warnings.
|
|
This property returns the number of warnings generated by the previously
|
executed operation.
|
)r± rû s ri Ú warning_countz!MySQLCursorAbstract.warning_countÁ rÔ ru c óf | j s
|
t « S t d | j D « « S )z[Returns column names.
|
|
This property returns the columns names as a tuple.
|
c 3 ó& K | ] }|d yw)r Nr~ )rg Úds ri rj z3MySQLCursorAbstract.column_names.<locals>.<genexpr>Ò s è ø Ò4aQqTÑ4ùs )rË rp rû s ri Ú column_namesz MySQLCursorAbstract.column_namesÊ s+ ð × Ò Ü7NÜÑ4 4×#3Ñ#3Ô4Ó4Ð4ru c óê | j y | j j « j d« S # t t f$ r+ t t | j j « « cY S w xY w)a Returns the latest executed statement.
|
|
When a multiple statement is executed, the value of `statement`
|
corresponds to the one that caused the current result set, provided
|
the statement-result mapping was enabled. Otherwise, the value of
|
`statement` matches the statement just as provided when calling
|
`execute()` and it does not change as result sets are traversed.
|
Nzutf-8)r² r Údecoder ÚUnicodeDecodeErrorr! rW rû s ri rv z MySQLCursorAbstract.statementÔ sc ð >>Ð !Øð 5Ø>>×'Ñ'Ó)×0Ñ0°Ó9Ð 9øÜ Ô 2Ð3ò 5ÜT^^× 1Ñ 1Ó 3Ó4Ò 4ð 5ús (8 ¸7A2Á1A2c ó, t | j « S )zÇReturns whether the cursor could have rows returned.
|
|
This property returns True when column descriptions are available and possibly
|
also rows, which will need to be fetched.
|
)rb r® rû s ri Ú with_rowsz MySQLCursorAbstract.with_rowså s ô D×%Ñ%Ó&Ð&ru c ó y)zÓReturns an iterator for stored results.
|
|
This method returns an iterator over results which are stored when callproc()
|
is called. The iterator will provide MySQLCursorBuffered instances.
|
Nr~ rû s ri Ústored_resultsz"MySQLCursorAbstract.stored_resultsî rv ru c ó K yw)a¢ Executes the given operation (a MySQL script) substituting any markers
|
with the given parameters.
|
|
For example, getting all rows where id is 5:
|
```
|
cursor.execute("SELECT * FROM t1 WHERE id = %s", (5,))
|
```
|
|
If you want each single statement in the script to be related
|
to its corresponding result set, you should enable the `map_results`
|
switch - see workflow example below.
|
|
If the given script uses `DELIMITER` statements (which are not recognized
|
by MySQL Server), the connector will parse such statements to remove them
|
from the script and substitute delimiters as needed. This pre-processing
|
may cause a performance hit when using long scripts. Note that when enabling
|
`map_results`, the script is expected to use `DELIMITER` statements in order
|
to split the script into multiple query strings.
|
|
The following characters are currently not supported by the connector in
|
`DELIMITER` statements: `"`, `'`, #`, `/*` and `*/`.
|
|
If warnings were generated, and `connection.get_warnings` is
|
`True`, then `self.warnings` will be a list containing these
|
warnings.
|
|
Args:
|
operation: Operation to be executed - it can be a single or a
|
multi statement.
|
params: The parameters found in the tuple or dictionary params are bound
|
to the variables in the operation. Specify variables using `%s` or
|
`%(name)s` parameter style (that is, using format or pyformat style).
|
map_results: It is `False` by default. If `True`, it allows you to know what
|
statement caused what result set - see workflow example below.
|
Only relevant when working with multi statements.
|
|
Returns:
|
`None`.
|
|
Example (basic usage):
|
The following example runs many single statements in a
|
single go and loads the corresponding result sets
|
sequentially:
|
|
```
|
sql_operation = '''
|
SET @a=1, @b='2024-02-01';
|
SELECT @a, LENGTH('hello'), @b;
|
SELECT @@version;
|
'''
|
async with await cnx.cursor() as cur:
|
await cur.execute(sql_operation)
|
|
result_set = await cur.fetchall()
|
# do something with result set
|
...
|
|
while (await cur.nextset()):
|
result_set = await cur.fetchall()
|
# do something with result set
|
...
|
```
|
|
In case the operation is a single statement, you may skip the
|
looping section as no more result sets are to be expected.
|
|
Example (statement-result mapping):
|
The following example runs many single statements in a
|
single go and loads the corresponding result sets
|
sequentially. Additionally, each result set gets related
|
to the statement that caused it:
|
|
```
|
sql_operation = '''
|
SET @a=1, @b='2024-02-01';
|
SELECT @a, LENGTH('hello'), @b;
|
SELECT @@version;
|
'''
|
async with await cnx.cursor() as cur:
|
await cur.execute(sql_operation, map_results=True)
|
|
# statement 1 is `SET @a=1, @b='2024-02-01'`,
|
# result set from statement 1 is `[]` - aka, an empty set.
|
result_set, statement = await cur.fetchall(), cur.statement
|
# do something with result set
|
...
|
|
# 1st call to `nextset()` will laod the result set from statement 2,
|
# statement 2 is `SELECT @a, LENGTH('hello'), @b`,
|
# result set from statement 2 is `[(1, 5, '2024-02-01')]`.
|
#
|
# 2nd call to `nextset()` will laod the result set from statement 3,
|
# statement 3 is `SELECT @@version`,
|
# result set from statement 3 is `[('9.0.0-labs-mrs-8',)]`.
|
#
|
# 3rd call to `nextset()` will return `None` as there are no more sets,
|
# leading to the end of the consumption process of result sets.
|
while (await cur.nextset()):
|
result_set, statement = await cur.fetchall(), cur.statement
|
# do something with result set
|
...
|
```
|
|
In case the mapping is disabled (`map_results=False`), all result
|
sets get related to the same statement, which is the one provided
|
when calling `execute()`. In other words, the property `statement`
|
will not change as result sets are consumed, which contrasts with
|
the case in which the mapping is enabled. Note that we offer a
|
new fetch-related API command which can be leveraged as a shortcut
|
for consuming result sets - it is equivalent to the previous
|
workflow.
|
|
```
|
sql_operation = '''
|
SET @a=1, @b='2024-02-01';
|
SELECT @a, LENGTH('hello'), @b;
|
SELECT @@version;
|
'''
|
async with await cnx.cursor() as cur:
|
await cur.execute(sql_operation, map_results=True)
|
async for statement, result_set in cur.fetchsets():
|
# do something with result set
|
```
|
Nr~ ©rr Ú operationÚparamsÚ map_resultss ri r4 zMySQLCursorAbstract.executeö rë rì c ó K yw)aÈ Executes the given operation (it can be a multi statement
|
or a MySQL script) substituting any markers with the given parameters.
|
|
**NOTE: `executemulti()` is deprecated and will be removed in a
|
future release. Use `execute()` instead.**
|
|
If you want each single statement in the script to be related
|
to its corresponding result set, you should enable the `map_results`
|
switch - see workflow example below. This capability reduces performance.
|
|
**Unexpected behavior might happen if your script includes the following
|
symbols as delimiters `"`, `'`, `#`, `/*` and `*/`. The use of these should
|
be avoided for now**.
|
|
Refer to the documentation of `execute()` to see the multi statement execution
|
workflow.
|
|
Args:
|
operation: Operation to be executed - it can be a single or a
|
multi statement.
|
params: The parameters found in the tuple or dictionary params are bound
|
to the variables in the operation. Specify variables using `%s` or
|
`%(name)s` parameter style (that is, using format or pyformat style).
|
map_results: It is `False` by default. If `True`, it allows you to know what
|
statement caused what result set - see workflow example below.
|
Only relevant when working with multi statements.
|
|
Returns:
|
`None`.
|
Nr~ rå s ri Ú executemultiz MySQLCursorAbstract.executemultiz rë rì c ó K yw)a= Prepare and execute a MySQL Prepared Statement many times.
|
|
This method will prepare the given operation and execute with each tuple found
|
the list seq_params.
|
|
If the cursor instance already had a prepared statement, it is first closed.
|
|
executemany() simply calls execute().
|
Nr~ )rr ræ Ú
|
seq_paramss ri Ú executemanyz MySQLCursorAbstract.executemany rë rì c ó K yw)zÆReturn next row of a query result set.
|
|
Raises:
|
InterfaceError: If there is no result to fetch.
|
|
Returns:
|
tuple or None: A row from query result set.
|
Nr~ rû s ri r5 z MySQLCursorAbstract.fetchone° rë rì c ó K yw)zÖReturn all rows of a query result set.
|
|
Raises:
|
InterfaceError: If there is no result to fetch.
|
|
Returns:
|
list: A list of tuples with all rows of a query result set.
|
Nr~ rû s ri Úfetchallz MySQLCursorAbstract.fetchall» rë rì c ó K yw)a< Return the next set of rows of a query result set.
|
|
When no more rows are available, it returns an empty list.
|
The number of rows returned can be specified using the size argument, which
|
defaults to one.
|
|
Returns:
|
list: The next set of rows of a query result set.
|
Nr~ )rr Úsizes ri Ú fetchmanyz MySQLCursorAbstract.fetchmanyÆ rë rì c óØ K d}| j s | j } | j « d{ }| j r | j n||f | j « d{ rR | j « d{ }| j r | j n||f | j « d{ rQyy7 # t $ r g }Y w xY w7 j7 S# t $ r g }Y ^w xY w7 /w)aÙ Generates the result sets stream caused by the last `execute*()`.
|
|
Returns:
|
A 2-tuple; the first element is the statement that caused the
|
result set, and the second is the result set itself.
|
|
Example:
|
Consider the following example where multiple statements are executed in one
|
go:
|
|
```
|
sql_operation = '''
|
SET @a=1, @b='2024-02-01';
|
SELECT @a, LENGTH('hello'), @b;
|
SELECT @@version;
|
'''
|
async with await cnx.cursor() as cur:
|
await cur.execute(sql_operation, map_results=True)
|
|
result_set, statement = await cur.fetchall(), cur.statement
|
# do something with result set
|
...
|
|
while (await cur.nextset()):
|
result_set, statement = await cur.fetchall(), cur.statement
|
# do something with result set
|
...
|
```
|
|
In this case, as an alternative to loading the result sets with `nextset()`
|
in combination with a `while` loop, you can use `fetchsets()` which is
|
equivalent to the previous approach:
|
|
```
|
sql_operation = '''
|
SET @a=1, @b='2024-02-01';
|
SELECT @a, LENGTH('hello'), @b;
|
SELECT @@version;
|
'''
|
async with await cnx.cursor() as cur:
|
await cur.execute(sql_operation, map_results=True)
|
async for statement, result_set in cur.fetchsets():
|
# do something with result set
|
```
|
N)r» rv rð r8 Únextset)rr Ústatement_cachedÚ
|
result_sets ri Ú fetchsetsz MySQLCursorAbstract.fetchsetsÒ sç è ø ðh ÐØ×%Ò%Ø #~~Ð ð Ø #}}×.Jð #× 4Ò 4DNNÐ:JØ ðó ð LLN×"Ð"ð Ø#'§=¡=£?× 2
|
ð #'×"8Ò"8Ð>NØðó ð LLN×"Ó"ð /ùÜ ò ØJð úð
|
#øà 2ùÜ!ò Ø
|
ð úð #ús C*C ±C ²C ¶2C*Á(CÁ)C*Á.C ÂCÂC Â2C*Â8C(Â9C*Â>C*Ã C Ã CÃ C*ÃCÃC*ÃC Ã C%Ã"C*Ã$C%Ã%C*c ó K yw)aK Makes the cursor skip to the next available set, discarding
|
any remaining rows from the current set.
|
|
This method should be used as part of the multi statement
|
execution workflow - see example below.
|
|
Returns:
|
It returns `None` if there are no more sets. Otherwise, it returns
|
`True` and subsequent calls to the `fetch*()` methods will return
|
rows from the next result set.
|
|
Example:
|
The following example runs many single statements in a
|
single go and loads the corresponding result sets
|
sequentially:
|
|
```
|
sql_operation = '''
|
SET @a=1, @b='2024-02-01';
|
SELECT @a, LENGTH('hello'), @b;
|
SELECT @@version;
|
'''
|
async with await cnx.cursor() as cur:
|
await cur.execute(sql_operation)
|
|
result_set = await cur.fetchall()
|
# do something with result set
|
...
|
|
while (await cur.nextset()):
|
result_set = await cur.fetchall()
|
# do something with result set
|
...
|
```
|
|
In case the operation is a single statement, you may skip the
|
looping section as no more result sets are to be expected.
|
Nr~ rû s ri rõ zMySQLCursorAbstract.nextset
|
rë rì c ó K yw)zClose the cursor.Nr~ rû s ri rÿ zMySQLCursorAbstract.closeC
|
rë rì rÐ c ó | j S )z·Return the value generated for an AUTO_INCREMENT column.
|
|
Returns the value generated for an AUTO_INCREMENT column by the previous
|
INSERT or UPDATE statement.
|
rÏ rû s ri Ú getlastrowidz MySQLCursorAbstract.getlastrowidG
|
s ð ×#Ñ#Ð#ru c ó K yw)z Reset the cursor to default.Nr~ )rr Úfrees ri ÚresetzMySQLCursorAbstract.resetP
|
rë rì c óH t | d« r| j j S y)zGets a list of query attributes from the connector's side.
|
|
Returns:
|
List of existing query attributes.
|
r N)Úhasattrr r¬ rû s ri Úget_attributesz"MySQLCursorAbstract.get_attributesS
|
s# ô 4 Ô 'Ø×#Ñ#×/Ñ/Ð /Øru c ó¶ t |t « s t d« | t |t « st d| d« | j j ||f« y)aþ Add a query attribute and its value into the connector's query attributes.
|
|
Query attributes must be enabled on the server - they are disabled by default. A
|
warning is logged when setting query attributes for a server connection
|
that does not support them.
|
|
Args:
|
name: Key name used to identify the attribute.
|
value: A value converted to the MySQL Binary Protocol.
|
|
Raises:
|
ProgrammingError: If the value's conversion fails.
|
ú&Parameter `name` must be a string typeNzObject z$ cannot be converted to a MySQL type)r! rW r; r& r r( )rr r rC s ri Ú add_attributez!MySQLCursorAbstract.add_attribute]
|
s] ô $¤Ô$Ü"Ð#KÓLÐ LØ Ð ¤Z°´~Ô%FÜ"Ø%Ð DÐEóð ð ×Ñ×+Ñ+¨T°5¨MÕ:ru c ón t |t « s t d« | j j |« S )a' Removes a query attribute by name from the connector's query attributes.
|
|
If no match, `None` is returned, else the corresponding value is returned.
|
|
Args:
|
name: Key name used to identify the attribute.
|
|
Returns:
|
value: Attribute's value.
|
r )r! rW r; r r+ r* s ri Úremove_attributez$MySQLCursorAbstract.remove_attributes
|
s1 ô $¤Ô$Ü"Ð#KÓLÐ LØ× Ñ ×2Ñ2°4Ó8Ð8ru c ó8 | j j « y)z<Clears the list of query attributes on the connector's side.N)r r- rû s ri Úclear_attributesz$MySQLCursorAbstract.clear_attributes
|
s à ×Ñ×*Ñ*Õ,ru r¡ )r¼ r r r r
r )rw r r r )rw zIterator[RowType])rw rF r r )rw r¥ r )rw zOptional[List[WarningType]])rw zTuple[str, ...]r r )rw z Iterator[MySQLCursorAbstract])r~ F)ræ rW rç z$Union[Sequence[Any], Dict[str, Any]]rè rb rw rx )ræ rW rì z Sequence[ParamsSequenceType]rw rx )rw r¤ )rw z List[RowType]r§ )rò rU rw zList[Sequence[Any]])rw z9AsyncGenerator[tuple[Optional[str], list[RowType]], None])rw r )T)rþ rb rw r )rw z.Optional[List[Tuple[str, BinaryProtocolType]]])r rW rC r> rw rx r£ rv )*ry rz r{ r| r÷ rü r rÁ rÅ r© r rª r
rË rÍ rÐ rÓ r# r. r- rÖ rØ rÜ rv rá r rã r4 rê rí r5 rð ró rø rõ rÿ rü rÿ r r r r r~ ru ri r r í s" Ù-ð
|
'+Ø'+ð !*à+ð!*ð $ð!*ð %ó !*óFð
|
37Ø-1Ø-1ð à/ðð +ðð +ð ð
|
|
ó óó ð ò
|
"ó ð
|
"ð ×Ñò %ó ð %ð@ ò
|
#ó ð
|
#ð ×Ñò &ó ð &ð@ ò!ó ð!ð& ò
|
ó ð
|
ð ò$ó ð$ð ò ó ð ñ Ð0Ð)×0Ñ0¸zÔJÓKò ó Lð ð ò#ó ð#ð ò5ó ð5ð ò5ó ð5ð ò'ó ð'ð ò ó ð ð ð 8:Ø !ð A àðA ð 5ðA ð ð A ð
|
|
ò A ó ðA ðF ð 8:Ø !ð # àð# ð 5ð# ð ð # ð
|
|
ò # ó ð# ðJ ð àð ð 1ð ð
|
ò ó ð ð ò ó ð ð ò ó ð ð ó ó ð ðFà BóFðP ò& ó ð& ðP ò ó ð ñ Ð0Ð)×0Ñ0¸{ÔKÓLò$ó Mð$ô+óó;ó, 9ô -ru r c ó e Zd ZdZy)ÚCMySQLPrepStmtaP Structure to represent a result from `CMySQLConnection.cmd_stmt_prepare`.
|
It can be used consistently as a type hint.
|
|
`_mysql_connector.MySQLPrepStmt` isn't available when the C-ext isn't built.
|
|
In this regard, `CmdStmtPrepareResult` acts as a proxy/wrapper entity for a
|
`_mysql_connector.MySQLPrepStmt` instance.
|
N)ry rz r{ r| r~ ru ri r r
|
s òru r )hr| Ú
|
__future__r Úmysql.connector.optionfilesr Ú__all__rÕ r rm rÛ Úabcr r Ú dataclassesr
|
r Úinspectr Útypesr Útypingr r r r r r r r r r r r r r r r r r r r! Ú _decoratingr# Ú abstractsr$ r% r& r' r( r) r* r+ Ú constantsr, r- r. r/ r0 r1 r2 r3 r4 Ú
|
conversionr5 r6 Úerrorsr7 r8 r9 r: r; Ú tls_ciphersr< r= r> r? r@ rA rB rC rD rE rF rG rH rI ÚutilsrJ rK ÚauthenticationrM rO rN rV rP ÚnetworkrQ rR r r© r r r r r~ ru ri ú<module>r s ðñ@ 2å "å 9â
|
Jã Û Û Û ç #ß (Ý Ý ÷÷ ÷ ÷ ÷ ó õ. %÷ ÷ ó ÷
|
÷
|
õ
|
÷ <÷õ ÷ S÷ ÷ ÷ ó ÷ 2Ý .ß 'Ý #áß8ð 77gÑ ð ÷ %ð %ó ð %ôDF cô F ôR:W
|
-#ô W
|
-ôt^õ ru
|
