G)f;dUdZddlmZgdZddlZddlZddlZddlZddlZddl m Z m Z ddl m Z mZddlmZddlmZdd lmZmZmZmZmZmZmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#d d l$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+d d l,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3d d l4m5Z5m6Z6d dl7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFmGZGd dlHmIZImJZJddlKmLZLddlMmNZNmMZMddlOmPZPerddlQmRZRmSZSejdk(ZUejZWdeXd<e GddZYGdde ZZGdde Z[Gdd eIZ\y)!z+Module gathering all abstract base classes.) annotations)MySQLConnectionAbstractMySQLCursorAbstract ServerInfoN)ABCabstractmethod) dataclassfield) signature) TracebackType) TYPE_CHECKINGAnyAsyncGeneratorBinaryIOCallableDict GeneratorIteratorListMappingNoReturnOptionalSequenceTupleTypeUnion)DUPLICATED_IN_LIST_ERRORKRB_SERVICE_PINCIPAL_ERRORMYSQL_PY_TYPESTLS_V1_3_SUPPORTEDTLS_VER_NO_SUPPORTEDTLS_VERSION_DEPRECATED_ERRORTLS_VERSION_ERROR) CONN_ATTRS_DNDEFAULT_CONFIGURATIONDEPRECATED_TLS_VERSIONSOPENSSL_CS_NAMESTLS_CIPHER_SUITES TLS_VERSIONS ClientFlag)MySQLConverterMySQLConverterBase)ErrorInterfaceError InternalErrorNotSupportedErrorProgrammingError) BinaryProtocolTypeDescriptionType EofPacketType HandShakeType OkPacketTypeParamsSequenceType ResultTypeRowTypeStatsPacketType StrOrBytes WarningType)GenericWrapper import_object)MySQLAuthenticator)Charsetcharsets) MySQLProtocol)MySQLTcpSocketMySQLUnixSocketposixz%weakref.WeakValueDictionary[Any, Any]NAMED_TUPLE_CACHEceZdZUdZded<ded<edZded <ded <ded <ded <ded <ded<ded<dZded<ddZy)rzStores the server information retrieved on the handshake. Also parses and validates the server version, storing it as a tuple. intprotocolstrversionF)initzTuple[int, ...] version_tuple thread_idcharset status_flags auth_pluginbytes auth_data capabilitiesboolquery_attrs_is_supportedctjd}|j|j}|s t dt d|j ddD}|dkrt d|jd||_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})(.*)zFailed parsing MySQL versionc32K|]}t|ywN)rJ).0vs Z/var/www/html/flask-app/venv/lib/python3.12/site-packages/mysql/connector/aio/abstracts.py z+ServerInfo.__post_init__..s<1AZ3dsd?Z4edud@Z5edudAZ6e d ddBZ7ddCZ8ddDZ9ddEZ:ddFZ;dmdGZddJZ?ddKZ@ddLZAedmdMZBdddNZCddOZDedmdPZEeEZFdQeGdR<e d ddSZHe d ddTZIe d ddUZJedmdVZKedmdWZLedudXZMeddYZNe d ddZZO dd[ZPeddd\ZQe dd]ZRe d dd^ZSedd_ZTedd`ZUeddaZV ddbZWeddcZXeddddZYeddeZZeddfZ[eddgZ\eddhZ]y)rz'Defines the MySQL connection interface.Nz 127.0.0.1i Fallow_local_infileallow_local_infile_in_pathconnect_timeout ssl_disabled))userpasswordhostportdatabase password1 password2 password3rQ collationrS client_flagscompressconsume_results autocommit time_zone conn_attrssql_mode init_command get_warningsraise_on_warningsbufferedrawkerberos_auth_modekrb_service_principal fido_callbackwebauthn_callbackrvrwconverter_classconverter_str_fallbackconnection_timeout unix_socketssl_cassl_certssl_keyssl_verify_certssl_verify_identityry tls_versionsloopc)||_||_||_||_||_||_||_||_|!|_| |_ ||_ | |_ ||_ ||_ ||_||_||_t#|_d|_d|_| |_| |_d|_|'|_|"|_|#|_|$|_|%|_|&|_|(|_g|_| |_ d|_!d|_"|)xstGjH|_%| xstMjN|_(|tSjT|_+i|_,d|_-g|_.t_|_0|xstb|_2||_3||_4||_5||_6||_7||_8||_9||_:||_;d|_<d|_=d|_>d|_?d|_@d|_A||_B||_Cd|_D|jy)NFT)F_user _password_host_port _database _password1 _password2 _password3 _unix_socket_connection_timeout_connection_attrs _compress_consume_results _autocommit _time_zone _sql_mode _init_commandrD _protocol_socket_charset _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 _handshakeasyncioget_event_loop_loopr+ get_default _client_flagsweakrefWeakSet_cursors _query_attrs_query_attrs_supported _columns_descrA_authenticatorr,_converter_class_converter_str_fallback_kerberos_auth_mode_krb_service_principal_allow_local_infile_allow_local_infile_in_path _get_warningsr _buffered_raw_have_next_result_unread_result _use_unicode_in_transaction_oci_config_file_oci_config_profile_fido_callback_webauthn_callback converter_validate_connection_options)*rgrzr{r|r}r~rrrrQrrSrrrrrrrrrrrrrrrrrvrwrrrrrrrrrryrrs* r^__init__z MySQLConnectionAbstract.__init__s^ &  &(((!,(: 1;'&5!+)2(0,8(5IM +/ ,31:!&#/&, (0'. 0?4G!2>68+61537  ,G**, #/"J*2H2H2J )0): ;=+0#462D2F6E6W-C$2D 5J#); :T(#/'8' ',$)"&%*/326 KX  48 ))+rjcbK|js|jd{|S7wr[)is_socket_connectedconnectrgs r^ __aenter__z"MySQLConnectionAbstract.__aenter__s+''),,.   !s $/-/c@K|jd{y7wr[closergexc_type exc_value tracebacks r^ __aexit__z!MySQLConnectionAbstract.__aexit__ jjl c |jr |jj|_|jr |j t j g|jrtjj|j}|r>tjj|rtjj|rtjj|r td|js |jr!|j t jgn!|j t j g|j dk(rt#d|j d|j$rtj&dk(rd|_|j(r|j d k(r t#d t+|j,t.s t#d t1|j2|j4|j6grt9|j6|j4gs td |j6du|j4duk7r td |j:r|j=|j>r|jAt+|jBtDs t#d|jBjGD]\}}|tHvrt+|tJst#d|d|jBdtM|dkDrt#d|d|jOdr t#dt+|tJst#d|d|dtM|dkDst#d|d|d|jPt jRzr|jU|jVrt+|jVtJs t#d|jVjY}|dk(r&tj&dk7r t#dd|_-n|d k(rd!|_-n t#d"|j\rt+|j\tJst#t_j`d#$|j\d%k(rt#t_j`d&$d'|j\vrt#t_j`d($|jbr9d)}tejf|th|jkd*|jbd+|jlr|jkd,|jld+yy#t$r}td|d}~wwxYw)-zValidate connection options.z'user' must be a stringNz.allow_local_infile_in_path must be a directoryauthentication_webauthn_client'z5' cannot be used as the default authentication pluginrGTmysql_clear_passwordzFClear password 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 neitherzconn_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 typeiz$' exceeds 1024 characters limit sizez('kerberos_auth_mode' must be of type strsspintz6'kerberos_auth_mode=SSPI' is only available on WindowsMySQLSSPIKerberosAuthPlugingssapiMySQLKerberosAuthPluginz@Invalid 'kerberos_auth_mode' mode. Please use 'SSPI' or 'GSSAPI'zis not a string)errorruzcan not be an empty string/zis incorrectly formattedzThe `fido_callback` connection argument is deprecated and it will be removed in a future release of MySQL Connector/Python. Use `webauth_callback` insteadrr@webauth_callback)7rstripAttributeErrorrset_client_flagsr+COMPRESSrospathabspathexistsisdirislinkr LOCAL_FILESrr/rnamer isinstancerrJanyrrrallr_validate_tls_versionsr_validate_tls_ciphersuitesrdictitemsr%rLlen startswithr CONNECT_ARGS_add_default_conn_attrsrlowerrrrformatrwarningswarnDeprecationWarning_validate_callabler)rgerrinfile_in_path attr_name attr_valuerwarn_msgs r^rz4MySQLConnectionAbstract._validate_connection_optionss  :: I!ZZ--/  >>  ! !:#6#6"7 8  + +WW__T-M-MNNGGNN>2 n577>>.1$%UVV  # #t'G'G  ! !:#9#9": ;  ! !J$:$:#:"; <    @ @ D%%&'    G!3!%D    $"3"37M"M   $**c* !JK K  dnndmm< = t~~67$P %4>>T+AB$J!!++-%%//1$00$7 !BC C%)%;%;%A%A%C  !IzM)i-$!{&)?)?(@C 9~"$&yk1ST##C($0 j#.$!)JzlC'' :%$!)JzlC999 B    7 7 7  ( ( *  # #d66<$%OPP!%!9!9!?!?!A !V+77d?(P+H'#x/*C'$V  & &d993?$.55?SH IsU%% U?. U::U?cg}|j}t|tr|jdr|j dst d|d|ddj d}|s t d|D]4}|jj}|s$|j|6n8t|ttfr|Dcgc]}|s| }}nt d |d|j td d n|jd d }|jd |d }ggg}i}g} td tj|dzD]2} |j!t"| | j%t&| 4|D]} d| vr9| | vr5| t&dvr|dj| +|d j| @| |vrd|| } | |vr t t)j*d| | t"dvr|dj|| |d j|| t d| d|d s|ds t ddj-|d dj-|dg|_y cc}w)z&Validates the tls_ciphersuites option.[]z)tls_ciphersuites must be a list, found: 'rr@,z6No valid cipher suite found in 'tls_ciphersuites' listzItls_ciphersuites should be a list with one or more ciphersuites. Found: 'NT)reverser-TLSv1.3tls_ciphersuiteslistvaluez The value 'z1' in tls_ciphersuites is not a valid cipher suitez:No valid cipher suite found in the 'tls_ciphersuites' list:)rr rLrendswithrsplitrupperappendr*setrr*sortindexupdater)extendr(rrjoin) rgr(tls_cstls_css_tls_csr newer_tls_vertranslated_namesiani_cipher_suites_namesossl_cipher_suites_namestls_verr translated_names r^rz2MySQLConnectionAbstract._validate_tls_ciphersuitess'' fc "%%c*vs/C$?xqIQrl((-G$L# 5 ,,...0$++G4 5 s ,5;F6vF F ))/3  $119LOt?Q?QRS?T  $'$Q .0H#% .0 $$Kl&8&8&G!&KL GG $ + +,=g,F G $ + +, L  HH%a( ) HH%a( )" o Gs I7 I7cg}|j}t|tr|jdr|j dst d|d|ddj d}|D]M}|j}|dk(r||vr t tjd | |j|O|d gk(rtst tj|tt|trJ|s t d |D]7}||vr t tjd | |j|9nNt|tr|D]}|j|n%t d dj!td|d|s t dg}g}g}|D]F}|tvr|j||t"vr|j|6|j|H|rG|d gk(r)ts#t%tj|t|j'||_y|r#t%t)j|t|r#t t+jty)z"Validates the tls_versions option.r!r"z%tls_versions must be a list, found: 'rr@r#r$rurr)r'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)rr rLrr-rr.rrrr0r!r"r*r*r1r6r'r1r2r#r$)rgr tls_versiontls_versr>use_tls_versionsdeprecated_tls_versionsinvalid_tls_versionss r^r z.MySQLConnectionAbstract._validate_tls_versionss (( k3 '**3/K4H4H4M$;K=J#1R(..s3H# 1%mmo "$,.(077!/{ ##K0 1I;&/A$(// \J T *$*' -l*(077!/w ##G, - S )& -##G, -!ii -.jaI   C  "$!# 5G,& ''011'..w7$++G4  5 I;.7I'(// \J  ! ! #!1D  $#,33+\  " !2!9!9'{m1#MN N8,778  !"K= H:6))3 6  " :&#0c9 :s A// B 8 BB cy)zMySQL connection ID.Nrsrs r^ connection_idz%MySQLConnectionAbstract.connection_idvrjc|jS)z$User used while connecting to MySQL.)rrs r^rzzMySQLConnectionAbstract.user{zzrjc|jS)z MySQL server IP address or name.)rrs r^ server_hostz#MySQLConnectionAbstract.server_hostrRrjc|jS)zMySQL server TCP/IP port.)rrs r^ server_portz#MySQLConnectionAbstract.server_portrRrjc|jS)z MySQL Unix socket file location.)rrs r^rz#MySQLConnectionAbstract.unix_sockets   rjctd)Get the current database.zoThe use of async properties are not supported by Python. Use `await get_database()` to get the database insteadr2rs r^r~z MySQLConnectionAbstract.databases E  rjctd)Set the current database.zsThe use of async properties are not supported by Python. Use `await set_database(name)` to set the database insteadrZrgr+s r^r~z MySQLConnectionAbstract.database I  rjcJK|jdd{}|dS7 w)rYzSELECT DATABASE()Nr info_query)rgresults r^ get_databasez$MySQLConnectionAbstract.get_databases'':;;ay< #! #cHK|jd|d{y7w)r\zUSE N) cmd_queryr]s r^ set_databasez$MySQLConnectionAbstract.set_databasesnntE7^,,,s " "c|jS)z"Returns whether to consume results)rrs r^can_consume_resultsz+MySQLConnectionAbstract.can_consume_resultss$$$rjc6t|tsJ||_y)zSet if can consume results.N)r rWrr]s r^riz+MySQLConnectionAbstract.can_consume_resultss%&& %rjc|jS)z(MySQL session has started a transaction.)rrs r^in_transactionz&MySQLConnectionAbstract.in_transactions###rjc|jS)zReturn the event loop.)rrs r^rzMySQLConnectionAbstract.looprRrjcJ|jxs|jduxrtS)z&Return True if is a secure connection.N)rrIS_POSIXrs r^ is_securez!MySQLConnectionAbstract.is_secures%OD$5$5T$A$NhOrjcHt|jjS)zReturns query attributes list.)r*rrrs r^ query_attrsz#MySQLConnectionAbstract.query_attrssD%%++-..rjc|jS)zReturn if have next result.)rrs r^have_next_resultz(MySQLConnectionAbstract.have_next_results%%%rjctd)$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 insteadrZrs r^rz"MySQLConnectionAbstract.autocommitr^rjctd)Toggle autocommit.zxThe use of async properties are not supported by Python. Use `await set_autocommit(value)` to set the autocommit insteadrZr]s r^rz"MySQLConnectionAbstract.autocommit N  rjcPK|jdd{}|ddk(S7 w)rvzSELECT @@session.autocommitNrr@r`r]s r^get_autocommitz&MySQLConnectionAbstract.get_autocommits,oo&CDDQx1}Es &$ &cbK|rdnd}|jd|d{||_y7 w)rxONOFFzSET @@session.autocommit = N)rfr)rgr+switchs r^set_autocommitz&MySQLConnectionAbstract.set_autocommits7Enn:6(CDDD  Es /- /ctd)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 insteadrZrs r^rz!MySQLConnectionAbstract.time_zones G  rjctd)Sets the time zone.zxThe use of async properties are not supported by Python. Use `await get_autocommit(value)` to get the autocommit insteadrZr]s r^rz!MySQLConnectionAbstract.time_zoneryrjcJK|jdd{}|dS7 w)rzSELECT @@session.time_zoneNrr`r]s r^ get_time_zonez%MySQLConnectionAbstract.get_time_zones'oo&BCCQxDrdcXK|jd|dd{||_y7 w)rzSET @@session.time_zone = 'rN)rfrr]s r^ set_time_zonez%MySQLConnectionAbstract.set_time_zones/nn:5'CDDD Es *( *c Ktdw)Gets the SQL mode.zoThe use of async properties are not supported by Python. Use `await get_sql_mode()` to get the SQL mode insteadrZrs r^rz MySQLConnectionAbstract.sql_modes E   c Ktdw)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 insteadrZr]s r^rz MySQLConnectionAbstract.sql_mode s J  rcK|j!|jdd{d|_|jS7w)rNzSELECT @@session.sql_moder)rrars r^ get_sql_modez$MySQLConnectionAbstract.get_sql_modes: >> !$(OO4O$PPRSTDN~~Qs !><>cKt|ttfrdj|}|j d|dd{||_y7 w)rr$zSET @@session.sql_mode = 'rN)r r*rer6rfrr]s r^ set_sql_modez$MySQLConnectionAbstract.set_sql_mode"sL edE] +HHUOEnn9%BCCC DsAAA Ac|jS)zGet whether this connection retrieves warnings automatically. This method returns whether this connection retrieves warnings automatically. )rrs r^rz$MySQLConnectionAbstract.get_warnings4s !!!rjcHt|ts td||_y)aSet 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 rWrGrr]s r^rz$MySQLConnectionAbstract.get_warnings<s"%&67 7"rjc|jS)zGet whether this connection raises an error on warnings. This method returns whether this connection will raise errors when MySQL reports warnings. )_raise_on_warningsrs r^rz)MySQLConnectionAbstract.raise_on_warningsJs&&&rjc\t|ts td||_|r||_yy)aSet 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. rN)r rWrGrrr]s r^rz)MySQLConnectionAbstract.raise_on_warningsSs2%&67 7"' !&D  rjc|jS)zGet whether there is an unread result. This method is used by cursors to check whether another cursor still needs to retrieve its result set. )rrs r^ unread_resultz%MySQLConnectionAbstract.unread_resulth"""rjcHt|ts td||_y)zSet 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. rN)r rWrGrr]s r^rz%MySQLConnectionAbstract.unread_resultqs"%&67 7#rjcJ|jr|jjSdS)aReturn 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. utf8rr rs r^rQzMySQLConnectionAbstract.charsets&*]]t}}!!>>rjcx|j|jjdvry|jjS)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. )utf8mb4utf8mb3binaryrrrs r^python_charsetz&MySQLConnectionAbstract.python_charsets9 == DMM$6$6; % }}!!!rjcy)z&Add the default connection attributes.Nrsrs r^rz/MySQLConnectionAbstract._add_default_conn_attrsrPrjc Kyw)zExecute 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. Nrs)rgquerys r^_execute_queryz&MySQLConnectionAbstract._execute_querycK|j|jjd{|j|jd{|j r#|j |j d{|jr#|j|jd{|jr$|j|jd{yy777h7;7w)zExecutes 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. N) set_charset_collationr charset_idrrrrrrrrrs r^_post_connectionz(MySQLConnectionAbstract._post_connections(()A)ABBB!!$"2"2333 ??$$T__5 5 5 >>##DNN3 3 3   %%d&8&89 9 9  C3 5 3 9sW)C,C""C,C$.C,=C&>.C,,C(-.C,C*C,$C,&C,(C,*C,cKd}t|ttfs|t|j dt|ts | td|rO|rMt|trt j |jn|}t j|||_ n|rpt|trt j ||_ nt|trt j||_ nZt|j d|rt j||_ n#td}t j||_ |jj|_ |jj|_|j!d|jjd|jjdd{ |j#|jj|j&r0|j&j)|jjyy7g#t$$rYJwxYww)aSet 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 NoneNrQz)collation should be either string or Nonez SET NAMES 'z ' COLLATE 'r)r rJrLrGrrC get_by_idr get_by_name_and_collationr get_by_nameget_by_collationr&rrrrfset_character_set_namerr set_charset)rgrQrerr_msg charset_strs r^rz-MySQLConnectionAbstract.set_charset_collations2@'C:.73FW^^I67 7)S)i.CHI I ygs+""7+00  %>>{IVDM '3' ( 2 27 ; GS) ( 4 4W =   !:;; $55i@DM+I6G$009DM!]]//"&--"9"9nn$--,,-[9P9P8QQR S      ' ' (:(: ; >> NN & &t}}'9'9 :     s6GI H8I %H:;>I : II II c&|j|zdkDS)z|Checks if a client flag is set. Returns: `True` if the client flag was set, `False` otherwise. r)r)rgflags r^isset_client_flagz)MySQLConnectionAbstract.isset_client_flags ""T)Q..rjc||_y)zySet the path that user can upload files. Args: path (str): Path that user can upload files. N)r)rgrs r^set_allow_local_infile_in_pathz6MySQLConnectionAbstract.set_allow_local_infile_in_paths ,0(rjc|S)zReturn self for weakref.proxy. This method is used when the original object is needed when using weakref.proxy. rsrs r^get_selfz MySQLConnectionAbstract.get_self s  rjc.|jjS)zGets the MySQL version. Returns: The MySQL server version as a tuple. If not previously connected, it will return `None`. ) _server_inforMrs r^get_server_versionz*MySQLConnectionAbstract.get_server_versions  (((rjcL |jdS#ttf$rYywxYw)zGets the original MySQL version information. Returns: The original MySQL server as text. If not previously connected, it will return `None`. server_version_originalN)r TypeErrorKeyErrorrs r^get_server_infoz'MySQLConnectionAbstract.get_server_infos. ??#<= =8$  s ##cy)zReports whether the socket is connected. Instead of ping the server like ``is_connected()``, it only checks if the socket connection flag is set. Nrsrs r^rz+MySQLConnectionAbstract.is_socket_connected(rPrjc Kyw)aReports 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. Nrsrs r^ is_connectedz$MySQLConnectionAbstract.is_connected0rrc Kyw)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. Nrs)rg reconnectattemptsdelays r^pingzMySQLConnectionAbstract.ping9rrc.t|tr|dkDr||_|jSt|ttfrM|D]<}|dkr |xjt |zc_(|xj|zc_>|jSt d)aSet 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. set_client_flags([ClientFlag.FOUND_ROWS,-ClientFlag.LONG_FLAG]) Raises: ProgrammingError: When the flags argument is not a set or an integer bigger than 0. rz+set_client_flags expect integer (>0) or set)r rJrrer*absr2)rgflagsrs r^rz(MySQLConnectionAbstract.set_client_flagsLs eS !eai!&D !!!t} - /!8&&3t9*4&&&$.&  /!!!##PQ Qrjc|r_t|trO||_||jj|j |_|j|j _ytd)zSet 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) issubclassr-rrr rrr str_fallbackr)rg convclasss r^set_converter_classz+MySQLConnectionAbstract.set_converter_classesY I/AB$-D !&t}}'9'94;L;LMDN*.*F*FDNN 'S rjcJ|\}}||jvr||j|<yy)aAdd 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. Nr)rgr+rrs r^query_attrs_appendz*MySQLConnectionAbstract.query_attrs_appendws1!& : D-- -+5D  i ( .rjc:|jj|dS)zRemove 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)rpoprgr s r^query_attrs_removez*MySQLConnectionAbstract.query_attrs_removes  $$T400rjci|_y)z5Clears query attributes list on the connector's side.Nrrs r^query_attrs_clearz)MySQLConnectionAbstract.query_attrs_clears rjcK|jr|jd{y|jr tdy7w)zHandle 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)rrrr0rs r^handle_unread_resultz,MySQLConnectionAbstract.handle_unread_resultsB  &&( ( (    56 6  )s AAAcZK|jr|jd{yy7w)zConsume pending results.N)rget_rowsrs r^rz'MySQLConnectionAbstract.consume_resultss&   --/ ! !  !s +)+cK|jdd{4d{}|j|d{|jd{cdddd{S7O7H7177 #1d{7swYyxYww)z&Send a query which only returns 1 row.T)rN)cursorexecutefetchone)rgrrs r^raz"MySQLConnectionAbstract.info_querysxd33 + +v..' ' '** + + +3 + '* + + + +svBA(BA*BA2A,A2A.A2 B"A0#B*B,A2.A20B2B8A; 9BBc:|jj|y)zAdd cursor to the weakref set.N)raddrgrs r^ add_cursorz"MySQLConnectionAbstract.add_cursors &!rjc:|jj|y)z#Remove cursor from the weakref set.N)rremovers r^ remove_cursorz%MySQLConnectionAbstract.remove_cursors V$rjc Kyw)zConnect to the MySQL server.Nrsrs r^rzMySQLConnectionAbstract.connectrrcKd}||k7ry|dz} |jd{|jd{|jd{ry |dkDrt j|d{||k7rxyy7`7J74#ttf$r#}||k(rd|d|}t ||Yd}~]d}~wwxYw7Gw)aAttempts 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. rr@Nz!Can not reconnect to MySQL after z attempt(s): ) disconnectrrr.IOErrorr/rsleep)rgrrcounterrmsgs r^rz!MySQLConnectionAbstract.reconnects"!kG 7oo'''lln$$**,,,-qymmE***!($,7# 7h&;H:F''*e-)-36 ' 7+sr CB BB BB BB C7B?8 CCB B B B<B72C7B<<CcKtw)akShuts 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. )NotImplementedErrorrs r^shutdownz MySQLConnectionAbstract.shutdowns"!s c Kyw)aClose 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. Nrsrs r^rzMySQLConnectionAbstract.closerrzCallable[[], Any]rc Kyw)aInstantiate 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 dictionary or named 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 CursorBase. ValueError: When cursor is not available. Nrs)rgrrprepared cursor_class dictionary named_tuples r^rzMySQLConnectionAbstract.cursorrrc Kyw)a3Get 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. Nrs)rgrcolumnsrs r^get_rowzMySQLConnectionAbstract.get_rowrrc Kyw)zGet 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. Nrs)rgcountrrr prep_stmts r^rz MySQLConnectionAbstract.get_rowsrrc Kyw)zCommit current transaction.Nrsrs r^commitzMySQLConnectionAbstract.commit-rrc Kyw)zRollback current transaction.Nrsrs r^rollbackz MySQLConnectionAbstract.rollback1rrc Kyw)zResets 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. Nrsrs r^cmd_reset_connectionz,MySQLConnectionAbstract.cmd_reset_connection5rrc Kyw)zChange 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. Nrs)rgr~s r^ cmd_init_dbz#MySQLConnectionAbstract.cmd_init_db=rrc Kyw)aSend 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. Nrs)rgrrr raw_as_strings r^rfz!MySQLConnectionAbstract.cmd_queryErrc Kyw)acSend 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 Nrs)rg statementss r^cmd_query_iterz&MySQLConnectionAbstract.cmd_query_iterYrrc Kyw)zFetch 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. Nrs)rg statement_idrowss r^cmd_stmt_fetchz&MySQLConnectionAbstract.cmd_stmt_fetchkrrc Kyw)zPrepare a MySQL statement. This method will send the PREPARE command to MySQL together with the given statement. Nrs)rg statements r^cmd_stmt_preparez(MySQLConnectionAbstract.cmd_stmt_preparesrrc Kyw)z#Execute a prepared MySQL statement.Nrs)rgrdatarIrs r^cmd_stmt_executez(MySQLConnectionAbstract.cmd_stmt_execute}rrc Kyw)z}Reset data for prepared statement sent as long data. The result is a dictionary with OK packet information. Nrsrgrs r^cmd_stmt_resetz&MySQLConnectionAbstract.cmd_stmt_resetrrc Kyw)zDeallocate a prepared MySQL statement. This method deallocates the prepared statement using the statement_id. Note that the MySQL server does not return anything. Nrsrs r^cmd_stmt_closez&MySQLConnectionAbstract.cmd_stmt_closerrc Kyw)aSend the Refresh command to the MySQL server. This method sends the Refresh command to the MySQL server. The options argument should be a bitwise value using constants.RefreshOption. Usage example: RefreshOption = mysql.connector.RefreshOption refresh = RefreshOption.LOG | RefreshOption.INFO cnx.cmd_refresh(refresh) Nrs)rgoptionss r^ cmd_refreshz#MySQLConnectionAbstract.cmd_refreshrrc Kyw)aSend 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. Nrs)rgrparam_idrs r^cmd_stmt_send_long_dataz/MySQLConnectionAbstract.cmd_stmt_send_long_datarrc Kyw)zClose the current connection with the server. Send the QUIT command to the MySQL server, closing the current connection. Nrsrs r^cmd_quitz MySQLConnectionAbstract.cmd_quitrrc Kyw)zShut 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. Nrs)rg shutdown_types r^ cmd_shutdownz$MySQLConnectionAbstract.cmd_shutdownrrc Kyw)zSend 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. Nrsrs r^cmd_statisticsz&MySQLConnectionAbstract.cmd_statisticsrrc Kyw)zKill 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. Nrs)rg mysql_pids r^cmd_process_killz(MySQLConnectionAbstract.cmd_process_killrrc Kyw)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. Nrsrs r^ cmd_debugz!MySQLConnectionAbstract.cmd_debugrrc Kyw)zSend 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. Nrsrs r^cmd_pingz MySQLConnectionAbstract.cmd_pingrr)Rrz Optional[str]r{rLr|rLr}rJr~r4rrLrrLrrLrQrLrrLrSr4r Optional[int]rrWrrWrrWrr4rzDict[str, str]rr4rr4rrWrrWrrWrrWrr4rr4r+Optional[Union[str, Callable[[str], None]]]rr6rvrWrwr4rzOptional[MySQLConverter]rrWrrJrr4rr4rr4rr4rOptional[bool]rr7ryr7rzOptional[List[str]]rz#Optional[asyncio.AbstractEventLoop])rlrNNNrzOptional[Type[BaseException]]rzOptional[BaseException]rzOptional[TracebackType]rlrmrk)r)rJrLrKzUnion[str, Callable]rLrJrlrmrlr5)rlrLrlrJrlr4)r+rLrlrmrlrW)r+rWrlrm)rlzasyncio.AbstractEventLoop)rlz$List[Tuple[str, BinaryProtocolType]])r+zUnion[str, Sequence[int]]rlrm)rrLrlr9NN)rQzOptional[Union[int, str]]rr4rlrm)rrJrlrW)rrLrlrm)rlzOptional[Tuple[int, ...]])Fr@r)rrWrrJrrJrlrW)rzUnion[int, Sequence[int]]rlrJ)rzOptional[Type[MySQLConverter]]rlrm)r+zTuple[str, BinaryProtocolType]rlrmr rLrlr3)rr<rlOptional[RowType])rrrlrm)r@r)rrJrrJrlrm)rlr)NNNNNN)rr7rr7rr7rz#Optional[Type[MySQLCursorAbstract]]rr7rr7rlr)FNN)rrWrOptional[List[DescriptionType]]rr7rlz1Tuple[Optional[RowType], Optional[EofPacketType]])NFNNN) rr5rrWrrArr7rrrlz-Tuple[List[RowType], Optional[EofPacketType]])r~rLrlr7)FFF) rr<rrWrrWr rWrlr9)rr<rlz!Generator[ResultType, None, None]r@)rrJrrJrlrm)rrTrlz/Mapping[str, Union[int, List[DescriptionType]]])rsrsr) rzUnion[int, CMySQLPrepStmt]rzSequence[BinaryProtocolType]rIrrrJrlz&Optional[Union[Dict[str, Any], Tuple]])rrJrlrm)r!rJrlr7)rrJr$rJrrrlrJ)rlrTr[)r)r5rlrm)rlr;)r.rJrlr7)rlr5)rlr7)^rnrorprqr&rrrrrr  staticmethodrpropertyrrOrzrTrVrr~setterrcrgrirlrrprrrtrr{rrrrrrrrrrrQrrrrrrrrrrrrrrrrrrrrrarrrrrrrrrrrrrrr r rfrrrrrrr"r%r'r*r,r/r1r3rsrjr^rrs 1 #"&%)&* % #'%'"&&*""',0/3EIIM#89M#N4I (5 59',"78I"J%) $"&!%*/.3'<^'L,.48[r,r, r,  r,  r, r,r,r,r,r,r,#r,$r,r, !r,"#r,$!%r,&#'r,( )r,*$+r,,-r,. /r,01r,23r,4*5r,6 -7r,8C9r,:G;r,<!=r,>%2?r,D2Er,F!%Gr,H Ir,J#Kr,LMr,N Or,PQr,R(Sr,T,Ur,V%Wr,X*Yr,Z2[r,h37-1-1 /++   PTdO bPRdJK  $8 DG    D##!!  __   -%%& & $$PP//&&     !         __  $ $"" # #''''(## $ $??"" 55  :"UYA;0A;DQA; A;F/0)     GH  14 AD   $"2$ 61 7" + "%++!+F "    %*J!)$("#'<@%)&*    !  :  #  $    437"    1    ;     $37"      1       7    **,,    #           & $ * $    8  .0! 202+2 2  2 0 22          +. 6>  "            rjrceZdZdZddZd dZ d! d"dZd#dZd$dZe d%dZ e d&d Z e d'd Z e d(d Z d(d Ze d&d Ze d)dZe d*dZe d+dZed,dZe d- d.dZ d/ d0dZe d1dZed2dZed3dZed4d5dZed+dZd'dZd6d7dZd8dZd9dZd:dZ d;dZ!y)r@) _connectionrr _description_last_insert_id _warnings_warning_count _executed_executed_list_stored_results_binaryr _rowcount_nextrow arraysizer)rg connections r^rzMySQLCursorAbstract.__init__s4>0: =A.26:#$/302*,"   L    ##D)rjcK|Swr[rsrs r^rzMySQLCursorAbstract.__aenter__s  Nc@K|jd{y7wr[rrs r^rzMySQLCursorAbstract.__aexit__rrcK|Sw)zIterate over result set. Iteration over the result set which calls self.fetchone() and returns the next row. rsrs r^ __aiter__zMySQLCursorAbstract.__aiter__ s  rVc|K |jd{}|st|S7#t$rtdwxYww)zm Used for iterating over the result set. Calles self.fetchone() to get the next row. N)rr/StopAsyncIteration)rgrows r^__next__zMySQLCursorAbstract.__next__sD  / 'C$ $ ( /$$ . /s <(&( <(9<c|jS)aReturn 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. )rIrs r^ descriptionzMySQLCursorAbstract.descriptions$   rjc|jS)aReturn 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. )rQrs r^rowcountzMySQLCursorAbstract.rowcount2s~~rjc|jS)zReturn the value generated for an AUTO_INCREMENT column. Returns the value generated for an AUTO_INCREMENT column by the previous INSERT or UPDATE statement or None when there is no such value available. rJrs r^ lastrowidzMySQLCursorAbstract.lastrowid?s###rjc|jS)zReturn warnings.rKrs r^rzMySQLCursorAbstract.warningsHs~~rjc|jS)zReturns Warnings.rfrs r^ fetchwarningsz!MySQLCursorAbstract.fetchwarningsMs ~~rjc|jS)zReturn the number of warnings. This property returns the number of warnings generated by the previously executed operation. )rLrs r^ warning_countz!MySQLCursorAbstract.warning_countQrrjcf|js tStd|jDS)z[Returns column names. This property returns the columns names as a tuple. c3&K|] }|d yw)rNrs)r\ds r^r_z3MySQLCursorAbstract.column_names..bs4aQqT4s)r_rers r^ column_namesz MySQLCursorAbstract.column_namesZs+ 7N44#3#3444rjc|jy |jjjS#ttf$r|jjcYSwxYw)zReturns the executed statement This property returns the executed statement. When multiple statements were executed, the current statement in the iterator will be returned. N)rMrdecoderUnicodeDecodeErrorrs r^rzMySQLCursorAbstract.statementdsZ >> ! *>>'')002 2 23 *>>'') ) *s'7)A#"A#c,t|jS)zReturns 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. )rWrIrs r^ with_rowszMySQLCursorAbstract.with_rowsssD%%&&rjcy)zReturns 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. Nrsrs r^stored_resultsz"MySQLCursorAbstract.stored_results|rPrjc Kyw)auExecutes the given operation. Executes the given operation substituting any markers with the given parameters. For example, getting all rows where id is 5: await cursor.execute("SELECT * FROM t1 WHERE id = %s", (5,)) If the `multi`` parameter is used a `ProgrammingError` is raised. The method for executing multiple statements is `executemulti()`. If warnings where generated, and connection.get_warnings is True, then self._warnings will be a list containing these warnings. Raises: ProgramingError: If multi parameter is used. Nrs)rg operationparamsmultis r^rzMySQLCursorAbstract.executerrc Kyw)zExecute multiple statements. Executes the given operation substituting any markers with the given parameters. Nrs)rgrwrxs r^ executemultiz MySQLCursorAbstract.executemultirrc Kyw)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(). Nrs)rgrw seq_paramss r^ executemanyzMySQLCursorAbstract.executemanyrrc Kyw)zReturn 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. Nrsrs r^rzMySQLCursorAbstract.fetchonerrc Kyw)zReturn 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. Nrsrs r^fetchallzMySQLCursorAbstract.fetchallrrc Kyw)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. Nrs)rgsizes r^ fetchmanyzMySQLCursorAbstract.fetchmanyrrc Kyw)zClose the cursor.Nrsrs r^rzMySQLCursorAbstract.closerrc|jS)zReturn the value generated for an AUTO_INCREMENT column. Returns the value generated for an AUTO_INCREMENT column by the previous INSERT or UPDATE statement. rcrs r^ getlastrowidz MySQLCursorAbstract.getlastrowids ###rjc Kyw)zReset the cursor to default.Nrs)rgfrees r^resetzMySQLCursorAbstract.resetrrct|dr|jjSt|dr|jjSy)zGets a list of query attributes from the connector's side. Returns: List of existing query attributes. _cnxrHN)hasattrrrrrHrs r^get_attributesz"MySQLCursorAbstract.get_attributess= 4 99(( ( 4 '##// /rjct|ts td|t|tstd|d|jj ||fy)aAdd 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 rLr2r rHr)rgr r+s r^ add_attributez!MySQLCursorAbstract.add_attributes]$$"#KL L  Z~%F"% DE  ++T5M:rjcnt|ts td|jj |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 rLr2rHrrs r^remove_attributez$MySQLCursorAbstract.remove_attribute s1$$"#KL L22488rjc8|jjy)zr?authenticationrArCrBrKrDnetworkrErFr roWeakValueDictionaryrHrrrrrrrsrjr^rs@2" J #(&<    2.'#8 77g ;V7;V;V;X8X %% %DJ cJ Z*u-#u-p ^ rj