o žŃŠb…Hć @sTdZzeWn eyeZYnwdZdZegZzddlZe dd„eDƒƒZ dZ Wn ey5dZ Ynwdd l m Z mZmZzždd lmZdd lmZdd lmZdd lmZddlmZddlmZz ddlmZe e”Wn ey|Ynwe e”eedƒrŠejZddlmZddlm Z ddlm!Z!ddlm"Z"ddlm#Z#ddlm$Z$ddlm%Z%ddlm&Z&ddlm'Z'ddlm(Z(ddlm)Z)ddlm*Z*iZ+e&j,j- .”D] \Z/Z0e0e+d 1e/”<qŚe&j2j- .”D] \Z/Z0e0e+d  1e/”<qģe&j3j4 .”D] \Z/Z0e0e+d! 1e/”<qže j5 .”D] \Z/Z0e0e+d" 1e/”<qe j6j7 .”D] \Z/Z0e0e+d# 1e/”<q"e j8j9 .”D] \Z/Z0e0e+d$ 1e/”<q5e j:j; .”D] \Z/Z0e0e+d% 1e/”<qHe"jj?j@ .”D] \Z/Z0e0e+d( 1e/”<q‚e#j>j?jA .”D] \Z/Z0e0e+d) 1e/”<q–e#j>jB .”D] \Z/Z0e0e+d* 1e/”<q©e$jCj- .”D] \Z/Z0e0e+d+ 1e/”<q¼e$jDj- .”D] \Z/Z0e0e+d, 1e/”<qĻe%jEjF .”D] \Z/Z0e0e+d- 1e/”<qāe%jGjH .”D] \Z/Z0e0e+d. 1e/”<qõe%jIjJ .”D] \Z/Z0e0e+d/ 1e/”<qe'jKjLj- .”D] \Z/Z0e0e+d0 1e/”<qe(jMjN .”D] \Z/Z0e0e+d1 1e/”<q/e O”ZPe QeP”ZReP SejT UejVjW””eP SejT Ue jVjW””eP SejT Ue!jVjW””eP SejT Ue"jVjW””eP SejT Ue#jVjW””eP SejT Ue$jVjW””eP SejT Ue%jVjW””eP SejT Ue&jVjW””eP SejT Ue'jVjW””eP SejT Ue(jVjW””eP SejT Ue)jVjW””eP SejT Ue*jVjW””e d2d„eDƒƒZ dZXdZYGd3d4„d4eZƒZ[Wn,eee\e]fy Z^zdZXedurõe^nd5ZYe sed6 1eY”ƒ‚WYdZ^[^ndZ^[^wwd7d8d9d:d;d<œZ_Gd=d>„d>eZƒZ`Gd?d@„d@eZƒZadAdB„ZbdS)CzXThis module contains the 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"g|] \}}tt |”ƒ|f‘qS©)ŚintŚ _mysqlxpbŚ enum_value©Ś.0ŚkeyŚvalrrśW/var/www/secure340b-portal/env/lib/python3.10/site-packages/mysqlx/protobuf/__init__.pyŚ Is’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.{0}zMysqlx.ServerMessages.Type.{0}zMysqlx.Error.Severity.{0}zMysqlx.Crud.DataModel.{0}zMysqlx.Crud.Find.RowLock.{0}zMysqlx.Crud.Order.Direction.{0}z*Mysqlx.Crud.UpdateOperation.UpdateType.{0}z Mysqlx.Datatypes.Scalar.Type.{0}zMysqlx.Datatypes.Any.Type.{0}z3Mysqlx.Expect.Open.Condition.ConditionOperation.{0}z$Mysqlx.Expect.Open.Condition.Key.{0}z#Mysqlx.Expect.Open.CtxOperation.{0}zMysqlx.Expr.Expr.Type.{0}z%Mysqlx.Expr.DocumentPathItem.Type.{0}zMysqlx.Notice.Frame.Scope.{0}zMysqlx.Notice.Warning.Level.{0}z/Mysqlx.Notice.SessionStateChanged.Parameter.{0}z,Mysqlx.Prepare.Prepare.OneOfMessage.Type.{0}z-Mysqlx.Resultset.ColumnMetaData.FieldType.{0}cCsg|] \}}t||f‘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©N)r'ŚfactoryZ GetPrototypeŚ_DESCRIPTOR_POOLZFindMessageTypeByName)ŚnameŚclsrrr Ś new_messageŲs’z_mysqlxpb_pure.new_messagecCst|Sr(r%)rrrr rŽóz_mysqlxpb_pure.enum_valuecCó| ”Sr()ZSerializeToString©Śmsgrrr Śserialize_messageār.z _mysqlxpb_pure.serialize_messagecCr/r()ZSerializePartialToStringr0rrr Śserialize_partial_messageęr.z(_mysqlxpb_pure.serialize_partial_messagecCst |”}| |”|Sr()r'r-ŚParseFromString)Ś msg_type_nameŚpayloadr1rrr Ś parse_messageźs  z_mysqlxpb_pure.parse_messagecCs4t |”}|std |”ƒ‚t |”}| |”|S)NzUnknown msg_type: {0})ŚSERVER_MESSAGESŚgetŚ ValueErrorŚformatr'r-r4)Śmsg_typer6r5r1rrr Śparse_server_messagešs   z#_mysqlxpb_pure.parse_server_messageN)Ś__name__Ś __module__Ś __qualname__Ś__doc__rZMessageFactoryr)Ś staticmethodr-rr2r3r7r=rrrr r'Ņs     r'zProtobuf >=3.0.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@s4eZdZdZer eneZerdndZe 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. FTcCs>|r ts td t”ƒ‚|ststdƒ‚|rtntt_|t_ dS)z”Sets whether to use the C extension or pure Python implementation. Args: use_pure (bool): `True` to use pure Python implementation. rCz-MySQL X Protobuf C extension is not availableN) Ś HAVE_PROTOBUFŚ ImportErrorr;ŚHAVE_PROTOBUF_ERRORŚHAVE_MYSQLXPB_CEXTr'rrHŚmysqlxpbŚuse_pure)rNrrr Ś set_use_pures’ zProtobuf.set_use_pureN) r>r?r@rArLrr'rMrNrBrOrrrr rHs   rHc@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] \}}| ||”qdS)NŚ_msg)rHrMr-Ś__dict__ŚitemsŚ __setattr__)Śselfr5ŚkwargsrŚvaluerrr Ś__init__-s’’’zMessage.__init__cCsĄtjrPt|tƒrt|j|t|ƒƒdSt|ttfƒr#t|j||ƒdSt|t ƒr3t |j|ƒ  |”dSt|t ƒrEt |j|ƒ  | ””dSt |j|ƒ  |”dSt|t ƒrY| ”n||j|<dSr()rHrNŚ isinstanceŚstrŚsetattrrQrrr ŚlistŚgetattrŚextendrPZ MergeFromŚ get_message©rUr+rWrrr rT3s    ’ ’zMessage.__setattr__cCs4ztjs |j|WSt|j|ƒWStyt‚wr()rHrNrQr]ŚKeyErrorŚAttributeError©rUr+rrr Ś __getattr__Cs ’ ’zMessage.__getattr__cCs| ||”dSr()rTr`rrr Ś __setitem__JszMessage.__setitem__cCs | |”Sr()rdrcrrr Ś __getitem__Ms zMessage.__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. rQ)rHrNrRr9r])rUr+Śdefaultrrr r9Ps ’žz Message.getcCs||jd<dS)zdSets the message. Args: msg (dict): Dictionary representing a message. rQN©rR)rUr1rrr Ś set_message^ózMessage.set_messagecCs |jdS)zøReturns the dictionary representing a message containing parsed data. Returns: dict: The dictionary representing a message containing parsed data. rQrh©rUrrr r_fs zMessage.get_messagecCótj |j”S)z…Serializes a message to a string. Returns: str: A string representing a message containing parsed data. )rHrMr2rQrkrrr Śserialize_to_stringorjzMessage.serialize_to_stringcCrl)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. )rHrMr3rQrkrrr Śserialize_partial_to_stringws z#Message.serialize_partial_to_stringcCstjs|jdS|jjjS)zstring: Message type name.Z_mysqlxpb_type_name)rHrNrQŚ DESCRIPTORZ full_namerkrrr Śtype‚s’z Message.typecCótj ||”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 )rHrMr7)r5r6rrr Śparseˆs 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 )rHrNZByteSizeŚlenrrmr0rrr Ś byte_size—s ’zMessage.byte_sizecCrq)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. )rHrMr=)r<r6rrr Śparse_from_server¦s zMessage.parse_from_servercCó|ƒ}| 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. )rirHrMr7)r,r5r6r1rrr Ś from_message³s zMessage.from_messagecCrv)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. )rirHrMr=)r,r<r6r1rrr Śfrom_server_messageÄs   ’zMessage.from_server_messager()r>r?r@rArXrTrdrerfr9rir_rmrnŚpropertyrprBrrrtruŚ classmethodrwrxrrrr rP&s0        rPcCs 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. )rHrMr)r+rrr Ś mysqlxpb_enum×s r{)crAŚModuleNotFoundErrorŚ NameErrorrJZ_SERVER_MESSAGES_TUPLESZPROTOBUF_VERSIONr\ZPROTOBUF_REPEATED_TYPESrŚdictr8rLŚhelpersr rrZgooglerZgoogle.protobufrrrrZ#google.protobuf.internal.containersrZgoogle.protobuf.pyext._messagerŚappendŚhasattrrŚrrrrrrrr r!r"r#r$r&ZClientMessagesŚTyperSrr r;ZServerMessagesŚErrorZSeverityZ DataModelZFindZRowLockZOrderZ DirectionZUpdateOperationZ UpdateTypeZScalarŚAnyZOpenŚ ConditionZConditionOperationŚKeyZ CtxOperationŚExprZDocumentPathItemŚFrameZScopeŚWarningZLevelZSessionStateChangedŚ ParameterZPrepareZ OneOfMessageZColumnMetaDataZ FieldTypeZDescriptorDatabaseZ_DESCRIPTOR_DBZDescriptorPoolr*ŚAddZFileDescriptorProtoZ FromStringroZ serialized_pbrIrKŚobjectr'Ś SyntaxErrorŚ TypeErrorŚerrZCRUD_PREPARE_MAPPINGrHrPr{rrrr ŚsH ’’ ’        ’              ’’’’’’’’  ’ ’ ’ ’ ’ ’ ’ ’ ’ ’ ’ ’ ’&’’ ’€ü ÷ 2