G)fdZdgZddlZddlZddlZddlZddlZddlZddlZddl Z ddl m Z ddl m Z ddlmZmZmZmZmZmZmZmZmZmZmZmZddlmZdd lmZmZm Z m!Z!m"Z"m#Z#dd l$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,dd l-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5dd l6m7Z7m8Z8m9Z9m:Z:d dl;mZ>d dl?m?Z?d dl@mAZAmBZBmCZCmDZDmEZEmFZFmGZGmHZHmIZImJZJmKZKmLZLd dlMmMZMd dlNmOZOmPZPGdde<ZQy)zDImplemention of the communication with MySQL servers in pure Python.MySQLConnectionN)Decimal)IOBase) AnyAsyncGeneratorBinaryIOCallableDictListMappingOptionalSequenceTupleTypeUnion)version) ClientFlag FieldType RefreshOption ServerCmd ServerFlag flag_is_set) DatabaseErrorErrorInterfaceError InternalErrorNotSupportedErrorOperationalErrorProgrammingError get_exception)BinaryProtocolTypeDescriptionType EofPacketType OkPacketType ResultTypeRowTypeStatsPacketType StrOrBytes) get_platform int1store int4storelc_int)MySQLConnectionAbstractMySQLCursorAbstract ServerInfo)charsets) MySQLCursorMySQLCursorBufferedMySQLCursorBufferedDictMySQLCursorBufferedNamedTupleMySQLCursorBufferedRawMySQLCursorDictMySQLCursorNamedTupleMySQLCursorPreparedMySQLCursorPreparedDictMySQLCursorPreparedNamedTupleMySQLCursorPreparedRawMySQLCursorRaw)logger)MySQLTcpSocketMySQLUnixSocketceZdZUdZdZeed<edeefdZ d^dZ d^dZ d e de fd Zd^d Zd^d Zd edefdZdeddfdZd edefdZde defdZd ede fdZd edee effdZd edeeeeeeefffdZ d_dedeeded eede dedee!fdZ" d`de#de de!fdZ$de fd Z%de fd!Z& dad"e d#ed$eddfd%Z'd^d&Z(d^d'Z)e)Z*e+ge,fed(< dbd)ee d*ee d+ee d,ee-e.d-ee d.ee de/fd/Z0 dcd0e d1eeed*ee deee1eeffd2Z2 ddd3eed0e d1eeed*ee d4e,deee1eeff d5Z3d^d6Z4d^d7Z5de fd8Z6d9e defd:Z7 ded e8d*e d)e d;e de f d<Z9d=e8de:e dffd>Z;dfd?ed@eddfdAZ dgd?edDe?e@dEe?e,dedeeeeeeefff dFZAd?eddfdGZBd?eddfdHZCdIedefdJZDd?edKedDe#defdLZEdefdMZFdhdNeeddfdOZGdeHfdPZIdQedefdRZJdefdSZKdefdTZL didUe dVe d9e dWedXe dYe dZe d[e d\e deefd]ZMy)jrz3Implementation of the pure Python MySQL connection.r. _mfa_nfactorreturncR|jr|jjdSy)zMySQL connection ID.server_threadidN) _handshakegetselfs [/var/www/html/flask-app/venv/lib/python3.12/site-packages/mysql/connector/aio/connection.py connection_idzMySQLConnection.connection_idts$ ????&&'89 9NcxK |jr/tjdk(rt|j|_n&t |j |j|_tj|jj|jd{|jd{|jd{|j$t&j(zr|jj+ |j-|j.|j5d{y777t#tjtjf$rt $r%|jj#d{7wxYw#t0$r}t3d|d}~wwxYw7|w)Nposix) unix_socket)hostportzFConverter classA should be a subclass of conversion.MySQLConverterBase) _unix_socketosnamerA_socketr@_host_portasynciowait_foropen_connection_connection_timeout _do_handshake_do_authCancelledError TimeoutError Exceptionclose_connection _client_flagsrCOMPRESSswitch_to_compressed_modeset_converter_class_converter_class TypeErrorAttributeError_post_connection)rJerrs rKconnectzMySQLConnection.connect{sm   RWW%7.4;L;LM -4::DJJO "" ,,.0H0H  $$& & &--/ ! !    3 3 3 LL 2 2 4   $ $T%:%: ;##%%%3  ' !&&(<(<=   ,,//1 1 1    0   &sF:BE E!E8E9EEE7F: F(F:;F8<F:EEEA FFFF: F5$ F00F55F:c t}tjjd}|ddk(rd}nd}t t j |dtjd|djtjdd Dcgc] }t |c}|d d }|jj|y cc}w) z&Add the default connection attributes. rGPLv2zGPL-2.0 Commercialarchzmysql-connector-python.r)_pid _platform _source_host _client_name_client_license_client_version_osN) r*rLICENSEsplitstrrTgetpidsocket gethostnamejoinVERSION_connection_attrsupdate)rJplatformlicense_chunksclient_licensexdefault_conn_attrss rK_add_default_conn_attrsz'MySQLConnection._add_default_conn_attrss> ..s3 !  '&N)N $!&)"..04-"xx19M(NAQ(NOI&  %%'9; )Os CqueryctK|jd{|j|d{S77w)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. N)handle_unread_result cmd_query)rJrs rK_execute_queryzMySQLConnection._execute_querys5'')))^^E*** **s848688c K|jjd{}tjd||ddk(r t ||j j ||_t|jd|jd|jd|jd|jd |jd |jd |jd  |_ tj|jjdtjd|jj|jr<|jr0tj |j|j|_n|jr@tj$|j|_|j"j&|_n|jr@tj(|j|_|j"j*|_nPtj,d|_|j"j*|_|j"j&|_|jd t.j0zsd|j2dk(r|j4s t7d|j8r t7dd|xj:t.j0zc_n/|j<s#|xj:t.j0zc_|jd t.j>zr |jAt.j>g|jd t.jBzr1d|j_"|jAt.jBg|jd t.jFzr!|jAt.jFgyy7ڭw)z(Get the handshake from the MySQL server.NzProtocol::Handshake packet: %sprotocolserver_version_originalrFcharset server_status auth_plugin auth_data capabilities)rr thread_idr status_flagsrrrrzProtocol::Handshake charset: %s-mysql_clear_passwordzEClear password authentication is not supported over insecure channelsz1SSL is required but the server doesn't support iti)errnoT)$rVreadr?debugr! _protocolparse_handshakerGr1 _server_infor2set_mysql_major_version version_tupler _charset_name_charset_collationget_by_name_and_collation_charset get_by_name collationget_by_collationrU get_by_idrSSL _auth_plugin is_securer_ssl_verify_certrc _ssl_disabled PLUGIN_AUTHset_client_flagsCLIENT_QUERY_ATTRIBUTESquery_attrs_is_supportedMULTI_FACTOR_AUTHENTICATIONrJpackets rKr]zMySQLConnection._do_handshakes ||((** 5v> !9 ' '..88@&__Z0OO$=>oo&78OOI.9 6ook28   (():):)H)H)KL 68I8I8Q8QR   $"9"9$>>""D$;$;DM  $001C1CDDM&*mm&=&=D #  $ $$55d6M6MNDM!%!3!3D  %..r2DM!%!3!3D &*mm&=&=D #~.?  $::4>>$($$$G   :>>/ 1 ##   *.. 0  ??> *Z-C-C C  ! !:#9#9": ; ??> *Z-O-O O9=D   6  ! !:#E#E"F G ??> *Z-S-S S  ! !:#I#I"J K T+sO=O:OO=cK|jr|jjds:|jr~|jjdrctjdk(rP|jsDt j |_tjd|j|j|jr%|j|jk7r |jn |j}d|_ |js |jtjzr|j j#|j$|j&|j(|j*|j,|j.|j0}|j2j5|j6j8|j}|j j;|d{|j j=|d{d |_ |j>jA|j |jB|j||jD|jF|jH|j6j8|j|j|jJ|jL|jN|jP|jR|jT|jV d{}|jY||jtjZzs1|jHr$|j]|jHd{yyy7m7M7j7w) afAuthenticate with the MySQL server. Authentication happens in two parts. We first send a response to the handshake. The MySQL server will then send either an AuthSwitchRequest or an error packet. Raises NotSupportedError when we get the old, insecure password reply back. Raises any error coming from MySQL. authentication_ociauthentication_kerberosntz4MySQL user is empty, OS user: %s will be used for %sF)ssl_cassl_certssl_keyssl_verify_certssl_verify_identity tls_versionstls_cipher_suites)r client_flagsNT)sock handshakeusername password1 password2 password3databaserrrauth_plugin_class conn_attrskrb_service_principaloci_config_fileoci_config_profilewebauthn_callback fido_callback)/r startswithrTrU_usergetpassgetuserr?r _password1 _password _ssl_activerrcrrrVbuild_ssl_context_ssl_ca _ssl_cert_ssl_keyr_ssl_verify_identity _tls_versions_tls_ciphersuitesr make_auth_sslr charset_idwrite switch_to_ssl_authenticator authenticaterG _password2 _password3 _database_auth_plugin_classr_krb_service_principal_oci_config_file_oci_config_profile_webauthn_callback_fido_callback _handle_okCONNECT_WITH_DB cmd_init_db)rJpassword ssl_contextrok_pkts rKr^zMySQLConnection._do_auths   !!,,-AB!!%%001JKGGtO** *DJ LLF !! 4>>T__#D OO  !!!t'9'9JNN'J,,88|| $ 5 5$($=$=!//"&"8"89K!NN88 00t?Q?Q9F,,$$V, , ,,,,,[9 9 9#D **77ooZZoooo^^MM,,++))"55--"&"="= 11#77"55--#8  & ""Z%?%??T^^""4>>2 2 2FT?3 - 9 , 3sJG!M#M$"MMC$M+M,AMM MMMMrc|ddk(r1|jj|}|j|d|S|ddk(r t|t d)zHandle a MySQL OK packet. This method handles a MySQL OK packet. When the packet is found to be an Error packet, an error will be raised. If the packet is neither an OK or an Error packet, InterfaceError will be raised. rr status_flagrzExpected OK packet)rparse_ok_handle_server_statusr!r)rJrrs rKrzMySQLConnection._handle_okHs^ !9>^^,,V4F  & &vm'< =M !9 ' '122rMflagscttj||_ttj||_y)aHandle the server flags found in MySQL packets. This method handles the server flags send by MySQL OK and EOF packets. It, for example, checks whether there exists more result sets or whether there is an ongoing transaction. N)rrMORE_RESULTS_EXISTS_have_next_resultSTATUS_IN_TRANS_in_transaction)rJrs rKrz%MySQLConnection._handle_server_statusWs."-Z-K-KU!S*:+E+EuMrMc|ddk(r1|jj|}|j|d|S|ddk(r t|t d)aHandle a MySQL EOF packet. This method handles a MySQL EOF packet. When the packet is found to be an Error packet, an error will be raised. If the packet is neither and OK or an Error packet, InterfaceError will be raised. rrrzExpected EOF packet)r parse_eofrr!r)rJreofs rK _handle_eofzMySQLConnection._handle_eofas_ !9 ..**62C  & &s='9 :J !9 ' '233rMfilenamec6Ktjj|}tjj|r t d|j s|j s td|j s{|j rotjj|j }d} tjj||g}||k7rd}t|j|| t|d}|j|j|dd{ |j!S#t$r-}d}t|jt||||d}~wwxYw7R#t"t$f$rYSwxYw#t"$rT |j&j)d d{7n#t*$r}t d |d}~wwxYwtd |d dwxYw# j!w#t"t$f$rYwwxYwxYww) z(Handle a LOAD DATA INFILE LOCAL request.z#Use of symbolic link is not allowedKLOAD DATA LOCAL INFILE file request rejected due to restrictions on access.NzL{} while loading file `{}` and path `{}` given in allow_local_infile_in_pathzEThe file `{}` is not found in the given allow_local_infile_in_path {}rbT)send_empty_packetrMMySQL Connection not availablezFile 'z' could not be read)rTpathabspathislinkr_allow_local_infile_allow_local_infile_in_pathr commonpath ValueErrorrformatr}openr _send_datacloseIOError NameErrorrVrri)rJr file_name infile_pathc_pathrkerr_msg data_files rK_handle_load_data_infilez(MySQLConnection._handle_load_data_infilepsGGOOH- 77>>) $"#HI I''0P0P* ''D,L,L''//$*J*JKKF ++[),DE$4$GNN9k$JKK Y-I??ooi4oHH != 5%NN3s8Y D  &IY'   T Rll((---! R&'GHcQ R 6)4G!HIt S  T !Y'  sB0H3!D>"H7-F$E7%F-E9=H> E4(E//E44H7F9F H F  H G+F=6F97F=<G+= G GGG++G..H0HHHHHHHcK|rt|dkr td|ddk(r|j|S|ddk(r,|ddj}|j |d{S|ddk(r|j |S|ddk(r t ||jj|}|rt|ts td dg|z|_ td|D]U}|jj|jjd{|j |j|<W|j |jjd{}d |_|j|d S77l7#w) auHandle a MySQL Result. This method handles a MySQL result, for example, after sending the query command. OK and EOF packets will be handled and returned. If the packet is an Error packet, an Error-exception will be raised. The dictionary returned of: - columns: column information - eof: the EOF-packet information rEmpty responserNrrzIllegal result setT)columnsr)lenrrdecoderrr!rparse_column_count isinstanceint _columns_descrange parse_columnrVrpython_charset unread_result)rJrr column_countirs rK_handle_resultzMySQLConnection._handle_resultsVq !12 2 !9>??6* * !9 abz((*H66x@@ @ !9 ##F+ + !9 ' '~~88@ :lC#@ !56 6  q,' A$(NN$?$?ll''))4+>+>%D  q !  T\\%6%6%889!--c::+A * 9s8A$F &F'B4F F A F &F 'F F  F c|ddk(r|jj|S|ddk(r t|td)a>Handle a MySQL Binary Protocol OK packet This method handles a MySQL Binary Protocol OK packet. When the packet is found to be an Error packet, an error will be raised. If the packet is neither an OK or an Error packet, InterfaceError will be raised. Returns a dict() rrrzExpected Binary OK packet)rparse_binary_prepare_okr!rrs rK_handle_binary_okz!MySQLConnection._handle_binary_oksG !9>>>99&A A !9 ' '899rMcnK|rt|dkr td|ddk(r|j|S|ddk(r|j|S|ddk(r t ||j j |}|rt|ts tddg|z}td|D]K}|j j|jjd{|j||<M|j|jjd{}|||fS7N7w)aHandle a MySQL Result This method handles a MySQL result, for example, after sending the query command. OK and EOF packets will be handled and returned. If the packet is an Error packet, an Error exception will be raised. The tuple returned by this method consist of: - the number of columns in the result, - a list of tuples with information about the columns, - the EOF packet information as a dictionary. Returns tuple() or dict() rr rrrzIllegal result set.N)r$rrrr!rr&r'r(r*r+rVrr,)rJrr.r#r/rs rK_handle_binary_resultz%MySQLConnection._handle_binary_results, Vq !12 2 !9>??6* * !9 ##F+ + !9 ' '~~88@ :lC#@ !67 7*.,)>q,' A44ll''))4+>+>GAJ  T\\%6%6%889gs++ * 9s%C D5"D1 #AD5#D3$D53D5commandargument packet_numberexpect_responsecompressed_packet_numbercRK|jd{ |jj|jj ||xs|||d{|sy|jjd{S7m7+#t $r}t d|d}~wwxYw7%w)aSend a command to the MySQL server. This method sends a command with an optional argument. If packet is not None, it will be sent and the argument will be ignored. The packet_number is optional and should usually not be used. Some commands might not result in the MySQL server returning a response. If a command does not return anything, you should set expect_response to False. The _send_cmd method will then return None instead of a MySQL packet. Nr )rrVrr make_commandrirr)rJr6r7r8rr9r:rks rK _send_cmdzMySQLConnection._send_cmds(''))) N,,$$++GV5GxH(  \\&&((( *   N"#CD# M N )sPB'BB'>BBB B'?B%B'B B" BB""B'rr c&K|jd{t|ds tdd} |j|dz }|r:|jj |d{|j|dz }|r:|r$ |jj dd{|jjd{}|S77g#t $r}td|d}~wwxYw7I#t $r}td|d}~wwxYw7Fw)a4Send data to the MySQL server This method accepts a file-like object and sends its data as is to the MySQL server. If the send_empty_packet is True, it will send an extra empty package (for example when using LOAD LOCAL DATA INFILE). Returns a MySQL packet. Nrzexpecting a file-like objectr rM)rhasattrrrrVrrir)rJrr  chunk_sizebufrkress rKrzMySQLConnection._send_data$s'')))y&);< <  N..b1Cll((---nnZ"_5  Rll((---LL%%'' + *. N"#CD# M N .! R&'GHcQ R(sDCD4C)C*CDC2&C0'C2+DD DC C- C((C--D0C22 D ; DD  Dcdt|jxr|jjS)zReports whether the socket is connected. Instead of ping the server like ``is_connected()``, it only checks if the socket connection flag is set. )boolrV is_connectedrIs rKis_socket_connectedz#MySQLConnection.is_socket_connectedGs% DLL@T\\%>%>%@AArMc`K |jd{y7#t$rYywxYww)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. NFT)cmd_pingrrIs rKrGzMySQLConnection.is_connectedOs5 --/ ! ! "  s(.. +.+. reconnectattemptsdelaycK |jd{y7#t$r5}|r|j||d{7n td|Yd}~yd}~wwxYww)a Check availability of the MySQL server. When reconnect is set to `True`, one or more attempts are made to try to reconnect to the MySQL server using the ``reconnect()`` method. ``delay`` is the number of seconds to wait between each retry. When the connection is not available, an InterfaceError is raised. Use the ``is_connected()`` method if you just want to check the connection without raising an error. Raises: InterfaceError: On errors. N)rLrMz$Connection to MySQL is not available)rJrrKr)rJrKrLrMrks rKpingzMySQLConnection.ping\sZ" V--/ ! ! VnnhenDDD$%KLRUUE VsBA A  AAAAA AA cK|jsy |jjd{y7#t$rYywxYww)ahShut down connection to MySQL Server. This method closes the socket. It raises no exceptions. Unlike `disconnect()`, `shutdown()` closes the client connection without attempting to send a QUIT command to the server first. Thus, it will not block if the connection is disrupted for some reason such as network failure. N)rVrbrarIs rKshutdownzMySQLConnection.shutdownus>||  ,,//1 1 1   s0A646A6 AAAAcK|jD]}|jd{|jj|jrT|jj r:t j t5|jd{ddd|jr"|jjd{d|_y77D#1swYCxYw7w)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. N) _cursorsrclearrVrG contextlibsuppressrcmd_quitrb)rJcursors rKrzMySQLConnection.closesmm !F,,.  !  <r7r8r5r9r6r:r=r;r<KeyErrorrr*r) rJrZr[r\r]r^r_ cursor_typetypesargsr/criterias rKrXzMySQLConnection.cursors2||4<<#<#<#>"#CD D'')))  #lK8&N!$' ''38_c$)) t  1 K $; 1 K   1 K $  1 K t  2 K"%&$,#&'-   &E+&- -O *P ODyy"'(JQkQ!V.D.IaJJH !c{  s 202rp prep_stmtcK| |j}|js tdgdf} |rD|j}|dk(rd}|jj |j |||d{}nD|jj|j |jj|d{}|\}} |sR|sP|jD|rBt|dr6|jj} |D cgc]} | | |j}} | $|jd| vr| dn| d d|_|| fS77#t$r}d|_|d}~wwxYwcc} ww) 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. NzNo result set availableutf8mb4utf8)rpF converterrr)rhr-rrrread_binary_resultrVread_text_resultrrrr)rArx row_to_pythonr) rJrprnr#r[rtrrrrkeof_pr{rows rKrqzMySQLConnection.get_rowssx ;))C!! 9: :GI4j ,,i'$G!^^>>LL'5'"^^<<LL$"3"3";";5= e3"".k* NN88MFJKsM#t'9'9:KDK    & & E)m$?+  "'D U{; !&D I LsZ*EAD>-D:.AD>2D<3D>7=E4E,E:D><D>> E EEEcBK|jdd{y7w)zCommit current transaction.COMMITN)rrIs rKcommitzMySQLConnection.commit9s!!(+++ cK|jr|jd{|jdd{y77w)zRollback current transaction.NROLLBACK)r-rqrrIs rKrollbackzMySQLConnection.rollback=s;   --/ ! !!!*--- "-s AAAAAAcK |j|jtjd{|j d{y7!7#t t f$rYywxYww)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. NTF)rr=rRESET_CONNECTIONrjrrrIs rKcmd_reset_connectionz$MySQLConnection.cmd_reset_connectionCs_   OO$..1K1K"LL M'') ) )M )!#34  sJA,-AAA AAA,AAA)&A,(A))A,rcK|j|jtj|j dd{S7w)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. zutf-8N)rr=rINIT_DBencode)rJrs rKrzMySQLConnection.cmd_init_dbPs< ..!2!2HOOG4LM M  Ms>A A  A  raw_as_stringc Kt|ts+t|tr|j}t|}|jj dk7r|jj nd}t}|j js'|jrtjdt|jtjzrUg}g}g} dgt|jdzdzz} t!|jD]2\} } | d} d}| K| | dzxxd| dzzzcc<|j#t%t&j(t%|z[t| t*r2|j,j/| \}}}| j#|n6t| trI| j|} | j#t1t| | zt&j2}nt| t4r8| j#t1t| | zt&j6}nt| t8rh| j#t1tt| j|t| j|zt&j:}nt| t<r6| j#t?j@d | t&jB}nt| tDjDtDjFfr0|j,jI| \}}| j#|n}t| tDjJtDjLfr0|j,jO| \}}| j#|n#tQd | jRjTd |j#t%|t%|z| dj|}|j#t1t||z5|jWt1t|j|jWt1d| r|jWd jY| Dcgc]}t?j@d|c}t%dzt[||D]'\}}|jW||jW|)| D]} |jW| |jW|t5|} |j]|j_t`jb|d {d {}|jjr tmd|Scc}w7.7$#tP$r1}|jddk(rd|jfvrd}ti||d }~wwxYww)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. rvrwO>O MMN      B B BEE"$F##d&7&7"81"<!BCK#,T->->#?. 7Z"1 =+qS1W~=+LL9>>!:Yu=M!MNeS) ==eD "MM&)s+!LL1EMM&U"4u"<=!*!2!2Ju-MM&U"4u"<=!*Jw/MMs3u:#4#4W#=>?e*++G45"+!2!2Ju-MM&++dE":;!*!1!1J(9(98=='IJ??F"MM&)(:(:HMM'JK+/>>+M+Me+T(VZMM&)*!OO445Y@ Yz2Yu5EEF!!}++G4 VCI.56]. 7b MM&T%6%6!78 9 MM&) $ HH{Kfkk#s3KLl#$'ue#4(KE4MM%(MM$'($)EMM%()  ef  ..nnY__e<<F  ! ! J  ;L=  yyD %E%P1$G,#5  s[R%W$'V BW$.V'4V#5 V'V%V'W$#V'%V'' W!0,WW!!W$ statementscKt}t|ts,t|tr|jd}t|}|jt j zr4|jtd|jtd|j|t|}|j|jtj|d{d{|jrb|jd{|j|j j#d{d{|jrayy77x7S7(7w)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 rwrr.N)rr'r}rrcrrrr-rr0r=rrrrrVr)rJrrrs rKcmd_query_iterzMySQLConnection.cmd_query_iters"*i0*c*'..v6 ":.J    B B B MM&) $ MM&) $ j!f ''dnnY__e.T(TUUU$$++- - -++$,,2C2C2E,EFF F$$)UU .,EFs`C"E1$E'% E10E)1&E1E+,E1E- E1E/E1%E1)E1+E1-E1/E1 statement_idrrcK|jj||}d|_|jtj |dd{d|_y7 w)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. Fr9NT)rmake_stmt_fetchr-r=r STMT_FETCH)rJrrrrs rKcmd_stmt_fetchzMySQLConnection.cmd_stmt_fetchsR // dC"nnY1165nQQQ! RsA A A A statementc>K|jtj|d{}|j|}g|d<g|d<|ddkDrt d|dD]Z}|dj |j j|jjd{|j\|j|jjd{|ddkDrt d|dD]Z}|dj |j j|jjd{|j\|j|jjd{|S7l777S7w)zPrepare a MySQL statement. This method will send the PREPARE command to MySQL together with the given statement. Nr# parameters num_paramsr num_columns) r=r STMT_PREPAREr3r*rrr+rVrr,r)rJrrr_s rKcmd_stmt_preparez MySQLConnection.cmd_stmt_preparesx~~i&<&N~~i&<&<^~TT11&99 E*<U9s^4F%F%F F%$F%D F%.F!/F%F#F% FF%FF%!F%#F%cK|j|jtjt |d{y7 w)z}Reset data for prepared statement sent as long data. The result is a dictionary with OK packet information. N)rr=r STMT_RESETr,rJrs rKcmd_stmt_resetzMySQLConnection.cmd_stmt_reset[s3 ..!5!5y7NO O Os8AA AcvK|jtjt|dd{y7w)zDeallocate a prepared MySQL statement. This method deallocates the prepared statement using the statement_id. Note that the MySQL server does not return anything. FrN)r=r STMT_CLOSEr,rs rKcmd_stmt_closezMySQLConnection.cmd_stmt_closeds7 nn  l #!   s /979optionscRK|tjtjztjztjztj ztj zzs td|tjzr|jdd{}|tjzr|jdd{}|tjzr|jdd{}|tjzr|jdd{}|tj zr|jdd{}|tj zr4|j|jjdkrd nd d{}S77777U7w) 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) zInvalid command REFRESH optionzFLUSH PRIVILEGESNz FLUSH LOGSz FLUSH TABLESz,TRUNCATE TABLE performance_schema.host_cachez FLUSH STATUS)rarz RESET SLAVEz RESET REPLICA) rGRANTLOGTABLESHOSTSTATUSREPLICArrrr)rJrrDs rK cmd_refreshzMySQLConnection.cmd_refreshpso    "" #   !""  # ##  $ => > ](( ('9::C ]&& &|44C ])) )~66C ]'' ''UVVC ])) )~66C ]** *$$22Z?$C  !;46V6smBF'F+F' F +F'5F6+F'!F!"+F' F#AF'F%F'F'F'!F'#F'%F'rcNKd}d} |j|}|ri|jj|||}|jtj |dd{|t |z }|j|}|ri|S7(#t$r}td|d}~wwxYww)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. r?rF)rr9Nr ) rrprepare_stmt_send_long_datar=rSTMT_SEND_LONG_DATAr$rir) rJrrrrB total_sentrCrrks rKrz'MySQLConnection.cmd_stmt_send_long_datas    N))J'CCC (Cnn11!$)% c#h& ii + N"#CD# M Ns;B%ABB%BB%B B" BB""B%cK|jd{|jjtj}|j j |d{|S7R7w)zClose the current connection with the server. Send the QUIT command to the MySQL server, closing the current connection. N)rrr<rQUITrVrrs rKrWzMySQLConnection.cmd_quitsX ''))),,Y^^<ll  (((  *(s"A-A)A A-"A+#A-+A- shutdown_typecBK|jdd{y7w)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. SHUTDOWNN)r)rJrs rK cmd_shutdownzMySQLConnection.cmd_shutdowns nnZ(((rcXK|jd{|jjtj}|j j |ddd{|jj|j jd{S77A7 w)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. Nr) rrr<r STATISTICSrVrparse_statisticsrrs rKcmd_statisticszMySQLConnection.cmd_statisticss ''))),,Y-A-ABll  A...~~..T\\5F5F5H/HII * //Hs4B*B$A B*$B&%6B*B( B*&B*(B* mysql_pidc|Kt|ts td|jd|d{S7w)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. zMySQL PID must be intzKILL N)r'r(rr)rJrs rKcmd_process_killz MySQLConnection.cmd_process_kills: )S)45 5^^eI;$78888s 3<:<czK|j|jtjd{S7w)a-Send the DEBUG command. This method sends the DEBUG command to the MySQL server, which requires the MySQL user to have SUPER privilege. The output will go to the MySQL server error log and the result of this method is a dictionary with EOF packet information. N)rr=rDEBUGrIs rK cmd_debugzMySQLConnection.cmd_debugs,dnnY__&E EFF E .;9 ;czK|j|jtjd{S7w)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. N)rr=rPINGrIs rKrJzMySQLConnection.cmd_pings*T^^INN%CCDDCruserrrrrrrrc fKt|ts td|dkr tdd|_||_||_||_||_||_|j r||j k7r |j }|jd{|jr td|r||_ | |_ |jj|j |j|j |j"||j$|j&|j(|j*|j, } t/j0d| |j2j5| dd{|j7|j2j9d{} |j$t:j<zs|r|j?|d{tAjB||_"|jDjF|_$|j7| S7777Qw) zChange the current logged in user. This method allows to change the current logged in user information. The result is a dictionary with OK packet information. zcharset must be an integerrz2charset should be either zero or a postive integerr.Nz-Change user is not supported with compression) rrrrrr ssl_enabledrrrz&Protocol::HandshakeResponse packet: %s)%r'r(rrCrrrrrr _compressrrrr make_authrGrrcrrrrr?rrVrrrrrrr2rrrUr) rJrrrrrrrrrr ok_packets rKcmd_change_userzMySQLConnection.cmd_change_users"'3'9: : Q;QR R !### ??x4??:H''))) >>#$ST T $3D !#5 ))ooZZ^^^^++(())--"55*    =vFll  +++OO$,,*;*;*=$=> ""Z%?%??X""8, , , **73 !]]//y))E *. ,$= -sJBH1H(C!H14H+5,H1!H-";H1H/A H1+H1-H1/H1)rDN)NrNTr)F)Fr.r)NNNNNN)FNN)NFNNN)FFF)r.)r r)N) r r rr r r r r )Nr __module__ __qualname____doc__rCr(__annotations__propertyr rLrlrr}r&rr]r^rr%rrr$rrr0r r3rrr r#r5rFrr=rrrHrGrOrQrrYr rrr0r3rXr'rsrqrrrrr)rrrrr rrr"rrrrrrWrr(rrrrJr r rMrKrros=L# x} &B<(+#+*+BLHH3T 3 3< 3N3N4N 4% 4M 40s0|0d&;5&;Z&;P::$sCx.: %,%, |U3_(=}#LMM N%,T%)"& $()!)!)5/!) !)  !)  !)#&!) ) !)H>C!!!6:! !FBTB D HIVV14VADV V2"0%*JS!)$("#'<@%)&*K4.Kd^K4. K t$789 K TN Kd^K K^37" $/0d^  x (="99 : * $37" 7}77$/0 7 d^ 7  7 tG}h}55 67r,. D  # , # www w  w  wr&G$&G  D( )&GP " "C " " eCo!6677 8F.0$& 33)*3SM 3  3 |U3_(=}#LMM N 3j         &&&P""+."6>" "H) )) Jo J99 9GGE E!"$B*B*B* B*  B*  B*B*B*B* B* , B*rM)Rr__all__rYrUrrrTrrrdecimalriortypingrrrr r r r r rrrrr r constantsrrrrrrerrorsrrrrrrr r!rkr"r#r$r%r&r'r(r)utilsr*r+r,r- abstractsr/r0r1r2rXr3r4r5r6r7r8r9r:r;r<r=r>r?networkr@rArr rMrKrs>K             ?>OO    4J*-J*rM