a cņf…Hć @s\dZzeWney"eZYn0dZdZegZz"ddlZe dd„eDƒƒZ dZ WneyjdZ Yn0dd l m Z mZmZzDdd lmZdd lmZdd lmZdd lmZddlmZddlmZzddlmZe e”WneyųYn0e e”eedƒrejZddlmZddlm 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/”<qe j5 .”D]\Z/Z0e0e+d" 1e/”<q&e j6j7 .”D]\Z/Z0e0e+d# 1e/”<qLe j8j9 .”D]\Z/Z0e0e+d$ 1e/”<qre j:j; .”D]\Z/Z0e0e+d% 1e/”<q˜e"jj?j@ .”D]\Z/Z0e0e+d( 1e/”<q e#j>j?jA .”D]\Z/Z0e0e+d) 1e/”<q4e#j>jB .”D]\Z/Z0e0e+d* 1e/”<qZe$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/”<q@e(jMjN .”D]\Z/Z0e0e+d1 1e/”<qfe 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[WnXeee\e]fyZ^z6dZXedurņe^nd5ZYe s ed6 1eY”ƒ‚WYdZ^[^n dZ^[^00d7d8d9d: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śU/home/httpd/docs/test/DocsMgr/lib/python3.9/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 Ķóc@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Žsz_mysqlxpb_pure.enum_valuecCs| ”Sr))ZSerializeToString©Śmsgrrr Śserialize_messageāsz _mysqlxpb_pure.serialize_messagecCs| ”Sr))ZSerializePartialToStringr/rrr Śserialize_partial_messageęsz(_mysqlxpb_pure.serialize_partial_messagecCst |”}| |”|Sr))r(r.ŚParseFromString)Ś msg_type_nameŚpayloadr0rrr Ś parse_messageźs  z_mysqlxpb_pure.parse_messagecCs4t |”}|std |”ƒ‚t |”}| |”|S)NzUnknown msg_type: {0})ŚSERVER_MESSAGESŚgetŚ ValueErrorŚformatr(r.r3)Śmsg_typer5r4r0rrr Śparse_server_messagešs    z#_mysqlxpb_pure.parse_server_messageN)Ś__name__Ś __module__Ś __qualname__Ś__doc__rZMessageFactoryr*Ś staticmethodr.rr1r2r6r<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@s4eZdZdZereneZer dndZe 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@|rtstd t”ƒ‚n|s(ts(tdƒ‚|r0tntt_|t_ dS)z”Sets 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Ś ImportErrorr:ŚHAVE_PROTOBUF_ERRORŚHAVE_MYSQLXPB_CEXTr(rrGŚmysqlxpbŚuse_pure)rMrrr Ś set_use_pures’zProtobuf.set_use_pureN) r=r>r?r@rKrr(rLrMrArNrrrr rGs   rGc@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)rGrLr.Ś__dict__ŚitemsŚ __setattr__)Śselfr4Ś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|ƒ  |”nt|t ƒrØ| ”n||j|<dSr))rGrMŚ isinstanceŚstrŚsetattrrPrrr ŚlistŚgetattrŚextendrOZ MergeFromŚ get_message©rTr,rVrrr rS3s   ’ ’zMessage.__setattr__cCs:ztjs|j|n t|j|ƒWSty4t‚Yn0dSr))rGrMrPr\ŚKeyErrorŚAttributeError©rTr,rrr Ś __getattr__Cs  ’ zMessage.__getattr__cCs| ||”dSr))rSr_rrr Ś __setitem__JszMessage.__setitem__cCs | |”Sr))rcrbrrr Ś __getitem__MszMessage.__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. rP)rGrMrQr8r\)rTr,Śdefaultrrr r8Ps ’žz Message.getcCs||jd<dS)zdSets the message. Args: msg (dict): Dictionary representing a message. rPN©rQ)rTr0rrr Ś 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. rPrg©rTrrr r^fszMessage.get_messagecCstj |j”S)z…Serializes a message to a string. Returns: str: A string representing a message containing parsed data. )rGrLr1rPrirrr Śserialize_to_stringoszMessage.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. )rGrLr2rPrirrr Śserialize_partial_to_stringws z#Message.serialize_partial_to_stringcCstjs|jdS|jjjS)zstring: Message type name.Z_mysqlxpb_type_name)rGrMrPŚ DESCRIPTORZ full_namerirrr Ś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 )rGrLr6)r4r5rrr Ś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 )rGrMZByteSizeŚlenrrjr/rrr Ś byte_size—s ’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. )rGrLr<)r;r5rrr Ś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. )rhrGrLr6)r-r4r5r0rrr Ś from_message³s 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. )rhrGrLr<)r-r;r5r0rrr Śfrom_server_messageÄs  ’zMessage.from_server_message)N)N)r=r>r?r@rWrSrcrdrer8rhr^rjrkŚpropertyrmrArnrprqŚ classmethodrrrsrrrr rO&s.         rOcCs 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. )rGrLr)r,rrr Ś mysqlxpb_enum×s rv)cr@ŚModuleNotFoundErrorŚ NameErrorrIZ_SERVER_MESSAGES_TUPLESZPROTOBUF_VERSIONr[ZPROTOBUF_REPEATED_TYPESrŚdictr7rKŚhelpersr rrZgooglerZgoogle.protobufrrrrZ#google.protobuf.internal.containersrZgoogle.protobuf.pyext._messagerŚappendŚhasattrrŚrrrrrrrr r!r"r#r$r&ZClientMessagesŚTyperRrr r:ZServerMessagesŚErrorZSeverityZ DataModelZFindZRowLockZOrderZ DirectionZUpdateOperationZ UpdateTypeZScalarŚAnyZOpenŚ ConditionZConditionOperationŚKeyZ CtxOperationŚExprZDocumentPathItemŚFrameZScopeŚWarningZLevelZSessionStateChangedŚ ParameterZPrepareZ OneOfMessageZColumnMetaDataZ FieldTypeZDescriptorDatabaseZ_DESCRIPTOR_DBZDescriptorPoolr+ŚAddZFileDescriptorProtoZ FromStringrlZ serialized_pbrHrJŚobjectr(Ś SyntaxErrorŚ TypeErrorŚerrZCRUD_PREPARE_MAPPINGrGrOrvrrrr Śs:  ’                        ’’’’’’’’  ’ ’ ’ ’ ’ ’ ’ ’ ’ ’ ’ ’ ’&’’÷2