:?h SrSSKrSSKrSSKJr SSKJrJrJrJ r J r J r SSK r SrSSKrSrSSKJrJrJrJr SS KJrJrJrJrJrJr SS KJ r J!r! SS K"J"r" SS K#J$r$J%r%J&r&J'r'J(r( SS K)J*r* SSK+J,r,J-r-J.r.J/r/J0r0J1r1J2r2J3r3J4r4J5r5 SSK6J7r7J8r8J9r9J:r:J;r;Jr> Sr?"SS5r@"SS5rA"SS5rB"SS5rCg!\a SrNf=f!\a SrNf=f)z3Implementation of the X protocol for MySQL servers.N)BytesIO)AnyDictListOptionalTupleUnionTF)InterfaceErrorNotSupportedErrorOperationalErrorProgrammingError) ExprParserbuild_bool_scalar build_exprbuild_int_scalar build_scalarbuild_unsigned_int_scalar)encode_to_bytesget_item_or_attr)logger)CRUD_PREPARE_MAPPINGPROTOBUF_REPEATED_TYPESSERVER_MESSAGESMessage mysqlxpb_enum)Column) AddStatementDeleteStatementFilterableStatement FindStatementInsertStatementModifyStatement ReadStatementRemoveStatement SqlStatementUpdateStatement) ColumnType MessageTypeProtobufMessageCextTypeProtobufMessageTypeResultBaseType SocketType StatementType StrOrBytesicN\rSrSrSrS\SS4SjrS\S\4Sjr S\S\4S jr S r g) CompressorezImplements compression/decompression using `zstd_stream`, `lz4_message` and `deflate_stream` algorithms. Args: algorithm (str): Compression algorithm. .. versionadded:: 8.0.21 algorithmreturnNcXlSUlSUlUS:Xa5[R"5Ul[R "5UlgUS:Xa5[ R"5Ul[ R"5Ulgg)N zstd_streamdeflate_stream) _algorithm _compressobj_decompressobjzstdZstdCompressorZstdDecompressorzlib compressobj decompressobjselfr3s W/var/www/ev-aguas/ev-aguas-proceso/venv/lib/python3.13/site-packages/mysqlx/protocol.py__init__Compressor.__init__psq(!%#'  % $ 3 3 5D "&"7"7"9D  * * $ 0 0 2D "&"4"4"6D +datacURS:XaURRU5$URS:Xa^[RR 5nUR 5nX2RU5- nX2R5- nSSS5 U$URRU5nX0RR[R5- nU$!,(df  W$=f)zCompresses data and returns it. Args: data (str, bytes or buffer object): Data to be compressed. Returns: bytes: Compressed data. r6 lz4_messageN) r8r9compresslz4frameLZ4FrameCompressorbeginflushr> Z_SYNC_FLUSH)rBrG compressor compresseds rCrJCompressor.compress|s ??m +$$--d3 3 ??m +--/:'--/ 11$77 ..00 0 &&//5 ''--d.?.?@@ 0/ s 6C"" C1cURS:XaURRU5$URS:Xa:[RR 5nURU5nSSS5 U$URRU5nX0RR [R5- nU$!,(df  W$=f)zDecompresses a frame of data and returns it as a string of bytes. Args: data (str, bytes or buffer object): Data to be compressed. Returns: bytes: Decompresssed data. r6rIN) r8r: decompressrKrLLZ4FrameDecompressorrOr>rP)rBrG decompressor decompresseds rCrUCompressor.decompresss ??m +&&11$7 7 ??m +//1\+66t< 2 **55d; ++11$2C2CDD 21 s B>> C )r8r9r:) __name__ __module__ __qualname____firstlineno____doc__strrDr/bytesrJrU__static_attributes__rFrCr1r1es@ 7# 7$ 7ZE.zerFr1cj\rSrSrSrS\SS4SjrS\4SjrS\4Sjr S \SS4S jr S \ SS4S jr S r g) MessageReaderzImplements a Message Reader. Args: socket_stream (mysqlx.connection.SocketStream): `SocketStream` object. .. versionadded:: 8.0.21 socket_streamr4Nc:XlSUlSUl/UlgN)_stream _compressor_msg _msg_queuerBrfs rCrDMessageReader.__init__s#0 15!% )+rFctUR(aURRS5$[R"SURR S55upUS:Xa [ S5eURR US- 5nU[;a[SU35eUS:XaUS :XaUR5$[R"X#5nUS :XaUS n[URRUS 55nSnXu:ay[R"SUR S55upUR US- 5n URR[R"X55 XxS -- nXu:aMyUR(aURRS5$S$U$)afReads X Protocol messages from the stream and returns a :class:`mysqlx.protobuf.Message` object. Raises: :class:`mysqlx.ProgrammingError`: If e connected server does not have the MySQL X protocol plugin enabled. Returns: mysqlx.protobuf.Message: MySQL X Protobuf Message. r T--8899MNOFO!5)/ufkk!n)M&  ++lQ&67&&w'B'B8'UV!#33 "5 .2__4??&&q) F$ FrFcfURbURnSUlU$UR5$)zORead message. Returns: mysqlx.protobuf.Message: MySQL X Protobuf Message. N)rkr}rBmsgs rC read_messageMessageReader.read_messages2 99 ))CDIJ!!##rFrc@URb [S5eXlg)zPush message. Args: msg (mysqlx.protobuf.Message): MySQL X Protobuf Message. Raises: :class:`mysqlx.OperationalError`: If message push slot is full. NzMessage push slot is full)rkr rs rC push_messageMessageReader.push_messages 99 "#>? ? rFr3cBU(a[U5UlgSUlg)zCreates a :class:`mysqlx.protocol.Compressor` object based on the compression algorithm. Args: algorithm (str): Compression algorithm. .. versionadded:: 8.0.21 Nr1rjrAs rCset_compressionMessageReader.set_compressions5>:i04rF)rjrkrlri)rZr[r\r]r^r-rDr)r}rrr_rrarbrFrCrdrds\,j,T, -{-^ $k $    H H HrFrdcR\rSrSrSrS\SS4SjrS\S\SS4S jr S \ SS4S jr S r g) MessageWriteri zImplements a Message Writer. Args: socket_stream (mysqlx.connection.SocketStream): `SocketStream` object. .. versionadded:: 8.0.21 rfr4NcXlSUlgrh)rirjrms rCrDMessageWriter.__init__s#0 15rFrrcfURU5nUR(Ga/U[:Ga$[UR 55n[ R "SUS-U5nURRSRXT/55n[S5nXS'US-US'[S5nXhS'SR[UR55S S [UR55/5n [S 5n [ R "S[U 5S-U 5nURRSRXY/55 g [UR 55n[ R "SUS-U5nURRSRXT/55 g ) zyWrite message. Args: msg_type (int): The message type. msg (mysqlx.protobuf.Message): MySQL X Protobuf Message. rpr rFzMysqlx.Connection.Compressionclient_messagesrqrurvNz&Mysqlx.ClientMessages.Type.COMPRESSION) byte_sizerj_COMPRESSION_THRESHOLDrserialize_to_stringrypackrJjoinrserialize_partial_to_stringrlenrisendall) rBrrmsg_sizemsg_strheaderrRmsg_first_fields msg_payloadoutput msg_comp_ids rC write_messageMessageWriter.write_messagesw==%    +A A%c&=&=&?@G[[1 h?F))22388V:i04rF)rjri) rZr[r\r]r^r-rDintr)rr_rrarbrFrCrr sK6j6T6#>c#> #>#>JHHHrFrc \rSrSrSrS\S\SS4Sjr\S\ \ 4Sj5r \ S \ S \SS4S j5rS \S\ \ 4S jrS7S \\\4S\S\\S\\\\444SjjrS \ S\SS4SjrS\S\ \ 4SjrS\ SS4SjrS\ 4SjrS\SS4SjrS8S\ S\ \ S\ \ SS4SjjrS\ 4Sjr!S\ SS4Sjr"S9Sjr#S\ S \ S \\$\%\&\'\(\)4SS4S jr*S\ S \ S \SS4S!jr+S"\,SS4S#jr-S\ S \ S \\\4SS4S$jr.S\ S \ SS4S%jr/S \\$\'4S\0\ \ 44S&jr1S \\&\)4S\0\ \ 44S'jr2S \\%\(4S\0\ \ 44S(jr3S:S)\ S \\ \44S*\ \5\ \4S\0\ \ 44S+jjr6\ S \\7\84S\0\ \ 44S,j5r9S\SS4S-jr:S\S\ \ 4S.jr;S\S\\<4S/jr=S9S0jr>S9S1jr?S9S2jr@S9S3jrAS:S4\ \S\4S5jjrBS6rCg);ProtocoliJzImplements the MySQL X Protocol. Args: read (mysqlx.protocol.MessageReader): A Message Reader object. writer (mysqlx.protocol.MessageWriter): A Message Writer object. .. versionchanged:: 8.0.21 readerwriterr4Nc8XlX lSUl/Ulgrh)_reader_writer_compression_algorithm _warnings)rBrrs rCrDProtocol.__init__Ts&, &, 59#$&rFcUR$)zstr: The compresion algorithm.)r)rBs rCcompression_algorithmProtocol.compression_algorithmZs***rFrstmtcbUR(aUR5US'UR(a"USRUR 55 UR (a"USRUR 55 UR(aUR5US'gg)zApply filter. Args: msg (mysqlx.protobuf.Message): The MySQL X Protobuf Message. stmt (Statement): A `Statement` based type object. criteriaordergroupinggrouping_criteriaN) has_whereget_where_exprhas_sortextend get_sort_expr has_group_by get_grouping has_having get_having)rrs rC _apply_filterProtocol._apply_filter_s >>"113C O == L   2 2 4 5     O " "4#4#4#6 7 ??'+'8C# $ rFargc [U[5(a [SUS9n[SSUS9n[SSUS9$[U[5(a[SS[ U5S9$[U[ 5(a.US :a[SS[ U5S9$[SS[U5S9$[U[5(aQ[U5S :XaBUupE[S UURU5S 9n[S UR5/S9n[SS US9$[U[5(d3[U[[45(a[US [5(a/nUHn /n U R5H>up[S U URU5S 9nU RUR55 M@ [S U S9n [SS U S9n URU R55 M [S5nXS'[SSUS9$[U[5(a]/n UH>up[S U URU5S 9nU RUR55 M@ [S U S9n [SS U S9n U $g)zxCreate any. Args: arg (object): Arbitrary object. Returns: mysqlx.protobuf.Message: MySQL X Protobuf Message. zMysqlx.Datatypes.Scalar.String)valuezMysqlx.Datatypes.Scalar)typev_stringMysqlx.Datatypes.Anyr )rscalarr#Mysqlx.Datatypes.Object.ObjectFieldkeyrMysqlx.Datatypes.ObjectfldrobjzMysqlx.Datatypes.Arrayr)rarrayN) isinstancer_rboolrrrrtupler _create_any get_messagedictlistitemsr)rBrrrarg_key arg_valueobj_fldr array_valuesrobj_fldsrmsg_objmsg_anyrs rCrProtocol._create_anypsw c3  T(a[U5R5$TRU5R5$rh)rrr)rrrBs rC build_value/Protocol._get_binding_args..build_values6#E*6688##E*668 8rFNz;The number of bind parameters and placeholders do not matchz*Unable to find placeholder for parameter: ) rr r+r* get_bindingsget_binding_maprrr) rBrrrbindings binding_maprcountargsnameposs ` ` rC_get_binding_argsProtocol._get_binding_argss" 9 9 &(?? @ 9 9$$&**,   4<=H5K&H= =K 4&. CM !"M $>>+KD&&@G#C#E*DI , >s Cresultc USS:Xa[R"SUS5nURRUR5 [ R "SURUR5 URURURUR5 gUSS:Xa"SUS5 gUSS:Xa[R"S US5nUS [S 5:XaGURUS Vs/sH'n[[US 5S 5R5PM) sn5 g[US [[ 55(aUS SOUS nUS [S5:XaUR#[US55 gUS [S5:XaUR%[US55 gggs snf)zProcess frame. Args: msg (mysqlx.protobuf.Message): A MySQL X Protobuf Message. result (Result): A `Result` based type object. rr zMysqlx.Notice.Warningrvz:Protocol.process_frame Received Warning Notice code %s: %srz$Mysqlx.Notice.SessionVariableChangedrz!Mysqlx.Notice.SessionStateChangedparamzBMysqlx.Notice.SessionStateChanged.Parameter.GENERATED_DOCUMENT_IDSrv_octetsrz9Mysqlx.Notice.SessionStateChanged.Parameter.ROWS_AFFECTEDv_unsigned_intz?Mysqlx.Notice.SessionStateChanged.Parameter.GENERATED_INSERT_IDN)r from_messagerrrrwarningcodeappend_warninglevelrset_generated_idsrdecoderrrset_rows_affectedset_generated_insert_id)rBrrwarn_msgsess_state_msgrsess_state_values rC_process_frameProtocol._process_frames v;! ++,CS^TH NN ! !(,, / NNL     ! !(..(-- N [A   !GY X [A $113S^Ng&-T+(( &4G%< &=E),UJ? &(#&= "&w/7N1O#7+A.(0 !"'*mO/,,()9;KL$G, U122()9;KL;s-GcURR5nWR S:Xa[ USUS5eUR S:XaURX!5 O|UR S:XagUR S :XaURS5 OIUR S :XaURS5 O'UR S :XaURS5 U$U$M![a<n[UR 55nU(a[USU35UeSnAGNSnAff=f![[4a GM<f=f) zHRead message. Args: result (Result): A `Result` based type object. Tz reason: N Mysqlx.ErrorrrMysqlx.Notice.FramezMysqlx.Sql.StmtExecuteOkzMysqlx.Resultset.FetchDonez(Mysqlx.Resultset.FetchDoneMoreResultsetsMysqlx.Resultset.Row) rr RuntimeErrorrepr get_warningsrr rAttributeErrorKeyError set_closedset_has_more_results set_has_data)rBrrerrwarningss rCr}Protocol._read_messages=  Mll//1 xx>)&s5z3v;??xx00''47799!!$'GG++D133##D)  3  M 3 3 56&#iz'BCL M'1s)C D) D&*1D!!D&)D>=D>r3c|XlURRU5 URRU5 g)zSets the compression algorithm to be used by the compression object, for uplink and downlink. Args: algorithm (str): Algorithm to be used in compression/decompression. .. versionadded:: 8.0.21 N)rrrrrAs rCrProtocol.set_compression?s.'0# $$Y/ $$Y/rFcV[S5nURR[S5U5 URR 5nUR S:Xa,URR 5nUR S:XaM,UR S:Xa[USUS5eU$)zSGet capabilities. Returns: mysqlx.protobuf.Message: MySQL X Protobuf Message. z!Mysqlx.Connection.CapabilitiesGetz/Mysqlx.ClientMessages.Type.CON_CAPABILITIES_GETrrrr)rrrrrrrr rs rCget_capabilitesProtocol.get_capabilitesMs 9: "" K L  ll'')hh//,,++-Chh// 88~ %"3u:s6{; ; rFkwargsc U(dg[S5nUR5Hup4[S5nX5S'[U[5(aqUn/nUH>n[SUUR Xh5S9n UR U R 55 M@ [SUS9n [S S U S 9n U R 5US 'OUR U5US 'US RUR 5/5 M [S5n X,S 'URR[S5U 5 UR5$![an U RS:waeSn A gSn A ff=f)zSet capabilities. Args: **kwargs: Arbitrary keyword arguments. Returns: mysqlx.protobuf.Message: MySQL X Protobuf Message. NzMysqlx.Connection.CapabilitieszMysqlx.Connection.Capabilityrrrrrrrrr capabilitiesz!Mysqlx.Connection.CapabilitiesSetz/Mysqlx.ClientMessages.Type.CON_CAPABILITIES_SETi)rrrrrrrrrrrread_okr errno)rBr'r)rr capabilityrritemrrrrrs rCset_capabilitiesProtocol.set_capabilitiesasd?@  ,,.JC !?@J!$v %&&!D%= "..u{;G OOG$7$7$9: """;J!"8qgN&-&9&9&; 7#&*&6&6u&= 7#  ( / /1G1G1I0J K')(9:*N "" K L   <<> ! yyD !  s.D>> E#EE#method auth_datainitial_responsec[S5nXS'UbX$S'UbX4S'URR[S5U5 g)zSend authenticate start. Args: method (str): Message method. auth_data (Optional[str]): Authentication data. initial_response (Optional[str]): Initial response. z Mysqlx.Session.AuthenticateStart mech_nameNr1r2z2Mysqlx.ClientMessages.Type.SESS_AUTHENTICATE_STARTrrrr)rBr0r1r2rs rCsend_auth_startProtocol.send_auth_startsR89!K  (   '&6" # "" N O  rFcURR5nURS:Xa,URR5nURS:XaM,URS:wa [S5eUS$)zRead authenticate continue. Raises: :class:`InterfaceError`: If the message type is not `Mysqlx.Session.AuthenticateContinue` Returns: str: The authentication data. r#Mysqlx.Session.AuthenticateContinuez>Unexpected message encountered during authentication handshaker1rrrr rs rCread_auth_continueProtocol.read_auth_continuesnll'')hh//,,++-Chh// 88< < P ;rFcb[SUS9nURR[S5U5 g)zMSend authenticate continue. Args: auth_data (str): Authentication data. r9)r1z5Mysqlx.ClientMessages.Type.SESS_AUTHENTICATE_CONTINUENr5)rBr1rs rCsend_auth_continueProtocol.send_auth_continues/ ;yQ "" Q R  rFcURR5nURS:XagURS:Xa[UR5eMR)zfRead authenticate OK. Raises: :class:`mysqlx.InterfaceError`: If message type is `Mysqlx.Error`. zMysqlx.Session.AuthenticateOkrN)rrrr rrs rC read_auth_okProtocol.read_auth_oksI ,,++-Cxx::xx>)$SWW-- rFrc$UR(aURS:waURS:XaURU5upBOVURS:XaURU5upBO2URS:XaUR U5upBO[ SU35e[ UR55n[S5n[S5n[SXeS 9US 'URS:Xa[SXeS -S 9US 'XrS '[Uup[S5n [U5U S'X*U '[S5n URU S'XS'URR[S5U 5 UR5 g![a n [ U eSn A ff=f)aV Send prepare statement. Args: msg_type (str): Message ID string. msg (mysqlx.protobuf.Message): MySQL X Protobuf Message. stmt (Statement): A `Statement` based type object. Raises: :class:`mysqlx.NotSupportedError`: If prepared statements are not supported. .. versionadded:: 8.0.16 Mysqlx.Crud.InsertMysqlx.Crud.FindMysqlx.Crud.UpdateMysqlx.Crud.DeletezInvalid message type: z!Mysqlx.Expr.Expr.Type.PLACEHOLDERzMysqlx.Crud.LimitExprzMysqlx.Expr.Expr)rposition row_countr offset limit_expr#Mysqlx.Prepare.Prepare.OneOfMessagerzMysqlx.Prepare.Preparestmt_idrz*Mysqlx.ClientMessages.Type.PREPARE_PREPAREN) has_limitr build_find build_update build_deleter|rrrrrrMrrr*r r ) rBrrr_rH placeholdermsg_limit_expr oneof_typeoneof_op msg_oneof msg_preparers rCsend_prepare_prepareProtocol.send_prepare_prepares6 >>chh*>>xx--.311**40311**403 #9(!DEE4,,./H'(KLK$%<=N*1"+N; 'xx--+2&[a<,x(!/ 3H= AB )*5 &!(67 !% I'F "" F G   - LLN -# , -s(E99 FF  Fc"[UupE[S5n[U5US'X&U'[S5nURUS'UR USS9nU(aUSR U5 UR (alUSR URUR55R5URUR55R5/5 URR[S5U5 g ) z Send execute statement. Args: msg_type (str): Message ID string. msg (mysqlx.protobuf.Message): MySQL X Protobuf Message. stmt (Statement): A `Statement` based type object. .. versionadded:: 8.0.16 rLrzMysqlx.Prepare.ExecuterMFrrz*Mysqlx.ClientMessages.Type.PREPARE_EXECUTEN) rrrrMrrrNrget_limit_row_countrget_limit_offsetrr) rBrrrrUrVrW msg_executers rCsend_prepare_executeProtocol.send_prepare_executes 4H= AB )*5 &!(67 !% I%%de%<    & &t , >>   & &$$T%=%=%?@LLN$$T%:%:%<=IIK  "" F G  rFrMc[S5nXS'URR[S5U5 UR 5 g)zf Send prepare deallocate statement. Args: stmt_id (int): Statement ID. .. versionadded:: 8.0.16 zMysqlx.Prepare.DeallocaterMz-Mysqlx.ClientMessages.Type.PREPARE_DEALLOCATEN)rrrrr*)rBrM msg_deallocs rCsend_prepare_deallocate Protocol.send_prepare_deallocate>s@9: !(I "" I J   rFc0UR(aE[S5nUR5US'URS:XaUR 5US'XBS'US:gnUR X5S9nU(aUSR U5 URX5 g ) z Send a message without prepared statements support. Args: msg_type (str): Message ID string. msg (mysqlx.protobuf.Message): MySQL X Protobuf Message. stmt (Statement): A `Statement` based type object. .. versionadded:: 8.0.16 zMysqlx.Crud.LimitrIrErJlimit+Mysqlx.ClientMessages.Type.SQL_STMT_EXECUTEr\rN)rNrr]rr^rrsend_msg)rBrrr msg_limitrrs rCsend_msg_without_psProtocol.send_msg_without_psOs >> 34I%)%=%=%?Ik "xx--&*&;&;&= (#$L MM %%d%@  K  t $ h$rFcNURR[U5U5 g)z Send a message. Args: msg_type (str): Message ID string. msg (mysqlx.protobuf.Message): MySQL X Protobuf Message. .. versionadded:: 8.0.16 N)rrr)rBrrs rCriProtocol.send_msgks ""=#:C@rFc&[UR5(aSOS5n[SURRUR RS9n[SX#S9nUR (aUR5US'URXA5 UR5(a[S5US 'O#UR5(a[S 5US 'URRS :aURRUS 'S U4$)aCBuild find/read message. Args: stmt (Statement): A :class:`mysqlx.ReadStatement` or :class:`mysqlx.FindStatement` object. Returns: (tuple): Tuple containing: * `str`: Message ID string. * :class:`mysqlx.protobuf.Message`: MySQL X Protobuf Message. .. versionadded:: 8.0.16 Mysqlx.Crud.DataModel.DOCUMENTMysqlx.Crud.DataModel.TABLEMysqlx.Crud.CollectionrschemarE data_model collection projectionz'Mysqlx.Crud.Find.RowLock.EXCLUSIVE_LOCKlockingz$Mysqlx.Crud.Find.RowLock.SHARED_LOCKrlocking_optionsz$Mysqlx.ClientMessages.Type.CRUD_FIND) r is_doc_basedrtargetrrthas_projectionget_projection_exprris_lock_exclusiveis_lock_sharedlock_contentionrrBrrvrwrs rCrOProtocol.build_findws"#  "" -.  $!!;;## (ZW    $ 8 8 :C  3%  ! ! # #*+TUC N  " "*+QRC N    % % )%)%9%9%?%?C! "5s::rFc[UR5(aSOS5n[SURRUR RS9n[SX#S9nUR XA5 UR5R5HvupV[S5nURUS'URUS 'URb[UR5US 'USRUR5/5 Mx S U4$) aDBuild update message. Args: stmt (Statement): A :class:`mysqlx.ModifyStatement` or :class:`mysqlx.UpdateStatement` object. Returns: (tuple): Tuple containing: * `str`: Message ID string. * :class:`mysqlx.protobuf.Message`: MySQL X Protobuf Message. .. versionadded:: 8.0.16 rprqrrrsrFruzMysqlx.Crud.UpdateOperation operationsourcerz&Mysqlx.ClientMessages.Type.CRUD_UPDATE)rr{rr|rrtrget_update_opsr update_typerrrrr)rBrrvrwrrR update_oprs rCrPProtocol.build_updates"#  "" -.  $!!;;##  Z  3% //1779LA =>I%.%:%:Ik ""+"2"2Ih *%/ %@ '"   # #Y%:%:%<$= > :8<upg[SUURU5S9nURUR 55 M@ [SUS9n [SS U S 9n U R 5/US 'S U4$) aZBuild execute statement. Args: namespace (str): The namespace. stmt (Statement): A `Statement` based type object. fields (Optional[dict]): The message fields. Returns: (tuple): Tuple containing: * `str`: Message ID string. * :class:`mysqlx.protobuf.Message`: MySQL X Protobuf Message. .. versionadded:: 8.0.16 zMysqlx.Sql.StmtExecuteF)rrcompact_metadatarrrrrrrrrh)rrrrr) rBrrrrrrrrrrs rCbuild_execute_statement Protocol.build_execute_statements* $"   H$lln !9**51  3 3 56 -7XFG41'JG"..01CK & __&E78C%&& CL''C)D)D)F(GH!G ##Z%6%B%B%D$EF J  s01 2' 4 % % NN,CM7<#e*!>c&kR R 88{ " !AB B #rFcd[S5nURR[S5U5 g)zSend connection close.zMysqlx.Connection.Closez$Mysqlx.ClientMessages.Type.CON_CLOSENr5rs rCsend_connection_closeProtocol.send_connection_closes*/0 "" @ A3 rFcd[S5nURR[S5U5 g)z Send close.zMysqlx.Session.Closez%Mysqlx.ClientMessages.Type.SESS_CLOSENr5rs rC send_closeProtocol.send_closes*,- "" A BC rFc[S5n[S5nXS'SUS'[S5nUR5/US'URR [S5U5 g ) zSend expectation.z3Mysqlx.Expect.Open.Condition.Key.EXPECT_FIELD_EXISTzMysqlx.Expect.Open.Condition condition_keyz6.1condition_valuezMysqlx.Expect.Opencondz&Mysqlx.ClientMessages.Type.EXPECT_OPENN)rrrrr)rBcond_keymsg_ocmsg_eos rCsend_expect_openProtocol.send_expect_opensh !VW78"*$) !-. ,,./v "" B CV rF keep_openc[S5nUc#UR5 UR5 SnU(aSUS'URR [ S5U5 UR5 U(agg![a SnNXf=f)zSend reset session message. Returns: boolean: ``True`` if the server will keep the session open, otherwise ``False``. zMysqlx.Session.ResetTFrz%Mysqlx.ClientMessages.Type.SESS_RESET)rrr*r rrr)rBrrs rC send_resetProtocol.send_resets,-   "%%'   #C  "" A BC   " "!  "s"A<< B  B )rrrr)T)NN)r4Nrh)DrZr[r\r]r^rdrrDpropertyrr_r staticmethodr)r rrrr r&rrr+r*rr,rr}rr%r.r6r`r;r>rAr!rr#r$r%r'rYr`rrdrkrirrOrPrQr.rrrr"rrrr(rr*rrrrrarbrFrCrrJs'}'m'' +x}++9;9.A9d99 HsHx '<HVQU,-|;<,IM, tDz4&9;R&R STT U,\4+4~4$4lNx 7LB 0 0 0(...f$(*.   C= #3-    0 E &  C  D   .B-B-B-         B- B-H# # "-# 5H# # Jst"%%%'56 %  %8 A A; A4 A(;-67(; sK (;T'=/?:;'= sK '=R=/?:;= sK =J,0 (B(BC&'(Bc3h( (B sK (BT2=L/122= sK 2=2=h C> Cd C ~ (;2G "."T*=M"H C    HTNdrFr)Dr^ryr>iortypingrrrrrr lz4.framerKHAVE_LZ4 ImportError zstandardr; HAVE_ZSTDerrorsr r r rrrrrrrrhelpersrrrprotobufrrrrrrr statementrrr r!r"r#r$r%r&r'typesr(r)r*r+r,r-r.r/rr1rdrrrbrFrCrs:: ::HI 7      AAHaHaHH:H:Hz@@C HIs"CCCCCC