U ƒeDNć @s¾dZdZdZegZzddlZdd„eDƒZdZWnek rHdZYnXdd l m Z m Z m Z zĪdd l mZdd lmZmZmZmZdd lmZzdd lmZe e”Wnek rĄYnXe e”eedƒrÜejZddlmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'iZ(e#j)j* +”D]\Z,Z-e-e(de,›<q$e#j.j* +”D]\Z,Z-e-e(de,›<qJe#j/j0 +”D]\Z,Z-e-e(de,›<qpej1 +”D]\Z,Z-e-e(de,›<q”ej2j3 +”D]\Z,Z-e-e(de,›<qŗej4j5 +”D]\Z,Z-e-e(de,›<qąej6j7 +”D]\Z,Z-e-e(de,›<qej8j* +”D]\Z,Z-e-e(de,›<q,ej9j* +”D]\Z,Z-e-e(de,›<qRe j:j;j< +”D]\Z,Z-e-e(de,›<qze j:j;j= +”D]\Z,Z-e-e(de,›<q¢e j:j> +”D]\Z,Z-e-e(de,›<qČe!j?j* +”D]\Z,Z-e-e(de,›<qīe!j@j* +”D]\Z,Z-e-e(de,›<qe"jAjB +”D]\Z,Z-e-e(de,›<q:e"jCjD +”D]\Z,Z-e-e(d e,›<q`e"jEjF +”D]\Z,Z-e-e(d!e,›<q†e$jGjHj* +”D]\Z,Z-e-e(d"e,›<q®e%jIjJ +”D]\Z,Z-e-e(d#e,›<qŌe K”ZLe MeL”ZNeL OejP QejRjS””eL OejP QejRjS””eL OejP QejRjS””eL OejP QejRjS””eL OejP Qe jRjS””eL OejP Qe!jRjS””eL OejP Qe"jRjS””eL OejP Qe#jRjS””eL OejP Qe$jRjS””eL OejP Qe%jRjS””eL OejP Qe&jRjS””eL OejP Qe'jRjS””d$d„eDƒZdZTdZUGd%d&„d&ƒZVWnVeeWeXfk r„ZYz0dZTedk rZeYnd'ZUested(eU›ƒeY‚W5dZY[YXYnXd)d*d+d,d-d.œZZGd/d0„d0ƒZ[Gd1d2„d2ƒZ\d3d4„Z]dS)5z?Implementation of a helper class for MySQL X Protobuf messages.))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.CompressionNécCs i|]\}}tt |”ƒ|“qS©)ŚintŚ _mysqlxpbŚ enum_value©Ś.0ŚkeyŚvalrrśY/var/www/html/assets/scripts/venv/lib/python3.8/site-packages/mysqlx/protobuf/__init__.pyŚ Us r TFé)Ś BYTE_TYPESŚ NUMERIC_TYPESŚencode_to_bytes)Śprotobuf)Śdescriptor_databaseŚdescriptor_pb2Śdescriptor_poolŚmessage_factory)ŚRepeatedCompositeFieldContainer)ŚRepeatedCompositeContainerŚ __version__é) Śmysqlx_connection_pb2Śmysqlx_crud_pb2Śmysqlx_cursor_pb2Śmysqlx_datatypes_pb2Śmysqlx_expect_pb2Śmysqlx_expr_pb2Śmysqlx_notice_pb2Ś mysqlx_pb2Śmysqlx_prepare_pb2Śmysqlx_resultset_pb2Śmysqlx_session_pb2Śmysqlx_sql_pb2zMysqlx.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.cCsi|]\}}t||“qSr©Ś _MESSAGESrrrr r żsc@s`eZdZdZe ”Zedd„ƒZedd„ƒZ edd„ƒZ edd „ƒZ ed d „ƒZ ed d „ƒZ dS)Ś_mysqlxpb_purez]This class implements the methods in pure Python used by the _mysqlxpb C++ extension.cCstj t |””}|ƒS)z«Create new Protobuf message. Args: name (str): Message type name. Returns: object: Protobuf message. )r'ŚfactoryZ GetPrototypeŚ_DESCRIPTOR_POOLZFindMessageTypeByName)ŚnameŚclsrrr Ś new_messages ’z_mysqlxpb_pure.new_messagecCst|S)zœReturn enum value. Args: enum_key (str): Enum key. Returns: object: Protobuf message. r%)Zenum_keyrrr rs z_mysqlxpb_pure.enum_valuecCs| ”S)zØSerialize message. Args: msg (object): Protobuf message. Returns: str: Serialized message string. )ZSerializeToString©Śmsgrrr Śserialize_message"s z _mysqlxpb_pure.serialize_messagecCs| ”S)zøSerialize partial message. Args: msg (object): Protobuf message. Returns: str: Serialized partial message string. )ZSerializePartialToStringr-rrr Śserialize_partial_message.s z(_mysqlxpb_pure.serialize_partial_messagecCst |”}| |”|S)zęSerialize partial message. Args: msg_type_name (str): Message type name. payload (bytes): Payload. Returns: object: Message parsed from string. )r'r,ŚParseFromString)Ś msg_type_nameŚpayloadr.rrr Ś parse_message:s  z_mysqlxpb_pure.parse_messagecCs4t |”}|std|›ƒ‚t |”}| |”|S)zėParse server message message. Args: msg_type (str): Message type name. payload (bytes): Payload. Returns: object: Server message parsed from string. zUnknown msg_type: )ŚSERVER_MESSAGESŚgetŚ ValueErrorr'r,r1)Śmsg_typer3r2r.rrr Śparse_server_messageIs   z#_mysqlxpb_pure.parse_server_messageN)Ś__name__Ś __module__Ś __qualname__Ś__doc__rZMessageFactoryr(Ś staticmethodr,rr/r0r4r9rrrr r's     r'zProtobuf >=3.11.0 is requiredśProtobuf is not available: )z-Mysqlx.Prepare.Prepare.OneOfMessage.Type.FINDŚfind)z/Mysqlx.Prepare.Prepare.OneOfMessage.Type.INSERTŚinsert)z/Mysqlx.Prepare.Prepare.OneOfMessage.Type.UPDATEŚupdate)z/Mysqlx.Prepare.Prepare.OneOfMessage.Type.DELETEŚdelete)z-Mysqlx.Prepare.Prepare.OneOfMessage.Type.STMTZ 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_EXECUTEc@s.eZdZdZereneZe Ze dd„ƒZ dS)ŚProtobufzŁProtobuf 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. cCs>|rtstdt›ƒ‚|s&ts&tdƒ‚|r.tntt_|t_dS)z”Sets whether to use the C extension or pure Python implementation. Args: use_pure (bool): `True` to use pure Python implementation. r?z-MySQL X Protobuf C extension is not availableN) Ś HAVE_PROTOBUFŚ ImportErrorŚHAVE_PROTOBUF_ERRORŚHAVE_MYSQLXPB_CEXTr'rrDŚmysqlxpbŚuse_pure)rJrrr Ś set_use_pure…s zProtobuf.set_use_pureN) r:r;r<r=rHrr'rIrJr>rKrrrr rD{s  rDc@s¬eZdZdZd#dd„Zdd„Zdd„Zd d „Zd d „Zd$d d„Z dd„Z dd„Z dd„Z dd„Z edd„ƒZedd„ƒZedd„ƒZedd„ƒZedd „ƒZed!d"„ƒZdS)%ŚMessagezŠHelper class for interfacing with the MySQL X Protobuf extension. Args: msg_type_name (string): Protobuf type name. **kwargs: Arbitrary keyword arguments with values for the message. NcKs<|rtj |”nd|jd<| ”D]\}}| ||”q"dS)NŚ_msg)rDrIr,Ś__dict__ŚitemsŚ __setattr__)Śselfr2Śkwargsr*Śvaluerrr Ś__init__œs’zMessage.__init__cCsŠtjr–t|tƒr$t|j|t|ƒƒqĢt|ttfƒrBt|j||ƒqĢt|t ƒr`t |j|ƒ  |”qĢt|t ƒr‚t |j|ƒ  | ””qĢt |j|ƒ  |”n6t|tƒr°t|ƒ|j|<nt|t ƒrĀ| ”n||j|<dS©N)rDrJŚ isinstanceŚstrŚsetattrrMrrr ŚlistŚgetattrŚextendrLZ MergeFromŚ get_message©rQr*rSrrr rP£s    ’zMessage.__setattr__cCs>ztjs|j|n t|j|ƒWStk r8td‚YnXdSrU)rDrJrMrZŚKeyErrorŚAttributeError©rQr*rrr Ś __getattr__·s ’zMessage.__getattr__cCs| ||”dSrU)rPr]rrr Ś __setitem__æszMessage.__setitem__cCs | |”SrU)rar`rrr Ś __getitem__ĀszMessage.__getitem__cCs*tjs|jd ||”St|jd||ƒS)a Returns 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. rM)rDrJrNr6rZ)rQr*Śdefaultrrr r6Ås ’żz Message.getcCs||jd<dS)zdSets the message. Args: msg (dict): Dictionary representing a message. rMN©rN)rQr.rrr Ś set_messageÕszMessage.set_messagecCs |jdS)zøReturns the dictionary representing a message containing parsed data. Returns: dict: The dictionary representing a message containing parsed data. rMre©rQrrr r\ŻszMessage.get_messagecCstj |j”S)z…Serializes a message to a string. Returns: str: A string representing a message containing parsed data. )rDrIr/rMrgrrr Śserialize_to_stringęszMessage.serialize_to_stringcCstj |j”S)z’Serializes 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. )rDrIr0rMrgrrr Śserialize_partial_to_stringīs z#Message.serialize_partial_to_stringcCstjs|jdS|jjjS)zstring: Message type name.Z_mysqlxpb_type_name)rDrJrMŚ DESCRIPTORZ full_namergrrr Śtypełs’ żz Message.typecCstj ||”S)a>Creates 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 )rDrIr4)r2r3rrr Śparses z Message.parsecCstjr| ”Stt| ”ƒƒS)zéReturns 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 )rDrJZByteSizeŚlenrrhr-rrr Ś byte_sizes’ żzMessage.byte_sizecCstj ||”S)aCreates 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. )rDrIr9)r8r3rrr Śparse_from_server#s zMessage.parse_from_servercCs|ƒ}| tj ||””|S)aCreates 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. )rfrDrIr4)r+r2r3r.rrr Ś from_message0s zMessage.from_messagecCs|ƒ}| tj ||””|S)aŽCreates 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. )rfrDrIr9)r+r8r3r.rrr Śfrom_server_messageAs zMessage.from_server_message)N)N)r:r;r<r=rTrPrarbrcr6rfr\rhriŚpropertyrkr>rlrnroŚ classmethodrprqrrrr rL”s.         rLcCs tj |”S)zÆReturns the value of a MySQL X Protobuf enumerator. Args: name (string): MySQL X Protobuf numerator name. Returns: int: Value of the enumerator. )rDrIr)r*rrr Ś mysqlxpb_enumSs rt)^r=Z_SERVER_MESSAGES_TUPLESZPROTOBUF_VERSIONrYZPROTOBUF_REPEATED_TYPESrr5rHrFŚhelpersr rrZgooglerZgoogle.protobufrrrrZ#google.protobuf.internal.containersrZgoogle.protobuf.pyext._messagerŚappendŚhasattrrŚrrrrrrrr r!r"r#r$r&ZClientMessagesŚTyperOrr ZServerMessagesŚErrorZSeverityZ DataModelZFindZRowLockZOrderZ DirectionZUpdateOperationZ UpdateTypeZScalarŚAnyZOpenŚ ConditionZConditionOperationŚKeyZ CtxOperationŚExprZDocumentPathItemŚFrameZScopeŚWarningZLevelZSessionStateChangedŚ ParameterZPrepareZ OneOfMessageZColumnMetaDataZ FieldTypeZDescriptorDatabaseZ_DESCRIPTOR_DBZDescriptorPoolr)ŚAddZFileDescriptorProtoZ FromStringrjZ serialized_pbrErGr'Ś SyntaxErrorŚ TypeErrorŚerrZCRUD_PREPARE_MAPPINGrDrLrtrrrr Śs$/’      8 ’’’’’’’’’’’’’’’’’’’’’’’’Z’"ļ@