:?hjS %SrSSKJr SSKJrJrJrJrJrJ r J r SSK J r J r Jr SrS\S'S rS \S '\/rS \S 'SS Kr\VVs0sHup\"\R-U55U_M snnrSrSSKJrJrJr SSKJr SSK J!r!J"r"J#r#J$r$ SSK%J&r& SSK'J(r( \RS\(5 \RS\&5 \*"\S5(a \RVrSSK,J-r-J.r.J/r/J0r0J1r1J2r2J3r3J4r4J5r5J6r6J7r7J8r8 0r9S\S'\4RtRRw5HurS=jrlg s snnf!\a SrGN f=f!\a GNf=fs snnf!\\f\g4a&rhSrc\b\hOS/rd\(d \"S0\d35\heS rhChNyS rhChff=f)?z?Implementation of a helper class for MySQL X Protobuf messages.) annotations)AnyDictListOptionalTupleTypeUnion) MessageTypeProtobufMessageCextTypeProtobufMessageType))zMysqlx.ServerMessages.Type.OKz Mysqlx.Ok)z Mysqlx.ServerMessages.Type.ERRORz Mysqlx.Error)z,Mysqlx.ServerMessages.Type.CONN_CAPABILITIESzMysqlx.Connection.Capabilities)z5Mysqlx.ServerMessages.Type.SESS_AUTHENTICATE_CONTINUEz#Mysqlx.Session.AuthenticateContinue)z/Mysqlx.ServerMessages.Type.SESS_AUTHENTICATE_OKzMysqlx.Session.AuthenticateOk)z!Mysqlx.ServerMessages.Type.NOTICEzMysqlx.Notice.Frame)z5Mysqlx.ServerMessages.Type.RESULTSET_COLUMN_META_DATAzMysqlx.Resultset.ColumnMetaData)z(Mysqlx.ServerMessages.Type.RESULTSET_ROWzMysqlx.Resultset.Row)z/Mysqlx.ServerMessages.Type.RESULTSET_FETCH_DONEzMysqlx.Resultset.FetchDone)z4Mysqlx.ServerMessages.Type.RESULTSET_FETCH_SUSPENDEDzMysqlx.Resultset.FetchSuspended)z?Mysqlx.ServerMessages.Type.RESULTSET_FETCH_DONE_MORE_RESULTSETSz(Mysqlx.Resultset.FetchDoneMoreResultsets)z.Mysqlx.ServerMessages.Type.SQL_STMT_EXECUTE_OKzMysqlx.Sql.StmtExecuteOk)z?Mysqlx.ServerMessages.Type.RESULTSET_FETCH_DONE_MORE_OUT_PARAMSz'Mysqlx.Resultset.FetchDoneMoreOutParams)z&Mysqlx.ServerMessages.Type.COMPRESSIONzMysqlx.Connection.CompressionzTuple[Tuple[str, str], ...]_SERVER_MESSAGES_TUPLESN Optional[str]PROTOBUF_VERSIONzpList[Union[Type[List[Dict[str, Any]]], Type[RepeatedCompositeContainer], Type[RepeatedCompositeFieldContainer]]]PROTOBUF_REPEATED_TYPESTF) BYTE_TYPES NUMERIC_TYPESencode_to_bytes)protobuf)descriptor_databasedescriptor_pb2descriptor_poolmessage_factory)RepeatedCompositeFieldContainer)RepeatedCompositeContainer __version__) mysqlx_connection_pb2mysqlx_crud_pb2mysqlx_cursor_pb2mysqlx_datatypes_pb2mysqlx_expect_pb2mysqlx_expr_pb2mysqlx_notice_pb2 mysqlx_pb2mysqlx_prepare_pb2mysqlx_resultset_pb2mysqlx_session_pb2mysqlx_sql_pb2zDict[str, int] _MESSAGESzMysqlx.ClientMessages.Type.zMysqlx.ServerMessages.Type.zMysqlx.Error.Severity.zMysqlx.Crud.DataModel.zMysqlx.Crud.Find.RowLock.zMysqlx.Crud.Order.Direction.z'Mysqlx.Crud.UpdateOperation.UpdateType.zMysqlx.Datatypes.Scalar.Type.zMysqlx.Datatypes.Any.Type.z0Mysqlx.Expect.Open.Condition.ConditionOperation.z!Mysqlx.Expect.Open.Condition.Key.z Mysqlx.Expect.Open.CtxOperation.zMysqlx.Expr.Expr.Type.z"Mysqlx.Expr.DocumentPathItem.Type.zMysqlx.Notice.Frame.Scope.zMysqlx.Notice.Warning.Level.z,Mysqlx.Notice.SessionStateChanged.Parameter.z)Mysqlx.Prepare.Prepare.OneOfMessage.Type.z*Mysqlx.Resultset.ColumnMetaData.FieldType.c\rSrSr%Sr\R "5rS\S'\ S Sj5r \ SSj5r \ SSj5r \ SSj5r \ SS j5r\ SS j5rS rg )_mysqlxpb_pureizUThis class implements the methods in pure Python used by the _mysqlxpb C++ extension.zmessage_factory.MessageFactoryfactoryct[RR[R U55nU"5$)zoCreate new Protobuf message. Args: name (str): Message type name. Returns: object: Protobuf message. )r-r. GetPrototype_DESCRIPTOR_POOLFindMessageTypeByName)nameclss `/var/www/ev-aguas/ev-aguas-proceso/venv/lib/python3.13/site-packages/mysqlx/protobuf/__init__.py new_message_mysqlxpb_pure.new_messages1!((55 66t<C5Lc[U$)zWReturn enum value. Args: enum_key (str): Enum key. Returns: int: enum value. )r+)enum_keys r5 enum_value_mysqlxpb_pure.enum_value%sX& &r8c"UR5$)ztSerialize message. Args: msg (object): Protobuf message. Returns: bytes: Serialized message bytes string. )SerializeToStringmsgs r5serialize_message _mysqlxpb_pure.serialize_message1s((* *r8c"UR5$)zSerialize partial message. Args: msg (object): Protobuf message. Returns: bytes: Serialized partial message bytes string. )SerializePartialToStringr?s r5serialize_partial_message(_mysqlxpb_pure.serialize_partial_message=s//1 1r8cR[RU5nURU5 U$)zSerialize partial message. Args: msg_type_name (str): Message type name. payload (bytes): Payload. Returns: object: Message parsed from string. )r-r6ParseFromString) msg_type_namepayloadr@s r5 parse_message_mysqlxpb_pure.parse_messageIs'!,,];C    (Jr8c[RU5nU(d[SU35e[R U5nUR U5 U$)zParse server message message. Args: msg_type (int): Message type. payload (bytes): Payload. Returns: object: Server message parsed from string. zUnknown msg_type: )SERVER_MESSAGESget ValueErrorr-r6rH)msg_typerJrIr@s r5parse_server_message#_mysqlxpb_pure.parse_server_messageXsM,//9M  #5hZ!@AA ,,];C    (Jr8N)r3strreturnr)r:rUrVint)r@rrVbytes)rIrUrJrXrVr)rQrWrJrXrVr)__name__ __module__ __qualname____firstlineno____doc__rMessageFactoryr.__annotations__ staticmethodr6r;rArErKrR__static_attributes__rTr8r5r-r-s $3B2P2P2R/R      '  '  +  +  2  2        r8r-zProtobuf >=3.11.0 is requiredProtobuf is not available: )z-Mysqlx.Prepare.Prepare.OneOfMessage.Type.FINDfind)z/Mysqlx.Prepare.Prepare.OneOfMessage.Type.INSERTinsert)z/Mysqlx.Prepare.Prepare.OneOfMessage.Type.UPDATEupdate)z/Mysqlx.Prepare.Prepare.OneOfMessage.Type.DELETEdelete)z-Mysqlx.Prepare.Prepare.OneOfMessage.Type.STMT stmt_execute)z$Mysqlx.ClientMessages.Type.CRUD_FINDz&Mysqlx.ClientMessages.Type.CRUD_INSERTz&Mysqlx.ClientMessages.Type.CRUD_UPDATEz&Mysqlx.ClientMessages.Type.CRUD_DELETEz+Mysqlx.ClientMessages.Type.SQL_STMT_EXECUTEzDict[str, Tuple[str, str]]CRUD_PREPARE_MAPPINGc\\rSrSr%Sr\(a\O\r\(+r S\ S'\ SSj5r Sr g) ProtobufizProtobuf class acts as a container of the Protobuf message class. It allows the switch between the C extension and pure Python implementation message handlers, by patching the `mysqlxpb` class attribute. booluse_purecU(a[(d[S[35eU(d[(d [S5eU(a[O[ [ lU[ lg)zSets whether to use the C extension or pure Python implementation. Args: use_pure (bool): `True` to use pure Python implementation. rbz-MySQL X Protobuf C extension is not availableN) HAVE_PROTOBUF ImportErrorHAVE_PROTOBUF_ERRORHAVE_MYSQLXPB_CEXTr- _mysqlxpbrjmysqlxpbrl)rls r5 set_use_pureProtobuf.set_use_puresI MM ;KD   T )*r8c[R(Ga[U[5(a![ UR U[ U55 g[U[[45(a[ UR X5 g[U[5(a&[UR U5RU5 g[U[5(a4[UR U5RUR55 g[UR U5RU5 g[U[5(a[ U5UR U'g[U[5(aUR5OUUR U'gN)rjrl isinstancerUsetattrrzrrrlistgetattrextendrx MergeFrom get_messager~r3rs r5r}Message.__setattr__s    %%% 4)?@EM:#>?? 4/E4(( 4(//6E7++ 4(2253D3D3FG 4(2259%%%"1%"8 $,6eW+E+EE%%'5 $r8c[R(dURU$[URU5$![a [ Sef=fr)rjrlrzrKeyErrorAttributeErrorr~r3s r5 __getattr__Message.__getattr__sL +'/'8'8 $ >EdiiQU>V  + d * +s #<<Ac&URX5 gr)r}rs r5 __setitem__Message.__setitem__s %r8c$URU5$r)rrs r5 __getitem__Message.__getitem__s%%r8c[R(dURSRX5$[ URSX5$)zReturns the value of an element of the message dictionary. Args: name (string): Key name. default (object): The default value if the key does not exists. Returns: object: The value of the provided key name. rz)rjrlr{rOr)r~r3defaults r5rO Message.getsE$$ MM& ! % %d 4 v.> r8c XRS'g)zLSets the message. Args: msg (dict): Dictionary representing a message. rzNr{)r~r@s r5 set_messageMessage.set_messages!$ fr8c URS$)zReturns the dictionary representing a message containing parsed data. Returns: dict: The dictionary representing a message containing parsed data. rzrr~s r5rMessage.get_messages}}V$$r8cT[RRUR5$)zmSerializes a message to a string. Returns: str: A string representing a message containing parsed data. )rjrsrArzrs r5serialize_to_stringMessage.serialize_to_strings   22499==r8cT[RRUR5$)zSerializes the protocol message to a binary string. This method is similar to serialize_to_string but doesn't check if the message is initialized. Returns: str: A string representation of the partial message. )rjrsrErzrs r5serialize_partial_to_string#Message.serialize_partial_to_strings  ::499EEr8c[R(dURS$URRR$)zstring: Message type name._mysqlxpb_type_name)rjrlrz DESCRIPTOR full_namers r5type Message.type s; $$ II+ , %%// r8c@[RRX5$)aCreates a new message, initialized with parsed data. Args: msg_type_name (string): Message type name. payload (string): Serialized message data. Returns: dict: The dictionary representing a message containing parsed data. .. versionadded:: 8.0.21 )rjrsrK)rIrJs r5parse Message.parses  ..}FFr8c[R(aUR5$[[ UR 555$)zReturns the size of the message in bytes. Args: msg (mysqlx.protobuf.Message): MySQL X Protobuf Message. Returns: int: Size of the message in bytes. .. versionadded:: 8.0.21 )rjrlByteSizelenrrr?s r5 byte_sizeMessage.byte_size&s:   LLN _S%<%<%>?@ r8c@[RRX5$)zCreates a new server-side message, initialized with parsed data. Args: msg_type (int): Message type. payload (string): Serialized message data. Returns: dict: The dictionary representing a message containing parsed data. )rjrsrR)rQrJs r5parse_from_serverMessage.parse_from_server8s  55hHHr8cpU"5nUR[RRX55 U$)aOCreates a new message, initialized with parsed data and returns a :class:`mysqlx.protobuf.Message` object. Args: msg_type_name (string): Message type name. payload (string): Serialized message data. Returns: mysqlx.protobuf.Message: The Message representing a message containing parsed data. )rrjrsrK)r4rIrJr@s r5 from_messageMessage.from_messageGs-e ))77 OP r8cpU"5nUR[RRX55 U$)aNCreates a new server-side message, initialized with parsed data and returns a :class:`mysqlx.protobuf.Message` object. Args: msg_type (int): Message type. payload (string): Serialized message data. Returns: mysqlx.protobuf.Message: The Message representing a message containing parsed data. )rrjrsrR)r4rQrJr@s r5from_server_messageMessage.from_server_messageXs-e ))>>xQR r8rTr)rIrrrrVrv)r3rUrrrVrv)r3rUrVr)r3rUrrrVr)r@3Union[ProtobufMessageType, ProtobufMessageCextType]rVrv)rVr)rVrX)rVrU)rIrUrJrXrVr)r@r rVrW)rQrWrJrXrVr)rIrUrJrXrVr )rQrWrJrXrVr )rYrZr[r\r]rr}rrrrOrrrrpropertyrr`rrr classmethodrrrarTr8r5rxrxs*(+&& $F$ $%> F  GG%*G <GG   " I I % I < I I r8rxc@[RRU5$)zReturns the value of a MySQL X Protobuf enumerator. Args: name (string): MySQL X Protobuf numerator name. Returns: int: Value of the enumerator. )rjrsr;)r3s r5 mysqlxpb_enumrjs    ' ' --r8)r3rUrVrW)mr] __future__rtypingrrrrrr r typesr r rrr_rrrrrrWr;rNrqrohelpersrrrgooglergoogle.protobufrrrr#google.protobuf.internal.containersrgoogle.protobuf.pyext._messagerappendhasattrrrr r!r"r#r$r%r&r'r(r)r*r+ClientMessagesr|keyvalServerMessagesErrorSeverity DataModelFindRowLockOrder DirectionUpdateOperation UpdateTypeScalarOpen ConditionConditionOperationKey CtxOperationExprDocumentPathItemFrameScopeWarningLevelSessionStateChanged ParameterPrepare OneOfMessageColumnMetaData FieldTypeDescriptorDatabase_DESCRIPTOR_DBDescriptorPoolr1AddFileDescriptorProto FromStringr serialized_pbrnrpr- SyntaxError TypeErrorerrrhrjrxr)rrs00r5rs>F#@@@MM-84-^#'-& F  =T>DDFSEH ;C5ABG)//44::<S;> 1#78=(,,11779S8; .se45:&**44GGMMOSNQ DSEJKP%**4488>>@S?B 5cU;<A%**77==?S>A 4SE:;@$((--335S47 *3%016#4499??AS@C 6se<=B&++11779S8; .se45:%--3399;S:= 067<%99CCIIKSJM @FGL'..;;@@FFHSGJ =cUCDI)77AAGGISHK >seDEJ);;=N&55nE**55 ! , , : :  **55  & & 4 4  **55  ( ( 6 6  **55 + + 9 9  **55  ( ( 6 6  **55  & & 4 4  **55  ( ( 6 6  **55  ! ! / /  **55  ) ) 7 7  **55 + + 9 9  **55  ) ) 7 7  **55  % % 3 3